adebaumann/arduino_gauge_controller
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Attempt with tcp probe

Browse Source
This commit is contained in:
Adrian A. Baumann
2026-04-21 20:26:31 +02:00
parent 1f8ba45685
commit 2ea19b14f8
1 changed files with 2 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
gauge.py
View File

@@ -884,25 +884,13 @@ def _subscribe_all(c):
c.subscribe(f"{prefix}/status_led/green/set") c.subscribe(f"{prefix}/status_led/green/set")
def _probe_tcp(host, port, timeout_s=10):
"""Open and immediately close a TCP connection to verify the route is up."""
import usocket
s = usocket.socket()
s.settimeout(timeout_s)
try:
s.connect(usocket.getaddrinfo(host, port)[0][-1])
finally:
s.close()
def connect_mqtt(): def connect_mqtt():
global client_ref, _mqtt_connected global client_ref, _mqtt_connected
info(f"Connecting to MQTT broker {MQTT_BROKER}:{MQTT_PORT} ...") info(f"Connecting to MQTT broker {MQTT_BROKER}:{MQTT_PORT} ...")
last_error = None last_error = None
for attempt in range(3): for attempt in range(3):
gc.collect()
try: try:
_probe_tcp(MQTT_BROKER, MQTT_PORT)
if client_ref is not None: if client_ref is not None:
try: try:
client_ref.disconnect() client_ref.disconnect()
@@ -925,7 +913,7 @@ def connect_mqtt():
return return
except Exception as e: except Exception as e:
last_error = e last_error = e
log_err(f"MQTT connect attempt {attempt + 1} failed: {e}") log_err(f"MQTT connect attempt {attempt + 1} failed: {type(e).__name__}: {e}")
try: try:
client.sock.close() client.sock.close()
except Exception: except Exception: