|
|
@ -125,7 +125,7 @@ public class A8kCanBusConnection extends WebSocketClient { |
|
|
|
} |
|
|
|
|
|
|
|
@Override public void onMessage(String s) { |
|
|
|
log.debug("RX-RAW: {}", s); |
|
|
|
log.trace("RX-RAW: {}", s); |
|
|
|
processCanRxMessage(s); |
|
|
|
} |
|
|
|
|
|
|
@ -259,7 +259,7 @@ public class A8kCanBusConnection extends WebSocketClient { |
|
|
|
|
|
|
|
// TX packet |
|
|
|
String txpacket = pack.toByteString(); |
|
|
|
log.debug("TX-RAW: {} | {}", txpacket, pack); |
|
|
|
log.trace("TX-RAW: {} | {}", txpacket, pack); |
|
|
|
send(txpacket); |
|
|
|
|
|
|
|
|
|
|
@ -310,10 +310,10 @@ public class A8kCanBusConnection extends WebSocketClient { |
|
|
|
|
|
|
|
|
|
|
|
if (packet.getPacketType() == A8kPacket.PACKET_TYPE_ACK || packet.getPacketType() == A8kPacket.PACKET_TYPE_ERROR_ACK) { |
|
|
|
log.debug("RX-ACK |RAW:{}| {}", s, packet); |
|
|
|
log.trace("RX-ACK |RAW:{}| {}", s, packet); |
|
|
|
context.pushReceipt(packet); |
|
|
|
} else if (packet.getPacketType() == A8kPacket.PACKET_TYPE_EVENT) { |
|
|
|
log.debug("RX-REPORT |RAW:{}| {}", s, packet); |
|
|
|
log.trace("RX-REPORT |RAW:{}| {}", s, packet); |
|
|
|
// eventBus.pushEvent(new A8kHardwareReport(packet)); |
|
|
|
} else { |
|
|
|
log.warn("RX-UNPROCESSABLE: |RAW:{}| {}", s, packet); |
|
|
|