opensm/libvendor/osm_vendor_al.c

76 	osm_vendor_t *p_vend;
90  * p_vend
135 	osm_vendor_t *p_vend = (osm_vendor_t *) p_async_rec->context;
136 	OSM_LOG_ENTER(p_vend->p_log);
138 	osm_log(p_vend->p_log, OSM_LOG_ERROR,
143 	OSM_LOG_EXIT(p_vend->p_log);
151 	osm_vendor_t *p_vend = p_bind->p_vend;
152 	OSM_LOG_ENTER(p_vend->p_log);
154 	osm_log(p_vend->p_log, OSM_LOG_INFO,
158 	OSM_LOG_EXIT(p_vend->p_log);
167 	osm_vendor_t *p_vend = p_bind->p_vend;
168 	OSM_LOG_ENTER(p_vend->p_log);
170 	osm_log(p_vend->p_log, OSM_LOG_ERROR,
175 	OSM_LOG_EXIT(p_vend->p_log);
185 	osm_vendor_t *const p_vend = p_bind->p_vend;
190 	OSM_LOG_ENTER(p_vend->p_log);
199 		if (osm_log_is_active(p_vend->p_log, OSM_LOG_DEBUG)) {
200 			osm_log(p_vend->p_log, OSM_LOG_DEBUG,
223 			osm_log(p_vend->p_log, OSM_LOG_DEBUG,
241 		osm_log(p_vend->p_log, OSM_LOG_DEBUG,
250 	OSM_LOG_EXIT(p_vend->p_log);
260 	osm_vendor_t *const p_vend = p_bind->p_vend;
268 	OSM_LOG_ENTER(p_vend->p_log);
331 	osm_log(p_vend->p_log, OSM_LOG_DEBUG,
339 	OSM_LOG_EXIT(p_vend->p_log);
345 osm_vendor_init(IN osm_vendor_t * const p_vend,
351 	p_vend->p_log = p_log;
356 	status = ib_open_al(&p_vend->h_al);
358 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
365 	p_vend->timeout = timeout;
378 	osm_vendor_t *p_vend;
382 	p_vend = malloc(sizeof(*p_vend));
383 	if (p_vend == NULL) {
384 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
390 	memset(p_vend, 0, sizeof(*p_vend));
392 	status = osm_vendor_init(p_vend, p_log, timeout);
394 		free(p_vend);
395 		p_vend = NULL;
400 	return (p_vend);
416 __osm_ca_info_init(IN osm_vendor_t * const p_vend,
422 	OSM_LOG_ENTER(p_vend->p_log);
426 	if (osm_log_is_active(p_vend->p_log, OSM_LOG_VERBOSE)) {
427 		osm_log(p_vend->p_log, OSM_LOG_VERBOSE,
432 	status = ib_query_ca_by_guid(p_vend->h_al, ca_guid, NULL,
435 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
446 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
452 	status = ib_query_ca_by_guid(p_vend->h_al, ca_guid, p_ca_info->p_attr,
455 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
463 	OSM_LOG_EXIT(p_vend->p_log);
470 osm_ca_info_destroy(IN osm_vendor_t * const p_vend,
473 	OSM_LOG_ENTER(p_vend->p_log);
480 	OSM_LOG_EXIT(p_vend->p_log);
485 osm_ca_info_t *osm_ca_info_new(IN osm_vendor_t * const p_vend,
491 	OSM_LOG_ENTER(p_vend->p_log);
501 	status = __osm_ca_info_init(p_vend, p_ca_info, ca_guid);
503 		osm_ca_info_destroy(p_vend, p_ca_info);
509 	OSM_LOG_EXIT(p_vend->p_log);
516 __osm_vendor_get_ca_guids(IN osm_vendor_t * const p_vend,
522 	OSM_LOG_ENTER(p_vend->p_log);
527 	status = ib_get_ca_guids(p_vend->h_al, NULL, p_num_guids);
529 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
537 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
546 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
552 	status = ib_get_ca_guids(p_vend->h_al, *p_guids, p_num_guids);
555 	if (osm_log_is_active(p_vend->p_log, OSM_LOG_VERBOSE)) {
556 		osm_log(p_vend->p_log, OSM_LOG_VERBOSE,
562 	OSM_LOG_EXIT(p_vend->p_log);
605 osm_vendor_get_all_port_attr(IN osm_vendor_t * const p_vend,
619 	OSM_LOG_ENTER(p_vend->p_log);
621 	CL_ASSERT(p_vend);
622 	CL_ASSERT(p_vend->p_ca_info == NULL);
629 	status = __osm_vendor_get_ca_guids(p_vend, &p_ca_guid, &ca_count);
631 	p_vend->p_ca_info = malloc(ca_count * sizeof(*p_vend->p_ca_info));
632 	if (p_vend->p_ca_info == NULL) {
633 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
639 	memset(p_vend->p_ca_info, 0, ca_count * sizeof(*p_vend->p_ca_info));
640 	p_vend->ca_count = ca_count;
646 		p_ca_info = &p_vend->p_ca_info[ca];
648 		status = __osm_ca_info_init(p_vend, p_ca_info, p_ca_guid[ca]);
651 			osm_log(p_vend->p_log, OSM_LOG_ERROR,
668 			p_ca_info = &p_vend->p_ca_info[ca];
689 	OSM_LOG_EXIT(p_vend->p_log);
696 osm_vendor_get_ca_guid(IN osm_vendor_t * const p_vend,
705 	OSM_LOG_ENTER(p_vend->p_log);
711 	if (p_vend->p_ca_info == NULL) {
716 		osm_vendor_get_all_port_attr(p_vend, NULL, &num_guids);
719 	CL_ASSERT(p_vend->p_ca_info);
720 	CL_ASSERT(p_vend->ca_count);
722 	for (ca = 0; ca < p_vend->ca_count; ca++) {
723 		p_ca_info = &p_vend->p_ca_info[ca];
731 				OSM_LOG_EXIT(p_vend->p_log);
740 	osm_log(p_vend->p_log, OSM_LOG_ERROR,
744 	OSM_LOG_EXIT(p_vend->p_log);
751 osm_vendor_get_port_num(IN osm_vendor_t * const p_vend,
760 	OSM_LOG_ENTER(p_vend->p_log);
766 	if (p_vend->p_ca_info == NULL) {
771 		osm_vendor_get_all_port_attr(p_vend, NULL, &num_guids);
774 	CL_ASSERT(p_vend->p_ca_info);
775 	CL_ASSERT(p_vend->ca_count);
777 	for (ca = 0; ca < p_vend->ca_count; ca++) {
778 		p_ca_info = &p_vend->p_ca_info[ca];
786 				OSM_LOG_EXIT(p_vend->p_log);
796 	osm_log(p_vend->p_log, OSM_LOG_ERROR,
800 	OSM_LOG_EXIT(p_vend->p_log);
807 __osm_vendor_open_ca(IN osm_vendor_t * const p_vend,
813 	OSM_LOG_ENTER(p_vend->p_log);
815 	ca_guid = osm_vendor_get_ca_guid(p_vend, port_guid);
817 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
825 	osm_log(p_vend->p_log, OSM_LOG_VERBOSE,
829 	status = ib_open_ca(p_vend->h_al,
831 			    __osm_al_ca_err_callback, p_vend, &p_vend->h_ca);
834 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
840 	CL_ASSERT(p_vend->h_ca);
842 	status = ib_alloc_pd(p_vend->h_ca, IB_PDT_ALIAS, p_vend, &p_vend->h_pd);
845 		ib_close_ca(p_vend->h_ca, __osm_al_ca_destroy_callback);
846 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
853 	CL_ASSERT(p_vend->h_pd);
856 	OSM_LOG_EXIT(p_vend->p_log);
874 osm_vendor_bind(IN osm_vendor_t * const p_vend,
888 	OSM_LOG_ENTER(p_vend->p_log);
897 	osm_log(p_vend->p_log, OSM_LOG_INFO,
901 	if (p_vend->h_ca == 0) {
902 		osm_log(p_vend->p_log, OSM_LOG_DEBUG,
907 		status = __osm_vendor_open_ca(p_vend, port_guid);
909 			osm_log(p_vend->p_log, OSM_LOG_ERROR,
919 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
926 	p_bind->p_vend = p_vend;
928 	p_bind->port_num = osm_vendor_get_port_num(p_vend, port_guid);
957 	status = ib_get_spl_qp(p_vend->h_pd,
966 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
994 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
1003 	status = ib_create_av(p_vend->h_pd, &av, &p_bind->h_dr_av);
1005 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
1013 	if (osm_log_is_active(p_vend->p_log, OSM_LOG_DEBUG)) {
1014 		osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1020 	OSM_LOG_EXIT(p_vend->p_log);
1032 	osm_vendor_t *p_vend = p_bind->p_vend;
1035 	OSM_LOG_ENTER(p_vend->p_log);
1048 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
1060 	if (osm_log_get_level(p_vend->p_log) >= OSM_LOG_DEBUG) {
1061 		osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1067 	OSM_LOG_EXIT(p_vend->p_log);
1077 	osm_vendor_t *p_vend = p_bind->p_vend;
1080 	OSM_LOG_ENTER(p_vend->p_log);
1086 	if (osm_log_get_level(p_vend->p_log) >= OSM_LOG_DEBUG) {
1087 		osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1094 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
1099 	OSM_LOG_EXIT(p_vend->p_log);
1109 	osm_vendor_t *const p_vend = p_bind->p_vend;
1117 	OSM_LOG_ENTER(p_vend->p_log);
1134 			osm_log(p_vend->p_log, OSM_LOG_ERROR,
1165 		if (osm_log_is_active(p_vend->p_log, OSM_LOG_DEBUG)) {
1166 			osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1176 		status = ib_create_av(p_vend->h_pd, &av, &p_vw->h_av);
1178 			osm_log(p_vend->p_log, OSM_LOG_ERROR,
1189 		if (osm_log_is_active(p_vend->p_log, OSM_LOG_DEBUG)) {
1190 			osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1209 	p_elem->timeout_ms = p_vend->timeout;
1221 		osm_log(p_vend->p_log, OSM_LOG_DEBUG,
1230 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
1239 	OSM_LOG_EXIT(p_vend->p_log);
1248 	osm_vendor_t *p_vend = p_bind->p_vend;
1252 	OSM_LOG_ENTER(p_vend->p_log);
1262 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
1270 	status = ib_create_av(p_vend->h_pd, &av, &p_bind->h_dr_av);
1272 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
1281 	OSM_LOG_EXIT(p_vend->p_log);
1290 	osm_vendor_t *p_vend = p_bind->p_vend;
1294 	OSM_LOG_ENTER(p_vend->p_log);
1300 	status = ib_modify_ca(p_vend->h_ca, p_bind->port_num,
1304 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
1310 	OSM_LOG_EXIT(p_vend->p_log);
1315 void osm_vendor_set_debug(IN osm_vendor_t * const p_vend, IN int32_t level)