sangge/tpre-python
2
1
Fork 1
Code Issues 6 Pull Requests Packages Projects 1 Activity

feat: finish timer

Browse Source
This commit is contained in:
sangge 2023-10-21 20:31:23 +08:00
parent ad3f14ae1f
commit 8a049fbe6f
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/server.py
View File

@ -28,7 +28,7 @@ cursor.execute('''CREATE TABLE IF NOT EXISTS nodes (
)''') )''')
def init(): def init():
nothing = receive_heartbeat_internal() task = asyncio.create_task(receive_heartbeat_internal())
def clean_env(): def clean_env():
# 关闭游标和连接 # 关闭游标和连接
@ -101,7 +101,7 @@ async def receive_heartbeat_internal() -> int:
cursor.execute("DELETE FROM nodes WHERE last_heartbeat < ?", (time.time() - timeout,)) cursor.execute("DELETE FROM nodes WHERE last_heartbeat < ?", (time.time() - timeout,))
conn.commit() conn.commit()
print('successful delete') print('successful delete')
time.sleep(timeout) await asyncio.sleep(timeout)
return 1 return 1
@app.get("/server/send_nodes_list") @app.get("/server/send_nodes_list")