Lines Matching defs:p_bo
232 osmv_bind_obj_t *p_bo;
239 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
248 p_bo = malloc(sizeof(osmv_bind_obj_t));
249 if (NULL == p_bo) {
250 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
256 memset(p_bo, 0, sizeof(osmv_bind_obj_t));
257 p_bo->p_vendor = p_vend;
258 p_bo->recv_cb = mad_recv_callback;
259 p_bo->send_err_cb = send_err_callback;
260 p_bo->cb_context = context;
261 p_bo->p_osm_pool = p_mad_pool;
262 p_bo->port_num = 1; /* anafa2 has one port */
263 p_bo->hca_hndl = 0; /* only one ca on anafa system */
266 osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
271 p_bo->is_closing = FALSE;
272 cl_spinlock_construct(&(p_bo->lock));
273 cl_st = cl_spinlock_init(&(p_bo->lock));
275 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
278 free(p_bo);
282 osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
284 if (osmv_txnmgr_init(&p_bo->txn_mgr, p_vend->p_log, &(p_bo->lock)) !=
286 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
289 cl_spinlock_destroy(&p_bo->lock);
290 free(p_bo);
296 osmv_transport_init(p_bind_info, OSMV_ANAFA_ID, hca_idx, p_bo)) {
297 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
300 osmv_txnmgr_done((osm_bind_handle_t) p_bo);
301 cl_spinlock_destroy(&p_bo->lock);
302 free(p_bo);
310 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
314 osmv_transport_done(p_bo->p_transp_mgr);
315 osmv_txnmgr_done((osm_bind_handle_t) p_bo);
316 cl_spinlock_destroy(&p_bo->lock);
317 free(p_bo);
322 cl_qlist_set_obj(p_obj, p_bo);
326 return (osm_bind_handle_t) p_bo;
337 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
338 osm_log_t *p_log = p_bo->p_vendor->p_log;
342 (cl_qlist_t * const)&p_bo->p_vendor->bind_handles;
347 p_item = cl_qlist_head(&p_bo->p_vendor->bind_handles);
348 while (p_item != cl_qlist_end(&p_bo->p_vendor->bind_handles)) {
364 OSM_LOG_EXIT(p_bo->p_vendor->p_log);
378 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
379 osm_vendor_t const *p_vend = p_bo->p_vendor;
433 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
438 OSM_LOG_ENTER(p_bo->p_vendor->p_log);
452 osmv_txn_lock(p_bo);
454 if (TRUE == p_bo->is_closing) {
455 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
498 osm_mad_pool_put(p_bo->p_osm_pool, p_madw);
506 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
514 p_bo->send_err_cb(p_bo->cb_context, p_madw);
517 osm_mad_pool_put(p_bo->p_osm_pool, p_madw);
523 osmv_txn_unlock(p_bo);
525 OSM_LOG_EXIT(p_bo->p_vendor->p_log);
539 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
540 osm_vendor_t const *p_vend = p_bo->p_vendor;
588 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
589 osm_vendor_t const *p_vend = p_bo->p_vendor;
600 p_mgr = (osmv_TOPSPIN_ANAFA_transport_mgr_t *) p_bo->p_transp_mgr;
623 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
624 osm_log_t *p_log = p_bo->p_vendor->p_log;
629 p_bo->txn_mgr.p_event_wheel->closing = TRUE;
631 osmv_txn_lock(p_bo);
632 p_bo->is_closing = TRUE;
640 osmv_txn_unlock(p_bo);
645 osmv_txn_lock(p_bo);
650 osmv_txn_unlock(p_bo);
652 we intentionally let the p_bo and its lock leak -
656 cl_spinlock_destroy(&p_bo->lock);
657 free(p_bo);
678 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
681 OSM_LOG_ENTER(p_bo->p_vendor->p_log);
707 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
717 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
743 OSM_LOG_EXIT(p_bo->p_vendor->p_log);