opensm/libvendor/osm_vendor_ts.c

83 __osm_ts_conv_mad_rcv_desc_to_osm_addr(IN osm_vendor_t * const p_vend,
146 	osm_vendor_t *p_vend = p_bind->p_vend;
151 	OSM_LOG_ENTER(p_vend->p_log);
163 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
169 	OSM_LOG_EXIT(p_vend->p_log);
175 void osm_vendor_construct(IN osm_vendor_t * const p_vend)
177 	memset(p_vend, 0, sizeof(*p_vend));
178 	cl_thread_construct(&(p_vend->smi_bind.poller));
179 	cl_thread_construct(&(p_vend->gsi_bind.poller));
185 void osm_vendor_destroy(IN osm_vendor_t * const p_vend)
187 	OSM_LOG_ENTER(p_vend->p_log);
188 	osm_transaction_mgr_destroy(p_vend);
192 	pthread_cancel(p_vend->smi_bind.poller.osd.id);
193 	pthread_cancel(p_vend->gsi_bind.poller.osd.id);
194 	cl_thread_destroy(&(p_vend->smi_bind.poller));
195 	cl_thread_destroy(&(p_vend->gsi_bind.poller));
196 	OSM_LOG_EXIT(p_vend->p_log);
216 osm_vendor_init(IN osm_vendor_t * const p_vend,
223 	p_vend->p_log = p_log;
224 	p_vend->p_transaction_mgr = NULL;
225 	osm_transaction_mgr_init(p_vend);
226 	p_vend->timeout = timeout;
229 	p_vend->smi_bind.ul_dev_fd = -1;
230 	p_vend->gsi_bind.ul_dev_fd = -1;
243 	osm_vendor_t *p_vend;
249 	p_vend = malloc(sizeof(*p_vend));
250 	if (p_vend != NULL) {
251 		memset(p_vend, 0, sizeof(*p_vend));
253 		status = osm_vendor_init(p_vend, p_log, timeout);
255 			osm_vendor_delete(&p_vend);
258 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
264 	return (p_vend);
281 	osm_log_t *const p_log = p_bind->p_vend->p_log;
289 		    osm_transaction_mgr_get_madw_for_tid(p_bind->p_vend,
381 	osm_log_t *const p_log = bind_info_p->p_vend->p_log;
455 	OSM_LOG_ENTER(p_bind->p_vend->p_log);
463 			osm_log(p_bind->p_vend->p_log, OSM_LOG_ERROR,
468 			osm_log(p_bind->p_vend->p_log, OSM_LOG_DEBUG,
482 			__osm_ts_conv_mad_rcv_desc_to_osm_addr(p_bind->p_vend,
501 	OSM_LOG_EXIT(p_bind->p_vend->p_log);
509 osm_vendor_bind(IN osm_vendor_t * const p_vend,
528 	OSM_LOG_ENTER(p_vend->p_log);
534 	osm_log(p_vend->p_log, OSM_LOG_INFO,
541 		p_bind = &(p_vend->smi_bind);
547 		p_bind = &(p_vend->gsi_bind);
554 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
567 	osm_log(p_vend->p_log, OSM_LOG_DEBUG,
572 	    osm_vendor_get_guid_ca_and_port(p_vend, port_guid, &hca_hndl,
575 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
585 	osm_log(p_vend->p_log, OSM_LOG_ERROR,
591 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
600 	p_bind->p_vend = p_vend;
622 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
637 	OSM_LOG_EXIT(p_vend->p_log);
651 	osm_vendor_t *p_vend = p_bind->p_vend;
653 	OSM_LOG_ENTER(p_vend->p_log);
662 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
675 	if (osm_log_get_level(p_vend->p_log) >= OSM_LOG_DEBUG) {
676 		osm_log(p_vend->p_log, OSM_LOG_DEBUG,
682 	OSM_LOG_EXIT(p_vend->p_log);
693 	osm_vendor_t *p_vend = p_bind->p_vend;
696 	OSM_LOG_ENTER(p_vend->p_log);
701 	if (osm_log_get_level(p_vend->p_log) >= OSM_LOG_DEBUG) {
702 		osm_log(p_vend->p_log, OSM_LOG_DEBUG,
718 	OSM_LOG_EXIT(p_vend->p_log);
731 	osm_vendor_t *const p_vend = p_bind->p_vend;
738 	OSM_LOG_ENTER(p_vend->p_log);
773 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
783 	OSM_LOG_EXIT(p_vend->p_log);
798 	osm_vendor_t *const p_vend = p_bind->p_vend;
802 	OSM_LOG_ENTER(p_vend->p_log);
815 			osm_log(p_vend->p_log, OSM_LOG_ERROR,
829 			osm_log(p_vend->p_log, OSM_LOG_ERROR,
846 	OSM_LOG_EXIT(p_vend->p_log);
856 	osm_vendor_t *p_vend = ((osm_ts_bind_info_t *) h_bind)->p_vend;
858 	OSM_LOG_ENTER(p_vend->p_log);
860 	osm_log(p_vend->p_log, OSM_LOG_DEBUG,
863 	OSM_LOG_EXIT(p_vend->p_log);
873 	osm_vendor_t *p_vend = p_bind->p_vend;
878 	OSM_LOG_ENTER(p_vend->p_log);
890 		osm_log(p_vend->p_log, OSM_LOG_ERROR,
896 	OSM_LOG_EXIT(p_vend->p_log);
901 void osm_vendor_set_debug(IN osm_vendor_t * const p_vend, IN int32_t level)