github/SleekXMPP
1
0
Fork 0
mirror of https://github.com/correl/SleekXMPP.git synced 2024-11-24 03:00:15 +00:00
Code Issues Projects Releases Packages Wiki Activity

Modified basexmpp.event() to pass a copy of the event data to each handler.

Browse source
This commit is contained in:
Lance Stout 2010-06-06 23:19:07 -04:00
parent 9962f1a664
commit 3c939313d2
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
sleekxmpp/basexmpp.py
View file

@ -27,6 +27,7 @@ from . stanza.error import Error
import logging import logging
import threading import threading
import copy
import sys import sys
@ -205,12 +206,13 @@ class basexmpp(object):
def event(self, name, eventdata = {}): # called on an event def event(self, name, eventdata = {}): # called on an event
for handler in self.event_handlers.get(name, []): for handler in self.event_handlers.get(name, []):
handlerdata = copy.copy(eventdata)
if handler[1]: #if threaded if handler[1]: #if threaded
#thread.start_new(handler[0], (eventdata,)) #thread.start_new(handler[0], (eventdata,))
x = threading.Thread(name="Event_%s" % str(handler[0]), target=handler[0], args=(eventdata,)) x = threading.Thread(name="Event_%s" % str(handler[0]), target=handler[0], args=(handlerdata,))
x.start() x.start()
else: else:
handler[0](eventdata) handler[0](handlerdata)
if handler[2]: #disposable if handler[2]: #disposable
with self.lock: with self.lock:
self.event_handlers[name].pop(self.event_handlers[name].index(handler)) self.event_handlers[name].pop(self.event_handlers[name].index(handler))