diff options
| author | Antonio Fuschetto <antonio.fuschetto@mongodb.com> | 2022-10-07 10:12:00 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-10-07 13:36:06 +0000 |
| commit | 29c8d88c97f9878f0d841adc61fcbf6758fca55f (patch) | |
| tree | 315deafae0f11cb9aa3f9cab51c3cff64c27cb43 /src/mongo/db | |
| parent | 41d01f91c084d81d5c5741942dcbe9e40f2edf64 (diff) | |
| download | mongo-29c8d88c97f9878f0d841adc61fcbf6758fca55f.tar.gz | |
SERVER-69898 Wait for the critical section catch-up phase before refreshing the DB version
Diffstat (limited to 'src/mongo/db')
| -rw-r--r-- | src/mongo/db/s/flush_database_cache_updates_command.cpp | 4 | ||||
| -rw-r--r-- | src/mongo/db/s/shard_filtering_metadata_refresh.cpp | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/s/flush_database_cache_updates_command.cpp b/src/mongo/db/s/flush_database_cache_updates_command.cpp index 8ffeb3b008e..729572272f6 100644 --- a/src/mongo/db/s/flush_database_cache_updates_command.cpp +++ b/src/mongo/db/s/flush_database_cache_updates_command.cpp @@ -173,8 +173,8 @@ public: // consistency guarantee. const auto dss = DatabaseShardingState::get(opCtx, _dbName()); auto dssLock = DatabaseShardingState::DSSLock::lockShared(opCtx, dss); - criticalSectionSignal = - dss->getCriticalSectionSignal(ShardingMigrationCriticalSection::kRead, dssLock); + criticalSectionSignal = dss->getCriticalSectionSignal( + ShardingMigrationCriticalSection::kWrite, dssLock); } if (criticalSectionSignal) diff --git a/src/mongo/db/s/shard_filtering_metadata_refresh.cpp b/src/mongo/db/s/shard_filtering_metadata_refresh.cpp index fe5a2b18dc4..e2d0b1155dd 100644 --- a/src/mongo/db/s/shard_filtering_metadata_refresh.cpp +++ b/src/mongo/db/s/shard_filtering_metadata_refresh.cpp @@ -71,7 +71,7 @@ bool joinDbVersionOperation(OperationContext* opCtx, invariant(dssLock->has_value()); if (auto critSect = - dss->getCriticalSectionSignal(ShardingMigrationCriticalSection::kRead, **dssLock)) { + dss->getCriticalSectionSignal(ShardingMigrationCriticalSection::kWrite, **dssLock)) { LOGV2_DEBUG(6697201, 2, "Waiting for exit from the critical section", |