mirror/OpenBK7231T_App
3
0
Fork 0
mirror of https://github.com/openshwprojects/OpenBK7231T_App.git synced 2026-02-05 02:25:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #35 from btsimonh/mods

Browse Source 
fix setting valus from mqtt
This commit is contained in:
openshwprojects
2022-02-23 03:17:39 +01:00
committed by GitHub
parent cde4839927 9d8633d0a9
commit 83485c2c7e
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/mqtt/new_mqtt.c
View File

@ -101,13 +101,18 @@ int g_incoming_channel_mqtt = 0;
static void mqtt_incoming_data_cb(void *arg, const u8_t *data, u16_t len, u8_t flags)
{
int iValue;
char copy[128];
// unused - left here as example
//const struct mqtt_connect_client_info_t* client_info = (const struct mqtt_connect_client_info_t*)arg;
//PR_NOTICE("MQTT client in mqtt_incoming_data_cb\n");
PR_NOTICE("MQTT client in mqtt_incoming_data_cb data is %s for ch %i\n",data,g_incoming_channel_mqtt);
strncpy(copy, (char *)data, len);
// strncpy does not terminate??!!!!
copy[len] = '\0';
iValue = atoi((char *)data);
//PR_NOTICE("MQTT client in mqtt_incoming_data_cb\n");
PR_NOTICE("MQTT client in mqtt_incoming_data_cb data is %s for ch %i\n", copy, g_incoming_channel_mqtt);
iValue = atoi((char *)copy);
CHANNEL_Set(g_incoming_channel_mqtt,iValue,0);
// PR_NOTICE(("MQTT client \"%s\" data cb: len %d, flags %d\n", client_info->client_id, (int)len, (int)flags));