try resetting connection on loss

This commit is contained in:
Sem van der Hoeven
2023-06-05 16:06:19 +02:00
parent 2b36a9a383
commit b565832773
2 changed files with 9 additions and 2 deletions

View File

@@ -110,7 +110,7 @@
document.getElementById("cpuload").innerHTML = "CPU load: " + data.data.cpu_usage.toString().substring(0, 6).substring(2, 4) + "%"; document.getElementById("cpuload").innerHTML = "CPU load: " + data.data.cpu_usage.toString().substring(0, 6).substring(2, 4) + "%";
document.getElementById("armed").innerHTML = "Armed: " + data.data.armed; document.getElementById("armed").innerHTML = "Armed: " + data.data.armed;
document.getElementById("control_mode").innerHTML = "Control mode: " + data.data.control_mode; document.getElementById("control_mode").innerHTML = "Control mode: " + data.data.control_mode;
document.getElementById("speed").innerHTML = "Current speed (m/s): x: " + data.data.speed[0] + " y: " + data.data.speed[1] + " z: " + data.data.speed[2]; document.getElementById("speed").innerHTML = "Current speed (m/s): x: " + data.data.velocity[0] + " y: " + data.data.velocity[1] + " z: " + data.data.velocity[2];
document.getElementById("position").innerHTML = "Current position (m): x: " + data.data.position[0] + " y: " + data.data.position[1] + " z: " + data.data.position[2]; document.getElementById("position").innerHTML = "Current position (m): x: " + data.data.position[0] + " y: " + data.data.position[1] + " z: " + data.data.position[2];
} else if (data.type == "FAILSAFE") { } else if (data.type == "FAILSAFE") {
document.getElementById("failsafe").innerHTML = "Failsafe: ENABLED"; document.getElementById("failsafe").innerHTML = "Failsafe: ENABLED";

View File

@@ -58,7 +58,14 @@ class CameraController(Node):
def setup_websocket(self): def setup_websocket(self):
loop = asyncio.new_event_loop() loop = asyncio.new_event_loop()
start_server = websockets.serve(self.websocket_video, "0.0.0.0", 9002,loop=loop) connected = False
while not connected:
try:
start_server = websockets.serve(self.websocket_video, "0.0.0.0", 9002,loop=loop)
connected = True
except Exception as e:
self.get_logger().error("error " + str(e))
connected = False
loop.run_until_complete(start_server) loop.run_until_complete(start_server)
loop.run_forever() loop.run_forever()