some fixes for twisted

[enigma2.git] / lib / base / ebase.cpp

diff --git a/lib/base/ebase.cpp b/lib/base/ebase.cpp
index 7a57d533acb511a2b7b1c6366b5dfb074590c89f..addd1b88de2c080cc39f03ea58e3a8378816a550 100644 (file)
--- a/lib/base/ebase.cpp
+++ b/lib/base/ebase.cpp
@@ -165,7 +165,6 @@ int eMainloop::processOneEvent(unsigned int user_timeout, PyObject **res, PyObje
        
        int ret = 0;
        
        
        int ret = 0;
        

-       

        if (poll_timeout)
        {
                std::multimap<int,eSocketNotifier*>::iterator it;
        if (poll_timeout)
        {
                std::multimap<int,eSocketNotifier*>::iterator it;


@@ -312,10 +311,31 @@ int eMainloop::iterate(unsigned int user_timeout, PyObject **res, PyObject *dict
 {
        int ret = 0;
        
 {
        int ret = 0;
        

+       timeval user_timer;
+       gettimeofday(&user_timer, 0);
+       user_timer += user_timeout;
+
+               /* TODO: this code just became ugly. fix that. */

        do
        do

-       { 
+       {
+               if (m_interrupt_requested)
+               {
+                       m_interrupt_requested = 0;
+                       return 0;
+               }

                if (app_quit_now) return -1;
                if (app_quit_now) return -1;

-               ret = processOneEvent(user_timeout, res, dict);
+               timeval now, timeout;
+               gettimeofday(&now, 0);
+               timeout = user_timer - now;
+               
+               if (user_timeout && (user_timer <= now))
+                       return 0;
+               
+               int to = 0;
+               if (user_timeout)
+                       to = timeout.tv_sec * 1000 + timeout.tv_usec / 1000;
+               
+               ret = processOneEvent(to, res, dict);

                if (res && *res)
                        return ret;
        } while (ret == 0);
                if (res && *res)
                        return ret;
        } while (ret == 0);


@@ -341,7 +361,7 @@ PyObject *eMainloop::poll(PyObject *timeout, PyObject *dict)
        }
        
        int user_timeout = (timeout == Py_None) ? 0 : PyInt_AsLong(timeout);
        }
        
        int user_timeout = (timeout == Py_None) ? 0 : PyInt_AsLong(timeout);

-       
+

        iterate(user_timeout, &res, dict);
        
        if (!res) /* return empty list on timeout */
        iterate(user_timeout, &res, dict);
        
        if (!res) /* return empty list on timeout */


@@ -350,6 +370,11 @@ PyObject *eMainloop::poll(PyObject *timeout, PyObject *dict)
        return res;
 }
 
        return res;
 }
 

+void eMainloop::interruptPoll()
+{
+       m_interrupt_requested = 1;
+}
+

 void eMainloop::quit(int ret)
 {
        retval = ret;
 void eMainloop::quit(int ret)
 {
        retval = ret;