infiniband-diags: initial port of linux ib diags
[mirror/winof/.git] / tools / infiniband_diags / src / ibportstate.c
1 /*\r
2  * Copyright (c) 2004-2008 Voltaire Inc.  All rights reserved.\r
3  *\r
4  * This software is available to you under a choice of one of two\r
5  * licenses.  You may choose to be licensed under the terms of the GNU\r
6  * General Public License (GPL) Version 2, available from the file\r
7  * COPYING in the main directory of this source tree, or the\r
8  * OpenIB.org BSD license below:\r
9  *\r
10  *     Redistribution and use in source and binary forms, with or\r
11  *     without modification, are permitted provided that the following\r
12  *     conditions are met:\r
13  *\r
14  *      - Redistributions of source code must retain the above\r
15  *        copyright notice, this list of conditions and the following\r
16  *        disclaimer.\r
17  *\r
18  *      - Redistributions in binary form must reproduce the above\r
19  *        copyright notice, this list of conditions and the following\r
20  *        disclaimer in the documentation and/or other materials\r
21  *        provided with the distribution.\r
22  *\r
23  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,\r
24  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF\r
25  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND\r
26  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS\r
27  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN\r
28  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN\r
29  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE\r
30  * SOFTWARE.\r
31  *\r
32  */\r
33 \r
34 #if HAVE_CONFIG_H\r
35 #  include <config.h>\r
36 #endif /* HAVE_CONFIG_H */\r
37 \r
38 #include <stdio.h>\r
39 #include <stdlib.h>\r
40 #include <unistd.h>\r
41 #include <stdarg.h>\r
42 #include <time.h>\r
43 #include <string.h>\r
44 #include <getopt.h>\r
45 \r
46 #include <infiniband/common.h>\r
47 #include <infiniband/umad.h>\r
48 #include <infiniband/mad.h>\r
49 \r
50 #include "ibdiag_common.h"\r
51 \r
52 #undef DEBUG\r
53 #define DEBUG   if (verbose>1) IBWARN\r
54 \r
55 static int dest_type = IB_DEST_LID;\r
56 static int verbose;\r
57 \r
58 char *argv0 = "ibportstate";\r
59 \r
60 /*******************************************/\r
61 \r
62 static int\r
63 get_node_info(ib_portid_t *dest, uint8_t *data)\r
64 {\r
65         int node_type;\r
66 \r
67         if (!smp_query(data, dest, IB_ATTR_NODE_INFO, 0, 0))\r
68                 return -1;\r
69 \r
70         node_type = mad_get_field(data, 0, IB_NODE_TYPE_F);\r
71         if (node_type == IB_NODE_SWITCH)        /* Switch NodeType ? */\r
72                 return 0;\r
73         else\r
74                 return 1;\r
75 }\r
76 \r
77 static int\r
78 get_port_info(ib_portid_t *dest, uint8_t *data, int portnum, int port_op)\r
79 {\r
80         char buf[2048];\r
81         char val[64];\r
82 \r
83         if (!smp_query(data, dest, IB_ATTR_PORT_INFO, portnum, 0))\r
84                 return -1;\r
85 \r
86         if (port_op != 4) {\r
87                 mad_dump_portstates(buf, sizeof buf, data, sizeof data);\r
88                 mad_decode_field(data, IB_PORT_LINK_WIDTH_SUPPORTED_F, val);\r
89                 mad_dump_field(IB_PORT_LINK_WIDTH_SUPPORTED_F, buf + strlen(buf), sizeof buf - strlen(buf), val);\r
90                 sprintf(buf+strlen(buf), "%s", "\n");\r
91                 mad_decode_field(data, IB_PORT_LINK_WIDTH_ENABLED_F, val);\r
92                 mad_dump_field(IB_PORT_LINK_WIDTH_ENABLED_F, buf + strlen(buf), sizeof buf - strlen(buf), val);\r
93                 sprintf(buf+strlen(buf), "%s", "\n");\r
94                 mad_decode_field(data, IB_PORT_LINK_WIDTH_ACTIVE_F, val);\r
95                 mad_dump_field(IB_PORT_LINK_WIDTH_ACTIVE_F, buf + strlen(buf), sizeof buf - strlen(buf), val);\r
96                 sprintf(buf+strlen(buf), "%s", "\n");\r
97                 mad_decode_field(data, IB_PORT_LINK_SPEED_SUPPORTED_F, val);\r
98                 mad_dump_field(IB_PORT_LINK_SPEED_SUPPORTED_F, buf + strlen(buf), sizeof buf - strlen(buf), val);\r
99                 sprintf(buf+strlen(buf), "%s", "\n");\r
100                 mad_decode_field(data, IB_PORT_LINK_SPEED_ENABLED_F, val);\r
101                 mad_dump_field(IB_PORT_LINK_SPEED_ENABLED_F, buf + strlen(buf), sizeof buf - strlen(buf), val);\r
102                 sprintf(buf+strlen(buf), "%s", "\n");\r
103                 mad_decode_field(data, IB_PORT_LINK_SPEED_ACTIVE_F, val);\r
104                 mad_dump_field(IB_PORT_LINK_SPEED_ACTIVE_F, buf + strlen(buf), sizeof buf - strlen(buf), val);\r
105                 sprintf(buf+strlen(buf), "%s", "\n");\r
106         } else {\r
107                 mad_decode_field(data, IB_PORT_LINK_SPEED_ENABLED_F, val);\r
108                 mad_dump_field(IB_PORT_LINK_SPEED_ENABLED_F, buf, sizeof buf, val);\r
109                 sprintf(buf+strlen(buf), "%s", "\n");\r
110         }\r
111 \r
112         printf("# Port info: %s port %d\n%s", portid2str(dest), portnum, buf);\r
113         return 0;\r
114 }\r
115 \r
116 static int\r
117 set_port_info(ib_portid_t *dest, uint8_t *data, int portnum, int port_op)\r
118 {\r
119         char buf[2048];\r
120         char val[64];\r
121 \r
122         if (!smp_set(data, dest, IB_ATTR_PORT_INFO, portnum, 0))\r
123                 return -1;\r
124 \r
125         if (port_op != 4)\r
126                 mad_dump_portstates(buf, sizeof buf, data, sizeof data);\r
127         else {\r
128                 mad_decode_field(data, IB_PORT_LINK_SPEED_ENABLED_F, val);\r
129                 mad_dump_field(IB_PORT_LINK_SPEED_ENABLED_F, buf, sizeof buf, val);\r
130                 sprintf(buf+strlen(buf), "%s", "\n");\r
131         }\r
132 \r
133         printf("\nAfter PortInfo set:\n");\r
134         printf("# Port info: %s port %d\n%s", portid2str(dest), portnum, buf);\r
135         return 0;\r
136 }\r
137 \r
138 static int\r
139 get_link_width(int lwe, int lws)\r
140 {\r
141         if (lwe == 255)\r
142                 return lws;\r
143         else\r
144                 return lwe;\r
145 }\r
146 \r
147 static int\r
148 get_link_speed(int lse, int lss)\r
149 {\r
150         if (lse == 15)\r
151                 return lss;\r
152         else\r
153                 return lse;\r
154 }\r
155 \r
156 static void\r
157 validate_width(int width, int peerwidth, int lwa)\r
158 {\r
159         if ((width & 0x8) && (peerwidth & 0x8)) {\r
160                 if (lwa != 8)\r
161                         IBWARN("Peer ports operating at active width %d rather than 8 (12x)", lwa);\r
162         } else {\r
163                 if ((width & 0x4) && (peerwidth & 0x4)) {\r
164                         if (lwa != 4)\r
165                                 IBWARN("Peer ports operating at active width %d rather than 4 (8x)", lwa);\r
166                 } else {\r
167                         if ((width & 0x2) && (peerwidth & 0x2)) {\r
168                                 if (lwa != 2)\r
169                                         IBWARN("Peer ports operating at active width %d rather than 2 (4x)", lwa);\r
170                         } else {\r
171                                 if ((width & 0x1) && (peerwidth & 0x1)) {\r
172                                         if (lwa != 1)\r
173                                                 IBWARN("Peer ports operating at active width %d rather than 1 (1x)", lwa);\r
174                                 }\r
175                         }\r
176                 }\r
177         }\r
178 }\r
179 \r
180 static void\r
181 validate_speed(int speed, int peerspeed, int lsa)\r
182 {\r
183         if ((speed & 0x4) && (peerspeed & 0x4)) {\r
184                 if (lsa != 4)\r
185                         IBWARN("Peer ports operating at active speed %d rather than  4 (10.0 Gbps)", lsa);\r
186         } else {\r
187                 if ((speed & 0x2) && (peerspeed & 0x2)) {\r
188                         if (lsa != 2)\r
189                                 IBWARN("Peer ports operating at active speed %d rather than 2 (5.0 Gbps)", lsa);\r
190                 } else {\r
191                         if ((speed & 0x1) && (peerspeed & 0x1)) {\r
192                                 if (lsa != 1)\r
193                                         IBWARN("Peer ports operating at active speed %d rather than 1 (2.5 Gbps)", lsa);\r
194                         }\r
195                 }\r
196         }\r
197 }\r
198 \r
199 void\r
200 usage(void)\r
201 {\r
202         char *basename;\r
203 \r
204         if (!(basename = strrchr(argv0, '/')))\r
205                 basename = argv0;\r
206         else\r
207                 basename++;\r
208 \r
209         fprintf(stderr, "Usage: %s [-d(ebug) -e(rr_show) -v(erbose) -D(irect) -G(uid) -s smlid -V(ersion) -C ca_name -P ca_port "\r
210                         "-t(imeout) timeout_ms] <dest dr_path|lid|guid> <portnum> [<op>]\n",\r
211                         basename);\r
212         fprintf(stderr, "\tsupported ops: enable, disable, reset, speed, query\n");\r
213         fprintf(stderr, "\n\texamples:\n");\r
214         fprintf(stderr, "\t\t%s 3 1 disable\t\t\t# by lid\n", basename);\r
215         fprintf(stderr, "\t\t%s -G 0x2C9000100D051 1 enable\t# by guid\n", basename);\r
216         fprintf(stderr, "\t\t%s -D 0 1\t\t\t# (query) by direct route\n", basename);\r
217         fprintf(stderr, "\t\t%s 3 1 reset\t\t\t# by lid\n", basename);\r
218         fprintf(stderr, "\t\t%s 3 1 speed 1\t\t\t# by lid\n", basename);\r
219         exit(-1);\r
220 }\r
221 \r
222 int\r
223 main(int argc, char **argv)\r
224 {\r
225         int mgmt_classes[3] = {IB_SMI_CLASS, IB_SMI_DIRECT_CLASS, IB_SA_CLASS};\r
226         ib_portid_t portid = {0};\r
227         ib_portid_t *sm_id = 0, sm_portid = {0};\r
228         extern int ibdebug;\r
229         int err;\r
230         int timeout = 0, udebug = 0;\r
231         char *ca = 0;\r
232         int ca_port = 0;\r
233         int port_op = 0;        /* default to query */\r
234         int speed = 15;\r
235         int is_switch = 1;\r
236         int state, physstate, lwe, lws, lwa, lse, lss, lsa;\r
237         int peerlocalportnum, peerlwe, peerlws, peerlwa, peerlse, peerlss, peerlsa;\r
238         int width, peerwidth, peerspeed;\r
239         uint8_t data[IB_SMP_DATA_SIZE];\r
240         ib_portid_t peerportid = {0};\r
241         int portnum = 0;\r
242         ib_portid_t selfportid = {0};\r
243         int selfport = 0;\r
244 \r
245         static char const str_opts[] = "C:P:t:s:devDGVhu";\r
246         static const struct option long_opts[] = {\r
247                 { "C", 1, 0, 'C'},\r
248                 { "P", 1, 0, 'P'},\r
249                 { "debug", 0, 0, 'd'},\r
250                 { "err_show", 0, 0, 'e'},\r
251                 { "verbose", 0, 0, 'v'},\r
252                 { "Direct", 0, 0, 'D'},\r
253                 { "Guid", 0, 0, 'G'},\r
254                 { "timeout", 1, 0, 't'},\r
255                 { "s", 1, 0, 's'},\r
256                 { "Version", 0, 0, 'V'},\r
257                 { "help", 0, 0, 'h'},\r
258                 { "usage", 0, 0, 'u'},\r
259                 { }\r
260         };\r
261 \r
262         argv0 = argv[0];\r
263 \r
264         while (1) {\r
265                 int ch = getopt_long(argc, argv, str_opts, long_opts, NULL);\r
266                 if ( ch == -1 )\r
267                         break;\r
268                 switch(ch) {\r
269                 case 'd':\r
270                         ibdebug++;\r
271                         madrpc_show_errors(1);\r
272                         umad_debug(udebug);\r
273                         udebug++;\r
274                         break;\r
275                 case 'e':\r
276                         madrpc_show_errors(1);\r
277                         break;\r
278                 case 'D':\r
279                         dest_type = IB_DEST_DRPATH;\r
280                         break;\r
281                 case 'G':\r
282                         dest_type = IB_DEST_GUID;\r
283                         break;\r
284                 case 'C':\r
285                         ca = optarg;\r
286                         break;\r
287                 case 'P':\r
288                         ca_port = strtoul(optarg, 0, 0);\r
289                         break;\r
290                 case 's':\r
291                         if (ib_resolve_portid_str(&sm_portid, optarg, IB_DEST_LID, 0) < 0)\r
292                                 IBERROR("can't resolve SM destination port %s", optarg);\r
293                         sm_id = &sm_portid;\r
294                         break;\r
295                 case 't':\r
296                         timeout = strtoul(optarg, 0, 0);\r
297                         madrpc_set_timeout(timeout);\r
298                         break;\r
299                 case 'v':\r
300                         verbose++;\r
301                         break;\r
302                 case 'V':\r
303                         fprintf(stderr, "%s %s\n", argv0, get_build_version() );\r
304                         exit(-1);\r
305                 default:\r
306                         usage();\r
307                         break;\r
308                 }\r
309         }\r
310         argc -= optind;\r
311         argv += optind;\r
312 \r
313         if (argc < 2)\r
314                 usage();\r
315 \r
316         madrpc_init(ca, ca_port, mgmt_classes, 3);\r
317 \r
318         if (ib_resolve_portid_str(&portid, argv[0], dest_type, sm_id) < 0)\r
319                 IBERROR("can't resolve destination port %s", argv[0]);\r
320 \r
321         /* First, make sure it is a switch port if it is a "set" */\r
322         if (argc >= 3) {\r
323                 if (!strcmp(argv[2], "enable"))\r
324                         port_op = 1;\r
325                 else if (!strcmp(argv[2], "disable"))\r
326                         port_op = 2;\r
327                 else if (!strcmp(argv[2], "reset"))\r
328                         port_op = 3;\r
329                 else if (!strcmp(argv[2], "speed")) {\r
330                         if (argc < 4)\r
331                                 IBERROR("speed requires an additional parameter");\r
332                         port_op = 4;\r
333                         /* Parse speed value */\r
334                         speed = strtoul(argv[3], 0, 0);\r
335                         if (speed > 15)\r
336                                 IBERROR("invalid speed value %d", speed);\r
337                 }\r
338         }\r
339 \r
340         err = get_node_info(&portid, data);\r
341         if (err < 0)\r
342                 IBERROR("smp query nodeinfo failed");\r
343         if (err) {              /* not switch */\r
344                 if (port_op == 0)       /* query op */\r
345                         is_switch = 0;\r
346                 else if (port_op != 4)  /* other than speed op */\r
347                         IBERROR("smp query nodeinfo: Node type not switch");\r
348         }\r
349 \r
350         if (argc-1 > 0)\r
351                 portnum = strtol(argv[1], 0, 0);\r
352 \r
353         if (port_op)\r
354                 printf("Initial PortInfo:\n");\r
355         else\r
356                 printf("PortInfo:\n");\r
357         err = get_port_info(&portid, data, portnum, port_op);\r
358         if (err < 0)\r
359                 IBERROR("smp query portinfo failed");\r
360 \r
361         /* Only if one of the "set" options is chosen */\r
362         if (port_op) {\r
363                 if (port_op == 1)               /* Enable port */\r
364                         mad_set_field(data, 0, IB_PORT_PHYS_STATE_F, 2);        /* Polling */\r
365                 else if ((port_op == 2) || (port_op == 3)) { /* Disable port */\r
366                         mad_set_field(data, 0, IB_PORT_STATE_F, 1);             /* Down */\r
367                         mad_set_field(data, 0, IB_PORT_PHYS_STATE_F, 3);        /* Disabled */\r
368                 } else if (port_op == 4) {      /* Set speed */\r
369                         mad_set_field(data, 0, IB_PORT_LINK_SPEED_ENABLED_F, speed);\r
370                         mad_set_field(data, 0, IB_PORT_STATE_F, 0);\r
371                         mad_set_field(data, 0, IB_PORT_PHYS_STATE_F, 0);\r
372                 }\r
373 \r
374                 err = set_port_info(&portid, data, portnum, port_op);\r
375                 if (err < 0)\r
376                         IBERROR("smp set portinfo failed");\r
377 \r
378                 if (port_op == 3) {     /* Reset port - so also enable */\r
379                         mad_set_field(data, 0, IB_PORT_PHYS_STATE_F, 2);        /* Polling */\r
380                         err = set_port_info(&portid, data, portnum, port_op);\r
381                         if (err < 0)\r
382                                 IBERROR("smp set portinfo failed");\r
383                 }\r
384         } else {        /* query op */\r
385                 /* only compare peer port if switch port */\r
386                 if (is_switch) {\r
387                         /* First, exclude SP0 */\r
388                         if (portnum) {\r
389                                 /* Now, make sure PortState is Active */\r
390                                 /* Or is PortPhysicalState LinkUp sufficient ? */\r
391                                 mad_decode_field(data, IB_PORT_STATE_F, &state);\r
392                                 mad_decode_field(data, IB_PORT_PHYS_STATE_F, &physstate);\r
393                                 if (state == 4) {       /* Active */\r
394                                         mad_decode_field(data, IB_PORT_LINK_WIDTH_ENABLED_F, &lwe );\r
395                                         mad_decode_field(data, IB_PORT_LINK_WIDTH_SUPPORTED_F, &lws);\r
396                                         mad_decode_field(data, IB_PORT_LINK_WIDTH_ACTIVE_F, &lwa);\r
397                                         mad_decode_field(data, IB_PORT_LINK_SPEED_SUPPORTED_F, &lss);\r
398                                         mad_decode_field(data, IB_PORT_LINK_SPEED_ACTIVE_F, &lsa);\r
399                                         mad_decode_field(data, IB_PORT_LINK_SPEED_ENABLED_F, &lse);\r
400 \r
401                                         /* Setup portid for peer port */\r
402                                         memcpy(&peerportid, &portid, sizeof(peerportid));\r
403                                         peerportid.drpath.cnt = 1;\r
404                                         peerportid.drpath.p[1] = portnum;\r
405 \r
406                                         /* Set DrSLID to local lid */\r
407                                         if (ib_resolve_self(&selfportid, &selfport, 0) < 0)\r
408                                                 IBERROR("could not resolve self");\r
409                                         peerportid.drpath.drslid = selfportid.lid;\r
410                                         peerportid.drpath.drdlid = 0xffff;\r
411 \r
412                                         /* Get peer port NodeInfo to obtain peer port number */\r
413                                         err = get_node_info(&peerportid, data);\r
414                                         if (err < 0)\r
415                                                 IBERROR("smp query nodeinfo failed");\r
416 \r
417                                         mad_decode_field(data, IB_NODE_LOCAL_PORT_F, &peerlocalportnum);\r
418 \r
419                                         printf("Peer PortInfo:\n");\r
420                                         /* Get peer port characteristics */\r
421                                         err = get_port_info(&peerportid, data, peerlocalportnum, port_op);\r
422                                         if (err < 0)\r
423                                                 IBERROR("smp query peer portinfofailed");\r
424 \r
425                                         mad_decode_field(data, IB_PORT_LINK_WIDTH_ENABLED_F, &peerlwe );\r
426                                         mad_decode_field(data, IB_PORT_LINK_WIDTH_SUPPORTED_F, &peerlws);\r
427                                         mad_decode_field(data, IB_PORT_LINK_WIDTH_ACTIVE_F, &peerlwa);\r
428                                         mad_decode_field(data, IB_PORT_LINK_SPEED_SUPPORTED_F, &peerlss);\r
429                                         mad_decode_field(data, IB_PORT_LINK_SPEED_ACTIVE_F, &peerlsa);\r
430                                         mad_decode_field(data, IB_PORT_LINK_SPEED_ENABLED_F, &peerlse);\r
431 \r
432                                         /* Now validate peer port characteristics */\r
433                                         /* Examine Link Width */\r
434                                         width = get_link_width(lwe, lws);\r
435                                         peerwidth = get_link_width(peerlwe, peerlws);\r
436                                         validate_width(width, peerwidth, lwa);\r
437 \r
438                                         /* Examine Link Speed */\r
439                                         speed = get_link_speed(lse, lss);\r
440                                         peerspeed = get_link_speed(peerlse, peerlss);\r
441                                         validate_speed(speed, peerspeed, lsa);\r
442                                 }\r
443                         }\r
444                 }\r
445         }\r
446 \r
447         exit(0);\r
448 }\r