diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-03-17 19:08:24 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-03-17 19:08:24 +0000 |
commit | 0f9b600d53b87bd10f3e282cc18ce7f9f8ce7018 (patch) | |
tree | 5ddac1d421fa8f977f6648b4d47ea7237ca5c807 /searchcore/src/tests/proton/documentdb/move_operation_limiter/move_operation_limiter_test.cpp | |
parent | 320330f55d4bc45a984750d2fd13965213065d74 (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.cpp | 10 |
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 { |