diff options
author | Rishab Joshi <rishab.joshi@mongodb.com> | 2022-09-15 10:27:24 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-09-15 11:29:18 +0000 |
commit | e6b184b48b2f4ceaff580c98c24e14eac26e2c03 (patch) | |
tree | 27410d5d07867ef6be3026cb69a9a9821e03e254 /src/mongo/db/repl/oplog_applier_impl.cpp | |
parent | 0797ff28efcd7cb954b88658425b7b38c980b605 (diff) | |
download | mongo-e6b184b48b2f4ceaff580c98c24e14eac26e2c03.tar.gz |
SERVER-66641 Introduce multi-tenancy for change collections.
Diffstat (limited to 'src/mongo/db/repl/oplog_applier_impl.cpp')
-rw-r--r-- | src/mongo/db/repl/oplog_applier_impl.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/repl/oplog_applier_impl.cpp b/src/mongo/db/repl/oplog_applier_impl.cpp index 032e9109f14..51eebc457bc 100644 --- a/src/mongo/db/repl/oplog_applier_impl.cpp +++ b/src/mongo/db/repl/oplog_applier_impl.cpp @@ -36,6 +36,7 @@ #include "mongo/db/catalog/document_validation.h" #include "mongo/db/catalog_raii.h" #include "mongo/db/change_stream_change_collection_manager.h" +#include "mongo/db/change_stream_serverless_helpers.h" #include "mongo/db/client.h" #include "mongo/db/commands/fsync.h" #include "mongo/db/db_raii.h" @@ -150,7 +151,7 @@ Status _insertDocumentsToOplogAndChangeCollections( // Write the corresponding oplog entries to tenants respective change // collections in the serverless. - if (ChangeStreamChangeCollectionManager::isChangeCollectionsModeActive()) { + if (change_stream_serverless_helpers::isChangeCollectionsModeActive()) { auto status = ChangeStreamChangeCollectionManager::get(opCtx).insertDocumentsToChangeCollection( opCtx, @@ -416,8 +417,7 @@ void scheduleWritesToOplogAndChangeCollection(OperationContext* opCtx, bool skipWritesToOplog) { // Skip performing any writes during the startup recovery when running in the non-serverless // environment. - if (skipWritesToOplog && - !ChangeStreamChangeCollectionManager::isChangeCollectionsModeActive()) { + if (skipWritesToOplog && !change_stream_serverless_helpers::isChangeCollectionsModeActive()) { return; } |