diff options
Diffstat (limited to 'src/mongo/db/s/session_catalog_migration_destination.cpp')
| -rw-r--r-- | src/mongo/db/s/session_catalog_migration_destination.cpp | 11 |
1 files changed, 0 insertions, 11 deletions
diff --git a/src/mongo/db/s/session_catalog_migration_destination.cpp b/src/mongo/db/s/session_catalog_migration_destination.cpp index 2ae622b4e51..380c97cb1da 100644 --- a/src/mongo/db/s/session_catalog_migration_destination.cpp +++ b/src/mongo/db/s/session_catalog_migration_destination.cpp @@ -55,7 +55,6 @@ namespace mongo { namespace { const auto kOplogField = "oplog"; -const auto kWaitsForNewOplogField = "waitsForNewOplog"; const WriteConcernOptions kMajorityWC(WriteConcernOptions::kMajority, WriteConcernOptions::SyncMode::UNSET, Milliseconds(0)); @@ -389,7 +388,6 @@ void SessionCatalogMigrationDestination::_retrieveSessionStateFromSource(Service nextBatch = getNextSessionOplogBatch(opCtx, _fromShard, _migrationSessionId); oplogArray = BSONArray{nextBatch[kOplogField].Obj()}; - const auto donorWaitsForNewOplog = nextBatch[kWaitsForNewOplogField].trueValue(); if (oplogArray.isEmpty()) { { @@ -422,15 +420,6 @@ void SessionCatalogMigrationDestination::_retrieveSessionStateFromSource(Service } } - // TODO: SERVER-40187 Completely remove after v4.2. donorWaitsForNewOplog is a - // 'feature flag' indicating that the donor does block until there are new oplog - // to return so we don't need to sleep here. - if (!donorWaitsForNewOplog && lastOpTimeWaited == lastResult.oplogTime) { - // We got an empty result at least twice in a row from the source shard so space - // it out a little bit so we don't hammer the shard - opCtx->sleepFor(Milliseconds(200)); - } - lastOpTimeWaited = lastResult.oplogTime; } } |