opensm/libvendor/osm_vendor_mlx_txn.c

60 static void __osmv_txn_all_done(osm_bind_handle_t h_bind);
67 osmv_txn_init(IN osm_bind_handle_t h_bind,
72 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
76 	CL_ASSERT(NULL != h_bind && NULL != pp_txn);
117 osmv_txn_init_rmpp_sender(IN osm_bind_handle_t h_bind,
125 	osmv_txn_remove_timeout_ev(h_bind, osmv_txn_get_key(p_txn));
144 osmv_txn_init_rmpp_receiver(IN osm_bind_handle_t h_bind,
149 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
155 	osmv_txn_remove_timeout_ev(h_bind, key);
158 	st = osmv_txn_set_timeout_ev(h_bind, key,
172 		osmv_txn_remove_timeout_ev(h_bind, key);
195 osmv_txn_set_timeout_ev(IN osm_bind_handle_t h_bind,
198 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
218 void osmv_txn_remove_timeout_ev(IN osm_bind_handle_t h_bind, IN uint64_t key)
221 	    ((osmv_bind_obj_t *) h_bind)->txn_mgr.p_event_wheel;
226 osmv_txn_done(IN osm_bind_handle_t h_bind,
230 	osmv_bind_obj_t *const p_bo = (osmv_bind_obj_t *) h_bind;
234 	CL_ASSERT(h_bind);
242 		osmv_txn_remove_timeout_ev(h_bind, key);
269 osmv_txn_lookup(IN osm_bind_handle_t h_bind,
272 	return __osmv_txnmgr_lookup(&(((osmv_bind_obj_t *) h_bind)->txn_mgr),
276 void osmv_txn_abort_rmpp_txns(osm_bind_handle_t h_bind)
278 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
348 void osmv_txnmgr_done(IN osm_bind_handle_t h_bind)
350 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
352 	__osmv_txn_all_done(h_bind);
472 void __osmv_txn_all_done(osm_bind_handle_t h_bind)
474 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
486 		osmv_txn_done(h_bind, osmv_txn_get_key(p_txn), FALSE);
497 void osmv_txn_lock(IN osm_bind_handle_t h_bind)
499 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
510 void osmv_txn_unlock(IN osm_bind_handle_t h_bind)
512 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;