diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-01-23 13:40:13 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-01-23 13:40:13 +0000 |
commit | 5d40e82b1c38ecdf0cb2ab54521530e152e33659 (patch) | |
tree | 25b316a870f8ae83c1f4b941b31a61fd0f43a3e7 /searchcore/src/tests/proton/documentdb/job_tracked_maintenance_job | |
parent | 3c8533f0ee5cc3abff0cc1bfc88fd00df0624921 (diff) |
Various readability and code cleanup. closure -> lambda
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/job_tracked_maintenance_job')
-rw-r--r-- | searchcore/src/tests/proton/documentdb/job_tracked_maintenance_job/job_tracked_maintenance_job_test.cpp | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/searchcore/src/tests/proton/documentdb/job_tracked_maintenance_job/job_tracked_maintenance_job_test.cpp b/searchcore/src/tests/proton/documentdb/job_tracked_maintenance_job/job_tracked_maintenance_job_test.cpp index 3f39c872ea7..2bde5761aea 100644 --- a/searchcore/src/tests/proton/documentdb/job_tracked_maintenance_job/job_tracked_maintenance_job_test.cpp +++ b/searchcore/src/tests/proton/documentdb/job_tracked_maintenance_job/job_tracked_maintenance_job_test.cpp @@ -1,15 +1,17 @@ // 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("job_tracked_maintenance_test"); + #include <vespa/searchcore/proton/server/i_blockable_maintenance_job.h> #include <vespa/searchcore/proton/server/job_tracked_maintenance_job.h> #include <vespa/searchcore/proton/test/simple_job_tracker.h> #include <vespa/vespalib/testkit/testapp.h> -#include <vespa/vespalib/util/closuretask.h> +#include <vespa/vespalib/util/lambdatask.h> #include <vespa/vespalib/util/gate.h> #include <vespa/vespalib/util/threadstackexecutor.h> +#include <vespa/log/log.h> +LOG_SETUP("job_tracked_maintenance_test"); + using namespace proton; using namespace vespalib; using test::SimpleJobTracker; @@ -79,7 +81,7 @@ struct Fixture EXPECT_EQUAL(endedGateCount, _tracker->_ended.getCount()); } void runJobAndWait(size_t runIdx, size_t startedGateCount, size_t endedGateCount) { - _exec.execute(makeTask(makeClosure(this, &Fixture::runJob))); + _exec.execute(vespalib::makeLambdaTask([this]() { runJob(); })); _tracker->_started.await(5000); assertTracker(startedGateCount, endedGateCount); _myJob->_runGates[runIdx]->countDown(); |