pep/slixmpp
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Fix crash conditions in IBB

Browse source
This commit is contained in:
Lance Stout 2013-05-22 14:27:14 -07:00
parent e48b650caa
commit 400f08db9d
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
sleekxmpp/plugins/xep_0047/ibb.py
View file

@ -85,7 +85,7 @@ class XEP_0047(BasePlugin):
self._streams[(jid, sid, peer_jid)] = stream self._streams[(jid, sid, peer_jid)] = stream
def _del_stream(self, jid, sid, peer_jid, data): def _del_stream(self, jid, sid, peer_jid, data):
with self._streams_lock: with self._stream_lock:
if (jid, sid, peer_jid) in self._streams: if (jid, sid, peer_jid) in self._streams:
del self._streams[(jid, sid, peer_jid)] del self._streams[(jid, sid, peer_jid)]
@ -207,7 +207,7 @@ class XEP_0047(BasePlugin):
def _handle_close(self, iq): def _handle_close(self, iq):
sid = iq['ibb_close']['sid'] sid = iq['ibb_close']['sid']
stream = self.api['get_stream'](stanza['to'], sid, stanza['from']) stream = self.api['get_stream'](iq['to'], sid, iq['from'])
if stream is not None and iq['from'] == stream.peer_jid: if stream is not None and iq['from'] == stream.peer_jid:
stream._closed(iq) stream._closed(iq)
self.api['del_stream'](stream.self_jid, stream.sid, stream.peer_jid) self.api['del_stream'](stream.self_jid, stream.sid, stream.peer_jid)