Lines Matching defs:p_bo
197 osmv_bind_obj_t *p_bo;
215 p_bo = malloc(sizeof(osmv_bind_obj_t));
216 if (NULL == p_bo) {
222 memset(p_bo, 0, sizeof(osmv_bind_obj_t));
223 p_bo->p_vendor = p_vend;
224 p_bo->recv_cb = mad_recv_callback;
225 p_bo->send_err_cb = send_err_callback;
226 p_bo->cb_context = context;
227 p_bo->p_osm_pool = p_mad_pool;
230 osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
235 status = osm_vendor_get_guid_ca_and_port(p_bo->p_vendor,
237 &(p_bo->hca_hndl),
239 &hca_index, &(p_bo->port_num));
241 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
245 free(p_bo);
249 /* Initialize the magic_ptr to the pointer of the p_bo info.
252 p_bo->magic_ptr = p_bo;
254 p_bo->is_closing = FALSE;
256 cl_spinlock_construct(&(p_bo->lock));
257 cl_st = cl_spinlock_init(&(p_bo->lock));
259 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
262 free(p_bo);
266 osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
268 if (osmv_txnmgr_init(&p_bo->txn_mgr, p_vend->p_log, &(p_bo->lock)) !=
270 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
273 cl_spinlock_destroy(&p_bo->lock);
274 free(p_bo);
280 osmv_transport_init(p_bind_info, hca_id, hca_index, p_bo)) {
281 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
284 osmv_txnmgr_done((osm_bind_handle_t) p_bo);
285 cl_spinlock_destroy(&p_bo->lock);
286 free(p_bo);
294 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
298 osmv_transport_done(p_bo->p_transp_mgr);
299 osmv_txnmgr_done((osm_bind_handle_t) p_bo);
300 cl_spinlock_destroy(&p_bo->lock);
301 free(p_bo);
305 cl_qlist_set_obj(p_obj, p_bo);
309 return (osm_bind_handle_t) p_bo;
320 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
321 osm_log_t *p_log = p_bo->p_vendor->p_log;
325 (cl_qlist_t * const)&p_bo->p_vendor->bind_handles;
364 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
365 osm_vendor_t const *p_vend = p_bo->p_vendor;
419 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
423 osm_log_t *p_log = p_bo->p_vendor->p_log;
424 osm_mad_pool_t *p_mad_pool = p_bo->p_osm_pool;
441 osmv_txn_lock(p_bo);
443 if (TRUE == p_bo->is_closing) {
450 /* When closing p_bo could be detroyed or is going to , thus could not refer to it */
505 p_bo->send_err_cb(p_bo->cb_context, p_madw);
510 } else { /* the transaction was aborted due to p_bo exit */
517 osmv_txn_unlock(p_bo);
533 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
534 osm_vendor_t const *p_vend = p_bo->p_vendor;
536 if (p_bo->is_closing != TRUE) {
586 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
587 osm_vendor_t const *p_vend = p_bo->p_vendor;
601 VAPI_modify_hca_attr(p_bo->hca_hndl, p_bo->port_num, &attr_mod,
625 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
626 osm_log_t *p_log = p_bo->p_vendor->p_log;
631 p_bo->txn_mgr.p_event_wheel->closing = TRUE;
633 osmv_txn_lock(p_bo);
639 p_bo->is_closing = TRUE;
645 osmv_txn_unlock(p_bo);
652 osmv_txn_lock(p_bo);
658 osmv_txn_unlock(p_bo);
661 we intentionally let the p_bo and its lock leak -
665 cl_spinlock_destroy(&p_bo->lock);
666 free(p_bo);
687 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
690 OSM_LOG_ENTER(p_bo->p_vendor->p_log);
705 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
720 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
730 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
743 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
760 OSM_LOG_EXIT(p_bo->p_vendor->p_log);