diff options
| author | Nathan Fritz <fritzy@netflint.net> | 2010-05-27 19:58:57 +0800 |
|---|---|---|
| committer | Thom Nichols <tmnichols@gmail.com> | 2010-06-01 22:07:52 +0800 |
| commit | 194e6bcb5149f145c389fa8837dbe902557d9215 (patch) | |
| tree | 9833402892ca0d1f738fc321cfb3c084da590854 /sleekxmpp/xmlstream/scheduler.py | |
| parent | 2e7024419a98e0dc69493010faf24b4a2c88d37e (diff) | |
| download | slixmpp-194e6bcb5149f145c389fa8837dbe902557d9215.tar.gz slixmpp-194e6bcb5149f145c389fa8837dbe902557d9215.tar.bz2 slixmpp-194e6bcb5149f145c389fa8837dbe902557d9215.tar.xz slixmpp-194e6bcb5149f145c389fa8837dbe902557d9215.zip | |
added pubsub state stanzas and scheduled events
Diffstat (limited to 'sleekxmpp/xmlstream/scheduler.py')
| -rw-r--r-- | sleekxmpp/xmlstream/scheduler.py | 6 |
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)) |