avm/hassio-addons
1
0
Fork 0
mirror of https://github.com/alexbelgium/hassio-addons.git synced 2026-09-04 17:03:34 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix(claude_desktop): expire stale keepalive sessions

Browse Source
This commit is contained in:
Alexandre
2026-08-02 17:53:40 +02:00
parent 307e2687f2
commit 0664e00ad1
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
claude_desktop/rootfs/usr/local/bin/headroom-proxy-gate.py
View File

@@ -232,7 +232,6 @@ class ProxyGate:
if ( if (
process is not None process is not None
and process.returncode is None and process.returncode is None
and self._active_connections == 0
and idle_for >= IDLE_TIMEOUT and idle_for >= IDLE_TIMEOUT
): ):
await self.stop_backend(f"idle for {int(idle_for)}s") await self.stop_backend(f"idle for {int(idle_for)}s")
@@ -258,7 +257,7 @@ class ProxyGate:
async def handle_client(self, client_reader: asyncio.StreamReader, client_writer: asyncio.StreamWriter) -> None: async def handle_client(self, client_reader: asyncio.StreamReader, client_writer: asyncio.StreamWriter) -> None:
self._active_connections += 1 self._active_connections += 1
self.touch() real_traffic = False
peer = client_writer.get_extra_info("peername") peer = client_writer.get_extra_info("peername")
try: try:
try: try:
@@ -277,6 +276,8 @@ class ProxyGate:
await client_writer.drain() await client_writer.drain()
return return
real_traffic = True
self.touch()
try: try:
await self.ensure_backend() await self.ensure_backend()
backend_reader, backend_writer = await asyncio.wait_for( backend_reader, backend_writer = await asyncio.wait_for(
@@ -306,6 +307,7 @@ class ProxyGate:
await backend_writer.wait_closed() await backend_writer.wait_closed()
finally: finally:
self._active_connections = max(0, self._active_connections - 1) self._active_connections = max(0, self._active_connections - 1)
if real_traffic:
self.touch() self.touch()
client_writer.close() client_writer.close()
with contextlib.suppress(Exception): with contextlib.suppress(Exception):