diff options
author | Harald Musum <musum@verizonmedia.com> | 2021-05-13 06:33:42 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-05-13 06:33:42 +0200 |
commit | 4602f58db14c6b73a0ed0c73e0d1fa7e64f0865d (patch) | |
tree | cea4880d18ab5a2089b4339349a78b54405cd385 /searchcore/src/tests/proton/documentdb/documentbucketmover | |
parent | d06fbe9946bdc7b6e43806ab8379e0ba5e21f79f (diff) |
Revert "Revert "Revert "Now that everything is controlled bucketwise by the bucket db we shou…"""
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/documentbucketmover')
-rw-r--r-- | searchcore/src/tests/proton/documentdb/documentbucketmover/documentmover_test.cpp | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/searchcore/src/tests/proton/documentdb/documentbucketmover/documentmover_test.cpp b/searchcore/src/tests/proton/documentdb/documentbucketmover/documentmover_test.cpp index 475d5064104..143d8f290c6 100644 --- a/searchcore/src/tests/proton/documentdb/documentbucketmover/documentmover_test.cpp +++ b/searchcore/src/tests/proton/documentdb/documentbucketmover/documentmover_test.cpp @@ -90,6 +90,23 @@ TEST_F(DocumentMoverTest, require_that_we_can_move_all_documents) } } +TEST_F(DocumentMoverTest, require_that_move_is_stalled_if_document_is_pending_commit) +{ + setupForBucket(_source.bucket(1), 6, 9); + { + IPendingLidTracker::Token token = _pendingLidsForCommit.produce(1); + EXPECT_FALSE(moveDocuments(5)); + EXPECT_FALSE(_mover.bucketDone()); + } + EXPECT_TRUE(moveDocuments(5)); + EXPECT_TRUE(_mover.bucketDone()); + EXPECT_EQ(5u, _handler._moves.size()); + EXPECT_EQ(5u, _limiter.beginOpCount); + for (size_t i = 0; i < 5u; ++i) { + assertEqual(_source.bucket(1), _source.docs(1)[0], 6, 9, _handler._moves[0]); + } +} + TEST_F(DocumentMoverTest, require_that_bucket_is_cached_when_IDocumentMoveHandler_handles_move_operation) { setupForBucket(_source.bucket(1), 6, 9); |