diff options
author | Oli <olivier.belanger@umontreal.ca> | 2007-07-19 00:39:46 (GMT) |
---|---|---|
committer | Oli <olivier.belanger@umontreal.ca> | 2007-07-19 00:39:46 (GMT) |
commit | 36b024ff659878920fe1378bbb81820dc0ab4b13 (patch) | |
tree | 84e34cac0cadb6d976fa0f59a09be2470b747773 /Util | |
parent | 2f077d6fe08a46cd583287e1985f79f116329bcc (diff) | |
parent | 1f3bff4d4b565bc655bd26f30e3d7df363c97b99 (diff) |
Merge branch 'master' of git+ssh://olipet@dev.laptop.org/git/projects/tamtam
Diffstat (limited to 'Util')
-rw-r--r-- | Util/Network.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/Util/Network.py b/Util/Network.py index 397110f..53a00e7 100644 --- a/Util/Network.py +++ b/Util/Network.py @@ -532,6 +532,7 @@ class Network: con.waitingForData = self.unpacker.unpack_uint() con.recvBuf = con.recvBuf[4:] else: + print "waiting for data" return # wait for more data elif con.waitingForData: @@ -540,8 +541,9 @@ class Network: con.recvBuf = con.recvBuf[con.waitingForData:] con.waitingForData = 0 for func in self.processMessage[con.message]: - func( sock, con.message, data ) + gobject.idle_add( func, sock, con.message, data ) else: + print "waiting for data" return # wait for more data else: @@ -549,7 +551,8 @@ class Network: if MSG_SIZE[con.message] == 0: con.recvBuf = con.recvBuf[1:] for func in self.processMessage[con.message]: - func( sock, con.message, "" ) + gobject.idle_add( func, sock, con.message, "" ) + else: con.waitingForData = MSG_SIZE[con.message] con.recvBuf = con.recvBuf[1:] |