opensm/opensm/osm_node_info_rcv.c

68 static void report_duplicated_guid(IN osm_sm_t * sm, osm_physp_t * p_physp,
78 	OSM_LOG(sm->p_log, OSM_LOG_SYS | OSM_LOG_ERROR, "ERR 0D01: "
90 	osm_dump_dr_path_v2(sm->p_log, osm_physp_get_dr_path_ptr(p_physp),
95 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D05: "
98 	osm_dump_dr_path_v2(sm->p_log, &path, FILE_ID, OSM_LOG_ERROR);
101 static void requery_dup_node_info(IN osm_sm_t * sm, osm_physp_t * p_physp,
109 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D0D: "
116 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D08: "
129 	status = osm_req_get(sm, &path, IB_MAD_ATTR_NODE_INFO, 0,
133 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D02: "
141 static void ni_rcv_set_links(IN osm_sm_t * sm, osm_node_t * p_node,
148 	OSM_LOG_ENTER(sm->p_log);
156 		OSM_LOG(sm->p_log, OSM_LOG_DEBUG,
162 	p_neighbor_node = osm_get_node_by_guid(sm->p_subn,
165 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D10: "
179 		OSM_LOG(sm->p_log, OSM_LOG_DEBUG, "Link already exists\n");
185 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR OD0E: "
200 		sm->p_subn->force_heavy_sweep = TRUE;
205 	    sm->p_subn->force_heavy_sweep == FALSE &&
226 			OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR OD0F: "
234 			report_duplicated_guid(sm, p_physp, p_neighbor_node,
236 			sm->p_subn->force_heavy_sweep = TRUE;
238 			requery_dup_node_info(sm, p_physp->p_remote_physp,
241 			requery_dup_node_info(sm, p_physp,
253 	    port_num != 0 && cl_qmap_count(&sm->p_subn->sw_guid_tbl) == 0) {
254 		OSM_LOG(sm->p_log, OSM_LOG_VERBOSE,
260 			OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR OD1D: "
267 		osm_dump_dr_path_v2(sm->p_log, osm_physp_get_dr_path_ptr(p_physp),
270 		if (sm->p_subn->opt.exit_on_fatal == TRUE) {
271 			osm_log_v2(sm->p_log, OSM_LOG_SYS, FILE_ID,
279 	OSM_LOG(sm->p_log, OSM_LOG_DEBUG,
286 	if (sm->ucast_mgr.cache_valid)
287 		osm_ucast_cache_check_new_link(&sm->ucast_mgr, p_node, port_num,
299 	osm_db_neighbor_set(sm->p_subn->p_neighbor,
304 	osm_db_neighbor_set(sm->p_subn->p_neighbor,
311 	OSM_LOG_EXIT(sm->p_log);
314 static void ni_rcv_get_port_info(IN osm_sm_t * sm, IN osm_node_t * node,
328 	if (sm->p_subn->opt.fdr10)
335 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR OD1E: "
349 	status = osm_req_get(sm, osm_physp_get_dr_path_ptr(physp),
353 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR OD02: "
357 		status = osm_req_get(sm,
363 			OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D0B: "
372 void osm_req_get_node_desc(IN osm_sm_t * sm, osm_physp_t * p_physp)
377 	OSM_LOG_ENTER(sm->p_log);
382 	status = osm_req_get(sm, osm_physp_get_dr_path_ptr(p_physp),
386 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D03: "
390 	OSM_LOG_EXIT(sm->p_log);
396 static void ni_rcv_get_node_desc(IN osm_sm_t * sm, IN osm_node_t * p_node,
404 	OSM_LOG_ENTER(sm->p_log);
420 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR OD1F: "
427 	osm_req_get_node_desc(sm, p_physp);
429 	OSM_LOG_EXIT(sm->p_log);
435 static void ni_rcv_process_new_ca_or_router(IN osm_sm_t * sm,
439 	OSM_LOG_ENTER(sm->p_log);
441 	ni_rcv_get_port_info(sm, p_node, p_madw);
449 		sm->p_subn->sm_port_guid = p_node->node_info.port_guid;
451 	OSM_LOG_EXIT(sm->p_log);
457 static void ni_rcv_process_existing_ca_or_router(IN osm_sm_t * sm,
469 	OSM_LOG_ENTER(sm->p_log);
480 	p_port = osm_get_port_by_guid(sm->p_subn, p_ni->port_guid);
482 		OSM_LOG(sm->p_log, OSM_LOG_VERBOSE,
490 			OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D04: "
499 		    (osm_port_t *) cl_qmap_insert(&sm->p_subn->port_guid_tbl,
507 			OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D12: "
518 			OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D11: "
527 			(osm_alias_guid_t *) cl_qmap_insert(&sm->p_subn->alias_port_guid_tbl,
532 			OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D13: "
548 		if (sm->p_subn->sm_state == IB_SMINFO_STATE_MASTER)
555 			OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D1C: "
573 	ni_rcv_get_port_info(sm, p_node, p_madw);
576 	OSM_LOG_EXIT(sm->p_log);
579 static void ni_rcv_process_switch(IN osm_sm_t * sm, IN osm_node_t * p_node,
588 	OSM_LOG_ENTER(sm->p_log);
603 	status = osm_req_get(sm, path, IB_MAD_ATTR_SWITCH_INFO, 0, TRUE, 0,
607 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D06: "
611 	OSM_LOG_EXIT(sm->p_log);
617 static void ni_rcv_process_existing_switch(IN osm_sm_t * sm,
621 	OSM_LOG_ENTER(sm->p_log);
628 		ni_rcv_process_switch(sm, p_node, p_madw);
630 	OSM_LOG_EXIT(sm->p_log);
636 static void ni_rcv_process_new_switch(IN osm_sm_t * sm, IN osm_node_t * p_node,
639 	OSM_LOG_ENTER(sm->p_log);
641 	ni_rcv_process_switch(sm, p_node, p_madw);
649 		sm->p_subn->sm_port_guid = p_node->node_info.port_guid;
651 	OSM_LOG_EXIT(sm->p_log);
657 static void ni_rcv_process_new(IN osm_sm_t * sm, IN const osm_madw_t * p_madw)
672 	OSM_LOG_ENTER(sm->p_log);
679 	osm_dump_smp_dr_path_v2(sm->p_log, p_smp, FILE_ID, OSM_LOG_VERBOSE);
681 	OSM_LOG(sm->p_log, OSM_LOG_VERBOSE,
688 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D0A: "
700 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D07: "
711 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D14: "
721 	    (osm_port_t *) cl_qmap_insert(&sm->p_subn->port_guid_tbl,
728 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D15: "
732 		osm_dump_dr_path_v2(sm->p_log,
735 		osm_dump_dr_path_v2(sm->p_log,
747 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D18: "
756 		(osm_alias_guid_t *) cl_qmap_insert(&sm->p_subn->alias_port_guid_tbl,
761 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D19: "
775 	if (sm->p_subn->sm_state == IB_SMINFO_STATE_MASTER)
782 			OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D1A: "
785 			p_rtr_guid_tbl = &sm->p_subn->rtr_guid_tbl;
791 				OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D1B: "
799 	    (osm_node_t *) cl_qmap_insert(&sm->p_subn->node_guid_tbl,
808 		OSM_LOG(sm->p_log, OSM_LOG_VERBOSE,
813 		ni_rcv_set_links(sm, p_node, port_num, p_ni_context);
816 		ni_rcv_set_links(sm, p_node, port_num, p_ni_context);
819 	ni_rcv_get_node_desc(sm, p_node, p_madw);
824 		ni_rcv_process_new_ca_or_router(sm, p_node, p_madw);
827 		ni_rcv_process_new_switch(sm, p_node, p_madw);
830 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D16: "
837 	OSM_LOG_EXIT(sm->p_log);
843 static void ni_rcv_process_existing(IN osm_sm_t * sm, IN osm_node_t * p_node,
851 	OSM_LOG_ENTER(sm->p_log);
858 	OSM_LOG(sm->p_log, OSM_LOG_VERBOSE,
866 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D0C: "
885 		ni_rcv_process_existing_ca_or_router(sm, p_node, p_madw);
889 		ni_rcv_process_existing_switch(sm, p_node, p_madw);
893 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D09: "
900 		OSM_LOG(sm->p_log, OSM_LOG_DEBUG, "Updated SysImageGUID: 0x%"
905 	ni_rcv_set_links(sm, p_node, port_num, p_ni_context);
909 	OSM_LOG_EXIT(sm->p_log);
914 	osm_sm_t *sm = context;
920 	CL_ASSERT(sm);
922 	OSM_LOG_ENTER(sm->p_log);
932 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D16: "
934 		osm_dump_smp_dr_path_v2(sm->p_log, p_smp, FILE_ID, OSM_LOG_ERROR);
939 		OSM_LOG(sm->p_log, OSM_LOG_ERROR, "ERR 0D17: "
941 		osm_dump_smp_dr_path_v2(sm->p_log, p_smp, FILE_ID, OSM_LOG_ERROR);
946 		OSM_LOG(sm->p_log, OSM_LOG_DEBUG,
958 	CL_PLOCK_EXCL_ACQUIRE(sm->p_lock);
959 	p_node = osm_get_node_by_guid(sm->p_subn, p_ni->node_guid);
961 	osm_dump_node_info_v2(sm->p_log, p_ni, FILE_ID, OSM_LOG_DEBUG);
964 		ni_rcv_process_new(sm, p_madw);
966 		ni_rcv_process_existing(sm, p_node, p_madw);
968 	CL_PLOCK_RELEASE(sm->p_lock);
971 	OSM_LOG_EXIT(sm->p_log);