added interval to recording

This commit is contained in:
UpstreamData
2022-06-02 14:25:55 -06:00
parent 64018cdad8
commit dcd3e99d73
3 changed files with 16 additions and 3 deletions

View File

@@ -34,6 +34,15 @@ def record_layout():
target="record_file", target="record_file",
), ),
], ],
[
sg.Spin(
[i for i in range(5, 101, 5)],
initial_value=10,
size=(5, 1),
key="record_interval",
),
sg.Text("Data Interval (seconds)"),
],
[ [
sg.Push(), sg.Push(),
sg.pin( sg.pin(

View File

@@ -26,7 +26,7 @@ class RecordingManager(metaclass=Singleton):
self.data: Dict[str:list] = {} self.data: Dict[str:list] = {}
self.miners = [] self.miners = []
self.output_file = None self.output_file = None
self.interval = 10 self.interval: int = 10
self.record_window = None self.record_window = None
async def _check_pause(self): async def _check_pause(self):
@@ -50,7 +50,6 @@ class RecordingManager(metaclass=Singleton):
for complete in asyncio.as_completed(tasks): for complete in asyncio.as_completed(tasks):
data = await complete data = await complete
print(data)
self.data[data.ip].append(data) self.data[data.ip].append(data)
for i in range(self.interval * 10): for i in range(self.interval * 10):
await self._check_pause() await self._check_pause()

View File

@@ -22,7 +22,12 @@ async def record_ui(ips: list):
if event == "start_recording": if event == "start_recording":
if values["record_file"]: if values["record_file"]:
asyncio.create_task( asyncio.create_task(
start_recording(ips, values["record_file"], record_window) start_recording(
ips,
values["record_file"],
record_window,
interval=int(values["record_interval"]),
)
) )
if event == "stop_recording": if event == "stop_recording":
asyncio.create_task(stop_recording(record_window)) asyncio.create_task(stop_recording(record_window))