25 #ifndef __MOTR_RPC_SESSION_INT_H__ 26 #define __MOTR_RPC_SESSION_INT_H__ M0_INTERNAL void m0_rpc_session_fini_locked(struct m0_rpc_session *session)
static struct io_request req
static struct m0_rpc_item * item
M0_INTERNAL bool m0_rpc_session_invariant(const struct m0_rpc_session *session)
M0_INTERNAL void session_state_set(struct m0_rpc_session *session, int state)
M0_INTERNAL void m0_rpc_session_hold_busy(struct m0_rpc_session *session)
M0_INTERNAL void m0_rpc_session_item_failed(struct m0_rpc_item *item)
M0_INTERNAL int session_state(const struct m0_rpc_session *session)
M0_INTERNAL struct m0_rpc_machine * session_machine(const struct m0_rpc_session *s)
M0_TL_DECLARE(rpc_session, M0_INTERNAL, struct m0_rpc_session)
M0_INTERNAL void m0_rpc_session_establish_reply_received(struct m0_rpc_item *item)
M0_TL_DESCR_DECLARE(rpc_session, M0_EXTERN)
M0_INTERNAL int m0_rpc_session_init_locked(struct m0_rpc_session *session, struct m0_rpc_conn *conn)
M0_INTERNAL bool m0_rpc_session_is_idle(const struct m0_rpc_session *session)
M0_INTERNAL void m0_rpc_session_terminate_reply_received(struct m0_rpc_item *item)
M0_INTERNAL int m0_rpc_rcv_session_terminate(struct m0_rpc_session *session)
static struct m0_addb2_source * s
M0_INTERNAL void m0_rpc_session_release(struct m0_rpc_session *session)