#ifndef _MQTT_H_
|
#define _MQTT_H_
|
|
#include "HIDO_TypeDef.h"
|
#include "HIDO_VLQueue.h"
|
|
#define MQTT_NUM 1
|
|
typedef enum
|
{
|
MQTT_STATE_IDLE = 0,
|
MQTT_STATE_CLOSED,
|
MQTT_STATE_CREATED,
|
MQTT_STATE_CONNECT,
|
MQTT_STATE_CLOSE_BEFORE_CONNECT,
|
MQTT_STATE_CLOSE,
|
MQTT_STATE_CONNECTED,
|
MQTT_STATE_CONNECT_FAILED,
|
} E_MQTTState;
|
|
typedef enum
|
{
|
MQTT_EVENT_CONNECT_FAILED,
|
MQTT_EVENT_CONNECTED,
|
MQTT_EVENT_CLOSED,
|
MQTT_EVENT_RECV_DATA,
|
MQTT_EVENT_DATA_PUBLISHED,
|
} E_MQTTEvent;
|
|
struct SubscribeTopic;
|
typedef struct SubscribeTopic ST_SubscribeTopic;
|
|
struct SubscribeTopic
|
{
|
ST_SubscribeTopic *m_pstNext;
|
HIDO_CHAR m_acTopic[64];
|
HIDO_UINT32 m_u32QOS;
|
};
|
|
typedef struct
|
{
|
HIDO_UINT8 m_u8Version;
|
HIDO_UINT8 m_u8PdpCid;
|
HIDO_UINT8 m_u8CleanSession;
|
HIDO_UINT8 m_u8Reserve;
|
HIDO_UINT32 m_u32PktTimeout;
|
HIDO_UINT32 m_u32RetryTimes;
|
HIDO_UINT32 m_u32KeepAlive;
|
HIDO_CHAR m_acClientID[64];
|
HIDO_CHAR m_acUsername[64];
|
HIDO_CHAR m_acPassword[64];
|
HIDO_CHAR m_acRemoteAddr[42];
|
HIDO_UINT16 m_u16RemotePort;
|
} ST_MQTTConfig;
|
|
typedef struct
|
{
|
HIDO_CHAR m_acTopic[64];
|
HIDO_UINT32 m_u32DataLen;
|
HIDO_UINT32 m_u32QOS;
|
HIDO_UINT32 m_u32Retain;
|
HIDO_UINT8 m_au8Data[4];
|
} ST_MQTTMessage;
|
|
typedef HIDO_VOID (*FN_MQTTEventProc)(HIDO_INT32, E_MQTTEvent, HIDO_VOID *);
|
|
HIDO_INT32 MQTT_HaveRecvData(HIDO_INT32 _i32SockID);
|
HIDO_INT32 MQTT_NoRecvData(HIDO_INT32 _i32SockID);
|
HIDO_BOOL MQTT_HasRecvData(HIDO_INT32 _i32SockID);
|
HIDO_VLQStruct *MQTT_GetRecvQueue(HIDO_INT32 _i32SockID);
|
HIDO_VLQStruct *MQTT_GetSendQueue(HIDO_INT32 _i32SockID);
|
E_MQTTState MQTT_GetMQTTState(HIDO_INT32 _i32SockID);
|
HIDO_INT32 MQTT_SetMQTTState(HIDO_INT32 _i32SockID, E_MQTTState _eState);
|
HIDO_UINT8 MQTT_GetVersion(HIDO_INT32 _i32ClientID);
|
HIDO_UINT8 MQTT_GetPdpCid(HIDO_INT32 _i32ClientID);
|
HIDO_UINT32 MQTT_GetPktTimeout(HIDO_INT32 _i32ClientID);
|
HIDO_UINT32 MQTT_GetRetryTimes(HIDO_INT32 _i32ClientID);
|
HIDO_UINT32 MQTT_GetCleanSession(HIDO_INT32 _i32ClientID);
|
HIDO_UINT32 MQTT_GetKeepAlive(HIDO_INT32 _i32ClientID);
|
HIDO_CHAR *MQTT_GetClientID(HIDO_INT32 _i32ClientID);
|
HIDO_CHAR *MQTT_GetUsername(HIDO_INT32 _i32ClientID);
|
HIDO_CHAR *MQTT_GetmPassword(HIDO_INT32 _i32ClientID);
|
HIDO_CHAR *MQTT_GetRemoteAddr(HIDO_INT32 _i32SockID);
|
HIDO_UINT16 MQTT_GetRemotePort(HIDO_INT32 _i32SockID);
|
HIDO_INT32 MQTT_RecvAll(void);
|
HIDO_INT32 MQTT_ClosedAll(void);
|
HIDO_INT32 MQTT_OnConnectFailed(HIDO_INT32 _i32SockID);
|
HIDO_INT32 MQTT_OnConnected(HIDO_INT32 _i32SockID);
|
HIDO_INT32 MQTT_OnClosed(HIDO_INT32 _i32SockID);
|
HIDO_INT32 MQTT_OnRecv(HIDO_INT32 _i32SockID);
|
HIDO_INT32 MQTT_OnSend(HIDO_INT32 _i32ClientID);
|
HIDO_INT32 MQTT_Create(HIDO_INT32 *_pi32SockID, FN_MQTTEventProc _fnEventProc, HIDO_VOID *_pArg);
|
HIDO_INT32 MQTT_Subscribe(HIDO_INT32 _i32ClientID, HIDO_CHAR *_pcTopic, HIDO_UINT32 _u32QOS);
|
ST_SubscribeTopic *MQTT_GetSubscribeTopicList(HIDO_INT32 _i32ClientID);
|
HIDO_UINT16 MQTT_GetMsgID(HIDO_INT32 _i32ClientID);
|
HIDO_INT32 MQTT_SetMsgID(HIDO_INT32 _i32ClientID, HIDO_UINT16 _u16MsgID);
|
HIDO_INT32 MQTT_Config(HIDO_INT32 _i32ClientID, ST_MQTTConfig *_pstConfig);
|
HIDO_INT32 MQTT_Connect(HIDO_INT32 _i32SockID);
|
HIDO_INT32 MQTT_Close(HIDO_INT32 _i32SockID);
|
HIDO_INT32 MQTT_Publish(HIDO_INT32 _i32ClientID, HIDO_CHAR *_pcTopic, HIDO_UINT8 *_pu8Data, HIDO_UINT32 _u32DataLen, HIDO_UINT32 _u32QOS);
|
HIDO_INT32 MQTT_Recv(HIDO_INT32 _i32ClientID, HIDO_CHAR *_pcTopic, HIDO_UINT8 *_pu8RecvBuff, HIDO_UINT32 _u32RecvBuffSize, HIDO_UINT32 *_u32RecvLen);
|
HIDO_INT32 MQTT_Init(HIDO_VOID);
|
#endif /* _MQTT_H_ */
|
