Lines Matching refs:rpc_t
20 } rpc_t;
29 int rpc_init(rpc_t *rpc, int cmd_id, int timeout_ms);
46 void rpc_put_reset(rpc_t *rpc);
54 int rpc_put_int(rpc_t *rpc, int v);
55 int rpc_put_uint8(rpc_t *rpc, uint8_t v);
56 int rpc_put_double(rpc_t *rpc, double v);
57 int rpc_put_point(rpc_t *rpc, const void *v);
58 int rpc_put_buffer(rpc_t *rpc, const void *data, size_t size);
59 int rpc_put_string(rpc_t *rpc, char *str);
71 void rpc_get_reset(rpc_t *rpc);
79 int rpc_get_int(rpc_t *rpc);
80 uint8_t rpc_get_uint8(rpc_t *rpc);
81 double rpc_get_double(rpc_t *rpc);
82 char *rpc_get_string(rpc_t *rpc);
83 void *rpc_get_point(rpc_t *rpc);
84 void *rpc_get_buffer(rpc_t *rpc, int *count);
93 void rpc_reply(rpc_t *rpc);
102 void rpc_deinit(rpc_t *rpc);
135 typedef int (*process_t)(void *context, rpc_t *rpc);
179 int uservice_call(uservice_t *srv, rpc_t *rpc);
182 使用自定义 rpc 实现微服务的命令调用，该命令可以通过 rpc_t 实现同步、异步、超时调用，也可以用 rpc_put_xxx 函数，向 rpc 中传入多个参数。服务器也可以通过 rpc 返回多个…
212 static void process_rpc(void *context, rpc_t *rpc)
362 rpc_t *current_cmd;
363 rpc_t *current_oob;
385 static int process_rpc(void *context, rpc_t *rpc)