remove fin list
This commit is contained in:
parent
f9beefe96a
commit
dd8b0ebdf2
@ -383,8 +383,7 @@ def stream_trimmer_loop():
|
|||||||
|
|
||||||
#if stream already marked as finished, just remove it
|
#if stream already marked as finished, just remove it
|
||||||
if '_fin' in systems[system].STATUS[stream_id] and systems[system].STATUS[stream_id]['LAST'] < _now - 5:
|
if '_fin' in systems[system].STATUS[stream_id] and systems[system].STATUS[stream_id]['LAST'] < _now - 5:
|
||||||
removed = systems[system].STATUS.pop(stream_id)
|
fin_list.append(stream_id)
|
||||||
continue
|
|
||||||
|
|
||||||
try:
|
try:
|
||||||
if systems[system].STATUS[stream_id]['LAST'] < _now - 5:
|
if systems[system].STATUS[stream_id]['LAST'] < _now - 5:
|
||||||
@ -394,6 +393,10 @@ def stream_trimmer_loop():
|
|||||||
systems[system].STATUS[stream_id]['LAST'] = _now
|
systems[system].STATUS[stream_id]['LAST'] = _now
|
||||||
continue
|
continue
|
||||||
|
|
||||||
|
#remove finished
|
||||||
|
for stream_id in fin_list:
|
||||||
|
removed = systems[system].STATUS.pop(stream_id)
|
||||||
|
|
||||||
for stream_id in remove_list:
|
for stream_id in remove_list:
|
||||||
if stream_id in systems[system].STATUS:
|
if stream_id in systems[system].STATUS:
|
||||||
_stream = systems[system].STATUS[stream_id]
|
_stream = systems[system].STATUS[stream_id]
|
||||||
|
Loading…
x
Reference in New Issue
Block a user