summaryrefslogtreecommitdiff
path: root/sleekxmpp/xmlstream/scheduler.py
diff options
context:
space:
mode:
authorNathan Fritz <fritzy@netflint.net>2010-05-27 04:58:57 -0700
committerNathan Fritz <fritzy@netflint.net>2010-05-27 04:58:57 -0700
commit3a28f9e5d247b9124e0d14c26c2a6e79aaee86ff (patch)
tree0d0cbd55785b8c06a86268e6de66201924f3dd55 /sleekxmpp/xmlstream/scheduler.py
parent0bda5fd3f28da14478db87c98fb89f647994deaa (diff)
downloadslixmpp-3a28f9e5d247b9124e0d14c26c2a6e79aaee86ff.tar.gz
slixmpp-3a28f9e5d247b9124e0d14c26c2a6e79aaee86ff.tar.bz2
slixmpp-3a28f9e5d247b9124e0d14c26c2a6e79aaee86ff.tar.xz
slixmpp-3a28f9e5d247b9124e0d14c26c2a6e79aaee86ff.zip
added pubsub state stanzas and scheduled events
Diffstat (limited to 'sleekxmpp/xmlstream/scheduler.py')
-rw-r--r--sleekxmpp/xmlstream/scheduler.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/sleekxmpp/xmlstream/scheduler.py b/sleekxmpp/xmlstream/scheduler.py
index 5cb8aff0..7aa59f3d 100644
--- a/sleekxmpp/xmlstream/scheduler.py
+++ b/sleekxmpp/xmlstream/scheduler.py
@@ -4,6 +4,7 @@ except ImportError:
import Queue as queue
import time
import threading
+import logging
class Task(object):
"""Task object for the Scheduler class"""
@@ -34,7 +35,7 @@ class Scheduler(object):
self.addq = queue.Queue()
self.schedule = []
self.thread = None
- self.run = True
+ self.run = False
def process(self, threaded=True):
if threaded:
@@ -44,6 +45,7 @@ class Scheduler(object):
self._process()
def _process(self):
+ self.run = True
while self.run:
wait = 5
updated = False
@@ -67,7 +69,7 @@ class Scheduler(object):
self.schedule.append(newtask)
finally:
if updated: self.schedule = sorted(self.schedule, key=lambda task: task.next)
- print [x.name for x in self.schedule]
+ logging.debug("Qutting Scheduler thread")
def add(self, name, seconds, callback, args=None, kwargs=None, repeat=False, qpointer=None):
self.addq.put(Task(name, seconds, callback, args, kwargs, repeat, qpointer))