summaryrefslogtreecommitdiff
path: root/src/mongo/s/catalog_cache_test.cpp
diff options
context:
space:
mode:
authorAllison Easton <allison.easton@mongodb.com>2022-11-23 16:06:22 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-11-23 16:33:06 +0000
commitd5209179dc52ac6411f8fcacb1b9405fe617d8a5 (patch)
tree917f8b89998e77aefecc7946a42db149f3e0a741 /src/mongo/s/catalog_cache_test.cpp
parent9114c3335f84c500eb767d06b7960eeff2802a56 (diff)
downloadmongo-d5209179dc52ac6411f8fcacb1b9405fe617d8a5.tar.gz
SERVER-70382 Replace boost::none index versions with the actual index version from the catalog cache or CSR
Diffstat (limited to 'src/mongo/s/catalog_cache_test.cpp')
-rw-r--r--src/mongo/s/catalog_cache_test.cpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/mongo/s/catalog_cache_test.cpp b/src/mongo/s/catalog_cache_test.cpp
index c295efaa664..91b3f6f9948 100644
--- a/src/mongo/s/catalog_cache_test.cpp
+++ b/src/mongo/s/catalog_cache_test.cpp
@@ -135,7 +135,7 @@ protected:
const auto scopedChunksProv = scopedChunksProvider(makeChunks(version.placementVersion()));
const auto swChunkManager =
- _catalogCache->getCollectionRoutingInfo(operationContext(), coll.getNss());
+ _catalogCache->getCollectionPlacementInfo(operationContext(), coll.getNss());
ASSERT_OK(swChunkManager.getStatus());
auto future = launchAsync([&] {
onCommand([&](const executor::RemoteCommandRequest& request) {
@@ -153,7 +153,7 @@ protected:
scopedCollectionProvider(Status(ErrorCodes::NamespaceNotFound, "collection not found"));
const auto swChunkManager =
- _catalogCache->getCollectionRoutingInfo(operationContext(), nss);
+ _catalogCache->getCollectionPlacementInfo(operationContext(), nss);
ASSERT_OK(swChunkManager.getStatus());
}
@@ -291,7 +291,7 @@ TEST_F(CatalogCacheTest, OnStaleShardVersionWithSameVersion) {
loadCollection(cachedCollVersion);
_catalogCache->invalidateShardOrEntireCollectionEntryForShardedCollection(
kNss, cachedCollVersion, kShards[0]);
- ASSERT_OK(_catalogCache->getCollectionRoutingInfo(operationContext(), kNss).getStatus());
+ ASSERT_OK(_catalogCache->getCollectionPlacementInfo(operationContext(), kNss).getStatus());
}
TEST_F(CatalogCacheTest, OnStaleShardVersionWithNoVersion) {
@@ -305,7 +305,7 @@ TEST_F(CatalogCacheTest, OnStaleShardVersionWithNoVersion) {
_catalogCache->invalidateShardOrEntireCollectionEntryForShardedCollection(
kNss, boost::none, kShards[0]);
const auto status =
- _catalogCache->getCollectionRoutingInfo(operationContext(), kNss).getStatus();
+ _catalogCache->getCollectionPlacementInfo(operationContext(), kNss).getStatus();
ASSERT(status == ErrorCodes::InternalError);
}
@@ -322,7 +322,7 @@ TEST_F(CatalogCacheTest, OnStaleShardVersionWithGreaterPlacementVersion) {
_catalogCache->invalidateShardOrEntireCollectionEntryForShardedCollection(
kNss, wantedCollVersion, kShards[0]);
const auto status =
- _catalogCache->getCollectionRoutingInfo(operationContext(), kNss).getStatus();
+ _catalogCache->getCollectionPlacementInfo(operationContext(), kNss).getStatus();
ASSERT(status == ErrorCodes::InternalError);
}
@@ -349,7 +349,7 @@ TEST_F(CatalogCacheTest, TimeseriesFieldsAreProperlyPropagatedOnCC) {
const auto scopedChunksProv = scopedChunksProvider(chunks);
const auto swChunkManager =
- _catalogCache->getCollectionRoutingInfoWithRefresh(operationContext(), coll.getNss());
+ _catalogCache->getCollectionPlacementInfoWithRefresh(operationContext(), coll.getNss());
ASSERT_OK(swChunkManager.getStatus());
const auto& chunkManager = swChunkManager.getValue();
@@ -374,7 +374,7 @@ TEST_F(CatalogCacheTest, TimeseriesFieldsAreProperlyPropagatedOnCC) {
const auto scopedChunksProv = scopedChunksProvider(std::vector{lastChunk});
const auto swChunkManager =
- _catalogCache->getCollectionRoutingInfoWithRefresh(operationContext(), coll.getNss());
+ _catalogCache->getCollectionPlacementInfoWithRefresh(operationContext(), coll.getNss());
ASSERT_OK(swChunkManager.getStatus());
const auto& chunkManager = swChunkManager.getValue();
@@ -399,7 +399,7 @@ TEST_F(CatalogCacheTest, LookupCollectionWithInvalidOptions) {
ErrorCodes::InvalidOptions, "Testing error with invalid options"));
const auto swChunkManager =
- _catalogCache->getCollectionRoutingInfoWithRefresh(operationContext(), coll.getNss());
+ _catalogCache->getCollectionPlacementInfoWithRefresh(operationContext(), coll.getNss());
ASSERT_EQUALS(swChunkManager.getStatus(), ErrorCodes::InvalidOptions);
}