Lines Matching refs:p_vend
76 osm_vendor_t *p_vend;
90 * p_vend
131 osm_vendor_t *p_vend = (osm_vendor_t *) p_async_rec->context;
132 OSM_LOG_ENTER(p_vend->p_log);
134 osm_log(p_vend->p_log, OSM_LOG_ERROR,
139 OSM_LOG_EXIT(p_vend->p_log);
145 osm_vendor_t *p_vend = p_bind->p_vend;
146 OSM_LOG_ENTER(p_vend->p_log);
148 osm_log(p_vend->p_log, OSM_LOG_INFO,
152 OSM_LOG_EXIT(p_vend->p_log);
159 osm_vendor_t *p_vend = p_bind->p_vend;
160 OSM_LOG_ENTER(p_vend->p_log);
162 osm_log(p_vend->p_log, OSM_LOG_ERROR,
167 OSM_LOG_EXIT(p_vend->p_log);
175 osm_vendor_t *const p_vend = p_bind->p_vend;
180 OSM_LOG_ENTER(p_vend->p_log);
189 if (osm_log_is_active(p_vend->p_log, OSM_LOG_DEBUG)) {
190 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
213 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
231 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
240 OSM_LOG_EXIT(p_vend->p_log);
248 osm_vendor_t *const p_vend = p_bind->p_vend;
256 OSM_LOG_ENTER(p_vend->p_log);
319 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
327 OSM_LOG_EXIT(p_vend->p_log);
331 osm_vendor_init(IN osm_vendor_t * const p_vend,
337 p_vend->p_log = p_log;
342 status = ib_open_al(&p_vend->h_al);
344 osm_log(p_vend->p_log, OSM_LOG_ERROR,
351 p_vend->timeout = timeout;
362 osm_vendor_t *p_vend;
366 p_vend = malloc(sizeof(*p_vend));
367 if (p_vend == NULL) {
368 osm_log(p_vend->p_log, OSM_LOG_ERROR,
374 memset(p_vend, 0, sizeof(*p_vend));
376 status = osm_vendor_init(p_vend, p_log, timeout);
378 free(p_vend);
379 p_vend = NULL;
384 return (p_vend);
396 __osm_ca_info_init(IN osm_vendor_t * const p_vend,
402 OSM_LOG_ENTER(p_vend->p_log);
406 if (osm_log_is_active(p_vend->p_log, OSM_LOG_VERBOSE)) {
407 osm_log(p_vend->p_log, OSM_LOG_VERBOSE,
412 status = ib_query_ca_by_guid(p_vend->h_al, ca_guid, NULL,
415 osm_log(p_vend->p_log, OSM_LOG_ERROR,
426 osm_log(p_vend->p_log, OSM_LOG_ERROR,
432 status = ib_query_ca_by_guid(p_vend->h_al, ca_guid, p_ca_info->p_attr,
435 osm_log(p_vend->p_log, OSM_LOG_ERROR,
443 OSM_LOG_EXIT(p_vend->p_log);
448 osm_ca_info_destroy(IN osm_vendor_t * const p_vend,
451 OSM_LOG_ENTER(p_vend->p_log);
458 OSM_LOG_EXIT(p_vend->p_log);
461 osm_ca_info_t *osm_ca_info_new(IN osm_vendor_t * const p_vend,
467 OSM_LOG_ENTER(p_vend->p_log);
477 status = __osm_ca_info_init(p_vend, p_ca_info, ca_guid);
479 osm_ca_info_destroy(p_vend, p_ca_info);
485 OSM_LOG_EXIT(p_vend->p_log);
490 __osm_vendor_get_ca_guids(IN osm_vendor_t * const p_vend,
496 OSM_LOG_ENTER(p_vend->p_log);
501 status = ib_get_ca_guids(p_vend->h_al, NULL, p_num_guids);
503 osm_log(p_vend->p_log, OSM_LOG_ERROR,
511 osm_log(p_vend->p_log, OSM_LOG_ERROR,
520 osm_log(p_vend->p_log, OSM_LOG_ERROR,
526 status = ib_get_ca_guids(p_vend->h_al, *p_guids, p_num_guids);
529 if (osm_log_is_active(p_vend->p_log, OSM_LOG_VERBOSE)) {
530 osm_log(p_vend->p_log, OSM_LOG_VERBOSE,
536 OSM_LOG_EXIT(p_vend->p_log);
577 osm_vendor_get_all_port_attr(IN osm_vendor_t * const p_vend,
591 OSM_LOG_ENTER(p_vend->p_log);
593 CL_ASSERT(p_vend);
594 CL_ASSERT(p_vend->p_ca_info == NULL);
601 status = __osm_vendor_get_ca_guids(p_vend, &p_ca_guid, &ca_count);
603 p_vend->p_ca_info = malloc(ca_count * sizeof(*p_vend->p_ca_info));
604 if (p_vend->p_ca_info == NULL) {
605 osm_log(p_vend->p_log, OSM_LOG_ERROR,
611 memset(p_vend->p_ca_info, 0, ca_count * sizeof(*p_vend->p_ca_info));
612 p_vend->ca_count = ca_count;
618 p_ca_info = &p_vend->p_ca_info[ca];
620 status = __osm_ca_info_init(p_vend, p_ca_info, p_ca_guid[ca]);
623 osm_log(p_vend->p_log, OSM_LOG_ERROR,
640 p_ca_info = &p_vend->p_ca_info[ca];
661 OSM_LOG_EXIT(p_vend->p_log);
666 osm_vendor_get_ca_guid(IN osm_vendor_t * const p_vend,
675 OSM_LOG_ENTER(p_vend->p_log);
681 if (p_vend->p_ca_info == NULL) {
686 osm_vendor_get_all_port_attr(p_vend, NULL, &num_guids);
689 CL_ASSERT(p_vend->p_ca_info);
690 CL_ASSERT(p_vend->ca_count);
692 for (ca = 0; ca < p_vend->ca_count; ca++) {
693 p_ca_info = &p_vend->p_ca_info[ca];
701 OSM_LOG_EXIT(p_vend->p_log);
710 osm_log(p_vend->p_log, OSM_LOG_ERROR,
714 OSM_LOG_EXIT(p_vend->p_log);
719 osm_vendor_get_port_num(IN osm_vendor_t * const p_vend,
728 OSM_LOG_ENTER(p_vend->p_log);
734 if (p_vend->p_ca_info == NULL) {
739 osm_vendor_get_all_port_attr(p_vend, NULL, &num_guids);
742 CL_ASSERT(p_vend->p_ca_info);
743 CL_ASSERT(p_vend->ca_count);
745 for (ca = 0; ca < p_vend->ca_count; ca++) {
746 p_ca_info = &p_vend->p_ca_info[ca];
754 OSM_LOG_EXIT(p_vend->p_log);
764 osm_log(p_vend->p_log, OSM_LOG_ERROR,
768 OSM_LOG_EXIT(p_vend->p_log);
773 __osm_vendor_open_ca(IN osm_vendor_t * const p_vend,
779 OSM_LOG_ENTER(p_vend->p_log);
781 ca_guid = osm_vendor_get_ca_guid(p_vend, port_guid);
783 osm_log(p_vend->p_log, OSM_LOG_ERROR,
791 osm_log(p_vend->p_log, OSM_LOG_VERBOSE,
795 status = ib_open_ca(p_vend->h_al,
797 __osm_al_ca_err_callback, p_vend, &p_vend->h_ca);
800 osm_log(p_vend->p_log, OSM_LOG_ERROR,
806 CL_ASSERT(p_vend->h_ca);
808 status = ib_alloc_pd(p_vend->h_ca, IB_PDT_ALIAS, p_vend, &p_vend->h_pd);
811 ib_close_ca(p_vend->h_ca, __osm_al_ca_destroy_callback);
812 osm_log(p_vend->p_log, OSM_LOG_ERROR,
819 CL_ASSERT(p_vend->h_pd);
822 OSM_LOG_EXIT(p_vend->p_log);
836 osm_vendor_bind(IN osm_vendor_t * const p_vend,
850 OSM_LOG_ENTER(p_vend->p_log);
859 osm_log(p_vend->p_log, OSM_LOG_INFO,
863 if (p_vend->h_ca == 0) {
864 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
869 status = __osm_vendor_open_ca(p_vend, port_guid);
871 osm_log(p_vend->p_log, OSM_LOG_ERROR,
881 osm_log(p_vend->p_log, OSM_LOG_ERROR,
888 p_bind->p_vend = p_vend;
890 p_bind->port_num = osm_vendor_get_port_num(p_vend, port_guid);
919 status = ib_get_spl_qp(p_vend->h_pd,
928 osm_log(p_vend->p_log, OSM_LOG_ERROR,
956 osm_log(p_vend->p_log, OSM_LOG_ERROR,
965 status = ib_create_av(p_vend->h_pd, &av, &p_bind->h_dr_av);
967 osm_log(p_vend->p_log, OSM_LOG_ERROR,
975 if (osm_log_is_active(p_vend->p_log, OSM_LOG_DEBUG)) {
976 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
982 OSM_LOG_EXIT(p_vend->p_log);
992 osm_vendor_t *p_vend = p_bind->p_vend;
995 OSM_LOG_ENTER(p_vend->p_log);
1008 osm_log(p_vend->p_log, OSM_LOG_ERROR,
1020 if (osm_log_get_level(p_vend->p_log) >= OSM_LOG_DEBUG) {
1021 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1027 OSM_LOG_EXIT(p_vend->p_log);
1035 osm_vendor_t *p_vend = p_bind->p_vend;
1038 OSM_LOG_ENTER(p_vend->p_log);
1044 if (osm_log_get_level(p_vend->p_log) >= OSM_LOG_DEBUG) {
1045 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1052 osm_log(p_vend->p_log, OSM_LOG_ERROR,
1057 OSM_LOG_EXIT(p_vend->p_log);
1065 osm_vendor_t *const p_vend = p_bind->p_vend;
1073 OSM_LOG_ENTER(p_vend->p_log);
1090 osm_log(p_vend->p_log, OSM_LOG_ERROR,
1121 if (osm_log_is_active(p_vend->p_log, OSM_LOG_DEBUG)) {
1122 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1132 status = ib_create_av(p_vend->h_pd, &av, &p_vw->h_av);
1134 osm_log(p_vend->p_log, OSM_LOG_ERROR,
1145 if (osm_log_is_active(p_vend->p_log, OSM_LOG_DEBUG)) {
1146 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1165 p_elem->timeout_ms = p_vend->timeout;
1177 osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1186 osm_log(p_vend->p_log, OSM_LOG_ERROR,
1195 OSM_LOG_EXIT(p_vend->p_log);
1202 osm_vendor_t *p_vend = p_bind->p_vend;
1206 OSM_LOG_ENTER(p_vend->p_log);
1216 osm_log(p_vend->p_log, OSM_LOG_ERROR,
1224 status = ib_create_av(p_vend->h_pd, &av, &p_bind->h_dr_av);
1226 osm_log(p_vend->p_log, OSM_LOG_ERROR,
1235 OSM_LOG_EXIT(p_vend->p_log);
1242 osm_vendor_t *p_vend = p_bind->p_vend;
1246 OSM_LOG_ENTER(p_vend->p_log);
1252 status = ib_modify_ca(p_vend->h_ca, p_bind->port_num,
1256 osm_log(p_vend->p_log, OSM_LOG_ERROR,
1262 OSM_LOG_EXIT(p_vend->p_log);
1265 void osm_vendor_set_debug(IN osm_vendor_t * const p_vend, IN int32_t level)