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

Agent: Use create_daemon_thread() instead of threading.Thread() in AgentEventsToIslandSender

This commit is contained in:
Shreya Malviya 2022-09-14 19:45:12 +05:30
parent 17e9c00180
commit 4eabf6e77b
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
monkey/infection_monkey/send_all_events_to_island.py
View File

@ -9,6 +9,7 @@ from common.common_consts.timeouts import MEDIUM_REQUEST_TIMEOUT
from common.event_serializers import EventSerializerRegistry from common.event_serializers import EventSerializerRegistry
from common.event_serializers.i_event_serializer import JSONSerializable from common.event_serializers.i_event_serializer import JSONSerializable
from common.events import AbstractAgentEvent from common.events import AbstractAgentEvent
from infection_monkey.utils.threading import create_daemon_thread
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@ -59,8 +60,8 @@ class AgentEventsToIslandSender:
self._stop_batch_and_send_thread = threading.Event() self._stop_batch_and_send_thread = threading.Event()
def start(self): def start(self):
self._batch_and_send_thread = threading.Thread( self._batch_and_send_thread = create_daemon_thread(
name="SendEventsToIslandInBatchesThread", target=self._manage_event_batches target=self._manage_event_batches, name="SendEventsToIslandInBatchesThread"
) )
self._batch_and_send_thread.start() self._batch_and_send_thread.start()