|
|
@ -145,6 +145,9 @@ def handle_long_poll(ws: WebSocket, exit_event: threading.Event | None) -> None: |
|
|
|
threading.Thread(target=ws_recv, args=(ws, end_event), name='ws_recv'), |
|
|
|
threading.Thread(target=ws_recv, args=(ws, end_event), name='ws_recv'), |
|
|
|
threading.Thread(target=ws_send, args=(ws, end_event), name='ws_send'), |
|
|
|
threading.Thread(target=ws_send, args=(ws, end_event), name='ws_send'), |
|
|
|
threading.Thread(target=upload_handler, args=(end_event,), name='upload_handler'), |
|
|
|
threading.Thread(target=upload_handler, args=(end_event,), name='upload_handler'), |
|
|
|
|
|
|
|
threading.Thread(target=upload_handler, args=(end_event,), name='upload_handler2'), |
|
|
|
|
|
|
|
threading.Thread(target=upload_handler, args=(end_event,), name='upload_handler3'), |
|
|
|
|
|
|
|
threading.Thread(target=upload_handler, args=(end_event,), name='upload_handler4'), |
|
|
|
threading.Thread(target=log_handler, args=(end_event,), name='log_handler'), |
|
|
|
threading.Thread(target=log_handler, args=(end_event,), name='log_handler'), |
|
|
|
threading.Thread(target=stat_handler, args=(end_event,), name='stat_handler'), |
|
|
|
threading.Thread(target=stat_handler, args=(end_event,), name='stat_handler'), |
|
|
|
] + [ |
|
|
|
] + [ |
|
|
|