opensm/libvendor/osm_vendor_mlx_txn.c

72 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
74 	OSM_LOG_ENTER(p_bo->p_vendor->p_log);
78 	osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
87 	p_txn->p_log = p_bo->txn_mgr.p_log;
94 	st = __osmv_txnmgr_insert_txn(&p_bo->txn_mgr, p_txn, key);
96 		osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
104 	OSM_LOG_EXIT(p_bo->p_vendor->p_log);
110 	OSM_LOG_EXIT(p_bo->p_vendor->p_log);
147 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
157 				     p_bo->p_vendor->ttime_timeout);
196 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
197 	cl_event_wheel_t *p_event_wheel = p_bo->txn_mgr.p_event_wheel;
202 				    p_bo /* The context */ );
228 	osmv_bind_obj_t *const p_bo = (osmv_bind_obj_t *) h_bind;
230 	OSM_LOG_ENTER(p_bo->p_vendor->p_log);
245 	    __osmv_txnmgr_remove_txn(&p_bo->txn_mgr, key, &p_ctx)) {
263 	OSM_LOG_EXIT(p_bo->p_vendor->p_log);
276 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
281 	cl_qmap_t *p_map = p_bo->txn_mgr.p_txn_map;
283 	OSM_LOG_ENTER(p_bo->p_vendor->p_log);
303 	OSM_LOG_EXIT(p_bo->p_vendor->p_log);
348 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
351 	free(p_bo->txn_mgr.p_txn_map);
353 	cl_event_wheel_destroy(p_bo->txn_mgr.p_event_wheel);
354 	free(p_bo->txn_mgr.p_event_wheel);
472 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
477 	OSM_LOG_ENTER(p_bo->p_vendor->p_log);
479 	p_item = cl_qmap_head(p_bo->txn_mgr.p_txn_map);
480 	while (p_item != cl_qmap_end(p_bo->txn_mgr.p_txn_map)) {
487 		p_item = cl_qmap_head(p_bo->txn_mgr.p_txn_map);
490 	OSM_LOG_EXIT(p_bo->p_vendor->p_log);
497 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
499 	osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
500 		"--> Acquiring lock %p on bind handle %p\n", &p_bo->lock, p_bo);
502 	cl_spinlock_acquire(&p_bo->lock);
504 	osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
505 		"--> Acquired lock %p on bind handle %p\n", &p_bo->lock, p_bo);
510 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
511 	cl_spinlock_t *p_lock = &p_bo->lock;
512 	osm_log_t *p_log = p_bo->p_vendor->p_log;
515 		"<-- Releasing lock %p on bind handle %p\n", p_lock, p_bo);
517 	cl_spinlock_release(&p_bo->lock);
519 	/* We'll use the saved ptrs, since now the p_bo can be destroyed already */
521 		"<-- Released lock %p on bind handle %p\n", p_lock, p_bo);
529 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) cb_context;
538 	OSM_LOG_ENTER(p_bo->p_vendor->p_log);
544 	if (p_bo->is_closing) {
548 	ret = osmv_txn_lookup(p_bo, key, &p_txn);
563 			osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
570 			ret = osmv_simple_send_madw((osm_bind_handle_t *) p_bo,
573 				osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
578 				osmv_txn_done((osm_bind_handle_t) p_bo, key,
586 				    p_bo->p_vendor->resp_timeout * (num_regs +
594 				osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
600 			osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
606 			osmv_txn_done((osm_bind_handle_t) p_bo, key,
615 		osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
627 			    1000 * p_bo->p_vendor->resp_timeout;
635 			osmv_rmpp_send_nak((osm_bind_handle_t) p_bo, p_mad,
645 		osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
649 		osmv_txn_done((osm_bind_handle_t) p_bo, key,
667 		p_bo->send_err_cb(p_bo->cb_context, p_madw);
673 	OSM_LOG_EXIT(p_bo->p_vendor->p_log);