rpc_base.h

浏览该文件的文档.

 
#ifndef __RPC_BASE_H__
#define __RPC_BASE_H__
 
/*============================ INCLUDES ======================================*/
 
#include "tuya_slist.h"
#include "tal_workq_service.h"
#include "tal_sw_timer.h"
#include "tal_mutex.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
/*============================ MACROS ========================================*/
/*============================ TYPES =========================================*/
typedef int (*rpc_send_cb)(char *addr,  uint8_t *data, uint32_t data_len, void *priv_data);
typedef int (*rpc_reply_cb)(char *addr, uint8_t *data, uint32_t data_len, void *priv_data, uint8_t *fuck_key);
 
typedef int (*rpc_recv_cb)(char *addr,  uint8_t *data, uint32_t data_len, void *priv_data, uint16_t sequence);
 
 
typedef struct {
    rpc_send_cb         send_cb;
    rpc_recv_cb         request_cb;
    rpc_recv_cb         notify_cb;
    void               *priv_data;
} rpc_base_cfg_t;
 
typedef struct {
    void              *data;
    uint32_t           data_len;
    uint16_t           timeout;
    rpc_reply_cb       reply_cb;
    char              *addr;
    void              *priv_data;
    uint8_t           *fuck_key;
} rpc_msg_t;
 
typedef struct {
    MUTEX_HANDLE        mutex;
    uint16_t            sequence;
    rpc_send_cb         send_cb;
    rpc_recv_cb         request_cb;
    rpc_recv_cb         notify_cb;
    rpc_recv_cb         pipe_cb;
    TIMER_ID            async_timer;
    MUTEX_HANDLE        async_mutex;
    SLIST_HEAD          async_list;
    void               *priv_data;
} rpc_base_t;
 
/*============================ PROTOTYPES ====================================*/
int rpc_base_init(rpc_base_t *base, rpc_base_cfg_t *cfg);
 
int rpc_base_request(rpc_base_t *base, rpc_msg_t *msg);
 
int rpc_base_notify(rpc_base_t  *base, rpc_msg_t *msg);
 
int rpc_base_reply(rpc_base_t *base, rpc_msg_t *msg, uint16_t sequence);
 
 
int rpc_base_frame_process(rpc_base_t     *base,
                           char           *addr,
                           uint8_t        *frame,
                           uint32_t        frame_len,
                           uint8_t        *fuck_key);
#ifdef __cplusplus
}
#endif
 
#endif