wn/mbusgateway3variant
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

more receiving

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2020-11-02 17:06:12 +01:00
parent 31a34068ad
commit 3e47fc60e5
Signed by: wn
GPG Key ID: 6C1E5E531E0D5D7F
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cube/User/Src/mbusComm.c
View File

@ -24,11 +24,12 @@ typedef struct {
uint8_t cmd; uint8_t cmd;
uint8_t addr; uint8_t addr;
uint8_t sendBuf[5]; uint8_t sendBuf[5];
uint8_t receiveCnt;
uint8_t receivedOctet; uint8_t receivedOctet;
bool receiving; bool receiving;
} t_mbusCommHandle; } 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); static void handleRequestEngine(void *handle);
@ -87,6 +88,7 @@ static void handleRequestEngine(void *handle) {
schAdd(timeoutHandler, handle, 500, 0); // 500ms timeout schAdd(timeoutHandler, handle, 500, 0); // 500ms timeout
localMbusCommHandle->state = RECEIVING; localMbusCommHandle->state = RECEIVING;
localMbusCommHandle->receiving = false; localMbusCommHandle->receiving = false;
localMbusCommHandle->receiveCnt = 0;
// no break // no break
case RECEIVING: case RECEIVING:
@ -96,7 +98,8 @@ static void handleRequestEngine(void *handle) {
HAL_UART_Receive_IT(&mbusUart, &(localMbusCommHandle->receivedOctet), 1); HAL_UART_Receive_IT(&mbusUart, &(localMbusCommHandle->receivedOctet), 1);
} else { } else {
localMbusCommHandle->receiving = false; 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); schAdd(handleRequestEngine, handle, 0, 0);
} }
break; break;