25 #ifndef __MOTR_RPC_INT_H__ 26 #define __MOTR_RPC_INT_H__ 34 #include "rpc/session_fops_xc.h" 38 #include "rpc/onwire_xc.h"
M0_TL_DESCR_DECLARE(item_source, M0_EXTERN)
M0_INTERNAL void m0_rpc_service_stop(struct m0_reqh *reqh)
static struct m0_rpc_item * item
M0_INTERNAL uint64_t m0_rpc_id_generate(const struct m0_fid *uniq_fid)
M0_INTERNAL void m0_rpc_session_module_fini(void)
M0_INTERNAL int m0_rpc__fop_post(struct m0_fop *fop, struct m0_rpc_session *session, const struct m0_rpc_item_ops *ops, m0_time_t abs_timeout)
struct m0_rpc_machine machine
M0_INTERNAL int m0_rpc_session_module_init(void)
M0_TL_DECLARE(item_source, M0_INTERNAL, struct m0_rpc_item_source)
M0_INTERNAL int m0_rpc_service_start(struct m0_reqh *reqh)
struct m0_rpc_session * ri_session
static struct m0_fop * fop
M0_INTERNAL int m0_rpc_item_dispatch(struct m0_rpc_item *item)
M0_INTERNAL void rpc_worker_thread_fn(struct m0_rpc_machine *machine)
M0_INTERNAL void m0_rpc_oneway_item_post_locked(const struct m0_rpc_conn *conn, struct m0_rpc_item *item)
M0_INTERNAL int m0_rpc__post_locked(struct m0_rpc_item *item)
struct m0_rpc_conn * s_conn
static struct m0_rpc_conn * item2conn(const struct m0_rpc_item *item)