Administrator
2023-09-12 7a9296449e96b3755bffb5d4c201875a1e245699
huaxin_client/l2_data_manager.py
@@ -237,10 +237,12 @@
                    l2_data_callback.OnMarketData(temp[0], temp[2])
                else:
                    upload_data(temp[0], temp[1], temp[2])
            time.sleep(0.01)
        except Exception as e:
            logger_local_huaxin_l2_error.exception(e)
            logger_local_huaxin_l2_error.error(f"上传普通数据出错:{str(e)}")
        finally:
            time.sleep(0.01)
def __run_upload_trading_canceled(l2_data_callback: L2DataCallBack):
@@ -329,9 +331,10 @@
                            t.start()
                            __upload_trans_threads[code] = t
                            logger_local_huaxin_l2_upload.info(f"重新创建L2成交上传线程:{code}")
                    time.sleep(3)
            except:
                pass
            finally:
                time.sleep(3)
    t = threading.Thread(target=lambda: upload_daemon(), daemon=True)
    t.start()