2 * Copyright (c) 2008, 2009, 2010, 2011 Nicira Networks.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at:
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
18 #include <arpa/inet.h>
22 #include <sys/socket.h>
24 #include <netinet/in.h>
33 #include "command-line.h"
37 #include "dynamic-string.h"
46 VLOG_DEFINE_THIS_MODULE(dpctl);
48 /* -s, --statistics: Print port statistics? */
49 static bool print_statistics;
51 static const struct command all_commands[];
53 static void usage(void) NO_RETURN;
54 static void parse_options(int argc, char *argv[]);
57 main(int argc, char *argv[])
59 set_program_name(argv[0]);
60 parse_options(argc, argv);
61 signal(SIGPIPE, SIG_IGN);
62 run_command(argc - optind, argv + optind, all_commands);
67 parse_options(int argc, char *argv[])
70 OPT_DUMMY = UCHAR_MAX + 1,
73 static struct option long_options[] = {
74 {"statistics", no_argument, NULL, 's'},
75 {"timeout", required_argument, NULL, 't'},
76 {"help", no_argument, NULL, 'h'},
77 {"version", no_argument, NULL, 'V'},
81 char *short_options = long_options_to_short_options(long_options);
84 unsigned long int timeout;
87 c = getopt_long(argc, argv, short_options, long_options, NULL);
94 print_statistics = true;
98 timeout = strtoul(optarg, NULL, 10);
100 ovs_fatal(0, "value %s on -t or --timeout is not at least 1",
111 ovs_print_version(0, 0);
129 printf("%s: Open vSwitch datapath management utility\n"
130 "usage: %s [OPTIONS] COMMAND [ARG...]\n"
131 " add-dp DP [IFACE...] add new datapath DP (with IFACEs)\n"
132 " del-dp DP delete local datapath DP\n"
133 " add-if DP IFACE... add each IFACE as a port on DP\n"
134 " del-if DP IFACE... delete each IFACE from DP\n"
135 " dump-dps display names of all datapaths\n"
136 " show show basic info on all datapaths\n"
137 " show DP... show basic info on each DP\n"
138 " dump-flows DP display flows in DP\n"
139 " del-flows DP delete all flows from DP\n",
140 program_name, program_name);
142 printf("\nOther options:\n"
143 " -t, --timeout=SECS give up after SECS seconds\n"
144 " -h, --help display this help message\n"
145 " -V, --version display version information\n");
149 static void run(int retval, const char *message, ...)
152 static void run(int retval, const char *message, ...)
157 va_start(args, message);
158 ovs_fatal_valist(retval, message, args);
162 static void do_add_if(int argc, char *argv[]);
164 static int if_up(const char *netdev_name)
166 struct netdev *netdev;
169 retval = netdev_open_default(netdev_name, &netdev);
171 retval = netdev_turn_flags_on(netdev, NETDEV_UP, true);
172 netdev_close(netdev);
178 parsed_dpif_open(const char *arg_, bool create, struct dpif **dpifp)
183 dp_parse_name(arg_, &name, &type);
186 result = dpif_create(name, type, dpifp);
188 result = dpif_open(name, type, dpifp);
197 do_add_dp(int argc OVS_UNUSED, char *argv[])
200 run(parsed_dpif_open(argv[1], true, &dpif), "add_dp");
203 do_add_if(argc, argv);
208 do_del_dp(int argc OVS_UNUSED, char *argv[])
211 run(parsed_dpif_open(argv[1], false, &dpif), "opening datapath");
212 run(dpif_delete(dpif), "del_dp");
217 do_add_if(int argc OVS_UNUSED, char *argv[])
219 bool failure = false;
223 run(parsed_dpif_open(argv[1], false, &dpif), "opening datapath");
224 for (i = 2; i < argc; i++) {
225 char *save_ptr = NULL;
226 struct netdev_options options;
227 struct netdev *netdev = NULL;
232 options.name = strtok_r(argv[i], ",", &save_ptr);
233 options.type = "system";
236 ovs_error(0, "%s is not a valid network device name", argv[i]);
241 while ((option = strtok_r(NULL, ",", &save_ptr)) != NULL) {
242 char *save_ptr_2 = NULL;
245 key = strtok_r(option, "=", &save_ptr_2);
246 value = strtok_r(NULL, "", &save_ptr_2);
251 if (!strcmp(key, "type")) {
252 options.type = value;
253 } else if (!shash_add_once(&args, key, value)) {
254 ovs_error(0, "duplicate \"%s\" option", key);
258 error = netdev_open(&options, &netdev);
260 ovs_error(error, "%s: failed to open network device",
265 error = netdev_set_config(netdev, &args);
267 ovs_error(error, "%s: failed to configure network device",
272 error = dpif_port_add(dpif, netdev, NULL);
274 ovs_error(error, "adding %s to %s failed", options.name, argv[1]);
278 error = if_up(options.name);
281 netdev_close(netdev);
293 get_port_number(struct dpif *dpif, const char *name, uint16_t *port)
295 struct dpif_port dpif_port;
297 if (!dpif_port_query_by_name(dpif, name, &dpif_port)) {
298 *port = dpif_port.port_no;
299 dpif_port_destroy(&dpif_port);
302 ovs_error(0, "no port named %s", name);
308 do_del_if(int argc OVS_UNUSED, char *argv[])
310 bool failure = false;
314 run(parsed_dpif_open(argv[1], false, &dpif), "opening datapath");
315 for (i = 2; i < argc; i++) {
316 const char *name = argv[i];
320 if (!name[strspn(name, "0123456789")]) {
322 } else if (!get_port_number(dpif, name, &port)) {
327 error = dpif_port_del(dpif, port);
329 ovs_error(error, "deleting port %s from %s failed", name, argv[1]);
340 print_stat(const char *leader, uint64_t value)
342 fputs(leader, stdout);
343 if (value != UINT64_MAX) {
344 printf("%"PRIu64, value);
351 print_human_size(uint64_t value)
353 if (value == UINT64_MAX) {
355 } else if (value >= 1024ULL * 1024 * 1024 * 1024) {
356 printf(" (%.1f TiB)", value / (1024.0 * 1024 * 1024 * 1024));
357 } else if (value >= 1024ULL * 1024 * 1024) {
358 printf(" (%.1f GiB)", value / (1024.0 * 1024 * 1024));
359 } else if (value >= 1024ULL * 1024) {
360 printf(" (%.1f MiB)", value / (1024.0 * 1024));
361 } else if (value >= 1024) {
362 printf(" (%.1f KiB)", value / 1024.0);
367 show_dpif(struct dpif *dpif)
369 struct dpif_port_dump dump;
370 struct dpif_port dpif_port;
371 struct odp_stats stats;
373 printf("%s:\n", dpif_name(dpif));
374 if (!dpif_get_dp_stats(dpif, &stats)) {
375 printf("\tlookups: frags:%llu, hit:%llu, missed:%llu, lost:%llu\n",
376 (unsigned long long int) stats.n_frags,
377 (unsigned long long int) stats.n_hit,
378 (unsigned long long int) stats.n_missed,
379 (unsigned long long int) stats.n_lost);
380 printf("\tflows: %llu\n", (unsigned long long int)stats.n_flows);
382 DPIF_PORT_FOR_EACH (&dpif_port, &dump, dpif) {
383 printf("\tport %u: %s", dpif_port.port_no, dpif_port.name);
385 if (strcmp(dpif_port.type, "system")) {
386 struct netdev_options netdev_options;
387 struct netdev *netdev;
390 printf (" (%s", dpif_port.type);
392 netdev_options.name = dpif_port.name;
393 netdev_options.type = dpif_port.type;
394 error = netdev_open(&netdev_options, &netdev);
399 error = netdev_get_config(netdev, &config);
401 const struct shash_node **nodes;
404 nodes = shash_sort(&config);
405 for (i = 0; i < shash_count(&config); i++) {
406 const struct shash_node *node = nodes[i];
407 printf("%c %s=%s", i ? ',' : ':',
408 node->name, (char *) node->data);
412 printf(", could not retrieve configuration (%s)",
415 shash_destroy_free_data(&config);
417 netdev_close(netdev);
419 printf(": open failed (%s)", strerror(error));
425 if (print_statistics) {
426 const struct netdev_stats *s = &dpif_port.stats;
428 print_stat("\t\tRX packets:", s->rx_packets);
429 print_stat(" errors:", s->rx_errors);
430 print_stat(" dropped:", s->rx_dropped);
431 print_stat(" overruns:", s->rx_over_errors);
432 print_stat(" frame:", s->rx_frame_errors);
435 print_stat("\t\tTX packets:", s->tx_packets);
436 print_stat(" errors:", s->tx_errors);
437 print_stat(" dropped:", s->tx_dropped);
438 print_stat(" aborted:", s->tx_aborted_errors);
439 print_stat(" carrier:", s->tx_carrier_errors);
442 print_stat("\t\tcollisions:", s->collisions);
445 print_stat("\t\tRX bytes:", s->rx_bytes);
446 print_human_size(s->rx_bytes);
447 print_stat(" TX bytes:", s->tx_bytes);
448 print_human_size(s->tx_bytes);
456 do_show(int argc, char *argv[])
458 bool failure = false;
461 for (i = 1; i < argc; i++) {
462 const char *name = argv[i];
466 error = parsed_dpif_open(name, false, &dpif);
470 ovs_error(error, "opening datapath %s failed", name);
479 dp_enumerate_types(&types);
480 SSET_FOR_EACH (type, &types) {
485 if (dp_enumerate_names(type, &names)) {
489 SSET_FOR_EACH (name, &names) {
493 error = dpif_open(name, type, &dpif);
497 ovs_error(error, "opening datapath %s failed", name);
501 sset_destroy(&names);
503 sset_destroy(&types);
511 do_dump_dps(int argc OVS_UNUSED, char *argv[] OVS_UNUSED)
513 struct sset dpif_names, dpif_types;
517 sset_init(&dpif_names);
518 sset_init(&dpif_types);
519 dp_enumerate_types(&dpif_types);
521 SSET_FOR_EACH (type, &dpif_types) {
525 retval = dp_enumerate_names(type, &dpif_names);
530 SSET_FOR_EACH (name, &dpif_names) {
532 if (!dpif_open(name, type, &dpif)) {
533 printf("%s\n", dpif_name(dpif));
539 sset_destroy(&dpif_names);
540 sset_destroy(&dpif_types);
547 do_dump_flows(int argc OVS_UNUSED, char *argv[])
549 const struct dpif_flow_stats *stats;
550 const struct nlattr *actions;
551 struct dpif_flow_dump dump;
552 const struct nlattr *key;
558 run(parsed_dpif_open(argv[1], false, &dpif), "opening datapath");
561 dpif_flow_dump_start(&dump, dpif);
562 while (dpif_flow_dump_next(&dump, &key, &key_len,
563 &actions, &actions_len, &stats)) {
565 odp_flow_key_format(key, key_len, &ds);
566 ds_put_cstr(&ds, ", ");
567 dpif_flow_stats_format(stats, &ds);
568 ds_put_cstr(&ds, ", actions:");
569 format_odp_actions(&ds, actions, actions_len);
570 printf("%s\n", ds_cstr(&ds));
572 dpif_flow_dump_done(&dump);
578 do_del_flows(int argc OVS_UNUSED, char *argv[])
582 run(parsed_dpif_open(argv[1], false, &dpif), "opening datapath");
583 run(dpif_flow_flush(dpif), "deleting all flows");
588 do_help(int argc OVS_UNUSED, char *argv[] OVS_UNUSED)
593 static const struct command all_commands[] = {
594 { "add-dp", 1, INT_MAX, do_add_dp },
595 { "del-dp", 1, 1, do_del_dp },
596 { "add-if", 2, INT_MAX, do_add_if },
597 { "del-if", 2, INT_MAX, do_del_if },
598 { "dump-dps", 0, 0, do_dump_dps },
599 { "show", 0, INT_MAX, do_show },
600 { "dump-flows", 1, 1, do_dump_flows },
601 { "del-flows", 1, 1, do_del_flows },
602 { "help", 0, INT_MAX, do_help },
603 { NULL, 0, 0, NULL },