judas/judas_client
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

feat(connector.py): require ACK for HELLO message, retry if not received

Browse Source
This commit is contained in:
Artur Borecki
2025-08-29 00:40:35 +02:00
parent eef39bc2c0
commit 5844d4b521
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/judas_client/connector.py
View File

@@ -139,7 +139,16 @@ class Connector:
def send_hello(self) -> None: def send_hello(self) -> None:
self.logger.debug("[.] Sending hello message...") self.logger.debug("[.] Sending hello message...")
hello_message: Message = Message.hello(self.mac_address) hello_message: Message = Message.hello(self.mac_address)
self.send(hello_message.to_bytes()) acknowledged: bool = False
while not acknowledged:
self.send(hello_message.to_bytes())
self.logger.debug("[.] Hello message sent, waiting for ACK...")
acknowledged = self._check_ack()
if not acknowledged:
self.logger.warning(
"[!] Hello message not acknowledged, retrying..."
)
time.sleep(1)
def _loop(self) -> None: def _loop(self) -> None:
self.logger.debug("Starting main loop...") self.logger.debug("Starting main loop...")