YunoHost/yunorunner
1
0
Fork 0
mirror of https://github.com/YunoHost/yunorunner.git synced 2024-09-03 20:05:52 +02:00
Code Issues Projects Releases Packages Wiki Activity

[fix] attemp to remove maybe dead websockets tasks that could memleaks

Browse source
This commit is contained in:
Laurent Peuch 2019-04-01 03:36:49 +02:00
parent ed6d7cf1c7
commit ae8a5a40bd
1 changed files with 24 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
run.py
View file

@ -512,8 +512,12 @@ async def ws_index(request, websocket):
}))
while True:
# do nothing with input but wait
await websocket.recv()
# ping periodically to remove dead connections
try:
await websocket.send("ping")
except ConnectionClosed:
return
await asyncio.sleep(60)
@app.websocket('/job-<job_id>-ws')
@ -533,8 +537,12 @@ async def ws_job(request, websocket, job_id):
}))
while True:
# do nothing with input but wait
await websocket.recv()
# ping periodically to remove dead connections
try:
await websocket.send("ping")
except ConnectionClosed:
return
await asyncio.sleep(60)
@app.websocket('/apps-ws')
@ -631,8 +639,12 @@ async def ws_apps(request, websocket):
}))
while True:
# do nothing with input but wait
await websocket.recv()
# ping periodically to remove dead connections
try:
await websocket.send("ping")
except ConnectionClosed:
return
await asyncio.sleep(60)
@app.websocket('/app-<app_name>-ws')
@ -650,8 +662,12 @@ async def ws_app(request, websocket, app_name):
}))
while True:
# do nothing with input but wait
await websocket.recv()
# ping periodically to remove dead connections
try:
await websocket.send("ping")
except ConnectionClosed:
return
await asyncio.sleep(60)
def require_token():