mirror/lwip
1
0
Fork 0
mirror of https://github.com/lwip-tcpip/lwip.git synced 2024-11-19 23:12:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

mqtt: allow calling mqtt_set_inpub_callback before mqtt_client_connect

Browse Source 
See also patch #10037
This commit is contained in:
Simon Goldschmidt 2021-03-04 20:14:46 +01:00
parent 600e248f06
commit d7a0757764
2 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/apps/mqtt/mqtt.c
View File

@ -1295,6 +1295,9 @@ mqtt_client_connect(mqtt_client_t *client, const ip_addr_t *ip_addr, u16_t port,
u16_t remaining_length = 2 + 4 + 1 + 1 + 2; u16_t remaining_length = 2 + 4 + 1 + 1 + 2;
u8_t flags = 0, will_topic_len = 0, will_msg_len = 0; u8_t flags = 0, will_topic_len = 0, will_msg_len = 0;
u16_t client_user_len = 0, client_pass_len = 0; u16_t client_user_len = 0, client_pass_len = 0;
mqtt_incoming_data_cb_t data_cb;
mqtt_incoming_publish_cb_t pub_cb;
void *inpub_arg;
LWIP_ASSERT_CORE_LOCKED(); LWIP_ASSERT_CORE_LOCKED();
LWIP_ASSERT("mqtt_client_connect: client != NULL", client != NULL); LWIP_ASSERT("mqtt_client_connect: client != NULL", client != NULL);
@ -1307,8 +1310,15 @@ mqtt_client_connect(mqtt_client_t *client, const ip_addr_t *ip_addr, u16_t port,
return ERR_ISCONN; return ERR_ISCONN;
} }
/* Wipe clean */ /* Wipe clean, but keep callbacks */
data_cb = client->data_cb;
pub_cb = client->pub_cb;
inpub_arg = client->inpub_arg;
memset(client, 0, sizeof(mqtt_client_t)); memset(client, 0, sizeof(mqtt_client_t));
client->data_cb = data_cb;
client->pub_cb = pub_cb;
client->inpub_arg = inpub_arg;
client->connect_arg = arg; client->connect_arg = arg;
client->connect_cb = cb; client->connect_cb = cb;
client->keep_alive = client_info->keep_alive; client->keep_alive = client_info->keep_alive;

2
src/include/lwip/apps/mqtt.h
View File

@ -183,7 +183,7 @@ void mqtt_client_free(mqtt_client_t* client);
u8_t mqtt_client_is_connected(mqtt_client_t *client); u8_t mqtt_client_is_connected(mqtt_client_t *client);
void mqtt_set_inpub_callback(mqtt_client_t *client, mqtt_incoming_publish_cb_t, void mqtt_set_inpub_callback(mqtt_client_t *client, mqtt_incoming_publish_cb_t pub_cb,
mqtt_incoming_data_cb_t data_cb, void *arg); mqtt_incoming_data_cb_t data_cb, void *arg);
err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub); err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub);