diff options
Diffstat (limited to 'src/mongo/db/s/session_catalog_migration_source.cpp')
| -rw-r--r-- | src/mongo/db/s/session_catalog_migration_source.cpp | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/src/mongo/db/s/session_catalog_migration_source.cpp b/src/mongo/db/s/session_catalog_migration_source.cpp index e99913c1eeb..c3b96f0302f 100644 --- a/src/mongo/db/s/session_catalog_migration_source.cpp +++ b/src/mongo/db/s/session_catalog_migration_source.cpp @@ -113,9 +113,7 @@ repl::OplogEntry makeSentinelOplogEntry(OperationSessionInfo sessionInfo) { SessionCatalogMigrationSource::SessionCatalogMigrationSource(OperationContext* opCtx, NamespaceString ns) - : _ns(std::move(ns)), - _rollbackIdAtInit( - uassertStatusOK(repl::ReplicationProcess::get(opCtx)->getRollbackID(opCtx))) { + : _ns(std::move(ns)), _rollbackIdAtInit(repl::ReplicationProcess::get(opCtx)->getRollbackID()) { // Sort is not needed for correctness. This is just for making it easier to write deterministic // tests. Query query; @@ -325,8 +323,7 @@ repl::OplogEntry SessionCatalogMigrationSource::SessionOplogIterator::getNext( if (excep.code() == ErrorCodes::IncompleteTransactionHistory) { // Note: no need to check if in replicaSet mode because having an iterator implies // oplog exists. - auto rollbackId = - uassertStatusOK(repl::ReplicationProcess::get(opCtx)->getRollbackID(opCtx)); + auto rollbackId = repl::ReplicationProcess::get(opCtx)->getRollbackID(); uassert(40656, str::stream() << "rollback detected, rollbackId was " << _initialRollbackId |