Lines Matching defs:p_bo
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,
88 p_txn->p_log = p_bo->txn_mgr.p_log;
95 st = __osmv_txnmgr_insert_txn(&p_bo->txn_mgr, p_txn, key);
97 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
106 OSM_LOG_EXIT(p_bo->p_vendor->p_log);
112 OSM_LOG_EXIT(p_bo->p_vendor->p_log);
149 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
159 p_bo->p_vendor->ttime_timeout);
198 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
199 cl_event_wheel_t *p_event_wheel = p_bo->txn_mgr.p_event_wheel;
204 p_bo /* The context */ );
230 osmv_bind_obj_t *const p_bo = (osmv_bind_obj_t *) h_bind;
232 OSM_LOG_ENTER(p_bo->p_vendor->p_log);
247 __osmv_txnmgr_remove_txn(&p_bo->txn_mgr, key, &p_ctx)) {
265 OSM_LOG_EXIT(p_bo->p_vendor->p_log);
278 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
283 cl_qmap_t *p_map = p_bo->txn_mgr.p_txn_map;
285 OSM_LOG_ENTER(p_bo->p_vendor->p_log);
305 OSM_LOG_EXIT(p_bo->p_vendor->p_log);
350 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
353 free(p_bo->txn_mgr.p_txn_map);
355 cl_event_wheel_destroy(p_bo->txn_mgr.p_event_wheel);
356 free(p_bo->txn_mgr.p_event_wheel);
474 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
479 OSM_LOG_ENTER(p_bo->p_vendor->p_log);
481 p_item = cl_qmap_head(p_bo->txn_mgr.p_txn_map);
482 while (p_item != cl_qmap_end(p_bo->txn_mgr.p_txn_map)) {
489 p_item = cl_qmap_head(p_bo->txn_mgr.p_txn_map);
492 OSM_LOG_EXIT(p_bo->p_vendor->p_log);
499 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
501 osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
502 "--> Acquiring lock %p on bind handle %p\n", &p_bo->lock, p_bo);
504 cl_spinlock_acquire(&p_bo->lock);
506 osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
507 "--> Acquired lock %p on bind handle %p\n", &p_bo->lock, p_bo);
512 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
513 cl_spinlock_t *p_lock = &p_bo->lock;
514 osm_log_t *p_log = p_bo->p_vendor->p_log;
517 "<-- Releasing lock %p on bind handle %p\n", p_lock, p_bo);
519 cl_spinlock_release(&p_bo->lock);
521 /* We'll use the saved ptrs, since now the p_bo can be destroyed already */
523 "<-- Released lock %p on bind handle %p\n", p_lock, p_bo);
531 osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) cb_context;
540 OSM_LOG_ENTER(p_bo->p_vendor->p_log);
546 if (p_bo->is_closing) {
550 ret = osmv_txn_lookup(p_bo, key, &p_txn);
565 osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
572 ret = osmv_simple_send_madw((osm_bind_handle_t *) p_bo,
575 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
581 osmv_txn_done((osm_bind_handle_t) p_bo, key,
589 p_bo->p_vendor->resp_timeout * (num_regs +
597 osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
603 osm_log(p_bo->p_vendor->p_log, OSM_LOG_ERROR,
610 osmv_txn_done((osm_bind_handle_t) p_bo, key,
619 osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
631 1000 * p_bo->p_vendor->resp_timeout;
639 osmv_rmpp_send_nak((osm_bind_handle_t) p_bo, p_mad,
649 osm_log(p_bo->p_vendor->p_log, OSM_LOG_DEBUG,
654 osmv_txn_done((osm_bind_handle_t) p_bo, key,
672 p_bo->send_err_cb(p_bo->cb_context, p_madw);
678 OSM_LOG_EXIT(p_bo->p_vendor->p_log);