opensm/libvendor/osm_vendor_mlx_txn.c

54 			 IN osmv_txn_ctx_t * p_txn, IN uint64_t key);
71 	osmv_txn_ctx_t *p_txn;
81 	p_txn = malloc(sizeof(osmv_txn_ctx_t));
82 	if (!p_txn) {
86 	memset(p_txn, 0, sizeof(osmv_txn_ctx_t));
87 	p_txn->p_log = p_bo->txn_mgr.p_log;
88 	p_txn->tid = tid;
89 	p_txn->key = key;
90 	p_txn->p_madw = NULL;
91 	p_txn->rmpp_txfr.rmpp_state = OSMV_TXN_RMPP_NONE;
94 	st = __osmv_txnmgr_insert_txn(&p_bo->txn_mgr, p_txn, key);
103 	*pp_txn = p_txn;
108 	free(p_txn);
116 			  IN osmv_txn_ctx_t * p_txn, IN osm_madw_t * p_madw)
120 	CL_ASSERT(p_txn);
123 	osmv_txn_remove_timeout_ev(h_bind, osmv_txn_get_key(p_txn));
125 	p_txn->rmpp_txfr.rmpp_state = OSMV_TXN_RMPP_SENDER;
126 	p_txn->rmpp_txfr.p_rmpp_send_ctx = malloc(sizeof(osmv_rmpp_send_ctx_t));
128 	if (!p_txn->rmpp_txfr.p_rmpp_send_ctx) {
132 	memset(p_txn->rmpp_txfr.p_rmpp_send_ctx, 0,
135 	st = osmv_rmpp_send_ctx_init(p_txn->rmpp_txfr.p_rmpp_send_ctx,
137 				     p_madw->mad_size, p_txn->p_log);
143 			    IN osmv_txn_ctx_t * p_txn,
148 	uint64_t key = osmv_txn_get_key(p_txn);
150 	CL_ASSERT(p_txn);
163 	p_txn->rmpp_txfr.rmpp_state = OSMV_TXN_RMPP_RECEIVER;
164 	p_txn->rmpp_txfr.is_rmpp_init_by_peer = is_init_by_peer;
166 	p_txn->rmpp_txfr.p_rmpp_recv_ctx = malloc(sizeof(osmv_rmpp_recv_ctx_t));
168 	if (!p_txn->rmpp_txfr.p_rmpp_recv_ctx) {
174 	memset(p_txn->rmpp_txfr.p_rmpp_recv_ctx, 0,
177 	st = osmv_rmpp_recv_ctx_init(p_txn->rmpp_txfr.p_rmpp_recv_ctx,
178 				     p_txn->p_log);
279 	osmv_txn_ctx_t *p_txn;
289 		p_txn = (osmv_txn_ctx_t *) cl_qmap_obj(p_obj);
290 		p_send_ctx = osmv_txn_get_rmpp_send_ctx(p_txn);
400 			 IN osmv_txn_ctx_t * p_txn, IN uint64_t key)
407 	CL_ASSERT(p_txn);
409 	key = osmv_txn_get_key(p_txn);
421 	cl_qmap_set_obj(p_obj, p_txn);
475 	osmv_txn_ctx_t *p_txn;
483 		p_txn = (osmv_txn_ctx_t *) cl_qmap_obj(p_obj);
484 		osmv_txn_done(h_bind, osmv_txn_get_key(p_txn), FALSE);
531 	osmv_txn_ctx_t *p_txn;
548 	ret = osmv_txn_lookup(p_bo, key, &p_txn);
554 	p_madw = p_txn->p_madw;
556 	switch (osmv_txn_get_rmpp_state(p_txn)) {
567 				osmv_txn_get_tid(p_txn), num_regs);
571 						    p_madw, p_txn, TRUE);
576 					osmv_txn_get_tid(p_txn));
604 				osmv_txn_get_tid(p_txn), num_regs);
618 			osmv_txn_get_tid(p_txn));
620 		p_send_ctx = osmv_txn_get_rmpp_send_ctx(p_txn);
647 			"Dropping the transaction.\n", osmv_txn_get_tid(p_txn));
652 		if (FALSE == osmv_txn_is_rmpp_init_by_peer(p_txn)) {