diff options
author | Allison Easton <allison.easton@mongodb.com> | 2021-09-21 13:39:28 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-09-21 14:39:04 +0000 |
commit | 9e1d37df7bf5bb4c8312f155bd671214f75ea296 (patch) | |
tree | c0895615554be30d482ec9923af19ea75b9745ae /src/mongo/s/catalog/sharding_catalog_client_test.cpp | |
parent | bfef41e47abf95ec8f8114552d44df6c58409c9c (diff) | |
download | mongo-9e1d37df7bf5bb4c8312f155bd671214f75ea296.tar.gz |
SERVER-52847 Make timestamp required in CollectionType and ShardCollectionType IDL
Diffstat (limited to 'src/mongo/s/catalog/sharding_catalog_client_test.cpp')
-rw-r--r-- | src/mongo/s/catalog/sharding_catalog_client_test.cpp | 27 |
1 files changed, 15 insertions, 12 deletions
diff --git a/src/mongo/s/catalog/sharding_catalog_client_test.cpp b/src/mongo/s/catalog/sharding_catalog_client_test.cpp index 35a5371bb89..49ec74a361a 100644 --- a/src/mongo/s/catalog/sharding_catalog_client_test.cpp +++ b/src/mongo/s/catalog/sharding_catalog_client_test.cpp @@ -86,7 +86,7 @@ TEST_F(ShardingCatalogClientTest, GetCollectionExisting) { configTargeter()->setFindHostReturnValue(HostAndPort("TestHost1")); CollectionType expectedColl( - NamespaceString("TestDB.TestNS"), OID::gen(), Date_t::now(), UUID::gen()); + NamespaceString("TestDB.TestNS"), OID::gen(), Timestamp(), Date_t::now(), UUID::gen()); expectedColl.setKeyPattern(BSON("KeyName" << 1)); const OpTime newOpTime(Timestamp(7, 6), 5); @@ -355,7 +355,7 @@ TEST_F(ShardingCatalogClientTest, GetChunksForNSWithSortAndLimit) { const auto collUuid = UUID::gen(); const auto collEpoch = OID::gen(); - const auto collTimestamp = boost::none; + const auto collTimestamp = Timestamp(1, 1); ChunkType chunkA; chunkA.setName(OID::gen()); @@ -441,7 +441,7 @@ TEST_F(ShardingCatalogClientTest, GetChunksForUUIDNoSortNoLimit) { const auto collUuid = UUID::gen(); const auto collEpoch = OID::gen(); - const auto collTimestamp = boost::none; + const auto collTimestamp = Timestamp(); ChunkVersion queryChunkVersion({1, 2, collEpoch, collTimestamp}); @@ -490,7 +490,7 @@ TEST_F(ShardingCatalogClientTest, GetChunksForNSInvalidChunk) { configTargeter()->setFindHostReturnValue(HostAndPort("TestHost1")); const auto collUuid = UUID::gen(); - ChunkVersion queryChunkVersion({1, 2, OID::gen(), boost::none /* timestamp */}); + ChunkVersion queryChunkVersion({1, 2, OID::gen(), Timestamp()}); const BSONObj chunksQuery( BSON(ChunkType::collectionUUID() @@ -516,14 +516,14 @@ TEST_F(ShardingCatalogClientTest, GetChunksForNSInvalidChunk) { chunkA.setCollectionUUID(collUuid); chunkA.setMin(BSON("a" << 1)); chunkA.setMax(BSON("a" << 100)); - chunkA.setVersion({1, 2, OID::gen(), boost::none /* timestamp */}); + chunkA.setVersion({1, 2, OID::gen(), Timestamp()}); chunkA.setShard(ShardId("shard0000")); ChunkType chunkB; chunkB.setCollectionUUID(collUuid); chunkB.setMin(BSON("a" << 100)); chunkB.setMax(BSON("a" << 200)); - chunkB.setVersion({3, 4, OID::gen(), boost::none /* timestamp */}); + chunkB.setVersion({3, 4, OID::gen(), Timestamp()}); // Missing shard id return vector<BSONObj>{chunkA.toConfigBSON(), chunkB.toConfigBSON()}; @@ -765,13 +765,14 @@ TEST_F(ShardingCatalogClientTest, RunUserManagementWriteCommandNotWritablePrimar TEST_F(ShardingCatalogClientTest, GetCollectionsValidResultsNoDb) { configTargeter()->setFindHostReturnValue(HostAndPort("TestHost1")); - CollectionType coll1(NamespaceString{"test.coll1"}, OID::gen(), network()->now(), UUID::gen()); + CollectionType coll1( + NamespaceString{"test.coll1"}, OID::gen(), Timestamp(), network()->now(), UUID::gen()); coll1.setKeyPattern(KeyPattern{BSON("_id" << 1)}); coll1.setUnique(false); CollectionType coll2( - NamespaceString{"anotherdb.coll1"}, OID::gen(), network()->now(), UUID::gen()); + NamespaceString{"anotherdb.coll1"}, OID::gen(), Timestamp(), network()->now(), UUID::gen()); coll2.setKeyPattern(KeyPattern{BSON("_id" << 1)}); coll2.setUnique(false); @@ -818,11 +819,13 @@ TEST_F(ShardingCatalogClientTest, GetCollectionsValidResultsNoDb) { TEST_F(ShardingCatalogClientTest, GetCollectionsValidResultsWithDb) { configTargeter()->setFindHostReturnValue(HostAndPort("TestHost1")); - CollectionType coll1(NamespaceString{"test.coll1"}, OID::gen(), network()->now(), UUID::gen()); + CollectionType coll1( + NamespaceString{"test.coll1"}, OID::gen(), Timestamp(), network()->now(), UUID::gen()); coll1.setKeyPattern(KeyPattern{BSON("_id" << 1)}); coll1.setUnique(true); - CollectionType coll2(NamespaceString{"test.coll2"}, OID::gen(), network()->now(), UUID::gen()); + CollectionType coll2( + NamespaceString{"test.coll2"}, OID::gen(), Timestamp(), network()->now(), UUID::gen()); coll2.setKeyPattern(KeyPattern{BSON("_id" << 1)}); coll2.setUnique(false); @@ -863,7 +866,7 @@ TEST_F(ShardingCatalogClientTest, GetCollectionsInvalidCollectionType) { }); CollectionType validColl( - NamespaceString{"test.coll1"}, OID::gen(), network()->now(), UUID::gen()); + NamespaceString{"test.coll1"}, OID::gen(), Timestamp(), network()->now(), UUID::gen()); validColl.setKeyPattern(KeyPattern{BSON("_id" << 1)}); validColl.setUnique(true); @@ -1185,7 +1188,7 @@ TEST_F(ShardingCatalogClientTest, ApplyChunkOpsDeprecatedSuccessfulWithCheck) { << "second precondition")); const NamespaceString nss("config.chunks"); const UUID uuid = UUID::gen(); - ChunkVersion lastChunkVersion(0, 0, OID(), boost::none /* timestamp */); + ChunkVersion lastChunkVersion(0, 0, OID(), Timestamp()); auto future = launchAsync([this, updateOps, preCondition, uuid, nss, lastChunkVersion] { auto status = |