X-Git-Url: http://code.vuplus.com/gitweb/?p=vuplus_dvbapp;a=blobdiff_plain;f=e2reactor.py;h=cca2f358eeb5632b98f9c11deb4d0802a69481be;hp=7caeb7f154bcccc82586f1657e471cc393844642;hb=acd6278e8ca1ef258c3add5cdff9957500c07108;hpb=842dabf727814691bfd949ac4d910ce04c32b887

diff --git a/e2reactor.py b/e2reactor.py
index 7caeb7f..cca2f35 100644
--- a/e2reactor.py
+++ b/e2reactor.py
@@ -11,7 +11,7 @@ Maintainer: U{Felix Domke<mailto:tmbinc@elitedvb.net>}
 import select, errno, sys
 
 # Twisted imports
-from twisted.python import log, threadable, failure
+from twisted.python import log, failure
 from twisted.internet import main, posixbase, error
 #from twisted.internet.pollreactor import PollReactor, poller
 
@@ -27,6 +27,7 @@ POLL_DISCONNECTED = (select.POLLHUP | select.POLLERR | select.POLLNVAL)
 class E2SharedPoll:
 	def __init__(self):
 		self.dict = { }
+		self.eApp = getApplication()
 
 	def register(self, fd, eventmask = select.POLLIN | select.POLLERR | select.POLLOUT):
 		self.dict[fd] = eventmask
@@ -35,7 +36,10 @@ class E2SharedPoll:
 		del self.dict[fd]
 	
 	def poll(self, timeout = None):
-		r = getApplication().poll(timeout, self.dict)
+		try:
+			r = self.eApp.poll(timeout, self.dict)
+		except KeyboardInterrupt:
+			return None
 		return r
 
 poller = E2SharedPoll()
@@ -58,7 +62,8 @@ class PollReactor(posixbase.PosixReactorBase):
 		else:
 			if selectables.has_key(fd): del selectables[fd]
 		
-		getApplication().interruptPoll()
+		
+		poller.eApp.interruptPoll()
 
 	def _dictRemove(self, selectable, mdict):
 		try:
@@ -188,7 +193,7 @@ class PollReactor(posixbase.PosixReactorBase):
 			self._disconnectSelectable(selectable, why, inRead)
 
 	def callLater(self, *args, **kwargs):
-		getApplication().interruptPoll()
+		poller.eApp.interruptPoll()
 		return posixbase.PosixReactorBase.callLater(self, *args, **kwargs)
 
 def install():