diff options
author | Randolph Tan <randolph@10gen.com> | 2017-03-09 10:51:50 -0500 |
---|---|---|
committer | Randolph Tan <randolph@10gen.com> | 2017-03-09 10:51:50 -0500 |
commit | 4e2cb91ed1fe8a9a8caead72a7f0bd56b2ba28d1 (patch) | |
tree | d17054bdecbcae1effc432ecf041a2ca5a853be9 /src/mongo/client/dbclient.cpp | |
parent | 73d3473fb11ff4fbdb404d0c6c409a309ccd7646 (diff) | |
download | mongo-4e2cb91ed1fe8a9a8caead72a7f0bd56b2ba28d1.tar.gz |
Revert "SERVER-27750 Attach LogicalTimeMetadata to globalConnPool and shardConnectionPool"
This reverts commit 34dbe2a42d1db621f16555878b57f48efb30cc28.
Diffstat (limited to 'src/mongo/client/dbclient.cpp')
-rw-r--r-- | src/mongo/client/dbclient.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/client/dbclient.cpp b/src/mongo/client/dbclient.cpp index 78c052b01f2..7b252bde560 100644 --- a/src/mongo/client/dbclient.cpp +++ b/src/mongo/client/dbclient.cpp @@ -185,8 +185,8 @@ rpc::UniqueReply DBClientWithCommands::runCommandWithMetadata(StringData databas metadataBob.appendElements(metadata); if (_metadataWriter) { - uassertStatusOK( - _metadataWriter((haveClient() ? cc().getOperationContext() : nullptr), &metadataBob)); + uassertStatusOK(_metadataWriter( + (haveClient() ? cc().getOperationContext() : nullptr), &metadataBob, host)); } auto requestBuilder = rpc::makeRequestBuilder(getClientRPCProtocols(), getServerRPCProtocols()); @@ -223,16 +223,16 @@ rpc::UniqueReply DBClientWithCommands::runCommandWithMetadata(StringData databas << "' ", requestBuilder->getProtocol() == commandReply->getProtocol()); - if (_metadataReader) { - uassertStatusOK(_metadataReader(commandReply->getMetadata(), host)); - } - if (ErrorCodes::SendStaleConfig == getStatusFromCommandResult(commandReply->getCommandReply())) { throw RecvStaleConfigException("stale config in runCommand", commandReply->getCommandReply()); } + if (_metadataReader) { + uassertStatusOK(_metadataReader(commandReply->getMetadata(), host)); + } + return rpc::UniqueReply(std::move(replyMsg), std::move(commandReply)); } |