summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/tenant_all_database_cloner_test.cpp
diff options
context:
space:
mode:
authorLingzhi Deng <lingzhi.deng@mongodb.com>2021-03-10 19:48:39 -0500
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-03-17 01:05:54 +0000
commitef10e1a9d7e4ba5278ce80190d181d4f5fbd684d (patch)
tree6af533e8966cfd1c95a64401c286878d17f540c7 /src/mongo/db/repl/tenant_all_database_cloner_test.cpp
parent77a1e00c536e2f76327bfb96aff1b3323bbfcc5a (diff)
downloadmongo-ef10e1a9d7e4ba5278ce80190d181d4f5fbd684d.tar.gz
SERVER-54267: Update tenant migration recipient currentOp output for cloners stats
Diffstat (limited to 'src/mongo/db/repl/tenant_all_database_cloner_test.cpp')
-rw-r--r--src/mongo/db/repl/tenant_all_database_cloner_test.cpp8
1 files changed, 8 insertions, 0 deletions
diff --git a/src/mongo/db/repl/tenant_all_database_cloner_test.cpp b/src/mongo/db/repl/tenant_all_database_cloner_test.cpp
index c05c035b094..c736493c0d6 100644
--- a/src/mongo/db/repl/tenant_all_database_cloner_test.cpp
+++ b/src/mongo/db/repl/tenant_all_database_cloner_test.cpp
@@ -392,6 +392,8 @@ TEST_F(TenantAllDatabaseClonerTest, ResumingFromLastClonedDb) {
auto databases = getDatabasesFromCloner(cloner.get());
ASSERT_EQUALS(1u, databases.size());
ASSERT_EQUALS(_tenantDbAAB, databases[0]);
+
+ ASSERT_EQUALS(1, cloner->getStats().databasesClonedBeforeFailover);
}
TEST_F(TenantAllDatabaseClonerTest, LastClonedDbDeleted_AllGreater) {
@@ -415,6 +417,8 @@ TEST_F(TenantAllDatabaseClonerTest, LastClonedDbDeleted_AllGreater) {
ASSERT_EQUALS(2u, databases.size());
ASSERT_EQUALS(_tenantDbAAB, databases[0]);
ASSERT_EQUALS(_tenantDbABC, databases[1]);
+
+ ASSERT_EQUALS(1, cloner->getStats().databasesClonedBeforeFailover);
}
TEST_F(TenantAllDatabaseClonerTest, LastClonedDbDeleted_SomeGreater) {
@@ -439,6 +443,8 @@ TEST_F(TenantAllDatabaseClonerTest, LastClonedDbDeleted_SomeGreater) {
auto databases = getDatabasesFromCloner(cloner.get());
ASSERT_EQUALS(1u, databases.size());
ASSERT_EQUALS(_tenantDbABC, databases[0]);
+
+ ASSERT_EQUALS(2, cloner->getStats().databasesClonedBeforeFailover);
}
TEST_F(TenantAllDatabaseClonerTest, LastClonedDbDeleted_AllLess) {
@@ -463,6 +469,8 @@ TEST_F(TenantAllDatabaseClonerTest, LastClonedDbDeleted_AllLess) {
// Nothing to clone.
auto databases = getDatabasesFromCloner(cloner.get());
ASSERT_EQUALS(0u, databases.size());
+
+ ASSERT_EQUALS(3, cloner->getStats().databasesClonedBeforeFailover);
}
} // namespace repl