aboutsummaryrefslogtreecommitdiffstats
path: root/storage/src/tests/distributor/splitbuckettest.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'storage/src/tests/distributor/splitbuckettest.cpp')
-rw-r--r--storage/src/tests/distributor/splitbuckettest.cpp26
1 files changed, 13 insertions, 13 deletions
diff --git a/storage/src/tests/distributor/splitbuckettest.cpp b/storage/src/tests/distributor/splitbuckettest.cpp
index ec58992ed3e..d9052c36db3 100644
--- a/storage/src/tests/distributor/splitbuckettest.cpp
+++ b/storage/src/tests/distributor/splitbuckettest.cpp
@@ -1,4 +1,6 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+#include "dummy_cluster_context.h"
+#include <tests/distributor/distributor_stripe_test_util.h>
#include <vespa/document/base/documentid.h>
#include <vespa/document/test/make_document_bucket.h>
#include <vespa/storage/distributor/distributor.h>
@@ -7,11 +9,8 @@
#include <vespa/storage/distributor/operations/idealstate/splitoperation.h>
#include <vespa/storageapi/message/bucketsplitting.h>
#include <vespa/storageapi/message/persistence.h>
-#include <tests/common/dummystoragelink.h>
-#include <tests/distributor/distributortestutil.h>
-#include <vespa/vespalib/util/size_literals.h>
#include <vespa/vespalib/gtest/gtest.h>
-#include "dummy_cluster_context.h"
+#include <vespa/vespalib/util/size_literals.h>
using document::test::makeDocumentBucket;
using namespace document;
@@ -19,7 +18,7 @@ using namespace ::testing;
namespace storage::distributor {
-struct SplitOperationTest : Test, DistributorTestUtil {
+struct SplitOperationTest : Test, DistributorStripeTestUtil {
uint32_t splitByteSize;
uint32_t tooLargeBucketSize;
uint32_t splitCount;
@@ -29,9 +28,10 @@ struct SplitOperationTest : Test, DistributorTestUtil {
void SetUp() override {
createLinks();
- getConfig().setSplitCount(splitCount);
- getConfig().setSplitSize(splitByteSize);
-
+ auto cfg = make_config();
+ cfg->setSplitCount(splitCount);
+ cfg->setSplitSize(splitByteSize);
+ configure_stripe(cfg);
}
void TearDown() override {
@@ -52,7 +52,7 @@ namespace {
}
TEST_F(SplitOperationTest, simple) {
- enableDistributorClusterState("distributor:1 storage:1");
+ enable_cluster_state("distributor:1 storage:1");
insertBucketInfo(document::BucketId(16, 1), 0, 0xabc, 1000,
tooLargeBucketSize, 250);
@@ -124,7 +124,7 @@ TEST_F(SplitOperationTest, multi_node_failure) {
getBucketDatabase().update(entry);
}
- enableDistributorClusterState("distributor:1 storage:2");
+ enable_cluster_state("distributor:1 storage:2");
SplitOperation op(dummy_cluster_context,
BucketAndNodes(makeDocumentBucket(document::BucketId(16, 1)),
@@ -198,7 +198,7 @@ TEST_F(SplitOperationTest, multi_node_failure) {
}
TEST_F(SplitOperationTest, copy_trusted_status_not_carried_over_after_split) {
- enableDistributorClusterState("distributor:1 storage:2");
+ enable_cluster_state("distributor:1 storage:2");
document::BucketId sourceBucket(16, 1);
/*
@@ -263,7 +263,7 @@ TEST_F(SplitOperationTest, operation_blocked_by_pending_join) {
clock.setAbsoluteTimeInSeconds(1);
OperationSequencer op_seq;
- enableDistributorClusterState("distributor:1 storage:2");
+ enable_cluster_state("distributor:1 storage:2");
document::BucketId joinTarget(2, 1);
std::vector<document::BucketId> joinSources = {
@@ -304,7 +304,7 @@ TEST_F(SplitOperationTest, split_is_blocked_by_locked_bucket) {
clock.setAbsoluteTimeInSeconds(1);
OperationSequencer op_seq;
- enableDistributorClusterState("distributor:1 storage:2");
+ enable_cluster_state("distributor:1 storage:2");
document::BucketId source_bucket(16, 1);
insertBucketInfo(source_bucket, 0, 0xabc, 1000, tooLargeBucketSize, 250);