diff options
| author | Mathias Stearn <mathias@10gen.com> | 2017-04-12 14:24:00 -0400 |
|---|---|---|
| committer | Mathias Stearn <mathias@10gen.com> | 2017-04-27 14:31:25 -0400 |
| commit | 86aa275a4b9b43d0c647dc0034c6626a95884e18 (patch) | |
| tree | c5eaa30f81df846855f60399c32e2524a92685a2 /src/mongo/tools | |
| parent | 0bd0382b2bcd0517ce717e7e1d1e57da792c6855 (diff) | |
| download | mongo-86aa275a4b9b43d0c647dc0034c6626a95884e18.tar.gz | |
SERVER-28508 OP_MSG in egress and mongod
Diffstat (limited to 'src/mongo/tools')
| -rw-r--r-- | src/mongo/tools/bridge.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/tools/bridge.cpp b/src/mongo/tools/bridge.cpp index 710b17f4215..b515ad7ca87 100644 --- a/src/mongo/tools/bridge.cpp +++ b/src/mongo/tools/bridge.cpp @@ -153,7 +153,8 @@ public: } std::unique_ptr<rpc::RequestInterface> cmdRequest; - if (request.operation() == dbQuery || request.operation() == dbCommand) { + if (request.operation() == dbQuery || request.operation() == dbCommand || + request.operation() == dbMsg) { cmdRequest = rpc::makeRequest(&request); if (receivingFirstMessage) { host = extractHostInfo(*cmdRequest); @@ -221,7 +222,8 @@ public: // OP_QUERY, OP_GET_MORE, and OP_COMMAND messages that we respond back to // '_mp' with. if (request.operation() == dbQuery || request.operation() == dbGetMore || - request.operation() == dbCommand) { + request.operation() == dbCommand || request.operation() == dbMsg) { + // TODO dbMsg moreToCome // Forward the message to 'dest' and receive its reply in 'response'. response.reset(); dest.port().call(request, response); |