37 #ifndef __MOTR_RPC_RPCCORE_H__ 38 #define __MOTR_RPC_RPCCORE_H__ 132 M0_INTERNAL uint32_t
m0_rpc_bufs_nr(uint32_t len, uint32_t tms_nr);
M0_INTERNAL uint32_t m0_rpc_max_segs_nr(struct m0_net_domain *ndom)
M0_INTERNAL int m0_rpc_post(struct m0_rpc_item *item)
M0_INTERNAL void m0_rpc_oneway_item_post(const struct m0_rpc_conn *conn, struct m0_rpc_item *item)
static struct m0_net_buffer_pool app_pool
M0_INTERNAL uint32_t m0_rpc_max_recv_msgs(struct m0_net_domain *ndom, m0_bcount_t rpc_size)
M0_INTERNAL m0_time_t m0_rpc__down_timeout(void)
static struct m0_rpc_item * item
M0_INTERNAL m0_bcount_t m0_rpc_max_msg_size(struct m0_net_domain *ndom, m0_bcount_t rpc_size)
M0_INTERNAL int m0_rpc_net_buffer_pool_setup(struct m0_net_domain *ndom, struct m0_net_buffer_pool *app_pool, uint32_t bufs_nr, uint32_t tm_nr)
M0_INTERNAL uint32_t m0_rpc_bufs_nr(uint32_t len, uint32_t tms_nr)
void m0_rpc_reply_post(struct m0_rpc_item *request, struct m0_rpc_item *reply)
M0_INTERNAL int m0_rpc_init(void)
M0_INTERNAL void m0_rpc_fini(void)
void m0_rpc_net_buffer_pool_cleanup(struct m0_net_buffer_pool *app_pool)
static struct m0_dtm_oper_descr reply
M0_INTERNAL m0_bcount_t m0_rpc_max_seg_size(struct m0_net_domain *ndom)