diff --git a/cube/User/Src/mbusComm.c b/cube/User/Src/mbusComm.c index 1777e49..87cebdf 100644 --- a/cube/User/Src/mbusComm.c +++ b/cube/User/Src/mbusComm.c @@ -24,11 +24,12 @@ typedef struct { uint8_t cmd; uint8_t addr; uint8_t sendBuf[5]; + uint8_t receiveCnt; uint8_t receivedOctet; bool receiving; } t_mbusCommHandle; -static t_mbusCommHandle mbusCommHandle = { .state = IDLE, .retryCnt = 0, .cmd = 0, .addr = 0, .receivedOctet = 0, .receiving = false }; +static t_mbusCommHandle mbusCommHandle = { .state = IDLE, .retryCnt = 0, .cmd = 0, .addr = 0, .receiveCnt = 0, .receivedOctet = 0, .receiving = false }; static void handleRequestEngine(void *handle); @@ -87,6 +88,7 @@ static void handleRequestEngine(void *handle) { schAdd(timeoutHandler, handle, 500, 0); // 500ms timeout localMbusCommHandle->state = RECEIVING; localMbusCommHandle->receiving = false; + localMbusCommHandle->receiveCnt = 0; // no break case RECEIVING: @@ -96,7 +98,8 @@ static void handleRequestEngine(void *handle) { HAL_UART_Receive_IT(&mbusUart, &(localMbusCommHandle->receivedOctet), 1); } else { localMbusCommHandle->receiving = false; - logMsg("hre received octet: 0x%02x", localMbusCommHandle->receivedOctet); + logMsg("hre received octet: 0x%02x: 0x%02x", localMbusCommHandle->receiveCnt, localMbusCommHandle->receivedOctet); + localMbusCommHandle->cnt += 1; schAdd(handleRequestEngine, handle, 0, 0); } break;