p59342861
/
monkey
forked from p15670423/monkey
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

agent: Fully flush BatchingTelemetryMessenger queue before stopping

This commit is contained in:
Mike Salvatore 2021-06-28 12:34:24 -04:00
parent 7e3eef90cb
commit 543f0031a2
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -57,7 +57,7 @@ class BatchingTelemetryMessenger(ITelemetryMessenger):
def _manage_telemetry_batches(self): def _manage_telemetry_batches(self):
self._reset() self._reset()
while self._should_run_batch_thread: while self._should_run_batch_thread or not self._queue.empty():
try: try:
telemetry = self._queue.get(block=True, timeout=self._period / WAKES_PER_PERIOD) telemetry = self._queue.get(block=True, timeout=self._period / WAKES_PER_PERIOD)