diff options
author | Enrico Golfieri <enrico.golfieri@mongodb.com> | 2022-06-20 16:17:43 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-06-20 17:30:32 +0000 |
commit | 3a40dc5b82be4a070fd140d422f817208b854a5c (patch) | |
tree | 1bf0301100800319f9b51b1f3fc980a33823f5a5 | |
parent | 68241e3d17119291b6c1295ae81d41937ae99042 (diff) | |
download | mongo-3a40dc5b82be4a070fd140d422f817208b854a5c.tar.gz |
SERVER-59658 [v4.2] Improve logging to reflect that sharding metadata refresh waiting on replication
-rw-r--r-- | src/mongo/db/s/shard_server_catalog_cache_loader.cpp | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/src/mongo/db/s/shard_server_catalog_cache_loader.cpp b/src/mongo/db/s/shard_server_catalog_cache_loader.cpp index 75bd30db265..e12d87e5a7b 100644 --- a/src/mongo/db/s/shard_server_catalog_cache_loader.cpp +++ b/src/mongo/db/s/shard_server_catalog_cache_loader.cpp @@ -607,7 +607,12 @@ void ShardServerCatalogCacheLoader::_runSecondaryGetChunksSince( const ChunkVersion& catalogCacheSinceVersion, stdx::function<void(OperationContext*, StatusWith<CollectionAndChangedChunks>)> callbackFn, std::shared_ptr<Notification<void>> notify) { + + Timer t; forcePrimaryCollectionRefreshAndWaitForReplication(opCtx, nss); + LOG_CATALOG_REFRESH(2) << "Cache loader on secondary successfully waited for primary refresh " + "and replication for collection " + << nss << " in " << t.millis() << "ms"; // Read the local metadata. @@ -739,8 +744,11 @@ void ShardServerCatalogCacheLoader::_runSecondaryGetDatabase( StringData dbName, stdx::function<void(OperationContext*, StatusWith<DatabaseType>)> callbackFn) { + Timer t; forcePrimaryDatabaseRefreshAndWaitForReplication(opCtx, dbName); - + LOG_CATALOG_REFRESH(2) << "Cache loader on secondary successfully waited for primary refresh " + "and replication for database " + << dbName << " in " << t.millis() << "ms"; // Read the local metadata. auto swDatabaseType = getPersistedDbMetadata(opCtx, dbName); callbackFn(opCtx, std::move(swDatabaseType)); |