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

error handling

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2020-11-18 13:23:17 +01:00
parent 737a2ce3ac
commit 8c6af80a11
Signed by: wn
GPG Key ID: 6C1E5E531E0D5D7F
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -58,7 +58,8 @@ typedef enum {
MBCS_DONE, MBCS_DONE,
MBCS_TIMEOUT, MBCS_TIMEOUT,
MBCS_DISABLE_FRONTEND, MBCS_DISABLE_FRONTEND,
MBCS_ERROR MBCS_ERROR,
MBCS_ERROR_CONTINUED
} e_mbusCommState; } e_mbusCommState;
typedef struct { typedef struct {
@ -105,6 +106,16 @@ t_mbusCommStats *mbusCommGetStats() {
return &mbusCommStats; return &mbusCommStats;
} }
static void printError(t_mbusCommHandle *localMbusCommHandle) {
float errorRatio = ((float) localMbusCommHandle->device->failures) / ((float) localMbusCommHandle->device->requests);
coloredMsg(LOG_YELLOW, true, "mbc pe [%d] Error ratio is %.2f",
localMbusCommHandle->requestId,
errorRatio);
}
static void parseAndPrintFrame(t_mbusCommHandle *localMbusCommHandle) { static void parseAndPrintFrame(t_mbusCommHandle *localMbusCommHandle) {
t_longframe *frame = &(localMbusCommHandle->frame); t_longframe *frame = &(localMbusCommHandle->frame);
@ -405,6 +416,11 @@ static void handleRequestEngine(void *handle) {
show(LED_RED, ON); show(LED_RED, ON);
coloredMsg(LOG_RED, true, "mbc hre [%d] err: already error, read the rest (now: %02x) until timeout", coloredMsg(LOG_RED, true, "mbc hre [%d] err: already error, read the rest (now: %02x) until timeout",
localMbusCommHandle->requestId, localMbusCommHandle->receivedOctet); localMbusCommHandle->requestId, localMbusCommHandle->receivedOctet);
printError(localMbusCommHandle);
localMbusCommHandle->state = MBCS_ERROR_CONTINUED;
// no break
case MBCS_ERROR_CONTINUED;
receiveNext(localMbusCommHandle); receiveNext(localMbusCommHandle);
break; break;