clair/CVM-Sentry
1
0
Fork 0
Code Activity

BULLSHIT

Browse Source
This commit is contained in:
Clair Delafuente
2025-11-10 02:16:21 -05:00
parent cdfbc7e55f
commit bc5bb81330
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cvmsentry.py
View File

@@ -477,17 +477,17 @@ for vm_dict_label, vm_obj in config.vms.items():
log.error( log.error(
f"Connection to VM '{vm_obj['ws_url']}' closed with error: {e}. Reconnecting..." f"Connection to VM '{vm_obj['ws_url']}' closed with error: {e}. Reconnecting..."
) )
await asyncio.sleep(5) # Wait before attempting to reconnect await asyncio.sleep(0)
except websockets.exceptions.ConnectionClosedOK: except websockets.exceptions.ConnectionClosedOK:
log.warning( log.warning(
f"Connection to VM '{vm_obj['ws_url']}' closed cleanly (code 1005). Reconnecting..." f"Connection to VM '{vm_obj['ws_url']}' closed cleanly (code 1005). Reconnecting..."
) )
await asyncio.sleep(5) # Wait before attempting to reconnect await asyncio.sleep(0)
except websockets.exceptions.InvalidStatus as e: except websockets.exceptions.InvalidStatus as e:
log.error( log.error(
f"Failed to connect to VM '{vm_obj['ws_url']}' with status code: {e}. Reconnecting..." f"Failed to connect to VM '{vm_obj['ws_url']}' with status code: {e}. Reconnecting..."
) )
await asyncio.sleep(10) # Wait longer for HTTP errors await asyncio.sleep(0)
except websockets.exceptions.WebSocketException as e: except websockets.exceptions.WebSocketException as e:
log.error( log.error(
f"WebSocket error connecting to VM '{vm_obj['ws_url']}': {e}. Reconnecting..." f"WebSocket error connecting to VM '{vm_obj['ws_url']}': {e}. Reconnecting..."
@@ -497,7 +497,7 @@ for vm_dict_label, vm_obj in config.vms.items():
log.error( log.error(
f"Unexpected error connecting to VM '{vm_obj['ws_url']}': {e}. Reconnecting..." f"Unexpected error connecting to VM '{vm_obj['ws_url']}': {e}. Reconnecting..."
) )
await asyncio.sleep(10) # Wait longer for unexpected errors await asyncio.sleep(0)
# Create tasks for VM connections # Create tasks for VM connections
vm_tasks = [connect_with_reconnect(vm) for vm in config.vms.values()] vm_tasks = [connect_with_reconnect(vm) for vm in config.vms.values()]