|
|
@@ -265,7 +265,7 @@ class SRIConnection(asyncio.Protocol):
|
|
|
Robot.rid: int32
|
|
|
Robot.name: string
|
|
|
Robot.type: int32
|
|
|
- Robot.state: RobotState Offline Online Busy
|
|
|
+ Robot.state: RobotState Offline 离线 Online 在线 Busy 忙线
|
|
|
"""
|
|
|
o1 = protobuf.Robot()
|
|
|
# o1.rid = self.client_info.get('rid')
|
|
|
@@ -408,7 +408,7 @@ class SRIConnection(asyncio.Protocol):
|
|
|
|
|
|
# --- send 4009 指定车端
|
|
|
for item in clients.values():
|
|
|
- if item.client_info.get('local_connection_id') == o1.peer:
|
|
|
+ if item.client_info and item.client_info.get('local_connection_id') == o1.peer:
|
|
|
"""
|
|
|
CSReq: 消息体
|
|
|
CSReq.peer: int32（rid，车端唯一标识）
|
|
|
@@ -716,7 +716,6 @@ class SRIConnection(asyncio.Protocol):
|
|
|
"""
|
|
|
"""
|
|
|
while True:
|
|
|
-
|
|
|
try:
|
|
|
# --- define ---
|
|
|
loop = asyncio.get_running_loop()
|
|
|
@@ -730,13 +729,13 @@ class SRIConnection(asyncio.Protocol):
|
|
|
print(f"Connection_e1:713|Server listening on 0.0.0.0:{Global.egoserver_port}", flush=True)
|
|
|
# await loop.create_task(Connection_e1:.check_clients())
|
|
|
await server.serve_forever()
|
|
|
-
|
|
|
except Exception as exception:
|
|
|
|
|
|
methods.debug_log("Connection_e1:735", f"exception: {exception.__class__.__name__}")
|
|
|
methods.debug_log("Connection_e1:735", f"traceback: {traceback.format_exc()}")
|
|
|
methods.debug_log('Connection_e1:735', f"wait 10s try again!")
|
|
|
- time.sleep(10)
|
|
|
+ await asyncio.sleep(10)
|
|
|
+
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
asyncio.run(SRIConnection.run())
|
Casper