git.cweiske.de
/
enigma2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
moved PID search to proper please, simplified a bit (using the first found PMT should...
[enigma2.git]
/
e2reactor.py
diff --git
a/e2reactor.py
b/e2reactor.py
index 1ecd40e836812ca40309192c3894ea7420d6b61d..7caeb7f154bcccc82586f1657e471cc393844642 100644
(file)
--- a/
e2reactor.py
+++ b/
e2reactor.py
@@
-35,7
+35,8
@@
class E2SharedPoll:
del self.dict[fd]
def poll(self, timeout = None):
del self.dict[fd]
def poll(self, timeout = None):
- return getApplication().poll(timeout, self.dict)
+ r = getApplication().poll(timeout, self.dict)
+ return r
poller = E2SharedPoll()
poller = E2SharedPoll()
@@
-56,6
+57,8
@@
class PollReactor(posixbase.PosixReactorBase):
poller.register(fd, mask)
else:
if selectables.has_key(fd): del selectables[fd]
poller.register(fd, mask)
else:
if selectables.has_key(fd): del selectables[fd]
+
+ getApplication().interruptPoll()
def _dictRemove(self, selectable, mdict):
try:
def _dictRemove(self, selectable, mdict):
try:
@@
-131,6
+134,7
@@
class PollReactor(posixbase.PosixReactorBase):
POLLIN=select.POLLIN,
POLLOUT=select.POLLOUT):
"""Poll the poller for new events."""
POLLIN=select.POLLIN,
POLLOUT=select.POLLOUT):
"""Poll the poller for new events."""
+
if timeout is not None:
timeout = int(timeout * 1000) # convert seconds to milliseconds
if timeout is not None:
timeout = int(timeout * 1000) # convert seconds to milliseconds
@@
-183,6
+187,9
@@
class PollReactor(posixbase.PosixReactorBase):
if why:
self._disconnectSelectable(selectable, why, inRead)
if why:
self._disconnectSelectable(selectable, why, inRead)
+ def callLater(self, *args, **kwargs):
+ getApplication().interruptPoll()
+ return posixbase.PosixReactorBase.callLater(self, *args, **kwargs)
def install():
"""Install the poll() reactor."""
def install():
"""Install the poll() reactor."""