取消测试

Administrator

2023-08-30 9f06233d02d036624bbdcf92ba81b2a6aaa970da

取消测试

 constant.py

@@ -1,7 +1,7 @@
# 是否为测试
import platform

TEST = True
TEST = False
# 是否允许交易
TRADE_ENABLE = True


 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(_pipe_strategy)
    # l2_data_manager.run_test(_pipe_strategy)
    global l2CommandManager
    l2CommandManager = command_manager.L2CommandManager()
    l2CommandManager.init(MyL2ActionCallback())

 huaxin_client/l2_data_manager.py

@@ -165,9 +165,10 @@
    if code not in tmep_order_detail_queue_dict:
        tmep_order_detail_queue_dict[code] = queue.Queue()
    tag = l2_data_transaction_protocol.get_mmap_tag_name_for_l2_order(code)
    with contextlib.closing(
            mmap.mmap(-1, 1000 * 100, tag,
                      access=mmap.ACCESS_WRITE)) as _mmap:
    # with contextlib.closing(
    #         mmap.mmap(-1, 1000 * 100, tag,
    #                   access=mmap.ACCESS_WRITE)) as _mmap:
    if True:
        while True:
            # print("order task")
            try:
@@ -181,8 +182,8 @@
                    udatas.append(temp)
                if udatas:
                    start_time = time.time()
                    # upload_data(code, "l2_order", udatas)
                    l2_data_transaction_protocol.send_l2_order_detail(pipe, _mmap, code, udatas)
                    upload_data(code, "l2_order", udatas)
                    # l2_data_transaction_protocol.send_l2_order_detail(pipe, _mmap, code, udatas)
                    use_time = int((time.time() - start_time) * 1000)
                    if use_time > 20:
                        logger_local_huaxin_l2_upload.info(f"{code}-上传代码耗时：{use_time}ms")

 log_module/log.py

@@ -363,10 +363,10 @@

def close_print():
    pass
    # logging.basicConfig(level=logging.ERROR)
    # if not constant.is_windows():
    #     os.close(1)
    #     os.open('/dev/null', os.O_WRONLY)
    logging.basicConfig(level=logging.ERROR)
    if not constant.is_windows():
        os.close(1)
        os.open('/dev/null', os.O_WRONLY)


if __name__ == "__main__":