diff options
author | Jason Carey <jcarey@argv.me> | 2018-05-07 13:18:05 -0400 |
---|---|---|
committer | Jason Carey <jcarey@argv.me> | 2018-05-08 10:29:58 -0400 |
commit | d66041a40af0d7511d3a693a662efebe5529bea5 (patch) | |
tree | dbb243e73a8a56bd973793473b9d21c68be6543a /src/mongo/transport/transport_layer_asio.cpp | |
parent | 6d193bce4316c42a283bd486399c8b3e606b5fe9 (diff) | |
download | mongo-d66041a40af0d7511d3a693a662efebe5529bea5.tar.gz |
SERVER-34473 Re-separate (in/eg)ress net counters
After unifying under Transport Layer ASIO, we're counting ingress and
egress bytes sent/received under counters that were formerly only
ingress.
This restores the old behavior.
Diffstat (limited to 'src/mongo/transport/transport_layer_asio.cpp')
-rw-r--r-- | src/mongo/transport/transport_layer_asio.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/mongo/transport/transport_layer_asio.cpp b/src/mongo/transport/transport_layer_asio.cpp index 92d6678c73c..87750d6b506 100644 --- a/src/mongo/transport/transport_layer_asio.cpp +++ b/src/mongo/transport/transport_layer_asio.cpp @@ -459,7 +459,7 @@ StatusWith<TransportLayerASIO::ASIOSessionHandle> TransportLayerASIO::_doSyncCon sock.non_blocking(false); try { - return std::make_shared<ASIOSession>(this, std::move(sock)); + return std::make_shared<ASIOSession>(this, std::move(sock), false); } catch (const DBException& e) { return e.toStatus(); } @@ -507,7 +507,8 @@ Future<SessionHandle> TransportLayerASIO::asyncConnect(HostAndPort peer, return connector->socket.async_connect(results->endpoint(), UseFuture{}); }) .then([this, connector, sslMode]() { - connector->session = std::make_shared<ASIOSession>(this, std::move(connector->socket)); + connector->session = + std::make_shared<ASIOSession>(this, std::move(connector->socket), false); connector->session->ensureAsync(); #ifndef MONGO_CONFIG_SSL if (sslMode == kEnableSSL) { @@ -753,7 +754,8 @@ void TransportLayerASIO::_acceptConnection(GenericAcceptor& acceptor) { } try { - std::shared_ptr<ASIOSession> session(new ASIOSession(this, std::move(peerSocket))); + std::shared_ptr<ASIOSession> session( + new ASIOSession(this, std::move(peerSocket), true)); _sep->startSession(std::move(session)); } catch (const DBException& e) { warning() << "Error accepting new connection " << e; |