| rjw | 1f88458 | 2022-01-06 17:20:42 +0800 | [diff] [blame^] | 1 | #ifndef _MQTT_MANAGER_H |
| 2 | #define _MQTT_MANAGER_H | ||||
| 3 | |||||
| 4 | #include "lynq_mqtt/lynq_mqtt.h" | ||||
| 5 | #include "thread_pool.h" | ||||
| 6 | #include "list.h" | ||||
| 7 | #include "common.h" | ||||
| 8 | |||||
| 9 | |||||
| 10 | |||||
| 11 | typedef struct | ||||
| 12 | { | ||||
| 13 | struct list_head list; | ||||
| 14 | struct mqtt_set_parament data; | ||||
| 15 | }MQTT_LIST_LINK_S; | ||||
| 16 | |||||
| 17 | |||||
| 18 | void mqtt_list_init(); | ||||
| 19 | int mqtt_param_verification(char result[][BUF_SIZE] , int line); | ||||
| 20 | int mqtt_list_locate(); | ||||
| 21 | int mqtt_act_handler(thread_pool_t *pool); | ||||
| 22 | |||||
| 23 | |||||
| 24 | #endif | ||||
| 25 | |||||