aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/maintenancecontroller
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-05-04 20:01:13 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2021-05-05 06:54:53 +0000
commite54133b4b3deda0afa56f0dead5f23c8f314f93c (patch)
tree1457d43c3805053dbd6881f94de05e8eed6962c0 /searchcore/src/tests/proton/documentdb/maintenancecontroller
parent1cf3fd15f0939eff93cd6494897f3a1ce9f6c2c0 (diff)
Make handle stop in a uniform way by putting the basics in the base class.
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/maintenancecontroller')
-rw-r--r--searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp19
1 files changed, 3 insertions, 16 deletions
diff --git a/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp b/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp
index 49236a829f5..e73fa739fbb 100644
--- a/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp
+++ b/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp
@@ -290,17 +290,14 @@ struct MySimpleJob : public BlockableMaintenanceJob
{
vespalib::CountDownLatch _latch;
size_t _runCnt;
- bool _stopped;
MySimpleJob(vespalib::duration delay,
vespalib::duration interval,
uint32_t finishCount)
: BlockableMaintenanceJob("my_job", delay, interval),
_latch(finishCount),
- _runCnt(0),
- _stopped(false)
- {
- }
+ _runCnt(0)
+ { }
void block() { setBlocked(BlockedReason::FROZEN_BUCKET); }
bool run() override {
LOG(info, "MySimpleJob::run()");
@@ -308,10 +305,6 @@ struct MySimpleJob : public BlockableMaintenanceJob
++_runCnt;
return true;
}
- void onStop() override {
- BlockableMaintenanceJob::onStop();
- _stopped = true;
- }
};
struct MySplitJob : public MySimpleJob
@@ -333,13 +326,11 @@ struct MySplitJob : public MySimpleJob
struct MyLongRunningJob : public BlockableMaintenanceJob
{
vespalib::Gate _firstRun;
- bool _stopped;
MyLongRunningJob(vespalib::duration delay,
vespalib::duration interval)
: BlockableMaintenanceJob("long_running_job", delay, interval),
- _firstRun(),
- _stopped(false)
+ _firstRun()
{
}
void block() { setBlocked(BlockedReason::FROZEN_BUCKET); }
@@ -348,10 +339,6 @@ struct MyLongRunningJob : public BlockableMaintenanceJob
usleep(10000);
return false;
}
- void onStop() override {
- BlockableMaintenanceJob::onStop();
- _stopped = true;
- }
};
using MyAttributeManager = test::MockAttributeManager;