[ofa-general] ***SPAM*** [PATCH 2/2] opensm/osm_console.c: Add dump and clear redir perfmgr command support

[Hal Rosenstock]

Also, cosmetic commentary change

Signed-off-by: Hal Rosenstock <hal.rosenstock at gmail.com>

---

diff --git a/opensm/opensm/osm_console.c b/opensm/opensm/osm_console.c
index 97be931..a2160f9 100644
--- a/opensm/opensm/osm_console.c
+++ b/opensm/opensm/osm_console.c
@@ -211,7 +211,7 @@ static void help_dump_conf(FILE *out, int detail)
 static void help_perfmgr(FILE * out, int detail)
 {
 	fprintf(out,
-		"perfmgr [enable|disable|clear_counters|dump_counters|print_counters|sweep_time[seconds]]\n");
+		"perfmgr [enable|disable|clear_counters|dump_counters|print_counters|dump_redir|clear_redir|sweep_time[seconds]]\n");
 	if (detail) {
 		fprintf(out,
 			"perfmgr -- print the performance manager state\n");
@@ -225,6 +225,10 @@ static void help_perfmgr(FILE * out, int detail)
 			"   [dump_counters [mach]] -- dump the counters (optionally in [mach]ine readable format)\n");
 		fprintf(out,
 			"   [print_counters <nodename|nodeguid>] -- print the counters for the specified node\n");
+		fprintf(out,
+			"   [dump_redir [<nodename|nodeguid>]] -- dump the redirection table\n");
+		fprintf(out,
+			"   [clear_redir [<nodename|nodeguid>]] -- clear the redirection table\n");
 	}
 }
 #endif				/* ENABLE_OSM_PERF_MGR */
@@ -1033,8 +1037,8 @@ static void lidbalance_check(osm_opensm_t * p_osm,
 				port_max_count = port_count[i];
 		}
 
-		/* Output if this CA/router is being forwarded an unbalanced number of
-		 * times to a destination.
+		/* Output if this CA/router is being forwarded an unbalanced
+		 * number of times to a destination.
 		 */
 		if ((rem_max_count - rem_min_count) > 1) {
 			fprintf(out,
@@ -1135,6 +1139,152 @@ static void dump_conf_parse(char **p_last, osm_opensm_t * p_osm, FILE * out)
 }
 
 #ifdef ENABLE_OSM_PERF_MGR
+static __monitored_node_t *find_node_by_name(osm_opensm_t * p_osm,
+					     char *nodename)
+{
+	cl_map_item_t *item;
+	__monitored_node_t *node;
+
+	item = cl_qmap_head(&p_osm->perfmgr.monitored_map);
+        while (item != cl_qmap_end(&p_osm->perfmgr.monitored_map)) {
+                node = (__monitored_node_t *)item;
+                if (strcmp(node->name, nodename) == 0)
+			return node;
+                item = cl_qmap_next(item);
+        }
+
+	return NULL;
+}
+
+static __monitored_node_t *find_node_by_guid(osm_opensm_t * p_osm,
+					     uint64_t guid)
+{
+	cl_map_item_t *node;
+
+	node = cl_qmap_get(&p_osm->perfmgr.monitored_map, guid);
+	if (node != cl_qmap_end(&p_osm->perfmgr.monitored_map))
+		return (__monitored_node_t *)node;
+
+	return NULL;
+}
+
+static void dump_redir_entry(__monitored_node_t *p_mon_node, FILE * out)
+{
+	int port, redir;
+
+	/* only display monitored nodes with redirection info */
+	redir = 0;
+	for (port = (p_mon_node->esp0) ? 0 : 1;
+	     port < p_mon_node->redir_tbl_size; port++) {
+		if (p_mon_node->redir_port[port].redirection) {
+			if (!redir) {
+				fprintf(out, "   Node GUID       ESP0   Name\n");
+				fprintf(out, "   ---------       ----   ----\n");
+				fprintf(out, "   0x%" PRIx64 " %d      %s\n",
+					p_mon_node->guid, p_mon_node->esp0,
+					p_mon_node->name);
+				fprintf(out, "\n   Port Invalid  LIDs     PKey  QP    PKey Index\n");
+				fprintf(out, "   ---- -------  ----     ----  --    ----------\n");
+				redir = 1;
+			}
+			/* per port redir_t */
+			fprintf(out, "   %d    %d        %u->%u  0x%x 0x%x   %d\n",
+				port, p_mon_node->redir_port[port].invalid,
+				cl_ntoh16(p_mon_node->redir_port[port].orig_lid),
+				cl_ntoh16(p_mon_node->redir_port[port].redir_lid),
+				cl_ntoh16(p_mon_node->redir_port[port].redir_pkey),
+				cl_ntoh32(p_mon_node->redir_port[port].redir_qp),
+				p_mon_node->redir_port[port].redir_pkey_ix);
+		}
+	}
+	if (redir)
+		fprintf(out, "\n");
+}
+
+static void dump_redir(osm_opensm_t * p_osm, char *nodename, FILE * out)
+{
+	__monitored_node_t *p_mon_node;
+	uint64_t guid;
+
+	if (!p_osm->subn.opt.perfmgr_redir)
+		fprintf(out, "Perfmgr redirection not enabled\n");
+
+	fprintf(out, "\nRedirection Table\n");
+	fprintf(out, "-----------------\n");
+	cl_plock_acquire(p_osm->perfmgr.lock);
+	if (nodename) {
+		guid = strtoull(nodename, NULL, 0);
+		if (guid == 0 && errno)
+			p_mon_node = find_node_by_name(p_osm, nodename);
+		else
+			p_mon_node = find_node_by_guid(p_osm, guid);
+		if (p_mon_node)
+			dump_redir_entry(p_mon_node, out);
+		else {
+			if (guid == 0 && errno)
+				fprintf(out, "Node %s not found...\n", nodename);
+			else
+				fprintf(out, "Node 0x%" PRIx64 " not found...\n", guid);
+		}
+	} else {
+		p_mon_node = (__monitored_node_t *) cl_qmap_head(&p_osm->perfmgr.monitored_map);
+		while (p_mon_node != (__monitored_node_t *) cl_qmap_end(&p_osm->perfmgr.monitored_map)) {
+			dump_redir_entry(p_mon_node, out);
+			p_mon_node = (__monitored_node_t *) cl_qmap_next((const cl_map_item_t *)p_mon_node);
+		}
+	}
+	cl_plock_release(p_osm->perfmgr.lock);
+}
+
+static void clear_redir_entry(__monitored_node_t *p_mon_node)
+{
+	int port;
+	ib_net16_t orig_lid;
+
+	for (port = (p_mon_node->esp0) ? 0 : 1;
+	     port < p_mon_node->redir_tbl_size; port++) {
+		if (p_mon_node->redir_port[port].redirection) {
+			orig_lid = p_mon_node->redir_port[port].orig_lid;
+			memset(&p_mon_node->redir_port[port], 0,
+			       sizeof(redir_t));
+			p_mon_node->redir_port[port].orig_lid = orig_lid;
+		}
+	}
+}
+
+static void clear_redir(osm_opensm_t * p_osm, char *nodename, FILE * out)
+{
+	__monitored_node_t *p_mon_node;
+	uint64_t guid;
+
+	if (!p_osm->subn.opt.perfmgr_redir)
+		fprintf(out, "Perfmgr redirection not enabled\n");
+
+	cl_plock_acquire(p_osm->perfmgr.lock);
+	if (nodename) {
+		guid = strtoull(nodename, NULL, 0);
+		if (guid == 0 && errno)
+			p_mon_node = find_node_by_name(p_osm, nodename);
+		else
+			p_mon_node = find_node_by_guid(p_osm, guid);
+		if (p_mon_node)
+			clear_redir_entry(p_mon_node);
+		else {
+			if (guid == 0 && errno)
+				fprintf(out, "Node %s not found...\n", nodename);
+			else
+				fprintf(out, "Node 0x%" PRIx64 " not found...\n", guid);
+		}
+	} else {
+		p_mon_node = (__monitored_node_t *) cl_qmap_head(&p_osm->perfmgr.monitored_map);
+		while (p_mon_node != (__monitored_node_t *) cl_qmap_end(&p_osm->perfmgr.monitored_map)) {
+			clear_redir_entry(p_mon_node);
+			p_mon_node = (__monitored_node_t *) cl_qmap_next((const cl_map_item_t *)p_mon_node);
+		}
+	}
+	cl_plock_release(p_osm->perfmgr.lock);
+}
+
 static void perfmgr_parse(char **p_last, osm_opensm_t * p_osm, FILE * out)
 {
 	char *p_cmd;
@@ -1167,6 +1317,12 @@ static void perfmgr_parse(char **p_last, osm_opensm_t * p_osm, FILE * out)
 				fprintf(out,
 					"print_counters requires a node name or node GUID to be specified\n");
 			}
+		} else if (strcmp(p_cmd, "dump_redir") == 0) {
+			p_cmd = name_token(p_last);
+			dump_redir(p_osm, p_cmd, out);
+		} else if (strcmp(p_cmd, "clear_redir") == 0) {
+			p_cmd = name_token(p_last);
+			clear_redir(p_osm, p_cmd, out);
 		} else if (strcmp(p_cmd, "sweep_time") == 0) {
 			p_cmd = next_token(p_last);
 			if (p_cmd) {
@@ -1403,9 +1559,8 @@ int osm_console(osm_opensm_t * p_osm)
 		if (p_oct->out) {
 			loop_command.loop_function(p_osm, p_oct->out);
 			fflush(p_oct->out);
-		} else {
+		} else
 			loop_command.on = 0;
-		}
 	}
 
 	if (poll(fds, nfds, 1000) <= 0)