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

Agent: Rename DEFAULT_TIME_PERIOD -> DEFAULT_TIME_PERIOD_SECONDS in send_all_events_to_island.py

This commit is contained in:
Shreya Malviya 2022-09-13 19:32:52 +05:30
parent 5ecc3e992a
commit 39a7ae0964
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
monkey/infection_monkey/send_all_events_to_island.py
View File

@ -12,8 +12,8 @@ from common.events import AbstractAgentEvent
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
DEFAULT_TIME_PERIOD = 5
WAKES_PER_PERIOD = 4 WAKES_PER_PERIOD = 4
DEFAULT_TIME_PERIOD_SECONDS = 5
EVENTS_API_URL = "https://%s/api/events" EVENTS_API_URL = "https://%s/api/events"
@ -27,7 +27,7 @@ class send_all_events_to_island:
self._queue: queue.Queue[AbstractAgentEvent] = queue.Queue() self._queue: queue.Queue[AbstractAgentEvent] = queue.Queue()
self._send_to_island_thread = self._batch_and_send_events_thread( self._send_to_island_thread = self._batch_and_send_events_thread(
self._queue, self._server_address, DEFAULT_TIME_PERIOD self._queue, self._server_address, DEFAULT_TIME_PERIOD_SECONDS
) )
self._send_to_island_thread.start() self._send_to_island_thread.start()
@ -63,7 +63,7 @@ class send_all_events_to_island:
def _manage_event_batches(self): def _manage_event_batches(self):
while self._should_run_batch_and_send_thread: while self._should_run_batch_and_send_thread:
self._send_events_to_island() self._send_events_to_island()
sleep(DEFAULT_TIME_PERIOD) sleep(self._time_period)
self._send_remaining_events() self._send_remaining_events()