Mercurial > libervia-backend

comparison src/plugins/plugin_xep_0047.py @ 585:9902ec2d8d9b

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Remove useless trailing semicolons.
author Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
date Fri, 18 Jan 2013 17:53:08 +0100
parents ca13633d3b6b
children 952322b1d490
comparison
equal deleted inserted replaced
584:1524c2c07256 585:9902ec2d8d9b
74 client.xep_0047_current_stream = {} #key: stream_id, value: data(dict) 74 client.xep_0047_current_stream = {} #key: stream_id, value: data(dict)
75 75
76 def _timeOut(self, sid, profile): 76 def _timeOut(self, sid, profile):
77 """Delecte current_stream id, called after timeout 77 """Delecte current_stream id, called after timeout
78 @param id: id of client.xep_0047_current_stream""" 78 @param id: id of client.xep_0047_current_stream"""
79 info(_("In-Band Bytestream: TimeOut reached for id %s [%s]") % (sid, profile)); 79 info(_("In-Band Bytestream: TimeOut reached for id %s [%s]") % (sid, profile))
80 self._killId(sid, False, "TIMEOUT", profile) 80 self._killId(sid, False, "TIMEOUT", profile)
81 81
82 def _killId(self, sid, success=False, failure_reason="UNKNOWN", profile=None): 82 def _killId(self, sid, success=False, failure_reason="UNKNOWN", profile=None):
83 """Delete an current_stream id, clean up associated observers 83 """Delete an current_stream id, clean up associated observers
84 @param sid: id of client.xep_0047_current_stream""" 84 @param sid: id of client.xep_0047_current_stream"""
290 client = self.host.getClient(profile) 290 client = self.host.getClient(profile)
291 if not client: 291 if not client:
292 raise ProfileNotInCacheError 292 raise ProfileNotInCacheError
293 if length != None: 293 if length != None:
294 error(_('stream length not managed yet')) 294 error(_('stream length not managed yet'))
295 return; 295 return
296 data = client.xep_0047_current_stream[sid] = {} 296 data = client.xep_0047_current_stream[sid] = {}
297 data["timer"] = reactor.callLater(TIMEOUT, self._timeOut, sid) 297 data["timer"] = reactor.callLater(TIMEOUT, self._timeOut, sid)
298 data["file_obj"] = file_obj 298 data["file_obj"] = file_obj
299 data["to"] = to_jid 299 data["to"] = to_jid
300 data["success_cb"] = successCb 300 data["success_cb"] = successCb