2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-10-20 06:35:33 +00:00

Drop frames when the queue backs up

Avoid accumulating lag when the
This commit is contained in:
Jarrod Johnson
2026-10-07 16:36:38 -04:00
parent c0c5d39a8c
commit 910aef879c
+4
View File
@@ -1092,6 +1092,8 @@ async def do_vnc(node, url, outputfile=None):
vncclientsbynode[node] = client
while True:
# Retrieve pixels as a 3D numpy array
while not draw_queue.empty():
await asyncio.sleep(0.05)
try:
# replace the stock screenshot function with our own
# ask for a video refresh, then do reads until the video is complete
@@ -1132,6 +1134,8 @@ def draw_node(node, imgdata, errorstr, firstnodename, cwidth, cheight):
def _draw_worker():
while True:
item = draw_queue.get()
while not draw_queue.empty():
item = draw_queue.get()
if item is None:
break
node, imgdata, errorstr, firstnodename, cwidth, cheight = item