summaryrefslogtreecommitdiff
path: root/src/mongo/s/catalog
diff options
context:
space:
mode:
authorAllison Easton <allison.easton@mongodb.com>2021-08-16 09:33:00 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-08-16 10:14:51 +0000
commitf38a3ad9917367784698a115b4a541bebfb4e65d (patch)
tree8138fa93d844190cd0c360e559b83804ca484b17 /src/mongo/s/catalog
parent6044b442c75a730e0d85cd3952ec51088b64c616 (diff)
downloadmongo-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.cpp22
-rw-r--r--src/mongo/s/catalog/type_database_test.cpp4
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();