X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/ccd9b3814f5736e32f689e37ba7f870d6a1066cd..1c3ff1d1c87ff3c035cf9c1e6458f7c13e9d52aa:/lib/base/ebase.cpp

diff --git a/lib/base/ebase.cpp b/lib/base/ebase.cpp
index 7f84cc91..fa5cff74 100644
--- a/lib/base/ebase.cpp
+++ b/lib/base/ebase.cpp
@@ -45,8 +45,8 @@ void eTimer::start(long msek, bool singleShot)
 	bSingleShot = singleShot;
 	interval = msek;
 	gettimeofday(&nextActivation, 0);
-	nextActivation += (msek<0 ? 0 : msek);
 //	eDebug("this = %p\nnow sec = %d, usec = %d\nadd %d msec", this, nextActivation.tv_sec, nextActivation.tv_usec, msek);
+	nextActivation += (msek<0 ? 0 : msek);
 //	eDebug("next Activation sec = %d, usec = %d", nextActivation.tv_sec, nextActivation.tv_usec );
 	context.addTimer(this);
 }
@@ -126,37 +126,6 @@ void eMainloop::removeSocketNotifier(eSocketNotifier *sn)
 
 void eMainloop::processOneEvent()
 {
-		/* notes:
-		  - we should use epoll(4)
-		  - timer are checked twice. there was a strong reason for it, but i can't remember. (FIXME)
-		  - for each time, we gettimeofday() and check wether the timer should fire.
-		    we should do this all better - we know how long the poll last, so we know which
-		    timers should fire. Problem is that a timer handler could have required so
-		    much time that another timer fired.
-
-		    A probably structure could look
-
-		    while (1)
-		    {
-			    time = gettimeofday()
-			    timeout = calculate_pending_timers(time);
-
-		      doPoll(timeout or infinite);
-
-		    	if (poll_had_results)
-		    		handle_poll_handler();
-		    	else
-				    fire_timers(time + timeout)
-			  }
-
-			  the gettimeofday() call is required because fire_timers could last more
-			  than nothing.
-
-			  when poll did no timeout, we don't handle timers, as this will be done
-			  in the next iteration (without adding overhead - we had to get the new
-			  time anyway
-		*/
-
 		/* get current time */
 	timeval now;
 	gettimeofday(&now, 0);
@@ -212,14 +181,15 @@ void eMainloop::processOneEvent()
 				} else if (pfd[i].revents & (POLLERR|POLLHUP|POLLNVAL))
 					eFatal("poll: unhandled POLLERR/HUP/NVAL for fd %d(%d) -> FIX YOUR CODE", pfd[i].fd,pfd[i].revents);
 			}
+			
+			ret = 1; /* poll did not timeout. */
 		} else if (ret < 0)
 		{
-				/* when we got a signal, we get EINTR. we do not care, 
-				   because we check current time in timers anyway. */
+				/* when we got a signal, we get EINTR. */
 			if (errno != EINTR)
 				eDebug("poll made error (%m)");
 			else
-				ret = 0;
+				ret = -1; /* don't assume the timeout has passed when we got a signal */
 		}
 		delete [] pfd;
 	}
@@ -227,6 +197,9 @@ void eMainloop::processOneEvent()
 		/* when we not processed anything, check timers. */
 	if (!ret)
 	{
+			/* we know that this time has passed. */
+		now += poll_timeout;
+		
 		singleLock s(recalcLock);
 
 			/* this will never change while we have the recalcLock */
@@ -235,7 +208,7 @@ void eMainloop::processOneEvent()
 			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))
+		while ((!m_timer_list.empty()) && (m_timer_list.begin()->getNextActivation() <= now))
 			m_timer_list.begin()->activate();
 	}
 }