X-Git-Url: http://code.vuplus.com/gitweb/?p=vuplus_dvbapp;a=blobdiff_plain;f=lib%2Fbase%2Febase.cpp;fp=lib%2Fbase%2Febase.cpp;h=62746f4be4ea144618b9ccc1054ea53015e9d103;hp=6121981194df5b4c9c8258791f3ddfeb1afebf46;hb=8ecfc549ce93bc353d6a64f43a0c25dcd65f860e;hpb=d49d7da0bf17411dfa54147307f30d71b4b9a1ed diff --git a/lib/base/ebase.cpp b/lib/base/ebase.cpp index 6121981..62746f4 100644 --- a/lib/base/ebase.cpp +++ b/lib/base/ebase.cpp @@ -6,6 +6,7 @@ #include #include +#include eSocketNotifier::eSocketNotifier(eMainloop *context, int fd, int requested, bool startnow): context(*context), fd(fd), state(0), requested(requested) { @@ -201,9 +202,14 @@ int eMainloop::processOneEvent(unsigned int twisted_timeout, PyObject **res, ePy if (this == eApp) { + gOpcode op; + op.dc = 0; + op.opcode = gOpcode::flush; + gRC::getInstance()->submit(op); Py_BEGIN_ALLOW_THREADS ret = ::poll(pfd, fdcount, poll_timeout); Py_END_ALLOW_THREADS + } else ret = ::poll(pfd, fdcount, poll_timeout);