summaryrefslogtreecommitdiffstats
path: root/storage/src/tests/distributor/distributortestutil.h
diff options
context:
space:
mode:
authorGeir Storli <geirst@verizonmedia.com>2021-05-11 19:32:05 +0200
committerGitHub <noreply@github.com>2021-05-11 19:32:05 +0200
commit809d093a732b81711fe54bcd8e2246b574396e0c (patch)
tree29f677aa767576ffae37768dd2a6328c1ed9558b /storage/src/tests/distributor/distributortestutil.h
parent839a6f9a7d1f66937f51db3766a2dfd3e7b90675 (diff)
parent284dba9f34a5eb84b83b7ae706cc6274f323ffac (diff)
Merge pull request #17824 from vespa-engine/geirst/deterministic-distributor-shutdown-in-new-stripe-mode
Stop all stripe threads before starting shutdown (and closing) of theā€¦
Diffstat (limited to 'storage/src/tests/distributor/distributortestutil.h')
-rw-r--r--storage/src/tests/distributor/distributortestutil.h6
1 files changed, 4 insertions, 2 deletions
diff --git a/storage/src/tests/distributor/distributortestutil.h b/storage/src/tests/distributor/distributortestutil.h
index de46905c870..63ca47755e6 100644
--- a/storage/src/tests/distributor/distributortestutil.h
+++ b/storage/src/tests/distributor/distributortestutil.h
@@ -17,16 +17,17 @@ namespace framework { struct TickingThreadPool; }
namespace distributor {
-class StripeBucketDBUpdater;
class Distributor;
class DistributorBucketSpace;
class DistributorBucketSpaceRepo;
-class DistributorStripeOperationContext;
class DistributorStripe;
class DistributorStripeComponent;
+class DistributorStripeOperationContext;
+class DistributorStripePool;
class ExternalOperationHandler;
class IdealStateManager;
class Operation;
+class StripeBucketDBUpdater;
// TODO STRIPE rename to DistributorStripeTestUtil?
class DistributorTestUtil : private DoneInitializeHandler
@@ -206,6 +207,7 @@ protected:
vdstestlib::DirConfig _config;
std::unique_ptr<TestDistributorApp> _node;
std::unique_ptr<framework::TickingThreadPool> _threadPool;
+ std::unique_ptr<DistributorStripePool> _stripe_pool;
std::unique_ptr<Distributor> _distributor;
std::unique_ptr<storage::DistributorComponent> _component;
DistributorMessageSenderStub _sender;