| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def add_subscript_codes(codes): |
|---|
| | | print("add_subscript_codes", codes) |
|---|
| | | # print("add_subscript_codes", codes) |
|---|
| | | # 加入上传队列 |
|---|
| | | common_queue.put(('', "l2_subscript_codes", list(codes))) |
|---|
| | | |
|---|
| | |
|---|
| | | return True |
|---|
| | | else: |
|---|
| | | # 再次发送 |
|---|
| | | print("再次发送") |
|---|
| | | # print("再次发送") |
|---|
| | | return __send_response(sk, msg) |
|---|
| | | except ConnectionResetError as e: |
|---|
| | | SendResponseSkManager.del_send_response_sk(type) |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def __run_upload_common(): |
|---|
| | | print("__run_upload_common") |
|---|
| | | # print("__run_upload_common") |
|---|
| | | logger_system.info(f"l2_client __run_upload_common 线程ID:{tool.get_thread_id()}") |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def __run_log(): |
|---|
| | | print("__run_log") |
|---|
| | | # print("__run_log") |
|---|
| | | logger_system.info(f"l2_client __run_log 线程ID:{tool.get_thread_id()}") |
|---|
| | | async_log_util.huaxin_l2_log.run_sync() |
|---|
| | | |
|---|
