w1cdn/spothole
1
0
Fork 0
mirror of https://git.ianrenton.com/ian/spothole.git synced 2026-06-24 05:35:10 +00:00
Code Issues 13 Packages Projects Releases Wiki Activity

SSE server reliability improvements

Browse Source
This commit is contained in:
Ian Renton
2026-06-05 16:11:25 +01:00
parent a2dff07c0e
commit 74caae342b
11 changed files with 26 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
server/handlers/api/alerts.py
View File

@@ -99,7 +99,7 @@ class APIAlertsStreamHandler(tornado_eventsource.handler.EventSourceHandler):
self._heartbeat.start()
# Flush headers immediately so nginx doesn't time out waiting for a response
self.write_message(msg="", event="keepalive")
self.write_message("keepalive", "")
except Exception as e:
logging.warning("Exception when serving SSE socket", e)
@@ -137,7 +137,7 @@ class APIAlertsStreamHandler(tornado_eventsource.handler.EventSourceHandler):
else:
# Send a keepalive comment if the queue was empty
self.write_message(msg="", event="keepalive")
self.write_message("keepalive", "")
if self._alert_queue not in self._sse_alert_queues:
logging.error("Web server cleared up a queue of an active connection!")

4
server/handlers/api/spots.py
View File

@@ -101,7 +101,7 @@ class APISpotsStreamHandler(tornado_eventsource.handler.EventSourceHandler):
self._heartbeat.start()
# Flush headers immediately so nginx doesn't time out waiting for a response
self.write_message(msg="", event="keepalive")
self.write_message("keepalive", "")
except Exception as e:
logging.warning("Exception when serving SSE socket", e)
@@ -139,7 +139,7 @@ class APISpotsStreamHandler(tornado_eventsource.handler.EventSourceHandler):
else:
# Send a keepalive comment if the queue was empty
self.write_message(msg="", event="keepalive")
self.write_message("keepalive", "")
if self._spot_queue not in self._sse_spot_queues:
logging.error("Web server cleared up a queue of an active connection!")