diff options
| author | Lucas de Castro Borges <lucas@gnuabordo.com.br> | 2025-02-11 15:07:35 -0300 |
|---|---|---|
| committer | Lucas de Castro Borges <lucas@gnuabordo.com.br> | 2025-02-11 15:07:35 -0300 |
| commit | 4cb8841196d0625dfa3825aa326f071cd27c7b8b (patch) | |
| tree | 1682a647d4463397c119183369ae6f750d5fdcff /src/mongo/s/catalog_cache_test.cpp | |
| parent | aa03c6362cbaa767638e6eed9b031d86dd2643d1 (diff) | |
| parent | 8f0827553e09872941945a093b647a4211a9db7f (diff) | |
Update upstream source from tag 'upstream/6.0.0'master
Update to upstream version '6.0.0'
with Debian dir 5604a80ec1c96ca76f25f40d78e6ef855abec322
Diffstat (limited to 'src/mongo/s/catalog_cache_test.cpp')
| -rw-r--r-- | src/mongo/s/catalog_cache_test.cpp | 66 |
1 files changed, 0 insertions, 66 deletions
diff --git a/src/mongo/s/catalog_cache_test.cpp b/src/mongo/s/catalog_cache_test.cpp index 61a6ca2b067..be608cbb68c 100644 --- a/src/mongo/s/catalog_cache_test.cpp +++ b/src/mongo/s/catalog_cache_test.cpp @@ -33,12 +33,9 @@ #include <boost/optional/optional_io.hpp> -#include "mongo/db/cursor_id.h" -#include "mongo/db/query/cursor_response.h" #include "mongo/s/catalog/type_database_gen.h" #include "mongo/s/catalog_cache.h" #include "mongo/s/catalog_cache_loader_mock.h" -#include "mongo/s/shard_cannot_refresh_due_to_locks_held_exception.h" #include "mongo/s/sharding_router_test_fixture.h" #include "mongo/s/stale_exception.h" #include "mongo/s/type_collection_common_types_gen.h" @@ -302,69 +299,6 @@ TEST_F(CatalogCacheTest, OnStaleShardVersionWithGraterVersion) { ASSERT(status == ErrorCodes::InternalError); } -TEST_F(CatalogCacheTest, GetCollectionRoutingInfoAllowLocksReturnsImmediately) { - const auto dbVersion = DatabaseVersion(UUID::gen(), Timestamp(1, 1)); - const auto cachedCollVersion = ChunkVersion(1, 0, OID::gen(), Timestamp(1, 1)); - - loadDatabases({DatabaseType(kNss.db().toString(), kShards[0], dbVersion)}); - loadCollection(cachedCollVersion); - - const auto swCm = - _catalogCache->getCollectionRoutingInfo(operationContext(), kNss, true /* allowLocks */); - ASSERT_OK(swCm.getStatus()); - - ASSERT(swCm.getValue().getVersion() == cachedCollVersion); -} - -TEST_F(CatalogCacheTest, GetCollectionRoutingInfoAllowLocksNeedsToFetchNewCollInfo) { - const auto dbVersion = DatabaseVersion(UUID::gen(), Timestamp(1, 1)); - const auto cachedCollVersion = ChunkVersion(1, 0, OID::gen(), Timestamp(1, 1)); - const auto wantedCollVersion = - ChunkVersion(2, 0, cachedCollVersion.epoch(), cachedCollVersion.getTimestamp()); - - loadDatabases({DatabaseType(kNss.db().toString(), kShards[0], dbVersion)}); - loadCollection(cachedCollVersion); - _catalogCache->invalidateShardOrEntireCollectionEntryForShardedCollection( - kNss, wantedCollVersion, kShards[0]); - - { - FailPointEnableBlock failPoint("blockCollectionCacheLookup"); - - const auto status = - _catalogCache->getCollectionRoutingInfo(operationContext(), kNss, true /* allowLocks */) - .getStatus(); - - ASSERT(status == ErrorCodes::ShardCannotRefreshDueToLocksHeld); - auto refreshInfo = status.extraInfo<ShardCannotRefreshDueToLocksHeldInfo>(); - ASSERT(refreshInfo); - } - // Cancel ongoing refresh - _catalogCache->invalidateCollectionEntry_LINEARIZABLE(kNss); -} - -TEST_F(CatalogCacheTest, GetCollectionRoutingInfoAllowLocksNeedsToFetchNewDBInfo) { - const auto dbVersion = DatabaseVersion(UUID::gen(), Timestamp(1, 1)); - const auto cachedCollVersion = ChunkVersion(1, 0, OID::gen(), Timestamp(1, 1)); - - loadDatabases({DatabaseType(kNss.db().toString(), kShards[0], dbVersion)}); - loadCollection(cachedCollVersion); - _catalogCache->invalidateDatabaseEntry_LINEARIZABLE(kNss.db()); - - { - FailPointEnableBlock failPoint("blockDatabaseCacheLookup"); - - const auto status = - _catalogCache->getCollectionRoutingInfo(operationContext(), kNss, true /* allowLocks */) - .getStatus(); - - ASSERT(status == ErrorCodes::ShardCannotRefreshDueToLocksHeld); - auto refreshInfo = status.extraInfo<ShardCannotRefreshDueToLocksHeldInfo>(); - ASSERT(refreshInfo); - } - // Cancel ongoing refresh - _catalogCache->invalidateDatabaseEntry_LINEARIZABLE(kNss.db()); -} - TEST_F(CatalogCacheTest, TimeseriesFieldsAreProperlyPropagatedOnCC) { const auto dbVersion = DatabaseVersion(UUID::gen(), Timestamp(1, 1)); const auto epoch = OID::gen(); |
