diff options
| author | Dwayne Boone <dwayne@zeroc.com> | 2007-09-05 14:44:03 -0230 |
|---|---|---|
| committer | Dwayne Boone <dwayne@zeroc.com> | 2007-09-05 14:44:03 -0230 |
| commit | bdcf4f222f50b915d2dfc0ea3960758adf6937db (patch) | |
| tree | e263a048b6297395c97e860c87a0ca27b569cb08 /cpp/src/IceStorm/SubscriberPool.cpp | |
| parent | Added missing file (diff) | |
| download | ice-bdcf4f222f50b915d2dfc0ea3960758adf6937db.tar.bz2 ice-bdcf4f222f50b915d2dfc0ea3960758adf6937db.tar.xz ice-bdcf4f222f50b915d2dfc0ea3960758adf6937db.zip | |
http://bugzilla.zeroc.com/bugzilla/show_bug.cgi?id=1351 - use monotonic timers where possible
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) |