diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-05-04 20:01:13 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-05-05 06:54:53 +0000 |
commit | e54133b4b3deda0afa56f0dead5f23c8f314f93c (patch) | |
tree | 1457d43c3805053dbd6881f94de05e8eed6962c0 /searchcore/src/tests/proton/documentdb/maintenancecontroller | |
parent | 1cf3fd15f0939eff93cd6494897f3a1ce9f6c2c0 (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.cpp | 19 |
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; |