|
TuyaOS
|
Common process - base rpc 更多...
#include "tuya_slist.h"#include "tal_workq_service.h"#include "tal_sw_timer.h"#include "tal_mutex.h"

结构体 | |
| struct | rpc_base_t |
类型定义 | |
| typedef int(* | rpc_recv_cb) (char *addr, uint8_t *data, uint32_t data_len, void *priv_data, uint16_t sequence) |
| rpc received callback 更多... | |
| typedef int(* | rpc_reply_cb) (char *addr, uint8_t *data, uint32_t data_len, void *priv_data, uint8_t *fuck_key) |
| rpc reply callback 更多... | |
| typedef int(* | rpc_send_cb) (char *addr, uint8_t *data, uint32_t data_len, void *priv_data) |
| rpc send callback 更多... | |
函数 | |
| int | rpc_base_frame_process (rpc_base_t *base, char *addr, uint8_t *frame, uint32_t frame_len, uint8_t *fuck_key) |
| rpc base reply 更多... | |
| int | rpc_base_init (rpc_base_t *base, rpc_base_cfg_t *cfg) |
| rpc base init 更多... | |
| int | rpc_base_notify (rpc_base_t *base, rpc_msg_t *msg) |
| rpc base notify 更多... | |
| int | rpc_base_reply (rpc_base_t *base, rpc_msg_t *msg, uint16_t sequence) |
| rpc base reply 更多... | |
| int | rpc_base_request (rpc_base_t *base, rpc_msg_t *msg) |
| rpc base request 更多... | |
Common process - base rpc
| typedef int(* rpc_recv_cb) (char *addr, uint8_t *data, uint32_t data_len, void *priv_data, uint16_t sequence) |
rpc received callback
| [in] | addr | peer addr |
| [in] | data | received data |
| [in] | data_len | received length |
| [in] | priv_data | user private data |
| [in] | sequence | sequence |
| typedef int(* rpc_reply_cb) (char *addr, uint8_t *data, uint32_t data_len, void *priv_data, uint8_t *fuck_key) |
rpc reply callback
| [in] | addr | peer addr, if NULL means timeout |
| [out] | data | received data |
| [out] | data_len | received length |
| [in] | priv_data | user private data |
| [in] | fuck_key | fast useful channel key |
| typedef int(* rpc_send_cb) (char *addr, uint8_t *data, uint32_t data_len, void *priv_data) |
rpc send callback
| [in] | addr | peer addr |
| [in] | data | send data |
| [in] | len | send length |
| [in] | priv_data | user private data |
| int rpc_base_frame_process | ( | rpc_base_t * | base, |
| char * | addr, | ||
| uint8_t * | frame, | ||
| uint32_t | frame_len, | ||
| uint8_t * | fuck_key | ||
| ) |
rpc base reply
| [in] | base | handle |
| [in] | addr | peer addr |
| [in] | frame | received frame data |
| [in] | frame_len | received frame len |
| [in] | fuck_key | fast useful channel key |
| int rpc_base_init | ( | rpc_base_t * | base, |
| rpc_base_cfg_t * | cfg | ||
| ) |
rpc base init
| [in] | base | handle |
| [in] | cfg | refer to rpc_base_cfg_t struct |
| int rpc_base_notify | ( | rpc_base_t * | base, |
| rpc_msg_t * | msg | ||
| ) |
rpc base notify
| [in] | base | handle |
| [in] | cfg | refer to rpc_base_cfg_t struct |
| int rpc_base_reply | ( | rpc_base_t * | base, |
| rpc_msg_t * | msg, | ||
| uint16_t | sequence | ||
| ) |
rpc base reply
| [in] | base | handle |
| [in] | cfg | refer to rpc_base_cfg_t struct |
| [in] | sequence | sequence |
| int rpc_base_request | ( | rpc_base_t * | base, |
| rpc_msg_t * | msg | ||
| ) |
rpc base request
| [in] | base | handle |
| [in] | msg | refer to rpc_msg_t struct |