asyncsched calls asyncore.loop(count=1)

diff --git a/lib/asyncsched.py b/lib/asyncsched.py
index c8b0871e148c81c6c53aee3f48bdceeb9c22344b..428fcf3fb39dcbfd710bb3653da880eefb085b9c 100644 (file)
--- a/lib/asyncsched.py
+++ b/lib/asyncsched.py
@@ -33,7 +33,7 @@ def schedule(delay, func, args=[], kwargs={}):
        heapq.heappush(tasks, task)
        return task
 
-def loop(timeout=30.0):
+def loop(timeout=30.0, use_poll=False):
        global running
        running = True
        oldhandler = signal.signal(signal.SIGTERM, exit)
@@ -48,7 +48,7 @@ def loop(timeout=30.0):
                if tasks:
                        t = max(min(t, tasks[0].time - now), 0)
 
-               asyncore.poll(timeout=t)
+               asyncore.loop(timeout=t, count=1, use_poll=use_poll)
        
        signal.signal(signal.SIGTERM, oldhandler)