alwyas backlog
This commit is contained in:
@@ -112,10 +112,9 @@ class Parser(threading.Thread):
|
|||||||
log("Parser.run: start")
|
log("Parser.run: start")
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
if environ.get("DEBUG", None):
|
backlog = self.inq.qsize()
|
||||||
backlog = self.inq.qsize()
|
if backlog:
|
||||||
if backlog:
|
log("Parser.run backlog", backlog)
|
||||||
log("Parser.run backlog", backlog)
|
|
||||||
clip = self.inq.get()
|
clip = self.inq.get()
|
||||||
if clip is None:
|
if clip is None:
|
||||||
break
|
break
|
||||||
|
|||||||
Reference in New Issue
Block a user