|
@@ -619,6 +619,8 @@ class SRIConnection(asyncio.Protocol):
|
|
|
|
|
|
|
|
|
|
for item in clients.values():
|
|
for item in clients.values():
|
|
|
|
+ if not item.client_type:
|
|
|
|
+ continue
|
|
if item.client_type == 'cockpit':
|
|
if item.client_type == 'cockpit':
|
|
"""
|
|
"""
|
|
message SCState
|
|
message SCState
|
|
@@ -640,6 +642,10 @@ class SRIConnection(asyncio.Protocol):
|
|
|
|
|
|
|
|
|
|
for item in clients.values():
|
|
for item in clients.values():
|
|
|
|
+ if not item.client_info:
|
|
|
|
+ continue
|
|
|
|
+ if not item.client_info.get('connection_id'):
|
|
|
|
+ continue
|
|
if item.client_info.get('connection_id') == o1.uid:
|
|
if item.client_info.get('connection_id') == o1.uid:
|
|
"""
|
|
"""
|
|
Leave: 消息体
|
|
Leave: 消息体
|