summaryrefslogtreecommitdiff
path: root/src/mongo/db/dbcommands.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/dbcommands.cpp')
-rw-r--r--src/mongo/db/dbcommands.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/db/dbcommands.cpp b/src/mongo/db/dbcommands.cpp
index 228c5ea150d..31c453ecaa3 100644
--- a/src/mongo/db/dbcommands.cpp
+++ b/src/mongo/db/dbcommands.cpp
@@ -92,6 +92,7 @@
#include "mongo/rpc/reply_builder_interface.h"
#include "mongo/rpc/metadata.h"
#include "mongo/rpc/metadata/config_server_metadata.h"
+#include "mongo/rpc/metadata/repl_set_metadata.h"
#include "mongo/rpc/metadata/server_selection_metadata.h"
#include "mongo/rpc/metadata/sharding_metadata.h"
#include "mongo/rpc/protocol.h"
@@ -1466,8 +1467,9 @@ bool Command::run(OperationContext* txn,
if (isReplSet) {
repl::OpTime lastOpTimeFromClient =
repl::ReplClientInfo::forClient(txn->getClient()).getLastOp();
- replCoord->prepareReplResponseMetadata(request, lastOpTimeFromClient, &metadataBob);
-
+ if (request.getMetadata().hasField(rpc::kReplSetMetadataFieldName)) {
+ replCoord->prepareReplMetadata(lastOpTimeFromClient, &metadataBob);
+ }
// For commands from mongos, append some info to help getLastError(w) work.
// TODO: refactor out of here as part of SERVER-18326
if (isShardingAware || serverGlobalParams.configsvr) {