diff options
Diffstat (limited to 'src/mongo/s/catalog/sharding_catalog_config_initialization_test.cpp')
-rw-r--r-- | src/mongo/s/catalog/sharding_catalog_config_initialization_test.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/mongo/s/catalog/sharding_catalog_config_initialization_test.cpp b/src/mongo/s/catalog/sharding_catalog_config_initialization_test.cpp index 9ad591d8ed1..b4aef2e25ce 100644 --- a/src/mongo/s/catalog/sharding_catalog_config_initialization_test.cpp +++ b/src/mongo/s/catalog/sharding_catalog_config_initialization_test.cpp @@ -221,7 +221,7 @@ TEST_F(ConfigInitializationTest, ReRunsIfDocRolledBackThenReElected) { auto opCtx = operationContext(); repl::UnreplicatedWritesBlock uwb(opCtx); auto nss = NamespaceString(VersionType::ConfigNS); - MONGO_WRITE_CONFLICT_RETRY_LOOP_BEGIN { + writeConflictRetry(opCtx, "removeConfigDocuments", nss.ns(), [&] { AutoGetCollection autoColl(opCtx, nss, MODE_IX); auto coll = autoColl.getCollection(); ASSERT_TRUE(coll); @@ -236,8 +236,7 @@ TEST_F(ConfigInitializationTest, ReRunsIfDocRolledBackThenReElected) { } wuow.commit(); ASSERT_EQUALS(0UL, coll->numRecords(opCtx)); - } - MONGO_WRITE_CONFLICT_RETRY_LOOP_END(opCtx, "removeConfigDocuments", nss.ns()); + }); } // Verify the document was actually removed. |