diff options
| author | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2022-04-01 14:23:20 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-04-01 15:39:51 +0000 |
| commit | c829cc9b78f8beffebf272b3157f557bd475571b (patch) | |
| tree | f245d463e69334d6a6f9e737178d473ab1cb2de6 /src/mongo/db/repl | |
| parent | 98ddeb44e4b0f97c92c1c4f22012c0b62142d06a (diff) | |
| download | mongo-c829cc9b78f8beffebf272b3157f557bd475571b.tar.gz | |
SERVER-64475 Change isOperationVersioned to isComingFromRouter
Diffstat (limited to 'src/mongo/db/repl')
| -rw-r--r-- | src/mongo/db/repl/oplog.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/mongo/db/repl/oplog.cpp b/src/mongo/db/repl/oplog.cpp index f8bf232917c..b4a1d1e88d4 100644 --- a/src/mongo/db/repl/oplog.cpp +++ b/src/mongo/db/repl/oplog.cpp @@ -540,9 +540,8 @@ std::vector<OpTime> logInsertOps( oplogLink.prevOpTime = opTimes[i - 1]; // Direct inserts to shards of orphan documents should not generate change stream events. - if (serverGlobalParams.clusterRole == ClusterRole::ShardServer && - (!oplogEntry.getFromMigrate() || !*oplogEntry.getFromMigrate()) && - !OperationShardingState::isOperationVersioned(opCtx) && + if (!oplogEntry.getFromMigrate().value_or(false) && + !OperationShardingState::isComingFromRouter(opCtx) && preWriteFilter.computeAction(Document(begin[i].doc)) == write_stage_common::PreWriteFilter::Action::kWriteAsFromMigrate) { LOGV2_DEBUG(6258100, |