aiot_mqtt_upload_api.h

浏览该文件的文档.

#ifndef __AIOT_MQTT_UPLOAD_API_H__
#define __AIOT_MQTT_UPLOAD_API_H__

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

#define STATE_MQTT_UPLOAD_BASE (-0x2100)

#define STATE_MQTT_UPLOAD_MQTT_HANDLE_IS_NULL (-0x2101)

#define STATE_MQTT_UPLOAD_FILENAME_IS_NULL (-0x2102)

#define STATE_MQTT_UPLOAD_PARAMS_IS_NULL (-0x2103)

#define STATE_MQTT_UPLOAD_FILE_DATA_IS_NULL (-0x2104)

#define STATE_MQTT_UPLOAD_MQTT_SYSDEP_IS_NULL (-0x2105)

#define STATE_MQTT_UPLOAD_PARSE_INIT_FAILED (-0x2106)

#define STATE_MQTT_UPLOAD_PARSE_UPLOAD_REPLY_FAILED (-0x2107)

#define STATE_MQTT_UPLOAD_PARSE_CANCEL_FAILED (-0x2108)

#define STATE_MQTT_UPLOAD_PARSE_JSON_FAILED (-0x2109)

#define STATE_MQTT_UPLOAD_RECV_FILE_INFO_ERROR (-0x210A)

#define STATE_MQTT_UPLOAD_RECV_UPLOADID_ERROR (-0x210B)

#define STATE_MQTT_UPLOAD_MALLOC_FAILED (-0x210C)

#define STATE_MQTT_UPLOAD_UPTASK_IS_NULL (-0x210D)

#define STATE_MQTT_UPLOAD_UPLOAD_REPLY_ERROR (-0x210E)

#define STATE_MQTT_UPLOAD_HANDLE_DEINIT (-0x210F)

#define STATE_MQTT_UPLOAD_FILE_RESTART_FAILED (-0x2110)

#define STATE_MQTT_UPLOAD_BLOCK_SIZE_ERROR (-0x2111)

#define STATE_MQTT_UPLOAD_READ_DATA_HANDLER_IS_NULL (-0x2112)

#define STATE_MQTT_UPLOAD_HANDLE_INIT (-0x2113)

#define STATE_MQTT_UPLOAD_PROCESS_REPLY_ERROR (-0x2114)

#define STATE_MQTT_UPLOAD_NONE (-0x2115)

#define STATE_MQTT_UPLOAD_REQUEST_INIT (-0x2116)
 
#define STATE_MQTT_UPLOAD_IS_UPLOADING (-0x2117)

#define STATE_MQTT_UPLOAD_REQUEST_CANCEL (-0x2118)

#define STATE_MQTT_UPLOAD_CANCEL_SUCCESS (-0x2119)

#define STATE_MQTT_UPLOAD_CANCEL_FAILED (-0x2120)

#define STATE_MQTT_UPLOAD_FAILED (-0x2121)

#define STATE_MQTT_UPLOAD_FAILED_TIMEOUT (-0x2122)

#define STATE_MQTT_UPLOAD_FAILED_MESSAGE_LIGMIT (-0x2123)

#define STATE_MQTT_UPLOAD_FAILED_WHOLE_CHECK (-0x2124)

#define STATE_MQTT_UPLOAD_FINISHED (-0x2125)

#define STATE_MQTT_UPLOAD_NO_UPLOAD_TASK (-0x2126)

#define STATE_MQTT_UPLOAD_OPEN_INIT_FAILED (-0x2127)

#define AIOT_MQTT_UPLOAD_FILE_MODE_OVERWRITE "overwrite"

#define AIOT_MQTT_UPLOAD_FILE_MODE_APPEND "append"

#define AIOT_MQTT_UPLOAD_FILE_MODE_FAIL "reject"

#define MQTT_UPLOAD_DEFAULT_FILENAME_LEN (128) 

typedef enum {
 UPLOAD_FILE_OK = 200,

 UPLOAD_FILE_FAILED_PAYLOAD_ERROR = 400,

 UPLOAD_FILE_FAILED_QPS_LIMIT = 429,
 
 UPLOAD_FILE_FAILED_PARAMS = 460,

 UPLOAD_FILE_FAILED_SERVER_OTHER = 500,
 
 UPLOAD_FILE_FAILED_MAX_FILESIZE = 78117,

 UPLOAD_FILE_FALED_BLOCK_SIZE_MORE = 78118,

 UPLOAD_FILE_FAILED_OFFSET_UNEQUAL = 78119,

 UPLOAD_FILE_FAILED_BLOCK_SIZE_LESS = 78120,

 UPLOAD_FILE_FAILED_BLOCK_CRC = 78121,

 UPLOAD_FILE_FAILED_NOT_FILE_TASK = 78122,

 UPLOAD_FILE_FAILED_SAME_FILE = 78123,

 UPLOAD_FILE_HAVE_FINISHED = 78124,

 UPLOAD_FILE_FAILED_WHOLE_CHECK = 78125,

 UPLOAD_FILE_FILE_BLOCK_DUPLICATION = 78126,
 
 UPLOAD_FILE_MESSAGE_LIMIT = 78127
 
} aiot_mqtt_upload_result_code_t;

typedef enum {
 AIOT_MQTT_UPLOADRECV_INIT_REPLY,
 AIOT_MQTT_UPLOADRECV_UPLOAD_REPLY,
 AIOT_MQTT_UPLOADRECV_CANCEL_REPLY
} aiot_mqtt_upload_recv_type_t;

typedef struct {
 char *file_name;

 uint32_t file_size;

 char *upload_id;

 uint32_t file_offset; 
 
 uint32_t block_size; 

 aiot_mqtt_upload_result_code_t code;

 char *message;

 uint8_t complete;

} aiot_mqtt_upload_desc_t;

typedef struct {
 aiot_mqtt_upload_recv_type_t type;
 
 aiot_mqtt_upload_desc_t desc;
} aiot_mqtt_upload_recv_t;

typedef enum {

 AIOT_MQTT_UPLOADOPT_MQTT_HANDLE,
 
 AIOT_MQTT_UPLOADOPT_RSP_TIMEOUT_MS,

 AIOT_MQTT_UPLOADOPT_RETRY_COUNT,

 AIOT_MQTT_UPLOADOPT_DEFAULLT_BLOCK_SIZE,
 
 AIOT_MQTT_UPLOADOPT_MAX

} aiot_mqtt_upload_option_t;

typedef struct 
{ 
 int32_t code;

 char file_name[MQTT_UPLOAD_DEFAULT_FILENAME_LEN];

} aiot_mqtt_upload_result_t;


typedef int32_t (*aiot_mqtt_upload_read_handler_t)(const aiot_mqtt_upload_recv_t *packet, uint8_t *data, uint32_t size, void *userdata);

void *aiot_mqtt_upload_init(void);

int32_t aiot_mqtt_upload_setopt(void *handle, aiot_mqtt_upload_option_t option, void *data);

int32_t aiot_mqtt_upload_deinit(void **handle);

int32_t aiot_mqtt_upload_open_stream(void *handle, char *file_name, uint32_t file_size,
 const char *mode, void *digest, aiot_mqtt_upload_read_handler_t read_data_handler, void *userdata);

int32_t aiot_mqtt_upload_cancel_stream(void *handle, char *file_name);

aiot_mqtt_upload_result_t aiot_mqtt_upload_process(void *handle);

#if defined(__cplusplus)
}
#endif

#endif /* __AIOT_MQTT_UPLOAD_API_H__ */