diff options
Diffstat (limited to 'src/mongo/db/op_observer_impl.cpp')
| -rw-r--r-- | src/mongo/db/op_observer_impl.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/mongo/db/op_observer_impl.cpp b/src/mongo/db/op_observer_impl.cpp index a295be04d5a..1ccf72f16da 100644 --- a/src/mongo/db/op_observer_impl.cpp +++ b/src/mongo/db/op_observer_impl.cpp @@ -53,7 +53,7 @@ #include "mongo/db/repl/replication_coordinator.h" #include "mongo/db/s/collection_sharding_state.h" #include "mongo/db/server_options.h" -#include "mongo/db/session_catalog.h" +#include "mongo/db/session_catalog_mongod.h" #include "mongo/db/transaction_participant.h" #include "mongo/db/views/durable_view_catalog.h" #include "mongo/scripting/engine.h" @@ -435,7 +435,7 @@ void OpObserverImpl::onInserts(OperationContext* opCtx, } } else if (nss == NamespaceString::kSessionTransactionsTableNamespace && !lastOpTime.isNull()) { for (auto it = first; it != last; it++) { - SessionCatalog::get(opCtx)->invalidateSessions(opCtx, it->doc); + MongoDSessionCatalog::invalidateSessions(opCtx, it->doc); } } } @@ -504,7 +504,7 @@ void OpObserverImpl::onUpdate(OperationContext* opCtx, const OplogUpdateEntryArg FeatureCompatibilityVersion::onInsertOrUpdate(opCtx, args.updateArgs.updatedDoc); } else if (args.nss == NamespaceString::kSessionTransactionsTableNamespace && !opTime.writeOpTime.isNull()) { - SessionCatalog::get(opCtx)->invalidateSessions(opCtx, args.updateArgs.updatedDoc); + MongoDSessionCatalog::invalidateSessions(opCtx, args.updateArgs.updatedDoc); } } @@ -570,7 +570,7 @@ void OpObserverImpl::onDelete(OperationContext* opCtx, uasserted(40670, "removing FeatureCompatibilityVersion document is not allowed"); } else if (nss == NamespaceString::kSessionTransactionsTableNamespace && !opTime.writeOpTime.isNull()) { - SessionCatalog::get(opCtx)->invalidateSessions(opCtx, documentKey); + MongoDSessionCatalog::invalidateSessions(opCtx, documentKey); } } @@ -730,7 +730,7 @@ void OpObserverImpl::onDropDatabase(OperationContext* opCtx, const std::string& 50714, "dropping the admin database is not allowed.", dbName != NamespaceString::kAdminDb); if (dbName == NamespaceString::kSessionTransactionsTableNamespace.db()) { - SessionCatalog::get(opCtx)->invalidateSessions(opCtx, boost::none); + MongoDSessionCatalog::invalidateSessions(opCtx, boost::none); } NamespaceUUIDCache::get(opCtx).evictNamespacesInDatabase(dbName); @@ -770,7 +770,7 @@ repl::OpTime OpObserverImpl::onDropCollection(OperationContext* opCtx, if (collectionName.coll() == DurableViewCatalog::viewsCollectionName()) { DurableViewCatalog::onExternalChange(opCtx, collectionName); } else if (collectionName == NamespaceString::kSessionTransactionsTableNamespace) { - SessionCatalog::get(opCtx)->invalidateSessions(opCtx, boost::none); + MongoDSessionCatalog::invalidateSessions(opCtx, boost::none); } AuthorizationManager::get(opCtx->getServiceContext()) @@ -1145,7 +1145,7 @@ void OpObserverImpl::onReplicationRollback(OperationContext* opCtx, // If there were ops rolled back that were part of operations on a session, then invalidate // the session cache. if (rbInfo.rollbackSessionIds.size() > 0) { - SessionCatalog::get(opCtx)->invalidateSessions(opCtx, boost::none); + MongoDSessionCatalog::invalidateSessions(opCtx, boost::none); } // Reset the key manager cache. |