[adas]修复ADAS订阅和取消订阅列表数据错误

This commit is contained in:
xinfengkun
2023-05-24 15:02:46 +08:00
parent 151db9ab54
commit 0bf23dbe1c
2 changed files with 9 additions and 5 deletions

View File

@@ -21,13 +21,13 @@ public class M1StitchedVideoMessage extends MyAbstractMessageHandler {
int len = raw.getPackageLengthValue() - raw.getOffsetValue();
byte[] data = new byte[len];
System.arraycopy(raw.originalData.toByteArray(), raw.getOffsetValue(), data, 0, len);
AdasChannel.calculateTimeConsumingOnDispatchRaw("M1StitchedVideoMessage", raw.receiveTime);
AdasChannel.calculateTimeConsumingOnDispatchRaw("M1拼接视频", raw.receiveTime);
long nowTime = 0;
if (CupidLogUtils.isEnableLog())
nowTime = SystemClock.elapsedRealtime();
if (adasListener != null) {
adasListener.onM1StitchedVideo(raw.getHeader(), data);
}
AdasChannel.calculateTimeConsumingBusiness("M1StitchedVideoMessage", nowTime);
AdasChannel.calculateTimeConsumingBusiness("M1拼接视频", nowTime);
}
}

View File

@@ -138,9 +138,13 @@ public class SubscribeInterface {
MessageType[] types = MessageType.values();
if (types.length > 0) {
for (MessageType messageType : types) {
//连接成功后只有M1拼接视频接收接口默认不进行订阅其他接收接口默认自动订阅
if (messageType != MessageType.TYPE_RECEIVE_M1_STITCHED_VIDEO && messageType.name().toLowerCase().contains("type_receive")) {
subscribedInterface.put(messageType, messageType.typeCode.getNumber());
if (messageType.name().toLowerCase().contains("type_receive")) {
//连接成功后只有M1拼接视频接收接口默认不进行订阅其他接收接口默认自动订阅
if (messageType == MessageType.TYPE_RECEIVE_M1_STITCHED_VIDEO) {
unsubscribedInterface.put(messageType, messageType.typeCode.getNumber());
} else {
subscribedInterface.put(messageType, messageType.typeCode.getNumber());
}
}
}
}