summaryrefslogtreecommitdiff
path: root/src/mongo/db/service_entry_point_common.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/service_entry_point_common.cpp')
-rw-r--r--src/mongo/db/service_entry_point_common.cpp7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/db/service_entry_point_common.cpp b/src/mongo/db/service_entry_point_common.cpp
index 6d2793b1a3e..130e7ae2736 100644
--- a/src/mongo/db/service_entry_point_common.cpp
+++ b/src/mongo/db/service_entry_point_common.cpp
@@ -571,6 +571,10 @@ private:
auto command = _execContext->getCommand();
auto& request = _execContext->getRequest();
+ if (command &&
+ (command->getName() == "aggregate" || command->getName() == "getMore" ||
+ command->getName() == "killCursors"))
+ std::cout << "Ahoo --> new Request: " << request.body << std::endl;
const auto apiParamsFromClient = initializeAPIParameters(request.body, command);
Client* client = opCtx->getClient();
@@ -1865,6 +1869,9 @@ DbResponse makeCommandResponse(std::shared_ptr<HandleRequest::ExecutionContext>
}
}
+ if (c &&
+ (c->getName() == "aggregate" || c->getName() == "getMore" || c->getName() == "killCursors"))
+ std::cout << "Ahoo ==> Reply: " << replyBuilder->getBodyBuilder().asTempObj() << std::endl;
dbResponse.response = replyBuilder->done();
CurOp::get(opCtx)->debug().responseLength = dbResponse.response.header().dataLen();