Lines Matching defs:p_txn
54 IN osmv_txn_ctx_t * p_txn, IN uint64_t key);
71 osmv_txn_ctx_t *p_txn;
82 p_txn = malloc(sizeof(osmv_txn_ctx_t));
83 if (!p_txn) {
87 memset(p_txn, 0, sizeof(osmv_txn_ctx_t));
88 p_txn->p_log = p_bo->txn_mgr.p_log;
89 p_txn->tid = tid;
90 p_txn->key = key;
91 p_txn->p_madw = NULL;
92 p_txn->rmpp_txfr.rmpp_state = OSMV_TXN_RMPP_NONE;
95 st = __osmv_txnmgr_insert_txn(&p_bo->txn_mgr, p_txn, key);
105 *pp_txn = p_txn;
110 free(p_txn);
118 IN osmv_txn_ctx_t * p_txn, IN osm_madw_t * p_madw)
122 CL_ASSERT(p_txn);
125 osmv_txn_remove_timeout_ev(h_bind, osmv_txn_get_key(p_txn));
127 p_txn->rmpp_txfr.rmpp_state = OSMV_TXN_RMPP_SENDER;
128 p_txn->rmpp_txfr.p_rmpp_send_ctx = malloc(sizeof(osmv_rmpp_send_ctx_t));
130 if (!p_txn->rmpp_txfr.p_rmpp_send_ctx) {
134 memset(p_txn->rmpp_txfr.p_rmpp_send_ctx, 0,
137 st = osmv_rmpp_send_ctx_init(p_txn->rmpp_txfr.p_rmpp_send_ctx,
139 p_madw->mad_size, p_txn->p_log);
145 IN osmv_txn_ctx_t * p_txn,
150 uint64_t key = osmv_txn_get_key(p_txn);
152 CL_ASSERT(p_txn);
165 p_txn->rmpp_txfr.rmpp_state = OSMV_TXN_RMPP_RECEIVER;
166 p_txn->rmpp_txfr.is_rmpp_init_by_peer = is_init_by_peer;
168 p_txn->rmpp_txfr.p_rmpp_recv_ctx = malloc(sizeof(osmv_rmpp_recv_ctx_t));
170 if (!p_txn->rmpp_txfr.p_rmpp_recv_ctx) {
176 memset(p_txn->rmpp_txfr.p_rmpp_recv_ctx, 0,
179 st = osmv_rmpp_recv_ctx_init(p_txn->rmpp_txfr.p_rmpp_recv_ctx,
180 p_txn->p_log);
281 osmv_txn_ctx_t *p_txn;
291 p_txn = (osmv_txn_ctx_t *) cl_qmap_obj(p_obj);
292 p_send_ctx = osmv_txn_get_rmpp_send_ctx(p_txn);
402 IN osmv_txn_ctx_t * p_txn, IN uint64_t key)
409 CL_ASSERT(p_txn);
411 key = osmv_txn_get_key(p_txn);
423 cl_qmap_set_obj(p_obj, p_txn);
477 osmv_txn_ctx_t *p_txn;
485 p_txn = (osmv_txn_ctx_t *) cl_qmap_obj(p_obj);
486 osmv_txn_done(h_bind, osmv_txn_get_key(p_txn), FALSE);
533 osmv_txn_ctx_t *p_txn;
550 ret = osmv_txn_lookup(p_bo, key, &p_txn);
556 p_madw = p_txn->p_madw;
558 switch (osmv_txn_get_rmpp_state(p_txn)) {
569 osmv_txn_get_tid(p_txn), num_regs);
573 p_madw, p_txn, TRUE);
579 osmv_txn_get_tid(p_txn));
608 osmv_txn_get_tid(p_txn), num_regs);
622 osmv_txn_get_tid(p_txn));
624 p_send_ctx = osmv_txn_get_rmpp_send_ctx(p_txn);
652 osmv_txn_get_tid(p_txn));
657 if (FALSE == osmv_txn_is_rmpp_init_by_peer(p_txn)) {