michael/scrypted
1
0
Fork 0
mirror of https://github.com/koush/scrypted.git synced 2026-06-10 12:50:32 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

server: Fix leaking fd due to cleanup (#2052)

Browse Source
This commit is contained in:
David Glandon
2026-05-30 01:15:21 -04:00
committed by GitHub
parent 1545790cdb
commit 07f9bfacac
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
server/python/cluster_setup.py
View File

@@ -127,9 +127,13 @@ class ClusterSetup:
except:
pass
finally:
self.clusterPeers.pop(clusterPeerKey)
self.clusterPeers.pop(clusterPeerKey, None)
peer.kill("cluster client killed")
writer.close()
try:
await writer.wait_closed()
except:
pass
clusterRpcServerInfo = await cluster_listen_zero(handleClusterClient)
self.clusterPort = clusterRpcServerInfo["port"]
@@ -182,7 +186,7 @@ class ClusterSetup:
)
)
except:
self.clusterPeers.pop(clusterPeerKey)
self.clusterPeers.pop(clusterPeerKey, None)
raise
async def run_loop():
@@ -191,7 +195,13 @@ class ClusterSetup:
except:
pass
finally:
self.clusterPeers.pop(clusterPeerKey)
self.clusterPeers.pop(clusterPeerKey, None)
clusterPeer.kill("cluster peer killed")
writer.close()
try:
await writer.wait_closed()
except:
pass
asyncio.run_coroutine_threadsafe(run_loop(), self.loop)
return clusterPeer