espressif/esp-mqtt
1
0
Fork 1
mirror of https://github.com/espressif/esp-mqtt.git synced 2025-08-03 04:35:15 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #24 from StudioSophisti/master

Browse Source 
Allow non-string lwt message
This commit is contained in:
Tuan
2018-02-27 23:00:43 +07:00
committed by GitHub
parent a8c78d5cbf 7322fc79e9
commit fbf592dec3
3 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
include/mqtt_client.h
View File

@@ -67,6 +67,7 @@ typedef struct {
char lwt_msg[MQTT_MAX_LWT_MSG]; char lwt_msg[MQTT_MAX_LWT_MSG];
int lwt_qos; int lwt_qos;
int lwt_retain; int lwt_retain;
int lwt_msg_len;
int disable_clean_session; int disable_clean_session;
int keepalive; int keepalive;
bool disable_auto_reconnect; bool disable_auto_reconnect;

4
include/mqtt_config.h
View File

@@ -12,9 +12,9 @@
#define MQTT_MAX_HOST_LEN 64 #define MQTT_MAX_HOST_LEN 64
#define MQTT_MAX_CLIENT_LEN 32 #define MQTT_MAX_CLIENT_LEN 32
#define MQTT_MAX_USERNAME_LEN 32 #define MQTT_MAX_USERNAME_LEN 32
#define MQTT_MAX_PASSWORD_LEN 32 #define MQTT_MAX_PASSWORD_LEN 65
#define MQTT_MAX_LWT_TOPIC 32 #define MQTT_MAX_LWT_TOPIC 32
#define MQTT_MAX_LWT_MSG 32 #define MQTT_MAX_LWT_MSG 128
#define MQTT_TASK_PRIORITY 5 #define MQTT_TASK_PRIORITY 5
#define MQTT_TASK_STACK (6*1024) #define MQTT_TASK_STACK (6*1024)
#define MQTT_KEEPALIVE_TICK (120) #define MQTT_KEEPALIVE_TICK (120)

7
mqtt_client.c
View File

@@ -127,7 +127,12 @@ static esp_err_t esp_mqtt_set_config(esp_mqtt_client_handle_t client, const esp_
if (config->lwt_msg[0]) { if (config->lwt_msg[0]) {
client->connect_info.will_message = strdup(config->lwt_msg); client->connect_info.will_message = strdup(config->lwt_msg);
client->connect_info.will_length = strlen(config->lwt_msg); if (config->lwt_msg_len > 0) {
client->connect_info.will_length = config->lwt_msg_len;
}
else {
client->connect_info.will_length = strlen(config->lwt_msg);
}
} }
client->connect_info.will_qos = config->lwt_qos; client->connect_info.will_qos = config->lwt_qos;