opensm/libvendor/osm_vendor_mlx_txn.c

49 __osmv_txnmgr_lookup(IN osmv_txn_mgr_t * p_tx_mgr,
53 __osmv_txnmgr_insert_txn(IN osmv_txn_mgr_t * p_tx_mgr,
57 __osmv_txnmgr_remove_txn(IN osmv_txn_mgr_t * p_tx_mgr,
307 osmv_txnmgr_init(IN osmv_txn_mgr_t * p_tx_mgr,
312 	p_tx_mgr->p_event_wheel = malloc(sizeof(cl_event_wheel_t));
313 	if (!p_tx_mgr->p_event_wheel) {
317 	memset(p_tx_mgr->p_event_wheel, 0, sizeof(cl_event_wheel_t));
319 	cl_event_wheel_construct(p_tx_mgr->p_event_wheel);
325 	cl_st = cl_event_wheel_init_ex(p_tx_mgr->p_event_wheel, p_lock);
327 		free(p_tx_mgr->p_event_wheel);
331 	p_tx_mgr->p_txn_map = malloc(sizeof(cl_qmap_t));
332 	if (!p_tx_mgr->p_txn_map) {
333 		cl_event_wheel_destroy(p_tx_mgr->p_event_wheel);
334 		free(p_tx_mgr->p_event_wheel);
338 	memset(p_tx_mgr->p_txn_map, 0, sizeof(cl_qmap_t));
340 	cl_qmap_init(p_tx_mgr->p_txn_map);
341 	p_tx_mgr->p_log = p_log;
358 __osmv_txnmgr_lookup(IN osmv_txn_mgr_t * p_tx_mgr,
367 	OSM_LOG_ENTER(p_tx_mgr->p_log);
369 	CL_ASSERT(p_tx_mgr);
372 	osm_log(p_tx_mgr->p_log, OSM_LOG_DEBUG,
375 		p_tx_mgr->p_txn_map);
377 	p_item = cl_qmap_head(p_tx_mgr->p_txn_map);
378 	while (p_item != cl_qmap_end(p_tx_mgr->p_txn_map)) {
380 		osm_log(p_tx_mgr->p_log, OSM_LOG_DEBUG,
386 	p_item = cl_qmap_get(p_tx_mgr->p_txn_map, key);
387 	if (cl_qmap_end(p_tx_mgr->p_txn_map) == p_item) {
394 	OSM_LOG_EXIT(p_tx_mgr->p_log);
399 __osmv_txnmgr_insert_txn(IN osmv_txn_mgr_t * p_tx_mgr,
406 	CL_ASSERT(p_tx_mgr);
414 	osm_log(p_tx_mgr->p_log, OSM_LOG_DEBUG,
417 		p_tx_mgr->p_txn_map);
423 	cl_qmap_insert(p_tx_mgr->p_txn_map, key, &p_obj->item);
425 	p_item = cl_qmap_head(p_tx_mgr->p_txn_map);
426 	while (p_item != cl_qmap_end(p_tx_mgr->p_txn_map)) {
428 		osm_log(p_tx_mgr->p_log, OSM_LOG_DEBUG,
438 __osmv_txnmgr_remove_txn(IN osmv_txn_mgr_t * p_tx_mgr,
444 	OSM_LOG_ENTER(p_tx_mgr->p_log);
446 	CL_ASSERT(p_tx_mgr);
449 	p_item = cl_qmap_remove(p_tx_mgr->p_txn_map, key);
451 	if (p_item == cl_qmap_end(p_tx_mgr->p_txn_map)) {
453 		osm_log(p_tx_mgr->p_log, OSM_LOG_ERROR,
457 		OSM_LOG_EXIT(p_tx_mgr->p_log);
466 	OSM_LOG_EXIT(p_tx_mgr->p_log);