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

refactor: make connector use queues #4

Merged
pufereq merged 12 commits from refactor/make-connector-use-queues into develop 2025-11-30 17:35:33 +00:00
Conversation 0 Commits 12 Files Changed 2 +151 -144
2 changed files with 151 additions and 144 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit bc62dbed66 - Show all commits

8
src/judas_client/connector.py
View File

@@ -106,14 +106,16 @@ class Connector:
def send_hello(self) -> None: def send_hello(self) -> None:
"""Send a HELLO message to the server.""" """Send a HELLO message to the server."""
self.logger.debug("[*] Sending HELLO message...") self.logger.debug("[*] Sending HELLO message...")
hello_message: bytes = Message.hello(self.mac_address).to_bytes() hello_message: Message = Message.hello(self.mac_address)
self.outbound_buffer += hello_message self.send(hello_message)
self._send_outbound()
def close(self) -> None: def close(self) -> None:
"""Close the connection and clean up resources.""" """Close the connection and clean up resources."""
self.logger.debug("[*] Closing connection...") self.logger.debug("[*] Closing connection...")
try:
self.selector.unregister(self.socket) self.selector.unregister(self.socket)
except Exception as e:
self.logger.error(f"[!] Error unregistering socket: {e}")
self.socket.close() self.socket.close()
self.logger.debug("[.] Connection closed.") self.logger.debug("[.] Connection closed.")