summaryrefslogtreecommitdiff
path: root/src/mongo/db/commands/write_commands.cpp
diff options
context:
space:
mode:
authorAlex Li <alex.li@mongodb.com>2021-07-12 18:35:15 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-07-23 13:59:00 +0000
commit60a4229054cda93a50265a25d7a8a71ca2763e96 (patch)
treea21db5b649495d27bc89e77a80adfa0bcde0c167 /src/mongo/db/commands/write_commands.cpp
parent306a69a50245fb0787391c26597b02c04a156488 (diff)
downloadmongo-60a4229054cda93a50265a25d7a8a71ca2763e96.tar.gz
SERVER-55412 shardVersion propogated for mirrored reads
Diffstat (limited to 'src/mongo/db/commands/write_commands.cpp')
-rw-r--r--src/mongo/db/commands/write_commands.cpp5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/db/commands/write_commands.cpp b/src/mongo/db/commands/write_commands.cpp
index 1397fe6ce09..d86302032dd 100644
--- a/src/mongo/db/commands/write_commands.cpp
+++ b/src/mongo/db/commands/write_commands.cpp
@@ -1172,6 +1172,11 @@ public:
invariant(!_commandObj.isEmpty());
+ if (const auto& shardVersion = _commandObj.getField("shardVersion");
+ !shardVersion.eoo()) {
+ bob->append(shardVersion);
+ }
+
bob->append("find", _commandObj["update"].String());
extractQueryDetails(_updateOpObj, bob);
bob->append("batchSize", 1);