aboutsummaryrefslogtreecommitdiffstats
path: root/storage/src/tests/visiting/visitortest.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'storage/src/tests/visiting/visitortest.cpp')
-rw-r--r--storage/src/tests/visiting/visitortest.cpp42
1 files changed, 2 insertions, 40 deletions
diff --git a/storage/src/tests/visiting/visitortest.cpp b/storage/src/tests/visiting/visitortest.cpp
index 11e5e355f0c..46b0f4d830d 100644
--- a/storage/src/tests/visiting/visitortest.cpp
+++ b/storage/src/tests/visiting/visitortest.cpp
@@ -30,10 +30,6 @@ using msg_ptr_vector = std::vector<api::StorageMessage::SP>;
struct TestParams
{
- TestParams& iteratorsPerBucket(uint32_t n) {
- _iteratorsPerBucket = n;
- return *this;
- }
TestParams& maxVisitorMemoryUsage(uint32_t bytes) {
_maxVisitorMemoryUsage = bytes;
return *this;
@@ -47,7 +43,6 @@ struct TestParams
return *this;
}
- uint32_t _iteratorsPerBucket {1};
uint32_t _maxVisitorMemoryUsage {UINT32_MAX};
uint32_t _parallelBuckets {1};
mbus::Error _autoReplyError;
@@ -62,7 +57,6 @@ private:
CPPUNIT_TEST(testNormalUsage);
CPPUNIT_TEST(testFailedCreateIterator);
CPPUNIT_TEST(testFailedGetIter);
- CPPUNIT_TEST(iterators_per_bucket_config_is_ignored_and_hardcoded_to_1);
CPPUNIT_TEST(testDocumentAPIClientError);
CPPUNIT_TEST(testNoDocumentAPIResendingForFailedVisitor);
CPPUNIT_TEST(testIteratorCreatedForFailedVisitor);
@@ -90,7 +84,6 @@ public:
void testNormalUsage();
void testFailedCreateIterator();
void testFailedGetIter();
- void iterators_per_bucket_config_is_ignored_and_hardcoded_to_1();
void testDocumentAPIClientError();
void testNoDocumentAPIResendingForFailedVisitor();
void testIteratorCreatedForFailedVisitor();
@@ -184,9 +177,6 @@ VisitorTest::initializeTest(const TestParams& params)
vdstestlib::DirConfig config(getStandardConfig(true, "visitortest"));
config.getConfig("stor-visitor").set("visitorthreads", "1");
config.getConfig("stor-visitor").set(
- "iterators_per_bucket",
- std::to_string(params._iteratorsPerBucket));
- config.getConfig("stor-visitor").set(
"defaultparalleliterators",
std::to_string(params._parallelBuckets));
config.getConfig("stor-visitor").set(
@@ -596,33 +586,6 @@ VisitorTest::testFailedGetIter()
CPPUNIT_ASSERT(waitUntilNoActiveVisitors());
}
-void VisitorTest::iterators_per_bucket_config_is_ignored_and_hardcoded_to_1() {
- initializeTest(TestParams().iteratorsPerBucket(20));
- auto cmd = makeCreateVisitor();
- _top->sendDown(cmd);
- sendCreateIteratorReply();
-
- auto getIterCmd = fetchSingleCommand<GetIterCommand>(*_bottom);
- CPPUNIT_ASSERT_EQUAL(spi::IteratorId(1234),
- getIterCmd->getIteratorId());
- sendGetIterReply(*getIterCmd);
-
- CPPUNIT_ASSERT_EQUAL(size_t(0), _bottom->getNumCommands());
-
- std::vector<document::Document::SP> docs;
- std::vector<document::DocumentId> docIds;
- std::vector<std::string> infoMessages;
- getMessagesAndReply(_documents.size(), getSession(0), docs, docIds, infoMessages);
- CPPUNIT_ASSERT_EQUAL(size_t(0), infoMessages.size());
- CPPUNIT_ASSERT_EQUAL(size_t(0), docIds.size());
-
- auto destroyIterCmd = fetchSingleCommand<DestroyIteratorCommand>(*_bottom);
-
- verifyCreateVisitorReply(api::ReturnCode::OK);
- CPPUNIT_ASSERT(waitUntilNoActiveVisitors());
- CPPUNIT_ASSERT_EQUAL(0L, getFailedVisitorDestinationReplyCount());
-}
-
void
VisitorTest::testDocumentAPIClientError()
{
@@ -709,7 +672,7 @@ VisitorTest::testNoDocumentAPIResendingForFailedVisitor()
void
VisitorTest::testIteratorCreatedForFailedVisitor()
{
- initializeTest(TestParams().iteratorsPerBucket(1).parallelBuckets(2));
+ initializeTest(TestParams().parallelBuckets(2));
std::shared_ptr<api::CreateVisitorCommand> cmd(
makeCreateVisitor());
cmd->addBucketToBeVisited(document::BucketId(16, 4));
@@ -928,8 +891,7 @@ void
VisitorTest::testNoMoreIteratorsSentWhileMemoryUsedAboveLimit()
{
initializeTest(TestParams().maxVisitorMemoryUsage(1)
- .parallelBuckets(1)
- .iteratorsPerBucket(1));
+ .parallelBuckets(1));
std::shared_ptr<api::CreateVisitorCommand> cmd(
makeCreateVisitor());
_top->sendDown(cmd);