25 #ifndef __MOTR_RPC_ITEM_INT_H__ 26 #define __MOTR_RPC_ITEM_INT_H__ M0_INTERNAL void m0_rpc_item_change_state(struct m0_rpc_item *item, enum m0_rpc_item_state state)
M0_INTERNAL int m0_rpc_item_timer_start(struct m0_rpc_item *item)
static struct io_request req
M0_INTERNAL void m0_rpc_item_replied_invoke(struct m0_rpc_item *req)
M0_INTERNAL int m0_rpc_item_module_init(void)
M0_INTERNAL void m0_rpc_item_failed(struct m0_rpc_item *item, int32_t rc)
M0_INTERNAL const char * item_kind(const struct m0_rpc_item *item)
static struct m0_rpc_item * item
M0_INTERNAL void m0_rpc_item_sm_fini(struct m0_rpc_item *item)
M0_INTERNAL bool m0_rpc_item_is_request(const struct m0_rpc_item *item)
M0_INTERNAL void m0_rpc_item_send_reply(struct m0_rpc_item *req, struct m0_rpc_item *reply)
M0_INTERNAL void m0_rpc_item_timer_stop(struct m0_rpc_item *item)
M0_INTERNAL void m0_rpc_item_process_reply(struct m0_rpc_item *req, struct m0_rpc_item *reply)
M0_INTERNAL void m0_rpc_item_module_fini(void)
M0_INTERNAL void m0_rpc_item_sm_init(struct m0_rpc_item *item, enum m0_rpc_item_dir dir)
M0_INTERNAL bool m0_rpc_item_is_oneway(const struct m0_rpc_item *item)
M0_INTERNAL void m0_rpc_item_send(struct m0_rpc_item *item)
M0_INTERNAL void m0_rpc_item_ha_timer_stop(struct m0_rpc_item *item)
M0_INTERNAL bool m0_rpc_item_is_update(const struct m0_rpc_item *item)
struct m0_rpc_machine machine
M0_INTERNAL bool m0_rpc_item_is_reply(const struct m0_rpc_item *item)
M0_INTERNAL void m0_rpc_item_xid_min_update(struct m0_rpc_item *item)
M0_INTERNAL void m0_rpc_item_sent_invoke(struct m0_rpc_item *item)
M0_INTERNAL void m0_rpc_item_xid_assign(struct m0_rpc_item *item)
static struct m0_dtm_oper_descr reply
M0_INTERNAL int m0_rpc_item_received(struct m0_rpc_item *item, struct m0_rpc_machine *machine)
M0_INTERNAL const char * item_state_name(const struct m0_rpc_item *item)