diff options
Diffstat (limited to 'cpp/src/IceStorm/Subscriber.cpp')
| -rw-r--r-- | cpp/src/IceStorm/Subscriber.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/IceStorm/Subscriber.cpp b/cpp/src/IceStorm/Subscriber.cpp index 7eab249578e..b7e5ef45aa9 100644 --- a/cpp/src/IceStorm/Subscriber.cpp +++ b/cpp/src/IceStorm/Subscriber.cpp @@ -613,7 +613,7 @@ SubscriberLink::queue(bool forwarded, const EventDataSeq& events) // forwarded argument an EventInfo thing where the queue-time // is lazy initialized. // - if(IceUtil::Time::now() < _next) + if(IceUtil::Time::now(IceUtil::Time::Monotonic) < _next) { return QueueStateNoFlush; } @@ -713,7 +713,7 @@ SubscriberLink::offline(const Ice::Exception& e) IceUtil::Mutex::Lock sync(_mutex); assert(_state != SubscriberStateOffline); - _next = IceUtil::Time::now() + _instance->discardInterval(); + _next = IceUtil::Time::now(IceUtil::Time::Monotonic) + _instance->discardInterval(); TraceLevelsPtr traceLevels = _instance->traceLevels(); if(_warn) |