From e579cb53b66430e079262a4f63732fc17822393b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Laura=20Kl=C3=BCnder?= Date: Thu, 30 Nov 2023 22:03:22 +0100 Subject: [PATCH] send all the data for the OTA --- src/c3nav/mesh/consumers.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/c3nav/mesh/consumers.py b/src/c3nav/mesh/consumers.py index c1c81707..b71e0f4b 100644 --- a/src/c3nav/mesh/consumers.py +++ b/src/c3nav/mesh/consumers.py @@ -451,7 +451,7 @@ class MeshConsumer(AsyncWebsocketConsumer): async with self.ota_chunks_available_condition: num_chunks = (update.build.binary.size-1)//OTA_CHUNK_SIZE+1 print('queueing chunks for update', update.id, 'num_chunks=%d' % num_chunks, "chunks:", chunks) - chunks = (set(range(min_chunk, num_chunks*0+10)) + chunks = (set(range(min_chunk, num_chunks)) if chunks is None else {chunk for chunk in chunks if chunk < num_chunks}) self.ota_chunks.setdefault(update.id, set()).update(chunks) @@ -490,7 +490,7 @@ class MeshConsumer(AsyncWebsocketConsumer): )) # wait a bit until we send more - await asyncio.sleep(0.1) # 100ms + await asyncio.sleep(0.05) # 50ms async with self.ota_chunks_available_condition: if not self.ota_chunks: