diff options
Diffstat (limited to 'src/mongo/db/repl/oplog.cpp')
-rw-r--r-- | src/mongo/db/repl/oplog.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/repl/oplog.cpp b/src/mongo/db/repl/oplog.cpp index 0908b06213a..7ffffbbf2c1 100644 --- a/src/mongo/db/repl/oplog.cpp +++ b/src/mongo/db/repl/oplog.cpp @@ -389,7 +389,7 @@ void _logOpsInner(OperationContext* opCtx, } // Insert the oplog records to the respective tenants change collections. - if (ChangeStreamChangeCollectionManager::isChangeCollectionEnabled()) { + if (ChangeStreamChangeCollectionManager::isChangeCollectionsModeActive()) { ChangeStreamChangeCollectionManager::get(opCtx).insertDocumentsToChangeCollection( opCtx, *records, timestamps); } @@ -1578,7 +1578,7 @@ Status applyOperation_inlock(OperationContext* opCtx, invariant(op.getObject2()); auto&& documentId = *op.getObject2(); auto documentFound = Helpers::findById( - opCtx, db, collection->ns().ns(), documentId, changeStreamPreImage); + opCtx, collection->ns().ns(), documentId, changeStreamPreImage); invariant(documentFound); } |