aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/documentbucketmover/scaniterator_test.cpp
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-07-18 12:37:02 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2022-08-12 15:26:19 +0000
commit8f74172202904bac49d7e2aba57529ccc32273e6 (patch)
treed5f2e665ea9b2c213cf74631000e24ed168b047f /searchcore/src/tests/proton/documentdb/documentbucketmover/scaniterator_test.cpp
parentc68ea1b2a5d2e5e34302b1b9ca0616c1e826a33c (diff)
Do not expose iterate api.
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/documentbucketmover/scaniterator_test.cpp')
-rw-r--r--searchcore/src/tests/proton/documentdb/documentbucketmover/scaniterator_test.cpp185
1 files changed, 0 insertions, 185 deletions
diff --git a/searchcore/src/tests/proton/documentdb/documentbucketmover/scaniterator_test.cpp b/searchcore/src/tests/proton/documentdb/documentbucketmover/scaniterator_test.cpp
deleted file mode 100644
index 4ec38ff7170..00000000000
--- a/searchcore/src/tests/proton/documentdb/documentbucketmover/scaniterator_test.cpp
+++ /dev/null
@@ -1,185 +0,0 @@
-// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-
-#include "bucketmover_common.h"
-#include <vespa/searchcore/proton/bucketdb/bucketscaniterator.h>
-#include <vespa/vespalib/gtest/gtest.h>
-
-#include <vespa/log/log.h>
-LOG_SETUP("document_bucket_mover_test");
-
-using namespace proton;
-using namespace proton::move::test;
-using document::BucketId;
-
-using ScanItr = bucketdb::ScanIterator;
-
-struct ScanTestBase : public ::testing::Test
-{
- test::UserDocumentsBuilder _builder;
- std::shared_ptr<bucketdb::BucketDBOwner> _bucketDB;
- MySubDb _ready;
- MySubDb _notReady;
- ScanTestBase();
- ~ScanTestBase();
-
- ScanItr getItr() {
- return getItr(BucketId());
- }
-
- ScanItr getItr(BucketId bucket) {
- return ScanItr(_bucketDB->takeGuard(), bucket);
- }
-};
-
-ScanTestBase::ScanTestBase()
- : _builder(),
- _bucketDB(std::make_shared<bucketdb::BucketDBOwner>()),
- _ready(_builder.getRepo(), _bucketDB, 1, SubDbType::READY),
- _notReady(_builder.getRepo(), _bucketDB, 2, SubDbType::NOTREADY)
-{}
-ScanTestBase::~ScanTestBase() = default;
-
-struct ScanTest : public ScanTestBase
-{
- ScanTest() : ScanTestBase()
- {
- _builder.createDocs(6, 1, 2);
- _builder.createDocs(8, 2, 3);
- _ready.insertDocs(_builder.getDocs());
- _builder.clearDocs();
- _builder.createDocs(2, 1, 2);
- _builder.createDocs(4, 2, 3);
- _notReady.insertDocs(_builder.getDocs());
- _builder.clearDocs();
- }
-};
-
-struct OnlyNotReadyScanTest : public ScanTestBase
-{
- OnlyNotReadyScanTest() : ScanTestBase()
- {
- _builder.createDocs(2, 1, 2);
- _builder.createDocs(4, 2, 3);
- _notReady.insertDocs(_builder.getDocs());
- }
-};
-
-struct OnlyReadyScanTest : public ScanTestBase
-{
- OnlyReadyScanTest() : ScanTestBase()
- {
- _builder.createDocs(6, 1, 2);
- _builder.createDocs(8, 2, 3);
- _ready.insertDocs(_builder.getDocs());
- }
-};
-
-struct BucketVector : public BucketId::List
-{
- BucketVector() : BucketId::List() {}
- BucketVector &add(const BucketId &bucket) {
- push_back(bucket);
- return *this;
- }
-};
-
-void
-advanceToFirstBucketWithDocs(ScanItr &itr, SubDbType subDbType)
-{
- while (itr.valid()) {
- if (subDbType == SubDbType::READY) {
- if (itr.hasReadyBucketDocs())
- return;
- } else {
- if (itr.hasNotReadyBucketDocs())
- return;
- }
- ++itr;
- }
-}
-
-void
-assertEquals(const BucketVector &exp, ScanItr &itr, SubDbType subDbType)
-{
- for (size_t i = 0; i < exp.size(); ++i) {
- advanceToFirstBucketWithDocs(itr, subDbType);
- EXPECT_TRUE(itr.valid());
- EXPECT_EQ(exp[i], itr.getBucket());
- ++itr;
- }
- advanceToFirstBucketWithDocs(itr, subDbType);
- EXPECT_FALSE(itr.valid());
-}
-
-TEST_F(ScanTest, require_that_we_can_iterate_all_buckets_from_start_to_end)
-{
- {
- ScanItr itr = getItr();
- assertEquals(BucketVector().
- add(_notReady.bucket(2)).
- add(_notReady.bucket(4)), itr, SubDbType::NOTREADY);
- }
- {
- ScanItr itr = getItr();
- assertEquals(BucketVector().
- add(_ready.bucket(6)).
- add(_ready.bucket(8)), itr, SubDbType::READY);
- }
-}
-
-TEST_F(ScanTest, require_that_we_can_iterate_from_the_middle_of_not_ready_buckets)
-{
- BucketId bucket = _notReady.bucket(4);
- {
- ScanItr itr = getItr(bucket);
- assertEquals(BucketVector().
- add(_notReady.bucket(4)), itr, SubDbType::NOTREADY);
- }
- {
- ScanItr itr = getItr();
- assertEquals(BucketVector().
- add(_ready.bucket(6)).
- add(_ready.bucket(8)), itr, SubDbType::READY);
- }
-}
-
-TEST_F(ScanTest, require_that_we_can_iterate_from_the_middle_of_ready_buckets)
-{
- {
- ScanItr itr = getItr();
- assertEquals(BucketVector().
- add(_notReady.bucket(2)).
- add(_notReady.bucket(4)), itr, SubDbType::NOTREADY);
- }
- {
- BucketId bucket = _ready.bucket(6);
- ScanItr itr = getItr(bucket);
- assertEquals(BucketVector().
- add(_ready.bucket(6)).
- add(_ready.bucket(8)), itr, SubDbType::READY);
- }
-}
-
-TEST_F(OnlyNotReadyScanTest, require_that_we_can_iterate_only_not_ready_buckets)
-{
- ScanItr itr = getItr();
- assertEquals(BucketVector().
- add(_notReady.bucket(2)).
- add(_notReady.bucket(4)), itr, SubDbType::NOTREADY);
-}
-
-TEST_F(OnlyReadyScanTest, require_that_we_can_iterate_only_ready_buckets)
-{
- ScanItr itr = getItr();
- assertEquals(BucketVector().
- add(_ready.bucket(6)).
- add(_ready.bucket(8)), itr, SubDbType::READY);
-}
-
-TEST_F(ScanTestBase, require_that_we_can_iterate_zero_buckets)
-{
- ScanItr itr = getItr();
- EXPECT_FALSE(itr.valid());
-}
-
-GTEST_MAIN_RUN_ALL_TESTS()