Compare commits

...

7 Commits

3 changed files with 22 additions and 20 deletions

View File

@@ -110,7 +110,7 @@ class basexmpp(object):
xep = "(XEP-%s) " % self.plugin[plugin].xep xep = "(XEP-%s) " % self.plugin[plugin].xep
logging.debug("Loaded Plugin %s%s" % (xep, self.plugin[plugin].description)) logging.debug("Loaded Plugin %s%s" % (xep, self.plugin[plugin].description))
except: except:
logging.error("Unable to load plugin: %s" %(plugin) ) logging.exception("Unable to load plugin: %s", plugin )
def register_plugins(self): def register_plugins(self):
"""Initiates all plugins in the plugins/__init__.__all__""" """Initiates all plugins in the plugins/__init__.__all__"""

View File

@@ -41,6 +41,7 @@ class Scheduler(object):
def process(self, threaded=True): def process(self, threaded=True):
if threaded: if threaded:
self.thread = threading.Thread(name='shedulerprocess', target=self._process) self.thread = threading.Thread(name='shedulerprocess', target=self._process)
self.thread.daemon = True
self.thread.start() self.thread.start()
else: else:
self._process() self._process()

View File

@@ -302,7 +302,8 @@ class XMLStream(object):
return True return True
def disconnect(self, reconnect=False): def disconnect(self, reconnect=False):
if not self.state.transition('connected','disconnected'): with self.state.transition_ctx('connected','disconnected') as locked:
if not locked:
logging.warning("Already disconnected.") logging.warning("Already disconnected.")
return return
logging.debug("Disconnecting...") logging.debug("Disconnecting...")