aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/move_operation_limiter/move_operation_limiter_test.cpp
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-03-17 19:08:24 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2021-03-17 19:08:24 +0000
commit0f9b600d53b87bd10f3e282cc18ce7f9f8ce7018 (patch)
tree5ddac1d421fa8f977f6648b4d47ea7237ca5c807 /searchcore/src/tests/proton/documentdb/move_operation_limiter/move_operation_limiter_test.cpp
parent320330f55d4bc45a984750d2fd13965213065d74 (diff)
Ensure onStop is proxied.
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/move_operation_limiter/move_operation_limiter_test.cpp')
-rw-r--r--searchcore/src/tests/proton/documentdb/move_operation_limiter/move_operation_limiter_test.cpp10
1 files changed, 7 insertions, 3 deletions
diff --git a/searchcore/src/tests/proton/documentdb/move_operation_limiter/move_operation_limiter_test.cpp b/searchcore/src/tests/proton/documentdb/move_operation_limiter/move_operation_limiter_test.cpp
index eaad2ac2576..1f152f4a257 100644
--- a/searchcore/src/tests/proton/documentdb/move_operation_limiter/move_operation_limiter_test.cpp
+++ b/searchcore/src/tests/proton/documentdb/move_operation_limiter/move_operation_limiter_test.cpp
@@ -1,19 +1,22 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-#include <vespa/log/log.h>
-LOG_SETUP("move_operation_limiter_test");
#include <vespa/searchcore/proton/server/i_blockable_maintenance_job.h>
#include <vespa/searchcore/proton/server/move_operation_limiter.h>
#include <vespa/vespalib/testkit/testapp.h>
#include <queue>
+#include <vespa/log/log.h>
+LOG_SETUP("move_operation_limiter_test");
+
using namespace proton;
struct MyBlockableMaintenanceJob : public IBlockableMaintenanceJob {
bool blocked;
+ bool stopped;
MyBlockableMaintenanceJob()
: IBlockableMaintenanceJob("my_job", 1s, 1s),
- blocked(false)
+ blocked(false),
+ stopped(false)
{}
void setBlocked(BlockedReason reason) override {
ASSERT_TRUE(reason == BlockedReason::OUTSTANDING_OPS);
@@ -26,6 +29,7 @@ struct MyBlockableMaintenanceJob : public IBlockableMaintenanceJob {
blocked = false;
}
bool run() override { return true; }
+ void onStop() override { stopped = true; }
};
struct Fixture {