| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091 |
- #ifndef MQTT_H
- #define MQTT_H
- #include "plt.h"
- struct mqtt_t
- {
- int dbg;
- MQTTClient cli;
- int enable;
- char szservip[32];
- int servport;
- char szclientid[150];
- char szaccesstoken[64];
- char szusername[64];
- char szpasswd[64];
- char sztopic[128];
- int timezone;
- int connlost;
- int conncnt;
- MQTTClient_deliveryToken token;
- MQTTClient_connectOptions conn_opts;
- int cmd;
- double txbuf_usage; /* 0-100 */
- double rxbuf_usage; /* 0-100 */
- double pub_starttime;
- double pub_endtime;
- double pub_totaltime; //
- double pub_totalcnt;
- double pub_max;
- double pub_ave;
- int pub_failed; // 当前连续失败了多少次
- double pub_totalFailcnt; // 总共失败了多少次
- double pub_maxFailcnt; // 连续失败多少次
- // int tick;
- struct statemachine_t sm;
- struct comm_t comm;
- };
- extern struct mqtt_t mqtt;
- int mqtt_init(void);
- int mqtt_set_state(int state, int errcode);
- int mqtt_get_state();
- int mqtt_send_sm_cmd(int cmd);
- int mqtt_get_cmd();
- void mqtt_reset_cmd();
- void mqtt_lock_txbuf();
- void mqtt_unlock_txbuf();
- int mqtt_get_rb_used(void);
- int mqtt_get_rb_size(void);
- void mqtt_init_txbuf();
- void mqtt_lock_txbuf();
- void mqtt_unlock_txbuf();
- void mqtt_queue_txbuf(mqtt_ringbuffer_element_t data);
- int mqtt_dequeue_txbuf(mqtt_ringbuffer_element_t *data);
- int mqtt_peek_txbuf(mqtt_ringbuffer_element_t *data, mqtt_ringbuffer_size_t index);
- int mqtt_get_txbuf_used(void);
- int mqtt_get_txbuf_size(void);
- void mqtt_init_rxbuf();
- void mqtt_lock_rxbuf();
- void mqtt_unlock_rxbuf();
- void mqtt_queue_rxbuf(mqtt_ringbuffer_element_t data);
- int mqtt_dequeue_rxbuf(mqtt_ringbuffer_element_t *data);
- int mqtt_peek_rxbuf(mqtt_ringbuffer_element_t *data, mqtt_ringbuffer_size_t index);
- int mqtt_get_rxbuf_used(void);
- int mqtt_get_rxbuf_size(void);
- int mqtt_connect(void);
- int mqtt_pub(char *sztopic, char *szpayload);
- int mqtt_get_tz();
- char *mqtt_get_state_str(void);
- int mqtt_get_stp(void);
- char *mqtt_get_err_str(void);
- int mqtt_get_tick(void);
- double mqtt_get_timing_ave(void);
- double mqtt_get_timing_cur(void);
- double mqtt_get_timing_max(void);
- int mqtt_get_enable(void);
- char *mqtt_get_servip_str(void);
- int mqtt_get_servport(void);
- char *mqtt_get_client_id(void);
- double mqtt_get_txbuf_usage(void);
- char *mqtt_get_access_token(void);
- int mqtt_get_tool_data(char *buf);
- int mqtt_set_dbg(int val);
- #endif /* MQTT_H */
|
