Compare commits
7 Commits
0.9-conn-f
...
sleek-0.9-
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8bdfa77024 | ||
|
|
15ac3e9fba | ||
|
|
e8d37b409c | ||
|
|
898f96f265 | ||
|
|
4fccd77685 | ||
|
|
77bff9cce7 | ||
|
|
3f41fdd231 |
@@ -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__"""
|
||||||
|
|||||||
@@ -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()
|
||||||
|
|||||||
@@ -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...")
|
||||||
|
|||||||
Reference in New Issue
Block a user