summaryrefslogtreecommitdiff
path: root/src/mongo/s/catalog/sharding_catalog_client_test.cpp
diff options
context:
space:
mode:
authorAllison Easton <allison.easton@mongodb.com>2021-09-21 13:39:28 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-09-21 14:39:04 +0000
commit9e1d37df7bf5bb4c8312f155bd671214f75ea296 (patch)
treec0895615554be30d482ec9923af19ea75b9745ae /src/mongo/s/catalog/sharding_catalog_client_test.cpp
parentbfef41e47abf95ec8f8114552d44df6c58409c9c (diff)
downloadmongo-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.cpp27
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 =