修复了两个bug,详见readme

This commit is contained in:
2024-07-01 19:06:18 +08:00
parent ad4b6ae8d6
commit 4e4d760db4
4 changed files with 35 additions and 9 deletions

View File

@ -139,11 +139,6 @@ def run_rl(hr, w2t):
{"name": "device_servo_trq_feedback", "channel": 4},
{"name": "device_servo_trq_feedback", "channel": 5},
{"name": "device_safety_estop", "channel": 0},
{"name": "device_safety_estop", "channel": 0},
{"name": "device_safety_estop", "channel": 0},
{"name": "device_safety_estop", "channel": 0},
{"name": "device_safety_estop", "channel": 0},
{"name": "device_safety_estop", "channel": 0},
]
_response = execution('diagnosis.set_params', hr, w2t, display_pdo_params=display_pdo_params)
print(f"执行采样: {_response}")

View File

@ -1,4 +1,4 @@
from json import load, dumps
from json import load, dumps, loads
from socket import socket, setdefaulttimeout, AF_INET, SOCK_STREAM
from threading import Thread
import selectors
@ -108,7 +108,7 @@ class HmiRequest(object):
sleep(2)
# with open(f"{current_path}/../../assets/templates/c_msg.log", "w", encoding='utf-8') as f:
# for msg in self.c_msg:
# f.write(msg + '\n')
# f.write(str(loads(msg)) + '\n')
def msg_storage(self, response, flag=0):
messages = self.c_msg if flag == 0 else self.c_msg_xs
@ -215,13 +215,14 @@ class HmiRequest(object):
print(f"in flag=0 else index = {self.index}")
print(f"in flag=0 else pkg size = {self.pkg_size}")
print(f"in flag=0 else leftover = {self.leftover}")
break
# break
elif self.flag == 1:
# 继续处理之前为接收完的数据处理完之后将flag重置为0
# !!!需要注意的是,包头/帧头也是有可能被分割开的!!!但是目前该程序未实现此种情况!!!
if self.broke == 1:
self.index = 0
self.leftover = int.from_bytes(self.half, byteorder='big')
self.broke = 0
print(f"broke 1 leftover: {self.leftover}")
elif self.broke == 2:
self.leftover = int.from_bytes(self.half+data[:1], byteorder='big')