aiot_compress_api.h

浏览该文件的文档.

#ifndef __AIOT_COMPRESS_API_H__
#define __AIOT_COMPRESS_API_H__

#if defined(__cplusplus)
extern "C" {
#endif

#include <stdint.h>

/* TODO: 这一段列出compress模块使用的状态码, 每个状态码需要有doxygen的brief说明, 每个码之间有1个空行隔开 */
#define STATE_COMPRESS_BASE                                             (-0x2200)

#define STATE_COMPRESS_LEVEL_INVALID                                    (-0x2201)

#define STATE_COMPRESS_COMPR_FAILED                                     (-0x2202)

#define STATE_COMPRESS_DECOMPR_FAILED                                   (-0x2203)

#define STATE_COMPRESS_APPEND_REPEATED                                  (-0x2204)

typedef enum {
    AIOT_COMPRESS_UPDATE_REPLY
} aiot_compress_recv_type_t;

typedef struct {
    aiot_compress_recv_type_t  type;
    union {
        struct {
            uint32_t code;
            char *message;
            uint32_t message_len;
        } update_reply;
    } data;
} aiot_compress_recv_t;

typedef void (* aiot_compress_recv_handler_t)(void *handle,
        const aiot_compress_recv_t *packet, void *userdata);

typedef enum {
    AIOT_COMPRESSOPT_MQTT_HANDLE,

    AIOT_COMPRESSOPT_LEVEL,

    AIOT_COMPRESSOPT_APPEND_COMPR_TOPIC,

    AIOT_COMPRESSOPT_APPEND_DECOMPR_TOPIC,

    AIOT_COMPRESSOPT_RECV_HANDLER,

    AIOT_COMPRESSOPT_USERDATA,

    AIOT_COMPRESSOPT_MAX,
} aiot_compress_option_t;

void *aiot_compress_init(void);

int32_t aiot_compress_setopt(void *handle, aiot_compress_option_t option, void *data);

int32_t aiot_compress_deinit(void **handle);


int32_t aiot_compress_topiclist_update(void *handle);

#if defined(__cplusplus)
}
#endif

#endif  /* __AIOT_COMPRESS_API_H__ */