修改L2数据传输方式

Administrator

2023-08-29 523391980ae381aa52346c66d44b82c8a4c64282

修改L2数据传输方式

 huaxin_client/l2_client.py

@@ -589,7 +589,7 @@
    l2_data_manager.run_upload_common()
    l2_data_manager.run_upload_trading_canceled()
    l2_data_manager.run_log()
    l2_data_manager.run_test()
    l2_data_manager.run_test(_pipe_strategy)
    global l2CommandManager
    l2CommandManager = command_manager.L2CommandManager()
    l2CommandManager.init(MyL2ActionCallback())

 huaxin_client/l2_data_manager.py

@@ -165,7 +165,9 @@
    if code not in tmep_order_detail_queue_dict:
        tmep_order_detail_queue_dict[code] = queue.Queue()

    with contextlib.closing(mmap.mmap(-1, 1000 * 100, tagname=l2_data_transaction_protocol.get_mmap_tag_name_for_l2_order(code), access=mmap.ACCESS_WRITE)) as _mmap:
    with contextlib.closing(
            mmap.mmap(-1, 1000 * 100, tagname=l2_data_transaction_protocol.get_mmap_tag_name_for_l2_order(code),
                      access=mmap.ACCESS_WRITE)) as _mmap:
        while True:
            # print("order task")
            try:
@@ -284,21 +286,23 @@
    t.start()


def __test():
def __test(pipe_strage):
    code = "002073"
    if code not in tmep_order_detail_queue_dict:
        tmep_order_detail_queue_dict[code] = queue.Queue()
    target_codes.add(code)
    run_upload_task(code, pipe_strage)
    while True:
        try:
            tmep_order_detail_queue_dict[code].put_nowait(['002073', 0.0, 88100, '1', '2', 103831240, 2011, 18190761, 18069131, 'D', 1693276711224])
            tmep_order_detail_queue_dict[code].put_nowait(
                ['002073', 0.0, 88100, '1', '2', 103831240, 2011, 18190761, 18069131, 'D', 1693276711224])
            time.sleep(5)
        except:
            pass


def run_test():
    t = threading.Thread(target=lambda: __test(), daemon=True)
def run_test(pipe_strage):
    t = threading.Thread(target=lambda: __test(pipe_strage), daemon=True)
    t.start()