| | |
| | | use_time = (time.time() - msg['time']) * 1000 |
| | | decoded_data, decoded_use_time = L2SharedMemoryDataUtil.get_data(shared_memory) |
| | | print(f"获取到逐笔委托数据: 数据长度:{len(decoded_data)} 通信耗时:{use_time}ms 解码耗时:{decoded_use_time}s") |
| | | if use_time > 0.1: |
| | | if use_time > 1: |
| | | logger_debug.info(f"委托通信耗时:{use_time}") |
| | | except Exception as e: |
| | | logging.exception(e) |
| | |
| | | use_time = (time.time() - msg['time']) * 1000 |
| | | decoded_data, decoded_use_time = L2SharedMemoryDataUtil.get_data(shared_memory) |
| | | print(f"获取到逐笔成交数据: 数据长度:{len(decoded_data)} 通信耗时:{use_time}ms 解码耗时:{decoded_use_time}s") |
| | | if use_time > 0.1: |
| | | if use_time > 1: |
| | | logger_debug.info(f"成交通信耗时:{use_time}") |
| | | except Exception as e: |
| | | logging.exception(e) |