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

chore(release): 0.2.0 #2

Merged
pufereq merged 9 commits from release/0.2.0 into main 2025-09-19 13:34:37 +00:00
Conversation 0 Commits 9 Files Changed 4 +26 -12
1 changed files with 26 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 8d06775c27 - Show all commits

10
src/judas_client/connector.py
View File

@@ -98,12 +98,18 @@ class Connector:
time.sleep(retry_interval) time.sleep(retry_interval)
self.connect(retry_interval=min(30, retry_interval * 2)) self.connect(retry_interval=min(30, retry_interval * 2))
def send(self, data: bytes) -> None: def send(self, data: bytes, no_check_ack: bool = False) -> None:
self.logger.debug(f"[>] Sending data: {data}") self.logger.debug(f"[>] Sending data: {data}")
while True: while True:
try: try:
self.socket.sendall(data) self.socket.sendall(data)
self.logger.info("[>] Data sent")
if no_check_ack:
self.logger.debug("[>] Data sent without ACK check")
break
else:
self.logger.info("[>] Data sent")
acknowledged: bool = self._check_ack() acknowledged: bool = self._check_ack()
if acknowledged: if acknowledged:
self.logger.debug("[.] Data acknowledged") self.logger.debug("[.] Data acknowledged")