#ifndef _MQTT_MANAGER_H | |
#define _MQTT_MANAGER_H | |
#include "lynq_mqtt/lynq_mqtt.h" | |
#include "thread_pool.h" | |
#include "list.h" | |
#include "common.h" | |
typedef struct | |
{ | |
struct list_head list; | |
struct mqtt_set_parament data; | |
}MQTT_LIST_LINK_S; | |
void mqtt_list_init(); | |
int mqtt_param_verification(char result[][BUF_SIZE] , int line); | |
int mqtt_list_locate(); | |
int mqtt_act_handler(thread_pool_t *pool); | |
#endif | |