diff options
| author | Mathias Stearn <mathias@10gen.com> | 2018-07-25 15:04:48 -0400 |
|---|---|---|
| committer | Mathias Stearn <mathias@10gen.com> | 2018-07-30 13:57:10 -0400 |
| commit | 480192de1789e8387b64976ad015c11fac990617 (patch) | |
| tree | 1bd8c4bf54334ca55254bbf534ad3d7127843355 /src/mongo/tools | |
| parent | d68d672dd4cc27c92be897e7523fad85664fc39e (diff) | |
| download | mongo-480192de1789e8387b64976ad015c11fac990617.tar.gz | |
SERVER-33135 Delete code for OP_COMMAND
Diffstat (limited to 'src/mongo/tools')
| -rw-r--r-- | src/mongo/tools/bridge.cpp | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/mongo/tools/bridge.cpp b/src/mongo/tools/bridge.cpp index 01093145986..6938882953d 100644 --- a/src/mongo/tools/bridge.cpp +++ b/src/mongo/tools/bridge.cpp @@ -40,7 +40,6 @@ #include "mongo/db/service_context.h" #include "mongo/platform/atomic_word.h" #include "mongo/platform/random.h" -#include "mongo/rpc/command_request.h" #include "mongo/rpc/factory.h" #include "mongo/rpc/message.h" #include "mongo/rpc/reply_builder_interface.h" @@ -288,7 +287,7 @@ DbResponse ServiceEntryPointBridge::handleRequest(OperationContext* opCtx, const boost::optional<OpMsgRequest> cmdRequest; if ((request.operation() == dbQuery && NamespaceString(DbMessage(request).getns()).isCommand()) || - request.operation() == dbCommand || request.operation() == dbMsg) { + request.operation() == dbMsg) { cmdRequest = rpc::opMsgRequestFromAnyProtocol(request); dest.extractHostInfo(*cmdRequest); @@ -350,10 +349,10 @@ DbResponse ServiceEntryPointBridge::handleRequest(OperationContext* opCtx, const uassertStatusOK(dest->sinkMessage(request)); // Send the message we received from 'source' to 'dest'. 'dest' returns a response for - // OP_QUERY, OP_GET_MORE, and OP_COMMAND messages that we respond with. + // OP_QUERY, OP_GET_MORE, and OP_MSG messages that we respond with. if (!isFireAndForgetCommand && (request.operation() == dbQuery || request.operation() == dbGetMore || - request.operation() == dbCommand || request.operation() == dbMsg)) { + request.operation() == dbMsg)) { // TODO dbMsg moreToCome // Forward the message to 'dest' and receive its reply in 'response'. auto response = uassertStatusOK(dest->sourceMessage()); |