summaryrefslogtreecommitdiff
path: root/src/mongo
diff options
context:
space:
mode:
authorEnrico Golfieri <enrico.golfieri@mongodb.com>2022-06-20 16:17:43 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-06-20 17:30:32 +0000
commit3a40dc5b82be4a070fd140d422f817208b854a5c (patch)
tree1bf0301100800319f9b51b1f3fc980a33823f5a5 /src/mongo
parent68241e3d17119291b6c1295ae81d41937ae99042 (diff)
downloadmongo-3a40dc5b82be4a070fd140d422f817208b854a5c.tar.gz
SERVER-59658 [v4.2] Improve logging to reflect that sharding metadata refresh waiting on replication
Diffstat (limited to 'src/mongo')
-rw-r--r--src/mongo/db/s/shard_server_catalog_cache_loader.cpp10
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));