diff options
Diffstat (limited to 'cpp/src/IceStorm/SubscriberPool.cpp')
| -rw-r--r-- | cpp/src/IceStorm/SubscriberPool.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/cpp/src/IceStorm/SubscriberPool.cpp b/cpp/src/IceStorm/SubscriberPool.cpp index 8fcbb75d4b1..254b99b4ae6 100644 --- a/cpp/src/IceStorm/SubscriberPool.cpp +++ b/cpp/src/IceStorm/SubscriberPool.cpp @@ -58,9 +58,9 @@ public: // if(computeInterval) { - IceUtil::Time start = IceUtil::Time::now(); + IceUtil::Time start = IceUtil::Time::now(IceUtil::Time::Monotonic); requeue = sub->flush(); - interval = IceUtil::Time::now() - start; + interval = IceUtil::Time::now(IceUtil::Time::Monotonic) - start; } else { @@ -350,7 +350,7 @@ SubscriberPool::dequeue(SubscriberPtr& subscriber, bool requeue, const IceUtil:: // if(_workers.size() > _size) { - IceUtil::Time now = IceUtil::Time::now(); + IceUtil::Time now = IceUtil::Time::now(IceUtil::Time::Monotonic); if(now - _lastStallCheck > _stallCheck) { _lastStallCheck = now; @@ -398,7 +398,7 @@ SubscriberPool::dequeue(SubscriberPtr& subscriber, bool requeue, const IceUtil:: return; } - _lastDequeue = IceUtil::Time::now(); + _lastDequeue = IceUtil::Time::now(IceUtil::Time::Monotonic); subscriber = _pending.front(); _pending.pop_front(); @@ -475,7 +475,7 @@ SubscriberPool::check() return; } - IceUtil::Time now = IceUtil::Time::now(); + IceUtil::Time now = IceUtil::Time::now(IceUtil::Time::Monotonic); IceUtil::Time interval = now - _lastDequeue; /* if(_traceLevels->subscriberPool > 1) |