diff options
author | samantharitter <samantha.ritter@10gen.com> | 2016-11-04 14:45:32 -0400 |
---|---|---|
committer | samantharitter <samantha.ritter@10gen.com> | 2016-11-05 21:26:59 -0400 |
commit | 0ac04999faae1d2fc0e10972aaf21082a2e48c8f (patch) | |
tree | d9b74efcf36c5381469cc622c3aea4c0f8166398 /src/mongo/transport/transport_layer_mock.h | |
parent | 2d1dd9e07a40f314853e29bffb56b45bf21df940 (diff) | |
download | mongo-0ac04999faae1d2fc0e10972aaf21082a2e48c8f.tar.gz |
SERVER-26674 transport::Session objects should be shared_ptr managed
Diffstat (limited to 'src/mongo/transport/transport_layer_mock.h')
-rw-r--r-- | src/mongo/transport/transport_layer_mock.h | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/src/mongo/transport/transport_layer_mock.h b/src/mongo/transport/transport_layer_mock.h index a8d37ab7a0d..420360a44de 100644 --- a/src/mongo/transport/transport_layer_mock.h +++ b/src/mongo/transport/transport_layer_mock.h @@ -51,12 +51,12 @@ public: class TicketMock : public TicketImpl { public: // Source constructor - TicketMock(const Session* session, + TicketMock(const SessionHandle& session, Message* message, Date_t expiration = Ticket::kNoExpirationDate); // Sink constructor - TicketMock(const Session* session, Date_t expiration = Ticket::kNoExpirationDate); + TicketMock(const SessionHandle& session, Date_t expiration = Ticket::kNoExpirationDate); TicketMock(TicketMock&&) = default; TicketMock& operator=(TicketMock&&) = default; @@ -68,7 +68,7 @@ public: boost::optional<Message*> msg() const; private: - const Session* _session; + const SessionHandle& _session; boost::optional<Message*> _message; Date_t _expiration; }; @@ -76,26 +76,26 @@ public: TransportLayerMock(); ~TransportLayerMock(); - Ticket sourceMessage(Session& session, + Ticket sourceMessage(const SessionHandle& session, Message* message, Date_t expiration = Ticket::kNoExpirationDate) override; - Ticket sinkMessage(Session& session, + Ticket sinkMessage(const SessionHandle& session, const Message& message, Date_t expiration = Ticket::kNoExpirationDate) override; Status wait(Ticket&& ticket) override; void asyncWait(Ticket&& ticket, TicketCallback callback) override; - SSLPeerInfo getX509PeerInfo(const Session& session) const override; - void setX509PeerInfo(const Session& session, SSLPeerInfo peerInfo); - void registerTags(const Session& session) override; + SSLPeerInfo getX509PeerInfo(const ConstSessionHandle& session) const override; + void setX509PeerInfo(const SessionHandle& session, SSLPeerInfo peerInfo); + void registerTags(const ConstSessionHandle& session) override; Stats sessionStats() override; - Session* createSession(); - Session* get(Session::Id id); + SessionHandle createSession(); + SessionHandle get(Session::Id id); bool owns(Session::Id id); - void end(Session& session) override; + void end(const SessionHandle& session) override; void endAllSessions(Session::TagMask tags) override; Status start() override; @@ -107,7 +107,7 @@ private: struct Connection { bool ended; - std::unique_ptr<Session> session; + SessionHandle session; SSLPeerInfo peerInfo; }; stdx::unordered_map<Session::Id, Connection> _sessions; |