ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-15 00:25:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use RelativeTime from startup in DeadlineTimer

Browse Source
This commit is contained in:
Vinnie Falco
2013-10-01 14:01:43 -07:00
parent ae22d5dc8a
commit 1dfd655959
2 changed files with 10 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
modules/beast_core/thread/DeadlineTimer.cpp
View File

@@ -42,7 +42,8 @@ public:
// Okay to call on an active timer.
// However, an extra notification may still happen due to concurrency.
//
void activate (DeadlineTimer& timer, double secondsRecurring, Time const& when)
void activate (DeadlineTimer& timer,
double secondsRecurring, RelativeTime const& when)
{
bassert (secondsRecurring >= 0);
@@ -85,7 +86,8 @@ public:
{
while (! threadShouldExit ())
{
Time const currentTime = Time::getCurrentTime ();
RelativeTime const currentTime (
RelativeTime::fromStartup ());
double seconds (0);
DeadlineTimer* timer (nullptr);
@@ -110,7 +112,7 @@ public:
{
// Yes so set the timer again.
timer->m_notificationTime =
currentTime + RelativeTime (timer->m_secondsRecurring);
currentTime + timer->m_secondsRecurring;
// Put it back into the list as active
insertSorted (*timer);
@@ -224,7 +226,8 @@ void DeadlineTimer::setExpiration (double secondsUntilDeadline)
{
bassert (secondsUntilDeadline != 0);
Time const when = Time::getCurrentTime () + RelativeTime (secondsUntilDeadline);
RelativeTime const when (
RelativeTime::fromStartup() + secondsUntilDeadline);
m_manager->activate (*this, 0, when);
}
@@ -233,13 +236,8 @@ void DeadlineTimer::setRecurringExpiration (double secondsUntilDeadline)
{
bassert (secondsUntilDeadline != 0);
Time const when = Time::getCurrentTime () + RelativeTime (secondsUntilDeadline);
RelativeTime const when (
RelativeTime::fromStartup() + secondsUntilDeadline);
m_manager->activate (*this, secondsUntilDeadline, when);
}
void DeadlineTimer::setExpirationTime (Time const& when)
{
m_manager->activate (*this, 0, when);
}

12
modules/beast_core/thread/DeadlineTimer.h
View File

@@ -52,7 +52,6 @@ public:
*/
void cancel ();
/** Set the timer to go off once in the future.
If the timer is already active, this will reset it.
@note If the timer is already active, the old one might go off
@@ -73,15 +72,6 @@ public:
*/
void setRecurringExpiration (double secondsUntilDeadline);
/** Set the timer to go off at a specific time.
If the timer is already active, this will reset it.
@note If the timer is already active, the old one might go off
before this function returns.
@note If the time is in the past, the timer will go off
immediately.
*/
void setExpirationTime (Time const& when);
/** Equality comparison.
Timers are equal if they have the same address.
*/
@@ -102,7 +92,7 @@ private:
Listener* const m_listener;
SharedPtr <SharedSingleton <Manager> > m_manager;
bool m_isActive;
Time m_notificationTime;
RelativeTime m_notificationTime;
double m_secondsRecurring; // non zero if recurring
};