summaryrefslogtreecommitdiff
path: root/src/mongo/transport/transport_layer_asio.cpp
diff options
context:
space:
mode:
authorJason Carey <jcarey@argv.me>2018-05-07 13:18:05 -0400
committerJason Carey <jcarey@argv.me>2018-05-08 10:29:58 -0400
commitd66041a40af0d7511d3a693a662efebe5529bea5 (patch)
treedbb243e73a8a56bd973793473b9d21c68be6543a /src/mongo/transport/transport_layer_asio.cpp
parent6d193bce4316c42a283bd486399c8b3e606b5fe9 (diff)
downloadmongo-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.cpp8
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;