opensm/libvendor/osm_vendor_mtl_transaction_mgr.c

58 	osm_transaction_mgr_t *trans_mgr_p;
78 	trans_mgr_p = (osm_transaction_mgr_t *) p_vend->p_transaction_mgr;
98 	cl_spinlock_acquire(&(trans_mgr_p->transaction_mgr_lock));
99 	p_list_item = cl_qlist_head(trans_mgr_p->madw_reqs_list_p);
100 	if (p_list_item == cl_qlist_end(trans_mgr_p->madw_reqs_list_p)) {
102 		cl_spinlock_release(&trans_mgr_p->transaction_mgr_lock);
131 			    cl_timer_start(&trans_mgr_p->madw_list_timer,
139 			cl_qlist_remove_item(trans_mgr_p->madw_reqs_list_p,
143 			cl_qlist_insert_tail(trans_mgr_p->madw_reqs_list_p,
151 			cl_qlist_remove_item(trans_mgr_p->madw_reqs_list_p,
164 		if (p_list_item == cl_qlist_end(trans_mgr_p->madw_reqs_list_p)) {
176 	if (p_list_item != cl_qlist_end(trans_mgr_p->madw_reqs_list_p)) {
187 		    cl_timer_start(&trans_mgr_p->madw_list_timer, new_timeout);
275 	osm_transaction_mgr_t *trans_mgr_p;
283 	trans_mgr_p = (osm_transaction_mgr_t *) p_vend->p_transaction_mgr;
286 	cl_spinlock_construct(&(trans_mgr_p->transaction_mgr_lock));
287 	CL_ASSERT(cl_spinlock_init(&(trans_mgr_p->transaction_mgr_lock)) ==
291 	trans_mgr_p->madw_reqs_list_p =
293 	cl_qlist_init(trans_mgr_p->madw_reqs_list_p);
296 	trans_mgr_p->madw_by_tid_map_p =
298 	cl_qmap_init(trans_mgr_p->madw_by_tid_map_p);
301 	cl_timer_construct(&(trans_mgr_p->madw_list_timer));
304 	cl_status = cl_timer_init(&trans_mgr_p->madw_list_timer,
317 	osm_transaction_mgr_t *trans_mgr_p;
324 	trans_mgr_p = (osm_transaction_mgr_t *) p_vend->p_transaction_mgr;
328 		cl_spinlock_acquire(&trans_mgr_p->transaction_mgr_lock);
332 		    cl_qlist_remove_head(trans_mgr_p->madw_reqs_list_p);
334 		       cl_qlist_end(trans_mgr_p->madw_reqs_list_p)) {
352 			cl_qmap_remove_item(trans_mgr_p->madw_by_tid_map_p,
357 			    cl_qlist_remove_head(trans_mgr_p->madw_reqs_list_p);
360 		free(trans_mgr_p->madw_reqs_list_p);
361 		free(trans_mgr_p->madw_by_tid_map_p);
363 		cl_spinlock_release(&trans_mgr_p->transaction_mgr_lock);
364 		cl_spinlock_destroy(&(trans_mgr_p->transaction_mgr_lock));
366 		cl_timer_trim(&trans_mgr_p->madw_list_timer, 1);
367 		cl_timer_destroy(&trans_mgr_p->madw_list_timer);
369 		free(trans_mgr_p);
370 		trans_mgr_p = NULL;
385 	osm_transaction_mgr_t *trans_mgr_p;
397 	trans_mgr_p = (osm_transaction_mgr_t *) p_vend->p_transaction_mgr;
415 	cl_spinlock_acquire(&(trans_mgr_p->transaction_mgr_lock));
417 	if (cl_is_qlist_empty(trans_mgr_p->madw_reqs_list_p)) {
419 		cl_timer_stop(&trans_mgr_p->madw_list_timer);
422 		cl_status = cl_timer_start(&trans_mgr_p->madw_list_timer,
432 	cl_qlist_insert_tail(trans_mgr_p->madw_reqs_list_p,
436 	cl_qmap_insert(trans_mgr_p->madw_by_tid_map_p, key,
438 	cl_spinlock_release(&trans_mgr_p->transaction_mgr_lock);
449 	osm_transaction_mgr_t *trans_mgr_p;
455 	trans_mgr_p = (osm_transaction_mgr_t *) p_vend->p_transaction_mgr;
462 	cl_spinlock_acquire(&trans_mgr_p->transaction_mgr_lock);
463 	p_map_item = cl_qmap_get(trans_mgr_p->madw_by_tid_map_p, key);
464 	if (p_map_item != cl_qmap_end(trans_mgr_p->madw_by_tid_map_p)) {
471 		cl_qlist_remove_item(trans_mgr_p->madw_reqs_list_p,
474 		cl_qmap_remove_item(trans_mgr_p->madw_by_tid_map_p,
489 	cl_spinlock_release(&trans_mgr_p->transaction_mgr_lock);
500 	osm_transaction_mgr_t *trans_mgr_p;
506 	trans_mgr_p = (osm_transaction_mgr_t *) p_vend->p_transaction_mgr;
515 	cl_spinlock_acquire(&(trans_mgr_p->transaction_mgr_lock));
516 	p_map_item = cl_qmap_get(trans_mgr_p->madw_by_tid_map_p, key);
517 	if (p_map_item != cl_qmap_end(trans_mgr_p->madw_by_tid_map_p)) {
525 		cl_qlist_remove_item(trans_mgr_p->madw_reqs_list_p,
528 		cl_qmap_remove_item(trans_mgr_p->madw_by_tid_map_p,
538 	cl_spinlock_release(&(trans_mgr_p->transaction_mgr_lock));