@@ -44,7 +44,7 @@ def run_forever(self):
4444while True :
4545if self .q :
4646t ,cnt ,cb ,args = heapq .heappop (self .q )
47- log .debug ("Nexttask to run: %s" , (t ,cnt ,cb ,args ))
47+ log .debug ("Nextcoroutine to run: %s" , (t ,cnt ,cb ,args ))
4848# __main__.mem_info()
4949tnow = self .time ()
5050delay = t - tnow
@@ -61,9 +61,9 @@ def run_forever(self):
6161try :
6262if args == ():
6363args = (None ,)
64- log .debug ("Gen %s send args: %s" ,cb ,args )
64+ log .debug ("Coroutine %s send args: %s" ,cb ,args )
6565ret = cb .send (* args )
66- log .debug ("Gen %s yield result: %s" ,cb ,ret )
66+ log .debug ("Coroutine %s yield result: %s" ,cb ,ret )
6767if isinstance (ret ,SysCall ):
6868if isinstance (ret ,Sleep ):
6969delay = ret .args [0 ]
@@ -86,10 +86,9 @@ def run_forever(self):
8686# Just reschedule
8787pass
8888else :
89- print (ret ,type (ret ))
90- assert False
89+ assert False ,"Unsupported coroutine yield value: %r (of type %r)" % (ret ,type (ret ))
9190except StopIteration as e :
92- log .debug ("Gen finished: %s" ,cb )
91+ log .debug ("Coroutine finished: %s" ,cb )
9392continue
9493self .call_later (delay ,cb ,* args )
9594