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

Agent: Rename `push_all_events_to_island` -> `send_all_events_to_island` for consistency

This commit is contained in:
Shreya Malviya 2022-09-13 12:49:54 +05:30
parent 5542f67ceb
commit 9475c86fba
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
monkey/infection_monkey/push_events_to_island.py
View File

@ -18,7 +18,7 @@ DEFAULT_TIME_PERIOD = 5
WAKES_PER_PERIOD = 4 WAKES_PER_PERIOD = 4
class push_all_events_to_island: class send_all_events_to_island:
def __init__(self, server_address: str): def __init__(self, server_address: str):
self._server_address = server_address self._server_address = server_address
self._queue: queue.Queue[AbstractAgentEvent] = queue.Queue() self._queue: queue.Queue[AbstractAgentEvent] = queue.Queue()
@ -32,7 +32,7 @@ class push_all_events_to_island:
topic_name = topic.getName() topic_name = topic.getName()
self._queue.put(self._serialize_event(event, topic_name)) self._queue.put(self._serialize_event(event, topic_name))
logger.debug(f"Pushing event of type {topic_name} to the Island at {self._server_address}") logger.debug(f"Sending event of type {topic_name} to the Island at {self._server_address}")
def _serialize_event(self, event: AbstractAgentEvent, topic_name: str): def _serialize_event(self, event: AbstractAgentEvent, topic_name: str):
pass pass