]>
git.proxmox.com Git - mirror_ovs.git/blob - utilities/ovs-dpctl.c
0e6c16fa44e1052ac62ca1a2ecf8d6153d53143a
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(netdev_name
, "system", &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 const char *name
, *type
;
226 char *save_ptr
= NULL
;
227 struct netdev
*netdev
= NULL
;
232 name
= strtok_r(argv
[i
], ",", &save_ptr
);
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")) {
253 } else if (!shash_add_once(&args
, key
, value
)) {
254 ovs_error(0, "duplicate \"%s\" option", key
);
258 error
= netdev_open(name
, type
, &netdev
);
260 ovs_error(error
, "%s: failed to open network device", name
);
264 error
= netdev_set_config(netdev
, &args
);
266 ovs_error(error
, "%s: failed to configure network device", name
);
270 error
= dpif_port_add(dpif
, netdev
, NULL
);
272 ovs_error(error
, "adding %s to %s failed", name
, argv
[1]);
279 netdev_close(netdev
);
291 get_port_number(struct dpif
*dpif
, const char *name
, uint16_t *port
)
293 struct dpif_port dpif_port
;
295 if (!dpif_port_query_by_name(dpif
, name
, &dpif_port
)) {
296 *port
= dpif_port
.port_no
;
297 dpif_port_destroy(&dpif_port
);
300 ovs_error(0, "no port named %s", name
);
306 do_del_if(int argc OVS_UNUSED
, char *argv
[])
308 bool failure
= false;
312 run(parsed_dpif_open(argv
[1], false, &dpif
), "opening datapath");
313 for (i
= 2; i
< argc
; i
++) {
314 const char *name
= argv
[i
];
318 if (!name
[strspn(name
, "0123456789")]) {
320 } else if (!get_port_number(dpif
, name
, &port
)) {
325 error
= dpif_port_del(dpif
, port
);
327 ovs_error(error
, "deleting port %s from %s failed", name
, argv
[1]);
338 print_stat(const char *leader
, uint64_t value
)
340 fputs(leader
, stdout
);
341 if (value
!= UINT64_MAX
) {
342 printf("%"PRIu64
, value
);
349 print_human_size(uint64_t value
)
351 if (value
== UINT64_MAX
) {
353 } else if (value
>= 1024ULL * 1024 * 1024 * 1024) {
354 printf(" (%.1f TiB)", value
/ (1024.0 * 1024 * 1024 * 1024));
355 } else if (value
>= 1024ULL * 1024 * 1024) {
356 printf(" (%.1f GiB)", value
/ (1024.0 * 1024 * 1024));
357 } else if (value
>= 1024ULL * 1024) {
358 printf(" (%.1f MiB)", value
/ (1024.0 * 1024));
359 } else if (value
>= 1024) {
360 printf(" (%.1f KiB)", value
/ 1024.0);
365 show_dpif(struct dpif
*dpif
)
367 struct dpif_port_dump dump
;
368 struct dpif_port dpif_port
;
369 struct ovs_dp_stats stats
;
371 printf("%s:\n", dpif_name(dpif
));
372 if (!dpif_get_dp_stats(dpif
, &stats
)) {
373 printf("\tlookups: frags:%llu, hit:%llu, missed:%llu, lost:%llu\n",
374 (unsigned long long int) stats
.n_frags
,
375 (unsigned long long int) stats
.n_hit
,
376 (unsigned long long int) stats
.n_missed
,
377 (unsigned long long int) stats
.n_lost
);
378 printf("\tflows: %llu\n", (unsigned long long int)stats
.n_flows
);
380 DPIF_PORT_FOR_EACH (&dpif_port
, &dump
, dpif
) {
381 printf("\tport %u: %s", dpif_port
.port_no
, dpif_port
.name
);
383 if (strcmp(dpif_port
.type
, "system")) {
384 struct netdev
*netdev
;
387 printf (" (%s", dpif_port
.type
);
389 error
= netdev_open(dpif_port
.name
, dpif_port
.type
, &netdev
);
394 error
= netdev_get_config(netdev
, &config
);
396 const struct shash_node
**nodes
;
399 nodes
= shash_sort(&config
);
400 for (i
= 0; i
< shash_count(&config
); i
++) {
401 const struct shash_node
*node
= nodes
[i
];
402 printf("%c %s=%s", i
? ',' : ':',
403 node
->name
, (char *) node
->data
);
407 printf(", could not retrieve configuration (%s)",
410 shash_destroy_free_data(&config
);
412 netdev_close(netdev
);
414 printf(": open failed (%s)", strerror(error
));
420 if (print_statistics
) {
421 const struct netdev_stats
*s
= &dpif_port
.stats
;
423 print_stat("\t\tRX packets:", s
->rx_packets
);
424 print_stat(" errors:", s
->rx_errors
);
425 print_stat(" dropped:", s
->rx_dropped
);
426 print_stat(" overruns:", s
->rx_over_errors
);
427 print_stat(" frame:", s
->rx_frame_errors
);
430 print_stat("\t\tTX packets:", s
->tx_packets
);
431 print_stat(" errors:", s
->tx_errors
);
432 print_stat(" dropped:", s
->tx_dropped
);
433 print_stat(" aborted:", s
->tx_aborted_errors
);
434 print_stat(" carrier:", s
->tx_carrier_errors
);
437 print_stat("\t\tcollisions:", s
->collisions
);
440 print_stat("\t\tRX bytes:", s
->rx_bytes
);
441 print_human_size(s
->rx_bytes
);
442 print_stat(" TX bytes:", s
->tx_bytes
);
443 print_human_size(s
->tx_bytes
);
451 do_show(int argc
, char *argv
[])
453 bool failure
= false;
456 for (i
= 1; i
< argc
; i
++) {
457 const char *name
= argv
[i
];
461 error
= parsed_dpif_open(name
, false, &dpif
);
465 ovs_error(error
, "opening datapath %s failed", name
);
474 dp_enumerate_types(&types
);
475 SSET_FOR_EACH (type
, &types
) {
480 if (dp_enumerate_names(type
, &names
)) {
484 SSET_FOR_EACH (name
, &names
) {
488 error
= dpif_open(name
, type
, &dpif
);
492 ovs_error(error
, "opening datapath %s failed", name
);
496 sset_destroy(&names
);
498 sset_destroy(&types
);
506 do_dump_dps(int argc OVS_UNUSED
, char *argv
[] OVS_UNUSED
)
508 struct sset dpif_names
, dpif_types
;
512 sset_init(&dpif_names
);
513 sset_init(&dpif_types
);
514 dp_enumerate_types(&dpif_types
);
516 SSET_FOR_EACH (type
, &dpif_types
) {
520 retval
= dp_enumerate_names(type
, &dpif_names
);
525 SSET_FOR_EACH (name
, &dpif_names
) {
527 if (!dpif_open(name
, type
, &dpif
)) {
528 printf("%s\n", dpif_name(dpif
));
534 sset_destroy(&dpif_names
);
535 sset_destroy(&dpif_types
);
542 do_dump_flows(int argc OVS_UNUSED
, char *argv
[])
544 const struct dpif_flow_stats
*stats
;
545 const struct nlattr
*actions
;
546 struct dpif_flow_dump dump
;
547 const struct nlattr
*key
;
553 run(parsed_dpif_open(argv
[1], false, &dpif
), "opening datapath");
556 dpif_flow_dump_start(&dump
, dpif
);
557 while (dpif_flow_dump_next(&dump
, &key
, &key_len
,
558 &actions
, &actions_len
, &stats
)) {
560 odp_flow_key_format(key
, key_len
, &ds
);
561 ds_put_cstr(&ds
, ", ");
562 dpif_flow_stats_format(stats
, &ds
);
563 ds_put_cstr(&ds
, ", actions:");
564 format_odp_actions(&ds
, actions
, actions_len
);
565 printf("%s\n", ds_cstr(&ds
));
567 dpif_flow_dump_done(&dump
);
573 do_del_flows(int argc OVS_UNUSED
, char *argv
[])
577 run(parsed_dpif_open(argv
[1], false, &dpif
), "opening datapath");
578 run(dpif_flow_flush(dpif
), "deleting all flows");
583 do_help(int argc OVS_UNUSED
, char *argv
[] OVS_UNUSED
)
588 static const struct command all_commands
[] = {
589 { "add-dp", 1, INT_MAX
, do_add_dp
},
590 { "del-dp", 1, 1, do_del_dp
},
591 { "add-if", 2, INT_MAX
, do_add_if
},
592 { "del-if", 2, INT_MAX
, do_del_if
},
593 { "dump-dps", 0, 0, do_dump_dps
},
594 { "show", 0, INT_MAX
, do_show
},
595 { "dump-flows", 1, 1, do_dump_flows
},
596 { "del-flows", 1, 1, do_del_flows
},
597 { "help", 0, INT_MAX
, do_help
},
598 { NULL
, 0, 0, NULL
},