diff options
| -rw-r--r-- | src/mongo/client/embedded/SConscript | 1 | ||||
| -rw-r--r-- | src/mongo/client/embedded/libmongodbcapi.cpp | 5 |
2 files changed, 6 insertions, 0 deletions
diff --git a/src/mongo/client/embedded/SConscript b/src/mongo/client/embedded/SConscript index 33bf377852b..89efeacc9e9 100644 --- a/src/mongo/client/embedded/SConscript +++ b/src/mongo/client/embedded/SConscript @@ -129,6 +129,7 @@ capi = env.Library( 'libmongodbcapi.cpp', ], LIBDEPS_PRIVATE=[ + '$BUILD_DIR/mongo/util/net/network', '$BUILD_DIR/mongo/db/service_context', '$BUILD_DIR/mongo/transport/transport_layer_mock', 'embedded', diff --git a/src/mongo/client/embedded/libmongodbcapi.cpp b/src/mongo/client/embedded/libmongodbcapi.cpp index 1e8fbf833da..bdc9d9f946e 100644 --- a/src/mongo/client/embedded/libmongodbcapi.cpp +++ b/src/mongo/client/embedded/libmongodbcapi.cpp @@ -270,6 +270,11 @@ int client_wire_protocol_rpc(libmongodbcapi_client* client, Message msg(std::move(sb)); client->response = sep->handleRequest(opCtx.get(), msg); + + MsgData::View outMessage(client->response.response.buf()); + outMessage.setId(nextMessageId()); + outMessage.setResponseToMsgId(msg.header().getId()); + *output_size = client->response.response.size(); *output = (void*)client->response.response.buf(); |