23 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_RPC 44 .
sd_name =
"m0_rpc_fom_sess_conn_term_phases init",
49 .sd_name =
"m0_rpc_fom_sess_conn_term_phases wait",
54 .sd_name =
"m0_rpc_fom_sess_conn_term_phases done",
60 .
scf_name =
"rpc_fom_session_terminate fom",
150 .
name =
"Rpc conn establish",
152 .
xt = m0_rpc_fop_conn_establish_xc,
159 .
name =
"Rpc conn terminate",
161 .
xt = m0_rpc_fop_conn_terminate_xc,
167 .
name =
"Rpc session establish",
169 .
xt = m0_rpc_fop_session_establish_xc,
175 .
name =
"Rpc session terminate",
177 .
xt = m0_rpc_fop_session_terminate_xc,
183 .
name =
"Rpc conn establish reply",
185 .
xt = m0_rpc_fop_conn_establish_rep_xc,
189 .
name =
"Rpc conn terminate reply",
191 .
xt = m0_rpc_fop_conn_terminate_rep_xc,
195 .
name =
"Rpc session establish reply",
197 .
xt = m0_rpc_fop_session_establish_rep_xc,
201 .
name =
"Rpc session terminate reply",
203 .
xt = m0_rpc_fop_session_terminate_rep_xc,
223 ctx->cec_sender_ep =
ep;
struct m0_fop_type m0_rpc_fop_session_terminate_rep_fopt
static void conn_establish_fop_release(struct m0_ref *ref)
static struct buffer * cur(struct m0_addb2_mach *mach, m0_bcount_t space)
#define M0_FOP_TYPE_INIT(ft,...)
M0_INTERNAL void m0_fop_init(struct m0_fop *fop, struct m0_fop_type *fopt, void *data, void(*fop_release)(struct m0_ref *))
struct m0_fom_type_ops m0_rpc_fom_session_establish_type_ops
struct m0_fop_type m0_rpc_fop_session_establish_rep_fopt
M0_INTERNAL int m0_rpc_session_fop_init(void)
void m0_fop_type_fini(struct m0_fop_type *fopt)
M0_INTERNAL void m0_rpc_session_fop_fini(void)
struct m0_fom_type_ops m0_rpc_fom_session_terminate_type_ops
#define container_of(ptr, type, member)
static struct m0_xcode_type ** xt[]
const struct m0_sm_conf m0_generic_conf
static struct m0_rpc_item * item
static const struct m0_reqh_service_ops rpc_ops
return M0_ERR(-EOPNOTSUPP)
M0_INTERNAL void m0_rpc_fop_conn_establish_ctx_init(struct m0_rpc_item *item, struct m0_net_end_point *ep)
struct m0_fom_type_ops m0_rpc_fom_conn_establish_type_ops
struct m0_fom_type_ops m0_rpc_fom_conn_terminate_type_ops
static struct m0_rpc_item_type_ops conn_establish_item_type_ops
M0_INTERNAL const struct m0_sm_conf m0_rpc_fom_sess_conn_term_phases_sm_conf
static int conn_establish_item_decode(const struct m0_rpc_item_type *item_type, struct m0_rpc_item **item, struct m0_bufvec_cursor *cur)
struct m0_reqh_service_type m0_rpc_service_type
M0_INTERNAL void m0_net_end_point_get(struct m0_net_end_point *ep)
M0_INTERNAL void m0_fop_fini(struct m0_fop *fop)
static struct fdmi_ctx ctx
void m0_net_end_point_put(struct m0_net_end_point *ep)
M0_INTERNAL int m0_fop_item_encdec(struct m0_rpc_item *item, struct m0_bufvec_cursor *cur, enum m0_xcode_what what)
struct m0_fop_type m0_rpc_fop_conn_terminate_fopt
struct m0_fop_type m0_rpc_fop_session_establish_fopt
struct m0_fop_type m0_rpc_fop_conn_establish_rep_fopt
#define M0_ALLOC_PTR(ptr)
static struct m0_fop * fop
static struct m0_sm_state_descr m0_rpc_fom_sess_conn_term_phases[]
struct m0_fop_type m0_rpc_fop_session_terminate_fopt
struct m0_rpc_item f_item
struct m0_fop_type m0_rpc_fop_conn_establish_fopt
#define M0_FOP_DEFAULT_ITEM_TYPE_OPS
struct m0_fop_type m0_rpc_fop_conn_terminate_rep_fopt