diff options
author | Allison Easton <allison.easton@mongodb.com> | 2021-08-16 09:33:00 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-08-16 10:14:51 +0000 |
commit | f38a3ad9917367784698a115b4a541bebfb4e65d (patch) | |
tree | 8138fa93d844190cd0c360e559b83804ca484b17 /src/mongo/s/catalog | |
parent | 6044b442c75a730e0d85cd3952ec51088b64c616 (diff) | |
download | mongo-f38a3ad9917367784698a115b4a541bebfb4e65d.tar.gz |
SERVER-58989 Make timestamp required in DatabaseVersionBase IDL
Diffstat (limited to 'src/mongo/s/catalog')
-rw-r--r-- | src/mongo/s/catalog/sharding_catalog_client_test.cpp | 22 | ||||
-rw-r--r-- | src/mongo/s/catalog/type_database_test.cpp | 4 |
2 files changed, 17 insertions, 9 deletions
diff --git a/src/mongo/s/catalog/sharding_catalog_client_test.cpp b/src/mongo/s/catalog/sharding_catalog_client_test.cpp index 54528489f36..cd23a564d32 100644 --- a/src/mongo/s/catalog/sharding_catalog_client_test.cpp +++ b/src/mongo/s/catalog/sharding_catalog_client_test.cpp @@ -158,7 +158,8 @@ TEST_F(ShardingCatalogClientTest, GetDatabaseInvalidName) { TEST_F(ShardingCatalogClientTest, GetDatabaseExisting) { configTargeter()->setFindHostReturnValue(HostAndPort("TestHost1")); - DatabaseType expectedDb("bigdata", ShardId("shard0000"), true, DatabaseVersion(UUID::gen())); + DatabaseType expectedDb( + "bigdata", ShardId("shard0000"), true, DatabaseVersion(UUID::gen(), Timestamp())); const OpTime newOpTime(Timestamp(7, 6), 5); @@ -205,7 +206,8 @@ TEST_F(ShardingCatalogClientTest, GetDatabaseStaleSecondaryRetrySuccess) { HostAndPort secondHost{"TestHost2"}; configTargeter()->setFindHostReturnValue(firstHost); - DatabaseType expectedDb("bigdata", ShardId("shard0000"), true, DatabaseVersion(UUID::gen())); + DatabaseType expectedDb( + "bigdata", ShardId("shard0000"), true, DatabaseVersion(UUID::gen(), Timestamp())); auto future = launchAsync([this, &expectedDb] { return catalogClient()->getDatabase( @@ -891,8 +893,10 @@ TEST_F(ShardingCatalogClientTest, GetCollectionsInvalidCollectionType) { TEST_F(ShardingCatalogClientTest, GetDatabasesForShardValid) { configTargeter()->setFindHostReturnValue(HostAndPort("TestHost1")); - DatabaseType dbt1("db1", ShardId("shard0000"), false, DatabaseVersion(UUID::gen())); - DatabaseType dbt2("db2", ShardId("shard0000"), false, DatabaseVersion(UUID::gen())); + DatabaseType dbt1( + "db1", ShardId("shard0000"), false, DatabaseVersion(UUID::gen(), Timestamp())); + DatabaseType dbt2( + "db2", ShardId("shard0000"), false, DatabaseVersion(UUID::gen(), Timestamp())); auto future = launchAsync([this] { return assertGet( @@ -934,7 +938,7 @@ TEST_F(ShardingCatalogClientTest, GetDatabasesForShardInvalidDoc) { }); onFindCommand([](const RemoteCommandRequest& request) { - DatabaseType dbt1("db1", {"shard0000"}, false, DatabaseVersion(UUID::gen())); + DatabaseType dbt1("db1", {"shard0000"}, false, DatabaseVersion(UUID::gen(), Timestamp())); return vector<BSONObj>{ dbt1.toBSON(), BSON(DatabaseType::name() << 0) // DatabaseType::name() should be a string @@ -1039,7 +1043,7 @@ TEST_F(ShardingCatalogClientTest, GetTagsForCollectionInvalidTag) { TEST_F(ShardingCatalogClientTest, UpdateDatabase) { configTargeter()->setFindHostReturnValue(HostAndPort("TestHost1")); - DatabaseType dbt("test", ShardId("shard0000"), true, DatabaseVersion(UUID::gen())); + DatabaseType dbt("test", ShardId("shard0000"), true, DatabaseVersion(UUID::gen(), Timestamp())); auto future = launchAsync([this, dbt] { auto status = @@ -1086,7 +1090,8 @@ TEST_F(ShardingCatalogClientTest, UpdateConfigDocumentNonRetryableError) { HostAndPort host1("TestHost1"); configTargeter()->setFindHostReturnValue(host1); - DatabaseType dbt("test", ShardId("shard0001"), false, DatabaseVersion(UUID::gen())); + DatabaseType dbt( + "test", ShardId("shard0001"), false, DatabaseVersion(UUID::gen(), Timestamp())); auto future = launchAsync([this, dbt] { auto status = @@ -1287,7 +1292,8 @@ TEST_F(ShardingCatalogClientTest, RetryOnFindCommandNetworkErrorSucceedsAtMaxRet } onFindCommand([](const RemoteCommandRequest& request) { - DatabaseType dbType("TestDB", ShardId("TestShard"), true, DatabaseVersion(UUID::gen())); + DatabaseType dbType( + "TestDB", ShardId("TestShard"), true, DatabaseVersion(UUID::gen(), Timestamp())); return vector<BSONObj>{dbType.toBSON()}; }); diff --git a/src/mongo/s/catalog/type_database_test.cpp b/src/mongo/s/catalog/type_database_test.cpp index 8a9eb73dcda..fe126d6b390 100644 --- a/src/mongo/s/catalog/type_database_test.cpp +++ b/src/mongo/s/catalog/type_database_test.cpp @@ -47,10 +47,12 @@ TEST(DatabaseType, Empty) { TEST(DatabaseType, Basic) { UUID uuid = UUID::gen(); + Timestamp timestamp = Timestamp(); StatusWith<DatabaseType> status = DatabaseType::fromBSON( BSON(DatabaseType::name("mydb") << DatabaseType::primary("shard") << DatabaseType::sharded(true) - << DatabaseType::version(BSON("uuid" << uuid << "lastMod" << 0)))); + << DatabaseType::version( + BSON("uuid" << uuid << "lastMod" << 0 << "timestamp" << timestamp)))); ASSERT_TRUE(status.isOK()); DatabaseType db = status.getValue(); |