diff options
author | amartin <olpc@xo-05-28-21.localdomain> | 2008-02-13 09:11:51 (GMT) |
---|---|---|
committer | amartin <olpc@xo-05-28-21.localdomain> | 2008-02-13 09:11:51 (GMT) |
commit | d0e18e63595b6f4f5aabb659f372fa067e1e982f (patch) | |
tree | 39baa978d0871cdff2ae16fded69f962456efa49 /common/Util/Network.py | |
parent | 79d06d1d48049b682f9d6b1a92d18768835c4753 (diff) |
network
Diffstat (limited to 'common/Util/Network.py')
-rw-r--r-- | common/Util/Network.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/common/Util/Network.py b/common/Util/Network.py index dbbc97d..65a15b0 100644 --- a/common/Util/Network.py +++ b/common/Util/Network.py @@ -80,7 +80,7 @@ class Listener( threading.Thread ): def run(self): while 1: # rely on the owner to kill us when necessary try: - inputReady, outputReady, exceptReady = select.select( self.inputSockets, self.outputSockets, self.exceptSockets ) + inputReady, outputReady, exceptReady = select.select( self.inputSockets, self.outputSockets, self.exceptSockets, 0.5 ) if not len( inputReady ): # timeout continue if self.listenerSocket in inputReady: @@ -549,6 +549,7 @@ class Network: if MSG_SIZE[con.message] == 0: con.recvBuf = con.recvBuf[1:] for func in self.processMessage[con.message]: + print "idle_add", func, con.message gobject.idle_add( func, sock, con.message, "" ) else: con.waitingForData = MSG_SIZE[con.message] |