martin/aqhomecontrol
Public Access
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

aqhome-tool: flush out message queue after sending FLASH_END

Browse Source
This commit is contained in:
Martin Preuss
2023-04-22 12:47:11 +02:00
parent 317524bd0f
commit c73f671deb
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
apps/aqhome-tool/flash.c
View File

@@ -303,6 +303,12 @@ int _doFlash(GWEN_DB_NODE *dbArgs)
return 4; return 4;
} }
rv=Utils_FlushOutMessageQueue(emgr, epTcp, timeoutInSeconds);
if (rv<0) {
DBG_INFO(NULL, "here (%d)", rv);
GWEN_MsgEndpointMgr_free(emgr);
return 4;
}
GWEN_MsgEndpointMgr_free(emgr); GWEN_MsgEndpointMgr_free(emgr);
return 0; return 0;
@@ -457,6 +463,8 @@ int _sendFlashData(GWEN_MSG_ENDPOINT_MGR *emgr,
GWEN_Text_LogString((const char*) ptr, sendLen, NULL, GWEN_LoggerLevel_Error); GWEN_Text_LogString((const char*) ptr, sendLen, NULL, GWEN_LoggerLevel_Error);
#endif #endif
fprintf(stdout, "Send data: dest addr=%04x, len=%d bytes\n", address, sendLen);
msgNode=AQH_FlashDataMsg_new(0, 0xc1, AQH_MSG_TYPE_FLASH_DATA, address, ptr, sendLen); msgNode=AQH_FlashDataMsg_new(0, 0xc1, AQH_MSG_TYPE_FLASH_DATA, address, ptr, sendLen);
if (msgNode==NULL) { if (msgNode==NULL) {
DBG_ERROR(NULL, "Error creating message"); DBG_ERROR(NULL, "Error creating message");