From: Felix Domke Date: Tue, 22 Nov 2005 16:53:20 +0000 (+0000) Subject: invalidate local time if time was changed X-Git-Tag: 2.6.0~5004 X-Git-Url: https://git.cweiske.de/enigma2.git/commitdiff_plain/ccd9b3814f5736e32f689e37ba7f870d6a1066cd invalidate local time if time was changed --- diff --git a/lib/base/ebase.cpp b/lib/base/ebase.cpp index 7951f6e7..7f84cc91 100644 --- a/lib/base/ebase.cpp +++ b/lib/base/ebase.cpp @@ -59,7 +59,7 @@ void eTimer::startLongTimer( int seconds ) bActive = bSingleShot = true; interval = 0; gettimeofday(&nextActivation, 0); -// eDebug("this = %p\nnow sec = %d, usec = %d\nadd %d msec", this, nextActivation.tv_sec, nextActivation.tv_usec, msek); +// eDebug("this = %p\nnow sec = %d, usec = %d\nadd %d sec", this, nextActivation.tv_sec, nextActivation.tv_usec, seconds); if ( seconds > 0 ) nextActivation.tv_sec += seconds; // eDebug("next Activation sec = %d, usec = %d", nextActivation.tv_sec, nextActivation.tv_usec ); @@ -160,6 +160,7 @@ void eMainloop::processOneEvent() /* get current time */ timeval now; gettimeofday(&now, 0); + m_now_is_invalid = 0; int poll_timeout = -1; /* infinite in case of empty timer list */ @@ -228,6 +229,11 @@ void eMainloop::processOneEvent() { singleLock s(recalcLock); + /* this will never change while we have the recalcLock */ + /* we can savely return here, the timer will be re-checked soon. */ + if (m_now_is_invalid) + return; + /* process all timers which are ready. first remove them out of the list. */ while ((!m_timer_list.empty()) && (m_timer_list.begin()->getNextActivation() < now)) m_timer_list.begin()->activate(); @@ -294,6 +300,7 @@ void eMainloop::addTimeOffset(int offset) ;it != eMainloop::existing_loops.end(); ++it) { singleLock s(it->recalcLock); + it->m_now_is_invalid = 1; for (ePtrList::iterator tit = it->m_timer_list.begin(); tit != it->m_timer_list.end(); ++tit ) tit->addTimeOffset(offset); } diff --git a/lib/base/ebase.h b/lib/base/ebase.h index 54b4063b..2a1fe628 100644 --- a/lib/base/ebase.h +++ b/lib/base/ebase.h @@ -176,6 +176,8 @@ class eMainloop void processOneEvent(); int retval; pthread_mutex_t recalcLock; + + int m_now_is_invalid; public: static void addTimeOffset(int offset); void addSocketNotifier(eSocketNotifier *sn); @@ -187,6 +189,7 @@ public: eMainloop() :app_quit_now(0),loop_level(0),retval(0) { + m_now_is_invalid = 0; existing_loops.push_back(this); pthread_mutex_init(&recalcLock, 0); }