diff options
Diffstat (limited to 'staging_vespalib/src/tests/metrics/mock_tick.cpp')
-rw-r--r-- | staging_vespalib/src/tests/metrics/mock_tick.cpp | 72 |
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 |