/freebsd/contrib/ofed/opensm/opensm/ |
H A D | osm_sm.c | 97 osm_sm_t * p_sm = p_ptr; in sm_sweeper() local 100 OSM_LOG_ENTER(p_sm->p_log); in sm_sweeper() 102 while (p_sm->thread_state == OSM_THREAD_STATE_RUN) { in sm_sweeper() 108 status = cl_event_wait_on(&p_sm->signal_event, in sm_sweeper() 112 OSM_LOG(p_sm->p_log, OSM_LOG_DEBUG, in sm_sweeper() 115 OSM_LOG(p_sm->p_log, OSM_LOG_ERROR, "ERR 2E01: " in sm_sweeper() 124 cl_spinlock_acquire(&p_sm->signal_lock); in sm_sweeper() 125 signals = p_sm->signal_mask; in sm_sweeper() 126 p_sm->signal_mask = 0; in sm_sweeper() 127 cl_spinlock_release(&p_sm->signal_lock); in sm_sweeper() [all …]
|
H A D | osm_remote_sm.c | 52 void osm_remote_sm_construct(IN osm_remote_sm_t * p_sm) in osm_remote_sm_construct() argument 54 memset(p_sm, 0, sizeof(*p_sm)); in osm_remote_sm_construct() 57 void osm_remote_sm_destroy(IN osm_remote_sm_t * p_sm) in osm_remote_sm_destroy() argument 59 memset(p_sm, 0, sizeof(*p_sm)); in osm_remote_sm_destroy() 62 void osm_remote_sm_init(IN osm_remote_sm_t * p_sm, in osm_remote_sm_init() argument 65 CL_ASSERT(p_sm); in osm_remote_sm_init() 67 osm_remote_sm_construct(p_sm); in osm_remote_sm_init() 69 p_sm->smi = *p_smi; in osm_remote_sm_init()
|
H A D | osm_congestion_control.c | 125 static void cc_setup_mad_data(osm_sm_t * p_sm) in cc_setup_mad_data() argument 127 osm_congestion_control_t *p_cc = &p_sm->p_subn->p_osm->cc; in cc_setup_mad_data() 128 osm_subn_opt_t *p_opt = &p_sm->p_subn->opt; in cc_setup_mad_data() 217 static ib_api_status_t cc_send_sw_cong_setting(osm_sm_t * p_sm, in cc_send_sw_cong_setting() argument 220 osm_congestion_control_t *p_cc = &p_sm->p_subn->p_osm->cc; in cc_send_sw_cong_setting() 227 OSM_LOG_ENTER(p_sm->p_log); in cc_send_sw_cong_setting() 231 force_update = p_physp->need_update || p_sm->p_subn->need_update; in cc_send_sw_cong_setting() 242 OSM_LOG(p_sm->p_log, OSM_LOG_ERROR, "ERR C101: " in cc_send_sw_cong_setting() 258 OSM_LOG_EXIT(p_sm->p_log); in cc_send_sw_cong_setting() 263 static ib_api_status_t cc_send_ca_cong_setting(osm_sm_t * p_sm, in cc_send_ca_cong_setting() argument [all …]
|
H A D | osm_sminfo_rcv.c | 273 IN const osm_remote_sm_t * p_sm, in smi_rcv_process_get_sm() argument 280 p_smi = &p_sm->smi; in smi_rcv_process_get_sm() 339 if (sm->master_sm_guid == p_sm->smi.guid) { in smi_rcv_process_get_sm() 423 osm_remote_sm_t *p_sm; in smi_rcv_process_get_response() local 487 p_sm = (osm_remote_sm_t *) cl_qmap_get(p_sm_tbl, port_guid); in smi_rcv_process_get_response() 488 if (p_sm == (osm_remote_sm_t *) cl_qmap_end(p_sm_tbl)) { in smi_rcv_process_get_response() 489 p_sm = malloc(sizeof(*p_sm)); in smi_rcv_process_get_response() 490 if (p_sm == NULL) { in smi_rcv_process_get_response() 496 osm_remote_sm_init(p_sm, p_smi); in smi_rcv_process_get_response() 498 cl_qmap_insert(p_sm_tbl, port_guid, &p_sm->map_item); in smi_rcv_process_get_response() [all …]
|
H A D | osm_state_mgr.c | 873 osm_remote_sm_t *p_sm; in state_mgr_exists_other_master_sm() local 882 for (p_sm = (osm_remote_sm_t *) cl_qmap_head(p_sm_tbl); in state_mgr_exists_other_master_sm() 883 p_sm != (osm_remote_sm_t *) cl_qmap_end(p_sm_tbl); in state_mgr_exists_other_master_sm() 884 p_sm = (osm_remote_sm_t *) cl_qmap_next(&p_sm->map_item)) { in state_mgr_exists_other_master_sm() 886 p_node = osm_get_node_by_guid(sm->p_subn, p_sm->smi.guid); in state_mgr_exists_other_master_sm() 887 if (ib_sminfo_get_state(&p_sm->smi) == IB_SMINFO_STATE_MASTER) { in state_mgr_exists_other_master_sm() 890 " (node %s)\n", cl_ntoh64(p_sm->smi.guid), in state_mgr_exists_other_master_sm() 892 p_sm_res = p_sm; in state_mgr_exists_other_master_sm() 911 osm_remote_sm_t *p_sm = NULL; in state_mgr_get_highest_sm() local 927 for (p_sm = (osm_remote_sm_t *) cl_qmap_head(p_sm_tbl); in state_mgr_get_highest_sm() [all …]
|
H A D | osm_port_info_rcv.c | 92 osm_remote_sm_t *p_sm; in pi_rcv_process_endport() local 148 p_sm = in pi_rcv_process_endport() 151 if (p_sm != (osm_remote_sm_t *) cl_qmap_end(p_sm_tbl)) in pi_rcv_process_endport() 153 p_sm->smi.pri_state = in pi_rcv_process_endport() 154 0xF0 & p_sm->smi.pri_state; in pi_rcv_process_endport() 191 p_sm = in pi_rcv_process_endport() 194 if (p_sm != (osm_remote_sm_t *) cl_qmap_end(p_sm_tbl)) in pi_rcv_process_endport() 195 free(p_sm); in pi_rcv_process_endport()
|
H A D | osm_drop_mgr.c | 171 osm_remote_sm_t *p_sm; in drop_mgr_remove_port() local 258 p_sm = (osm_remote_sm_t *) cl_qmap_remove(p_sm_guid_tbl, port_guid); in drop_mgr_remove_port() 259 if (p_sm != (osm_remote_sm_t *) cl_qmap_end(p_sm_guid_tbl)) { in drop_mgr_remove_port() 264 free(p_sm); in drop_mgr_remove_port()
|
H A D | osm_port.c | 676 IN const struct osm_sm * p_sm) in osm_physp_set_port_info() argument 698 osm_db_guid2mkey_set(p_sm->p_subn->p_g2m, in osm_physp_set_port_info()
|
H A D | osm_subnet.c | 263 osm_sm_t *p_sm = &p_subn->p_osm->sm; in opts_setup_sminfo_polling_timeout() local 266 cl_timer_stop(&p_sm->polling_timer); in opts_setup_sminfo_polling_timeout() 267 cl_timer_start(&p_sm->polling_timer, sminfo_polling_timeout); in opts_setup_sminfo_polling_timeout() 272 osm_sm_t *p_sm = &p_subn->p_osm->sm; in opts_setup_sm_priority() local 275 osm_set_sm_priority(p_sm, sm_priority); in opts_setup_sm_priority()
|
H A D | osm_ucast_dfsssp.c | 1708 static int update_mcft(osm_sm_t * p_sm, vertex_t * adj_list, in update_mcft() argument 1722 OSM_LOG_ENTER(p_sm->p_log); in update_mcft() 1729 OSM_LOG(p_sm->p_log, OSM_LOG_VERBOSE, in update_mcft() 1797 OSM_LOG_EXIT(p_sm->p_log); in update_mcft()
|
H A D | osm_sa.c | 159 ib_api_status_t osm_sa_init(IN osm_sm_t * p_sm, IN osm_sa_t * p_sa, in osm_sa_init() argument 171 p_sa->sm = p_sm; in osm_sa_init()
|
/freebsd/contrib/ofed/opensm/include/opensm/ |
H A D | osm_sm.h | 192 void osm_sm_construct(IN osm_sm_t * p_sm); 221 void osm_sm_shutdown(IN osm_sm_t * p_sm); 244 void osm_sm_destroy(IN osm_sm_t * p_sm); 272 ib_api_status_t osm_sm_init(IN osm_sm_t * p_sm, IN osm_subn_t * p_subn, 326 void osm_sm_signal(IN osm_sm_t * p_sm, osm_signal_t signal); 350 void osm_sm_sweep(IN osm_sm_t * p_sm); 374 ib_api_status_t osm_sm_bind(IN osm_sm_t * p_sm, IN ib_net64_t port_guid); 647 static inline cl_status_t osm_sm_wait_for_subnet_up(IN osm_sm_t * p_sm, in osm_sm_wait_for_subnet_up() argument 651 return cl_event_wait_on(&p_sm->subnet_up_event, wait_us, interruptible); in osm_sm_wait_for_subnet_up()
|
H A D | osm_remote_sm.h | 114 void osm_remote_sm_construct(IN osm_remote_sm_t * p_sm); 143 void osm_remote_sm_destroy(IN osm_remote_sm_t * p_sm); 171 void osm_remote_sm_init(IN osm_remote_sm_t * p_sm, IN const ib_sm_info_t * p_smi);
|
H A D | osm_sa.h | 352 ib_api_status_t osm_sa_init(IN osm_sm_t * p_sm, IN osm_sa_t * p_sa,
|
H A D | osm_port.h | 455 IN const struct osm_sm * p_sm);
|