diff options
Diffstat (limited to 'src/mongo/transport/transport_layer.cpp')
-rw-r--r-- | src/mongo/transport/transport_layer.cpp | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/src/mongo/transport/transport_layer.cpp b/src/mongo/transport/transport_layer.cpp index 442cf78b15c..e2b997add0c 100644 --- a/src/mongo/transport/transport_layer.cpp +++ b/src/mongo/transport/transport_layer.cpp @@ -31,11 +31,20 @@ #include "mongo/platform/basic.h" #include "mongo/base/status.h" +#include "mongo/db/operation_context.h" +#include "mongo/platform/atomic_word.h" +#include "mongo/transport/baton.h" #include "mongo/transport/transport_layer.h" namespace mongo { namespace transport { +namespace { + +AtomicWord<uint64_t> reactorTimerIdCounter(0); + +} // namespace + const Status TransportLayer::SessionUnknownStatus = Status(ErrorCodes::TransportSessionUnknown, "TransportLayer does not own the Session."); @@ -48,5 +57,11 @@ const Status TransportLayer::TicketSessionUnknownStatus = Status( const Status TransportLayer::TicketSessionClosedStatus = Status( ErrorCodes::TransportSessionClosed, "Operation attempted on a closed transport Session."); +ReactorTimer::ReactorTimer() : _id(reactorTimerIdCounter.addAndFetch(1)) {} + +BatonHandle TransportLayer::makeDefaultBaton(OperationContext* opCtx) { + return opCtx->getServiceContext()->makeBaton(opCtx); +} + } // namespace transport } // namespace mongo |