aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/job_tracked_maintenance_job
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-01-31 15:14:57 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2021-01-31 17:36:43 +0000
commit2503a877f21838e66e873f839a5b6fd0c38abfab (patch)
tree966ae9d7757aa58e7bff4aaa4b9b45b5f6668329 /searchcore/src/tests/proton/documentdb/job_tracked_maintenance_job
parent5ac0d0b71749c7555167c3c3906ff6843bf178f0 (diff)
Use vespalib::duration for timeouts
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.cpp8
1 files changed, 4 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 2bde5761aea..c12b91c4c1e 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
@@ -24,7 +24,7 @@ getGateVector(size_t size)
{
GateVector retval;
for (size_t i = 0; i < size; ++i) {
- retval.push_back(GateUP(new Gate()));
+ retval.push_back(std::make_unique<Gate>());
}
return retval;
}
@@ -46,7 +46,7 @@ struct MyMaintenanceJob : public IBlockableMaintenanceJob
void unBlock(BlockedReason) override { _blocked = false; }
bool isBlocked() const override { return _blocked; }
bool run() override {
- _runGates[_runIdx++]->await(5000);
+ _runGates[_runIdx++]->await(5s);
return _runIdx == _runGates.size();
}
};
@@ -82,10 +82,10 @@ struct Fixture
}
void runJobAndWait(size_t runIdx, size_t startedGateCount, size_t endedGateCount) {
_exec.execute(vespalib::makeLambdaTask([this]() { runJob(); }));
- _tracker->_started.await(5000);
+ _tracker->_started.await(5s);
assertTracker(startedGateCount, endedGateCount);
_myJob->_runGates[runIdx]->countDown();
- _runGates[runIdx]->await(5000);
+ _runGates[runIdx]->await(5s);
}
};