Selaa lähdekoodia

add:添加mqtt设置自动重连函数

Dozingfiretruck 1 vuosi sitten
vanhempi
sitoutus
512cc7345c

+ 9 - 0
components/network/libemqtt/luat_mqtt.h

@@ -186,6 +186,15 @@ int luat_mqtt_set_rxbuff_size(luat_mqtt_ctrl_t *mqtt_ctrl, uint32_t rxbuff_size)
  */
 int luat_mqtt_set_keepalive(luat_mqtt_ctrl_t *mqtt_ctrl, uint32_t keepalive);
 
+/**
+ *@brief 设置MQTT服务器 是否自动重连
+ *@param mqtt_ctrl luatos_mqtt对象实例
+ *@param auto_connect 是否自动重连
+ *@param reconnect_time 自动重连时间 单位ms
+ *@return 成功为0,其他值失败
+ */
+int luat_mqtt_set_auto_connect(luat_mqtt_ctrl_t *mqtt_ctrl, uint8_t auto_connect,uint32_t reconnect_time);
+
 /**
  *@brief 手动发起重连
  *@param mqtt_ctrl luatos_mqtt对象实例

+ 6 - 0
components/network/libemqtt/luat_mqtt_client.c

@@ -103,6 +103,12 @@ int luat_mqtt_set_keepalive(luat_mqtt_ctrl_t *mqtt_ctrl, uint32_t keepalive){
     return 0;
 }
 
+int luat_mqtt_set_auto_connect(luat_mqtt_ctrl_t *mqtt_ctrl, uint8_t auto_connect,uint32_t reconnect_time){
+    mqtt_ctrl->reconnect = auto_connect;
+    mqtt_ctrl->reconnect_time = reconnect_time;
+    return 0;
+}
+
 int luat_mqtt_set_connopts(luat_mqtt_ctrl_t *mqtt_ctrl, luat_mqtt_connopts_t *opts) {
     memcpy(mqtt_ctrl->host, opts->host, strlen(opts->host) + 1);
     mqtt_ctrl->remote_port = opts->port;