copyleftie
/
gajim-plural
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

remove in_buffer patch from xmppp because it was slowing parsing because of timeout being too high? anyways we should reelase 0.8 someday

This commit is contained in:
Nikos Kouremenos 2005-08-03 10:28:21 +00:00
parent 542c97df49
commit 4054ed3384
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/common/xmpp/dispatcher.py
View File

@ -32,7 +32,6 @@ class Dispatcher(PlugIn):
""" Ancestor of PlugIn class. Handles XMPP stream, i.e. aware of stream headers. """ Ancestor of PlugIn class. Handles XMPP stream, i.e. aware of stream headers.
Can be plugged out/in to restart these headers (used for SASL f.e.). """ Can be plugged out/in to restart these headers (used for SASL f.e.). """
def __init__(self): def __init__(self):
self.in_buffer=''
PlugIn.__init__(self) PlugIn.__init__(self)
DBG_LINE='dispatcher' DBG_LINE='dispatcher'
self.handlers={} self.handlers={}
@ -111,13 +110,9 @@ class Dispatcher(PlugIn):
3) 0 (zero) if underlying connection is closed.""" 3) 0 (zero) if underlying connection is closed."""
for handler in self._cycleHandlers: handler(self) for handler in self._cycleHandlers: handler(self)
if self._owner.Connection.pending_data(timeout): if self._owner.Connection.pending_data(timeout):
if not self.in_buffer: try: data=self._owner.Connection.receive()
try: self.in_buffer=self._owner.Connection.receive()
except IOError: return except IOError: return
data = self.in_buffer[:1024] # parse first 1 MB
self.Stream.Parse(data) self.Stream.Parse(data)
self.in_buffer=self.in_buffer[1024:] # parse the rest next time
#if data:
return len(data) return len(data)
return '0' # It means that nothing is received but link is alive. return '0' # It means that nothing is received but link is alive.