diff options
| author | Benety Goh <benety@mongodb.com> | 2015-05-12 11:46:12 -0400 |
|---|---|---|
| committer | Benety Goh <benety@mongodb.com> | 2015-05-19 10:44:09 -0400 |
| commit | 4d0d95aa01a2c06769e56e42698db41a0dd877c4 (patch) | |
| tree | b2d7ff4dc7e10f51db2e2e4d1fa58ac3be62ccb5 /src/mongo/db/repl/database_cloner_test.cpp | |
| parent | 0736269db8697f72bc2deb05abbb917b716d14a4 (diff) | |
| download | mongo-4d0d95aa01a2c06769e56e42698db41a0dd877c4.tar.gz | |
SERVER-18016 added database replication applier
grant internal authorization to db worker thread
added test case to replication executor test to verify that exclusive lock work items are still invoked with a canceled status during shutdown
Diffstat (limited to 'src/mongo/db/repl/database_cloner_test.cpp')
| -rw-r--r-- | src/mongo/db/repl/database_cloner_test.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/db/repl/database_cloner_test.cpp b/src/mongo/db/repl/database_cloner_test.cpp index 6a55abf61c5..ef1165bf6f1 100644 --- a/src/mongo/db/repl/database_cloner_test.cpp +++ b/src/mongo/db/repl/database_cloner_test.cpp @@ -211,7 +211,7 @@ namespace { // Keep going even if initial batch is empty. processNetworkResponse(createListCollectionsResponse(1, BSONArray())); - ASSERT_EQUALS(getDefaultStatus(), getStatus()); + ASSERT_EQUALS(getDetectableErrorStatus(), getStatus()); ASSERT_TRUE(databaseCloner->isActive()); // Final batch is also empty. Database cloner should stop and return a successful status. @@ -248,7 +248,7 @@ namespace { sourceInfos[1] << sourceInfos[2]))); - ASSERT_EQUALS(getDefaultStatus(), getStatus()); + ASSERT_EQUALS(getDetectableErrorStatus(), getStatus()); ASSERT_TRUE(databaseCloner->isActive()); const std::vector<BSONObj>& collectionInfos = databaseCloner->getCollectionInfos(); @@ -265,7 +265,7 @@ namespace { BSON("name" << "b" << "options" << BSONObj())}; processNetworkResponse(createListCollectionsResponse(1, BSON_ARRAY(sourceInfos[0]))); - ASSERT_EQUALS(getDefaultStatus(), getStatus()); + ASSERT_EQUALS(getDetectableErrorStatus(), getStatus()); ASSERT_TRUE(databaseCloner->isActive()); { @@ -277,7 +277,7 @@ namespace { processNetworkResponse( createListCollectionsResponse(0, BSON_ARRAY(sourceInfos[1]), "nextBatch")); - ASSERT_EQUALS(getDefaultStatus(), getStatus()); + ASSERT_EQUALS(getDetectableErrorStatus(), getStatus()); ASSERT_TRUE(databaseCloner->isActive()); { @@ -435,7 +435,7 @@ namespace { processNetworkResponse(createListCollectionsResponse(0, BSON_ARRAY(sourceInfos[0] << sourceInfos[1]))); - ASSERT_EQUALS(getDefaultStatus(), getStatus()); + ASSERT_EQUALS(getDetectableErrorStatus(), getStatus()); ASSERT_TRUE(databaseCloner->isActive()); // Collection cloners are run serially for now. @@ -476,7 +476,7 @@ namespace { processNetworkResponse(createListCollectionsResponse(0, BSON_ARRAY(sourceInfos[0] << sourceInfos[1]))); - ASSERT_EQUALS(getDefaultStatus(), getStatus()); + ASSERT_EQUALS(getDetectableErrorStatus(), getStatus()); ASSERT_TRUE(databaseCloner->isActive()); // Collection cloners are run serially for now. |