summaryrefslogtreecommitdiffstats
path: root/staging_vespalib/src/tests/metrics/mock_tick.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'staging_vespalib/src/tests/metrics/mock_tick.cpp')
-rw-r--r--staging_vespalib/src/tests/metrics/mock_tick.cpp72
1 files changed, 0 insertions, 72 deletions
diff --git a/staging_vespalib/src/tests/metrics/mock_tick.cpp b/staging_vespalib/src/tests/metrics/mock_tick.cpp
index 2178b5364e9..68e8d7a7daa 100644
--- a/staging_vespalib/src/tests/metrics/mock_tick.cpp
+++ b/staging_vespalib/src/tests/metrics/mock_tick.cpp
@@ -3,76 +3,4 @@
namespace vespalib::metrics {
-TimeStamp
-MockTick::next(TimeStamp prev)
-{
- std::unique_lock<std::mutex> locker(_lock);
- _prevValue = prev;
- _blocked = true;
- _blockedCond.notify_all();
- while (_runFlag && !_provided) {
- _providedCond.wait(locker);
- }
- _blocked = false;
- if (_provided) {
- _provided = false;
- return _nextValue;
- } else {
- // killed
- return TimeStamp(0);
- }
-}
-
-void
-MockTick::kill()
-{
- std::unique_lock<std::mutex> locker(_lock);
- _runFlag = false;
- _blockedCond.notify_all();
- _providedCond.notify_all();
-}
-
-bool
-MockTick::alive()
-{
- std::unique_lock<std::mutex> locker(_lock);
- return _runFlag;
-}
-
-void
-MockTick::provide(TimeStamp value)
-{
- std::unique_lock<std::mutex> locker(_lock);
- _nextValue = value;
- _blocked = false;
- _provided = true;
- _providedCond.notify_all();
-}
-
-TimeStamp
-MockTick::waitUntilBlocked()
-{
- std::unique_lock<std::mutex> locker(_lock);
- while (_runFlag && !_blocked) {
- _blockedCond.wait(locker);
- }
- if (_blocked) {
- return _prevValue;
- } else {
- // killed
- return TimeStamp(0);
- }
-}
-
-MockTick::MockTick()
- : _lock(),
- _runFlag(true),
- _provided(false),
- _blocked(false),
- _providedCond(),
- _blockedCond(),
- _nextValue(0.0),
- _prevValue(0.0)
-{}
-
} // namespace vespalib::metrics