|
|
@ -739,17 +739,14 @@ public class A8kCanBusService { |
|
|
|
receipt = receiptQueue.poll(overtime, TimeUnit.MILLISECONDS); |
|
|
|
} catch (InterruptedException e) { |
|
|
|
isWaitingReceipt = false; |
|
|
|
// throw new AppException(MId.valueOf(pack.getModuleId()), A8kEcode.Overtime.index); |
|
|
|
throw AppException.of(new HardwareError(A8kEcode.Overtime, MId.valueOf(pack.getModuleId()), CmdId.valueOf(pack.getCmdId()))); |
|
|
|
} |
|
|
|
isWaitingReceipt = false; |
|
|
|
if (receipt == null) { |
|
|
|
// throw new AppException(MId.valueOf(pack.getModuleId()), A8kEcode.Overtime.index); |
|
|
|
throw AppException.of(new HardwareError(A8kEcode.Overtime, MId.valueOf(pack.getModuleId()), CmdId.valueOf(pack.getCmdId()))); |
|
|
|
} |
|
|
|
|
|
|
|
if (receipt.getPacketType() == A8kPacket.PACKET_TYPE_ERROR_ACK) { |
|
|
|
// throw new AppException(MId.valueOf(pack.getModuleId()), (receipt.getContentI32(0))); |
|
|
|
throw AppException.of(new HardwareError(A8kEcode.fromInt(receipt.getContentI32(0)), |
|
|
|
MId.valueOf(pack.getModuleId()), |
|
|
|
CmdId.valueOf(pack.getCmdId()))); |
|
|
|