p15670423
/
monkey
1
0
Fork 5
Code Issues Pull Requests 3 Projects Releases Wiki Activity

agent: Define _manage_telemetry_batches_thread in __init_()

This commit is contained in:
Mike Salvatore 2021-06-29 06:38:56 -04:00
parent a454449cca
commit 9d3d4611dc
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
monkey/infection_monkey/telemetry/messengers/batching_telemetry_messenger.py
View File

@ -45,6 +45,8 @@ class BatchingTelemetryMessenger(ITelemetryMessenger):
self._last_sent_time = time.time()
self._telemetry_batches: Dict[str, IBatchableTelem] = {}
self._manage_telemetry_batches_thread = None
def start(self):
self._should_run_batch_thread = True
self._manage_telemetry_batches_thread = threading.Thread(
@ -55,6 +57,7 @@ class BatchingTelemetryMessenger(ITelemetryMessenger):
def stop(self):
self._should_run_batch_thread = False
self._manage_telemetry_batches_thread.join()
self._manage_telemetry_batches_thread = None
def _manage_telemetry_batches(self):
self._reset()