diff options
| author | Jason Carey <jcarey@argv.me> | 2016-08-23 13:17:56 -0400 |
|---|---|---|
| committer | Jason Carey <jcarey@argv.me> | 2016-08-23 15:33:58 -0400 |
| commit | eedc87f13014319a6890ee06a908c75a1ac7a13b (patch) | |
| tree | 76053bdd6280cc4516c096d5ba0c2bff62fb7f05 /src/mongo | |
| parent | dd74cff611986d34464fd4476e67dbcd6443d3ca (diff) | |
| download | mongo-eedc87f13014319a6890ee06a908c75a1ac7a13b.tar.gz | |
SERVER-25755 Remove extra logging from TL change
Clean up some logging we shouldn't have been doing since the transport layer went in
Diffstat (limited to 'src/mongo')
| -rw-r--r-- | src/mongo/db/service_entry_point_mongod.cpp | 4 | ||||
| -rw-r--r-- | src/mongo/s/service_entry_point_mongos.cpp | 3 |
2 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/db/service_entry_point_mongod.cpp b/src/mongo/db/service_entry_point_mongod.cpp index fc079b2ffbc..8135afbec6b 100644 --- a/src/mongo/db/service_entry_point_mongod.cpp +++ b/src/mongo/db/service_entry_point_mongod.cpp @@ -112,7 +112,8 @@ void ServiceEntryPointMongod::_sessionLoop(Session* session) { inMessage.reset(); auto status = session->sourceMessage(&inMessage).wait(); - if (ErrorCodes::isInterruption(status.code())) { + if (ErrorCodes::isInterruption(status.code()) || + ErrorCodes::isNetworkError(status.code())) { break; } @@ -137,7 +138,6 @@ void ServiceEntryPointMongod::_sessionLoop(Session* session) { // If this is an exhaust cursor, don't source more Messages if (dbresponse.exhaustNS.size() > 0 && setExhaustMessage(&inMessage, dbresponse)) { - log() << "we are in exhaust"; inExhaust = true; } else { inExhaust = false; diff --git a/src/mongo/s/service_entry_point_mongos.cpp b/src/mongo/s/service_entry_point_mongos.cpp index fe7d92fd1ad..d7d40e4beee 100644 --- a/src/mongo/s/service_entry_point_mongos.cpp +++ b/src/mongo/s/service_entry_point_mongos.cpp @@ -92,7 +92,8 @@ void ServiceEntryPointMongos::_sessionLoop(Session* session) { { auto status = session->sourceMessage(&message).wait(); - if (ErrorCodes::isInterruption(status.code())) { + if (ErrorCodes::isInterruption(status.code()) || + ErrorCodes::isNetworkError(status.code())) { break; } |