Link Kit C-SDK  4.0.0
| 宏定义 | 类型定义 | 枚举 | 函数
aiot_mqtt_upload_api.h 文件参考

MQTT UPLOAD模块头文件, 提供通过mqtt进行文件上传的能力 更多...

浏览源代码.

struct  aiot_mqtt_upload_desc_t
 接收到的服务端应答消息的报文信息 更多...
 
struct  aiot_mqtt_upload_recv_t
 MQTT UPLOAD模块收到服务端应答的报文信息, 通知用户的报文内容 更多...
 
struct  aiot_mqtt_upload_result_t
 aiot_mqtt_upload_process 循环处理,返回对应文件的上传状态给到用户 更多...
 

宏定义

#define STATE_MQTT_UPLOAD_BASE   (-0x2100)
 -0x2100~-0x21FF表达SDK在mqtt_upload模块内的状态码 更多...
 
#define STATE_MQTT_UPLOAD_MQTT_HANDLE_IS_NULL   (-0x2101)
 MQTT UPLOAD Handle 为空 更多...
 
#define STATE_MQTT_UPLOAD_FILENAME_IS_NULL   (-0x2102)
 MQTT UPLOAD 请求上传文件时,文件名是空的 更多...
 
#define STATE_MQTT_UPLOAD_PARAMS_IS_NULL   (-0x2103)
 MQTT UPLOAD PUB到服务端的时候参数为空 更多...
 
#define STATE_MQTT_UPLOAD_FILE_DATA_IS_NULL   (-0x2104)
 MQTT UPLOAD上传文件数据为空 更多...
 
#define STATE_MQTT_UPLOAD_MQTT_SYSDEP_IS_NULL   (-0x2105)
 MQTT portfile是空的 更多...
 
#define STATE_MQTT_UPLOAD_PARSE_INIT_FAILED   (-0x2106)
 MQTT UPLOAD 解析服务端初始化应答的Json数据失败 更多...
 
#define STATE_MQTT_UPLOAD_PARSE_UPLOAD_REPLY_FAILED   (-0x2107)
 MQTT UPLOAD 解析服务端文件数据上传应答的Json数据失败 更多...
 
#define STATE_MQTT_UPLOAD_PARSE_CANCEL_FAILED   (-0x2108)
 MQTT UPLOAD 解析服务端取消应答的Json数据失败 更多...
 
#define STATE_MQTT_UPLOAD_PARSE_JSON_FAILED   (-0x2109)
 MQTT UPLOAD 解析服务端应答的Json数据失败 更多...
 
#define STATE_MQTT_UPLOAD_RECV_FILE_INFO_ERROR   (-0x210A)
 MQTT UPLOAD 接收到的服务端应答文件信息不对 更多...
 
#define STATE_MQTT_UPLOAD_RECV_UPLOADID_ERROR   (-0x210B)
 MQTT UPLOAD uploadId不匹配或者设备端为初始化请求 更多...
 
#define STATE_MQTT_UPLOAD_MALLOC_FAILED   (-0x210C)
 MQTT UPLOAD malloc失败 更多...
 
#define STATE_MQTT_UPLOAD_UPTASK_IS_NULL   (-0x210D)
 MQTT UPLOAD 初始化文件upload的句柄时失败 更多...
 
#define STATE_MQTT_UPLOAD_UPLOAD_REPLY_ERROR   (-0x210E)
 MQTT UPLOAD 收到服务端应答的文件上传的偏移量和分包大小错误,与上次上传的不相同 更多...
 
#define STATE_MQTT_UPLOAD_HANDLE_DEINIT   (-0x210F)
 MQTT UPLOAD 反初始化 更多...
 
#define STATE_MQTT_UPLOAD_FILE_RESTART_FAILED   (-0x2110)
 重新启动文件上传失败 更多...
 
#define STATE_MQTT_UPLOAD_BLOCK_SIZE_ERROR   (-0x2111)
 MQTT UPLOAD 配置分包上传的大小错误,不在256~128K范围内,继续保持默认的2K. 更多...
 
#define STATE_MQTT_UPLOAD_READ_DATA_HANDLER_IS_NULL   (-0x2112)
 MQTT UPLOAD 请求文件上传,回调函数为空 更多...
 
#define STATE_MQTT_UPLOAD_HANDLE_INIT   (-0x2113)
 MQTT UPLOAD 初始化 更多...
 
#define STATE_MQTT_UPLOAD_PROCESS_REPLY_ERROR   (-0x2114)
 MQTT UPLOAD 处理服务端应答的回调时失败 更多...
 
#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)
 文件上传,取消上传任务成功,取消成功后会销毁对应的upload task释放内存资源 更多...
 
#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)
 文件上传过程中,消息限流可以重新调用aiot_mqtt_upload_open_stream 使用AIOT_MQTT_UPLOAD_FILE_MODE_APPEND 更多...
 
#define STATE_MQTT_UPLOAD_FAILED_WHOLE_CHECK   (-0x2124)
 文件完整性校验失败 更多...
 
#define STATE_MQTT_UPLOAD_FINISHED   (-0x2125)
 已经完成文件上传的任务,完成文件上传后会销毁对应的upload task释放内存资源 更多...
 
#define STATE_MQTT_UPLOAD_NO_UPLOAD_TASK   (-0x2126)
 没有文件上传任务,无法执行取消操作 更多...
 
#define STATE_MQTT_UPLOAD_OPEN_INIT_FAILED   (-0x2127)
 请求初始化失败,请求参数错误或重复请求 更多...
 
#define AIOT_MQTT_UPLOAD_FILE_MODE_OVERWRITE   "overwrite"
 同名的文件的处理策略 overwrite: 覆盖模式,服务端删除之前的同名文件,原有文件无法找回 更多...
 
#define AIOT_MQTT_UPLOAD_FILE_MODE_APPEND   "append"
 同名的文件的处理策略 append:文件追加模式 有同名文件未完成上传:在服务端文件未完成上传的情况下,云端返回当前已上传文件的信息,以便设备端继续上传后续的文件内 容,未完成的文件云端保留24H,超过24小时后删除未完成的文件,下次请求时重新建立 有同名已完成上传:返回错误码 UPLOAD_FILE_FAILED_SAME_FILE ,请求上传失败 无同名文件:服务端新建文件信息 更多...
 
#define AIOT_MQTT_UPLOAD_FILE_MODE_FAIL   "reject"
 同名的文件的处理策略 reject: 拒绝模式,服务端返回文件已经存在不能再次上传的错误码 UPLOAD_FILE_FAILED_SAME_FILE 更多...
 
#define MQTT_UPLOAD_DEFAULT_FILENAME_LEN   (128)
 MQTT上传文件名的最大长度 更多...
 

类型定义

typedef int32_t(* aiot_mqtt_upload_read_handler_t) (const aiot_mqtt_upload_recv_t *packet, uint8_t *data, uint32_t size, void *userdata)
 回调函数读取用户的本地文件或内存数据不能在回调函数中执行 aiot_mqtt_upload_open_streamaiot_mqtt_upload_cancel_stream 多个文件同时请求上传时,可以使用不同的回调函数,也可以使用同一个回调函数用户根据file_name区分对应的文件或内存区 更多...
 

枚举

enum  aiot_mqtt_upload_result_code_t {
  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
}
 请求文件上传和文件传输过程中的服务端返回的文件信息 更多...
 
enum  aiot_mqtt_upload_recv_type_t { AIOT_MQTT_UPLOADRECV_INIT_REPLY, AIOT_MQTT_UPLOADRECV_UPLOAD_REPLY, AIOT_MQTT_UPLOADRECV_CANCEL_REPLY }
 MQTT UPLOAD模块收到从服务端应答的报文类型 更多...
 
enum  aiot_mqtt_upload_option_t {
  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_setopt 接口的option参数可选值. 更多...
 

函数

void * aiot_mqtt_upload_init (void)
 创建MQTT UPLOAD会话实例, 并以默认值配置会话参数 更多...
 
int32_t aiot_mqtt_upload_setopt (void *handle, aiot_mqtt_upload_option_t option, void *data)
 配置MQTT UPLOAD会话 更多...
 
int32_t aiot_mqtt_upload_deinit (void **handle)
 结束MQTT UPLOAD会话, 销毁实例并回收资源 更多...
 
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)
 向MQTT UPLOAD 服务请求发送文件 更多...
 
int32_t aiot_mqtt_upload_cancel_stream (void *handle, char *file_name)
 向mqtt_upload服务器请求关闭MQTT通道数据上传命令 更多...
 
aiot_mqtt_upload_result_t aiot_mqtt_upload_process (void *handle)
 MQTT Upload 处理函数,处理超时和重发逻辑,返回对应文件的执行的状态 更多...
 

详细描述

MQTT UPLOAD模块头文件, 提供通过mqtt进行文件上传的能力

宏定义说明

#define STATE_MQTT_UPLOAD_BASE   (-0x2100)

-0x2100~-0x21FF表达SDK在mqtt_upload模块内的状态码

#define STATE_MQTT_UPLOAD_MQTT_HANDLE_IS_NULL   (-0x2101)

MQTT UPLOAD Handle 为空

#define STATE_MQTT_UPLOAD_FILENAME_IS_NULL   (-0x2102)

MQTT UPLOAD 请求上传文件时,文件名是空的

#define STATE_MQTT_UPLOAD_PARAMS_IS_NULL   (-0x2103)

MQTT UPLOAD PUB到服务端的时候参数为空

#define STATE_MQTT_UPLOAD_FILE_DATA_IS_NULL   (-0x2104)

MQTT UPLOAD上传文件数据为空

#define STATE_MQTT_UPLOAD_MQTT_SYSDEP_IS_NULL   (-0x2105)

MQTT portfile是空的

#define STATE_MQTT_UPLOAD_PARSE_INIT_FAILED   (-0x2106)

MQTT UPLOAD 解析服务端初始化应答的Json数据失败

#define STATE_MQTT_UPLOAD_PARSE_UPLOAD_REPLY_FAILED   (-0x2107)

MQTT UPLOAD 解析服务端文件数据上传应答的Json数据失败

#define STATE_MQTT_UPLOAD_PARSE_CANCEL_FAILED   (-0x2108)

MQTT UPLOAD 解析服务端取消应答的Json数据失败

#define STATE_MQTT_UPLOAD_PARSE_JSON_FAILED   (-0x2109)

MQTT UPLOAD 解析服务端应答的Json数据失败

#define STATE_MQTT_UPLOAD_RECV_FILE_INFO_ERROR   (-0x210A)

MQTT UPLOAD 接收到的服务端应答文件信息不对

#define STATE_MQTT_UPLOAD_RECV_UPLOADID_ERROR   (-0x210B)

MQTT UPLOAD uploadId不匹配或者设备端为初始化请求

#define STATE_MQTT_UPLOAD_MALLOC_FAILED   (-0x210C)

MQTT UPLOAD malloc失败

#define STATE_MQTT_UPLOAD_UPTASK_IS_NULL   (-0x210D)

MQTT UPLOAD 初始化文件upload的句柄时失败

#define STATE_MQTT_UPLOAD_UPLOAD_REPLY_ERROR   (-0x210E)

MQTT UPLOAD 收到服务端应答的文件上传的偏移量和分包大小错误,与上次上传的不相同

#define STATE_MQTT_UPLOAD_HANDLE_DEINIT   (-0x210F)

MQTT UPLOAD 反初始化

#define STATE_MQTT_UPLOAD_FILE_RESTART_FAILED   (-0x2110)

重新启动文件上传失败

#define STATE_MQTT_UPLOAD_BLOCK_SIZE_ERROR   (-0x2111)

MQTT UPLOAD 配置分包上传的大小错误,不在256~128K范围内,继续保持默认的2K.

#define STATE_MQTT_UPLOAD_READ_DATA_HANDLER_IS_NULL   (-0x2112)

MQTT UPLOAD 请求文件上传,回调函数为空

#define STATE_MQTT_UPLOAD_HANDLE_INIT   (-0x2113)

MQTT UPLOAD 初始化

#define STATE_MQTT_UPLOAD_PROCESS_REPLY_ERROR   (-0x2114)

MQTT UPLOAD 处理服务端应答的回调时失败

#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)

文件上传,取消上传任务成功,取消成功后会销毁对应的upload task释放内存资源

#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)

文件上传过程中,消息限流可以重新调用aiot_mqtt_upload_open_stream 使用AIOT_MQTT_UPLOAD_FILE_MODE_APPEND

#define STATE_MQTT_UPLOAD_FAILED_WHOLE_CHECK   (-0x2124)

文件完整性校验失败

#define STATE_MQTT_UPLOAD_FINISHED   (-0x2125)

已经完成文件上传的任务,完成文件上传后会销毁对应的upload task释放内存资源

#define STATE_MQTT_UPLOAD_NO_UPLOAD_TASK   (-0x2126)

没有文件上传任务,无法执行取消操作

#define STATE_MQTT_UPLOAD_OPEN_INIT_FAILED   (-0x2127)

请求初始化失败,请求参数错误或重复请求

#define AIOT_MQTT_UPLOAD_FILE_MODE_OVERWRITE   "overwrite"

同名的文件的处理策略 overwrite: 覆盖模式,服务端删除之前的同名文件,原有文件无法找回

#define AIOT_MQTT_UPLOAD_FILE_MODE_APPEND   "append"

同名的文件的处理策略 append:文件追加模式 有同名文件未完成上传:在服务端文件未完成上传的情况下,云端返回当前已上传文件的信息,以便设备端继续上传后续的文件内 容,未完成的文件云端保留24H,超过24小时后删除未完成的文件,下次请求时重新建立 有同名已完成上传:返回错误码 UPLOAD_FILE_FAILED_SAME_FILE ,请求上传失败 无同名文件:服务端新建文件信息

#define AIOT_MQTT_UPLOAD_FILE_MODE_FAIL   "reject"

同名的文件的处理策略 reject: 拒绝模式,服务端返回文件已经存在不能再次上传的错误码 UPLOAD_FILE_FAILED_SAME_FILE

#define MQTT_UPLOAD_DEFAULT_FILENAME_LEN   (128)

MQTT上传文件名的最大长度

类型定义说明

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

回调函数读取用户的本地文件或内存数据不能在回调函数中执行 aiot_mqtt_upload_open_streamaiot_mqtt_upload_cancel_stream 多个文件同时请求上传时,可以使用不同的回调函数,也可以使用同一个回调函数用户根据file_name区分对应的文件或内存区

参数
[in]packet服务端的应答报文,包含应答的状态和错误信息,更多信息参考 aiot_mqtt_upload_recv_t
[in]data指向用于接收用户数据的缓冲块的指针
[in]size数据缓冲区大小, 此大小在发送过程中会变化
[in]userdata指向用户上下文的指针
返回
int32_t
返回值
用户实际拷贝到buf中的数据长度

枚举类型说明

请求文件上传和文件传输过程中的服务端返回的文件信息

枚举值
UPLOAD_FILE_OK 

文件上传正常

UPLOAD_FILE_FAILED_PAYLOAD_ERROR 

请求上传的payload格式非法,无法解析其中的json格式数据

UPLOAD_FILE_FAILED_QPS_LIMIT 

文件上传被限流

UPLOAD_FILE_FAILED_PARAMS 

文件上传请求参数错误

UPLOAD_FILE_FAILED_SERVER_OTHER 

服务端其他异常

UPLOAD_FILE_FAILED_MAX_FILESIZE 

申请使用mqtt协议上传文件时,文件大小超过阈值16M

UPLOAD_FILE_FALED_BLOCK_SIZE_MORE 

设备上传文件分片时,分片大小超过阈值128KB

UPLOAD_FILE_FAILED_OFFSET_UNEQUAL 

设备上传文件分片时,当前分片的offset与已上传至的服务端文件大小不一致

UPLOAD_FILE_FAILED_BLOCK_SIZE_LESS 

设备上传文件分片时,当前分片的大小小于最小阈值,除最后一片文件外,传输过程中分片大小不得小于256Byte

UPLOAD_FILE_FAILED_BLOCK_CRC 

设备上传文件分片时,当前分片的CRC校验失败,SDK内会自动对当前分片进行重传

UPLOAD_FILE_FAILED_NOT_FILE_TASK 

上传文件的任务不存在,用户需要发起新的上传请求调用 aiot_mqtt_upload_open_stream

UPLOAD_FILE_FAILED_SAME_FILE 

同名文件已经存在,在追加模式 AIOT_MQTT_UPLOAD_FILE_MODE_APPEND 和拒绝模式 AIOT_MQTT_UPLOAD_FILE_MODE_FAIL 下会返回该错误码

UPLOAD_FILE_HAVE_FINISHED 

文件上传任务已经完成,通知用户对应的文件上传已经完成,销毁对应的upload task释放内存资源

UPLOAD_FILE_FAILED_WHOLE_CHECK 

文件完整性校验失败,在调用 aiot_mqtt_upload_open_stream 时,如果传入 degist参数服务端会对文件完整性进行校验,传入NULL时云端不校验

UPLOAD_FILE_FILE_BLOCK_DUPLICATION 

重传或网络断开造成文件写入重复,忽略

UPLOAD_FILE_MESSAGE_LIMIT 

文件上传过程中,消息限流

MQTT UPLOAD模块收到从服务端应答的报文类型

枚举值
AIOT_MQTT_UPLOADRECV_INIT_REPLY 

收到的服务端应答请求初始化时的报文信息,通过回调函数反馈给用户

AIOT_MQTT_UPLOADRECV_UPLOAD_REPLY 

收到的服务端应答上传分片文件时的应答报文消息,通过回调反馈给用户,同时也会调用回调获取下一段分片文件

AIOT_MQTT_UPLOADRECV_CANCEL_REPLY 

收到的服务端应答取消上传的报文应答

aiot_mqtt_upload_setopt 接口的option参数可选值.

下文每个选项中的数据类型, 指的是aiot_mqtt_upload_setopt 中, data参数的数据类型

枚举值
AIOT_MQTT_UPLOADOPT_MQTT_HANDLE 

关联MQTT Handle会话,UPLOAD过程中使用MQTT的通道能力, 用以向服务端请求上传、发送分片文件、请求关闭通道

AIOT_MQTT_UPLOADOPT_RSP_TIMEOUT_MS 

MQTT UPLOAD会话发送消息时,超时重发的最长时间间隔, 数据类型为(uint32_t *)

AIOT_MQTT_UPLOADOPT_RETRY_COUNT 

配置MQTT文件上传单包发送超时时候的重试次数, 数据类型为(uint32_t *)

AIOT_MQTT_UPLOADOPT_DEFAULLT_BLOCK_SIZE 

配置文件上传的分片长度,默认是2048byte, 数据类型为(uint32_t *)

AIOT_MQTT_UPLOADOPT_MAX 

设置MQTT的最大值,设置失败

函数说明

void* aiot_mqtt_upload_init ( void  )

创建MQTT UPLOAD会话实例, 并以默认值配置会话参数

返回
void *
返回值
非NULL,返回mqtt_upload_handle_t实例的句柄
NULL初始化失败, 一般是内存分配失败导致

函数调用图:

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

配置MQTT UPLOAD会话

参数
[in]handleMQTT UPLOAD会话句柄
[in]option配置选项, 更多信息请参考 aiot_mqtt_upload_option_t
[in]data配置选项数据, 更多信息请参考 aiot_mqtt_upload_option_t
返回
int32_t
返回值
STATE_SUCCESS参数配置成功
STATE_USER_INPUT_NULL_POINTER入参handle或data为NULL
STATE_USER_INPUT_OUT_RANGE入参optioin的枚举值>=AIOT_DMOPT_MAX
others参考 aiot_state_api.h

函数调用图:

int32_t aiot_mqtt_upload_deinit ( void **  handle)

结束MQTT UPLOAD会话, 销毁实例并回收资源

参数
[in]handle指向MQTT UPLOAD会话句柄的指针
返回
int32_t
返回值
<STATE_SUCCESS执行失败
>=STATE_SUCCESS执行成功

函数调用图:

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 
)

向MQTT UPLOAD 服务请求发送文件

参数
[in]handleMQTT UPLOAD会话句柄
[in]file_name需要在服务端创建的文件名
[in]file_size需要上传的文件大小
[in]mode同名的文件的处理策略, 更多信息请参考 AIOT_MQTT_UPLOAD_FILE_MODE_OVERWRITE AIOT_MQTT_UPLOAD_FILE_MODE_APPEND AIOT_MQTT_UPLOAD_FILE_MODE_FAIL
[in]digest文件完整的CRC64,不需要完整性校验则为NULL
[in]read_data_handler读取用户文件数据的回调函数, 更多信息请参考 aiot_mqtt_upload_read_handler_t
[in]userdata用户上下文
返回
int32_t
返回值
<STATE_SUCCESS请求发送失败
>=STATE_SUCCESS请求发送成功
others参考aiot_state_api.hSTATE_MQTT_UPLOAD_BASE 中对应的错误码说明
注解

函数调用图:

int32_t aiot_mqtt_upload_cancel_stream ( void *  handle,
char *  file_name 
)

向mqtt_upload服务器请求关闭MQTT通道数据上传命令

参数
[in]handleMQTT UPLOAD会话句柄
[in]file_name需要取消继续上传的文件名
返回
int32_t
返回值
<STATE_SUCCESS请求发送失败
>=STATE_SUCCESS请求发送成功
others参考aiot_state_api.hSTATE_MQTT_UPLOAD_BASE 中对应的错误码说明

函数调用图:

aiot_mqtt_upload_result_t aiot_mqtt_upload_process ( void *  handle)

MQTT Upload 处理函数,处理超时和重发逻辑,返回对应文件的执行的状态

参数
[in]handleMQTT UPLOAD 会话句柄
返回
aiot_mqtt_upload_result_t 返回消息包括两个code, file_name; 更多信息请参考 aiot_mqtt_upload_result_t
返回值
STATE_MQTT_UPLOAD_NONE无任何状态,未开始进行文件上传的处理
STATE_MQTT_UPLOAD_REQUEST_INIT请求服务端进行文件上传,等待服务端返回结果
STATE_MQTT_UPLOAD_IS_UPLOADING正在执行文件上传任务
STATE_MQTT_UPLOAD_REQUEST_CANCEL通知服务端取消文件上传
STATE_MQTT_UPLOAD_CANCEL_SUCCESS文件上传,取消上传任务成功,取消成功后会销毁对应的upload task释放内存资源
STATE_MQTT_UPLOAD_CANCEL_FAILED文件上传,取消上传任务失败
STATE_MQTT_UPLOAD_FAILED文件上传失败
STATE_MQTT_UPLOAD_FAILED_TIMEOUT文件上传超时失败
STATE_MQTT_UPLOAD_FAILED_WHOLE_CHECK文件完整性校验失败
STATE_MQTT_UPLOAD_FINISHED已经完成文件上传的任务,完成文件上传后会销毁对应的upload task释放内存资源

函数调用图: