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 static const struct command all_commands
[];
50 static void usage(void) NO_RETURN
;
51 static void parse_options(int argc
, char *argv
[]);
54 main(int argc
, char *argv
[])
56 set_program_name(argv
[0]);
57 parse_options(argc
, argv
);
58 signal(SIGPIPE
, SIG_IGN
);
59 run_command(argc
- optind
, argv
+ optind
, all_commands
);
64 parse_options(int argc
, char *argv
[])
67 OPT_DUMMY
= UCHAR_MAX
+ 1,
70 static struct option long_options
[] = {
71 {"timeout", required_argument
, 0, 't'},
72 {"help", no_argument
, 0, 'h'},
73 {"version", no_argument
, 0, 'V'},
77 char *short_options
= long_options_to_short_options(long_options
);
80 unsigned long int timeout
;
83 c
= getopt_long(argc
, argv
, short_options
, long_options
, NULL
);
90 timeout
= strtoul(optarg
, NULL
, 10);
92 ovs_fatal(0, "value %s on -t or --timeout is not at least 1",
103 OVS_PRINT_VERSION(0, 0);
121 printf("%s: Open vSwitch datapath management utility\n"
122 "usage: %s [OPTIONS] COMMAND [ARG...]\n"
123 " add-dp DP [IFACE...] add new datapath DP (with IFACEs)\n"
124 " del-dp DP delete local datapath DP\n"
125 " add-if DP IFACE... add each IFACE as a port on DP\n"
126 " del-if DP IFACE... delete each IFACE from DP\n"
127 " dump-dps display names of all datapaths\n"
128 " show show basic info on all datapaths\n"
129 " show DP... show basic info on each DP\n"
130 " dump-flows DP display flows in DP\n"
131 " del-flows DP delete all flows from DP\n",
132 program_name
, program_name
);
134 printf("\nOther options:\n"
135 " -t, --timeout=SECS give up after SECS seconds\n"
136 " -h, --help display this help message\n"
137 " -V, --version display version information\n");
141 static void run(int retval
, const char *message
, ...)
144 static void run(int retval
, const char *message
, ...)
149 fprintf(stderr
, "%s: ", program_name
);
150 va_start(args
, message
);
151 vfprintf(stderr
, message
, args
);
154 fputs(": unexpected end of file\n", stderr
);
156 fprintf(stderr
, ": %s\n", strerror(retval
));
163 static void do_add_if(int argc
, char *argv
[]);
165 static int if_up(const char *netdev_name
)
167 struct netdev
*netdev
;
170 retval
= netdev_open_default(netdev_name
, &netdev
);
172 retval
= netdev_turn_flags_on(netdev
, NETDEV_UP
, true);
173 netdev_close(netdev
);
179 parsed_dpif_open(const char *arg_
, bool create
, struct dpif
**dpifp
)
184 dp_parse_name(arg_
, &name
, &type
);
187 result
= dpif_create(name
, type
, dpifp
);
189 result
= dpif_open(name
, type
, dpifp
);
198 do_add_dp(int argc OVS_UNUSED
, char *argv
[])
201 run(parsed_dpif_open(argv
[1], true, &dpif
), "add_dp");
204 do_add_if(argc
, argv
);
209 do_del_dp(int argc OVS_UNUSED
, char *argv
[])
212 run(parsed_dpif_open(argv
[1], false, &dpif
), "opening datapath");
213 run(dpif_delete(dpif
), "del_dp");
218 do_add_if(int argc OVS_UNUSED
, char *argv
[])
220 bool failure
= false;
224 run(parsed_dpif_open(argv
[1], false, &dpif
), "opening datapath");
225 for (i
= 2; i
< argc
; i
++) {
226 char *save_ptr
= NULL
;
227 struct netdev_options options
;
228 struct netdev
*netdev
;
233 options
.name
= strtok_r(argv
[i
], ",", &save_ptr
);
234 options
.type
= "system";
235 options
.args
= &args
;
236 options
.ethertype
= NETDEV_ETH_TYPE_NONE
;
239 ovs_error(0, "%s is not a valid network device name", argv
[i
]);
244 while ((option
= strtok_r(NULL
, "", &save_ptr
)) != NULL
) {
245 char *save_ptr_2
= NULL
;
248 key
= strtok_r(option
, "=", &save_ptr_2
);
249 value
= strtok_r(NULL
, "", &save_ptr_2
);
254 if (!strcmp(key
, "type")) {
255 options
.type
= value
;
256 } else if (!shash_add_once(&args
, key
, value
)) {
257 ovs_error(0, "duplicate \"%s\" option", key
);
261 error
= netdev_open(&options
, &netdev
);
263 ovs_error(error
, "%s: failed to open network device",
266 error
= dpif_port_add(dpif
, netdev
, NULL
);
268 ovs_error(error
, "adding %s to %s failed",
269 options
.name
, argv
[1]);
271 error
= if_up(options
.name
);
273 netdev_close(netdev
);
286 get_port_number(struct dpif
*dpif
, const char *name
, uint16_t *port
)
288 struct dpif_port dpif_port
;
290 if (!dpif_port_query_by_name(dpif
, name
, &dpif_port
)) {
291 *port
= dpif_port
.port_no
;
292 dpif_port_destroy(&dpif_port
);
295 ovs_error(0, "no port named %s", name
);
301 do_del_if(int argc OVS_UNUSED
, char *argv
[])
303 bool failure
= false;
307 run(parsed_dpif_open(argv
[1], false, &dpif
), "opening datapath");
308 for (i
= 2; i
< argc
; i
++) {
309 const char *name
= argv
[i
];
313 if (!name
[strspn(name
, "0123456789")]) {
315 } else if (!get_port_number(dpif
, name
, &port
)) {
320 error
= dpif_port_del(dpif
, port
);
322 ovs_error(error
, "deleting port %s from %s failed", name
, argv
[1]);
333 show_dpif(struct dpif
*dpif
)
335 struct dpif_port_dump dump
;
336 struct dpif_port dpif_port
;
337 struct odp_stats stats
;
339 printf("%s:\n", dpif_name(dpif
));
340 if (!dpif_get_dp_stats(dpif
, &stats
)) {
341 printf("\tports: cur:%"PRIu32
", max:%"PRIu32
"\n",
342 stats
.n_ports
, stats
.max_ports
);
343 printf("\tlookups: frags:%llu, hit:%llu, missed:%llu, lost:%llu\n",
344 (unsigned long long int) stats
.n_frags
,
345 (unsigned long long int) stats
.n_hit
,
346 (unsigned long long int) stats
.n_missed
,
347 (unsigned long long int) stats
.n_lost
);
349 DPIF_PORT_FOR_EACH (&dpif_port
, &dump
, dpif
) {
350 printf("\tport %u: %s", dpif_port
.port_no
, dpif_port
.name
);
352 if (strcmp(dpif_port
.type
, "system")) {
353 struct netdev_options netdev_options
;
354 struct netdev
*netdev
;
357 printf (" (%s", dpif_port
.type
);
359 netdev_options
.name
= dpif_port
.name
;
360 netdev_options
.type
= dpif_port
.type
;
361 netdev_options
.args
= NULL
;
362 netdev_options
.ethertype
= NETDEV_ETH_TYPE_NONE
;
363 error
= netdev_open(&netdev_options
, &netdev
);
365 const struct shash_node
**nodes
;
366 const struct shash
*config
;
369 config
= netdev_get_config(netdev
);
370 nodes
= shash_sort(config
);
371 for (i
= 0; i
< shash_count(config
); i
++) {
372 const struct shash_node
*node
= nodes
[i
];
373 printf("%c %s=%s", i
? ',' : ':',
374 node
->name
, (char *) node
->data
);
378 netdev_close(netdev
);
380 printf(": open failed (%s)", strerror(error
));
390 do_show(int argc
, char *argv
[])
392 bool failure
= false;
395 for (i
= 1; i
< argc
; i
++) {
396 const char *name
= argv
[i
];
400 error
= parsed_dpif_open(name
, false, &dpif
);
404 ovs_error(error
, "opening datapath %s failed", name
);
414 dp_enumerate_types(&types
);
415 SVEC_FOR_EACH (i
, type
, &types
) {
421 if (dp_enumerate_names(type
, &names
)) {
425 SVEC_FOR_EACH (j
, name
, &names
) {
429 error
= dpif_open(name
, type
, &dpif
);
433 ovs_error(error
, "opening datapath %s failed", name
);
437 svec_destroy(&names
);
439 svec_destroy(&types
);
447 do_dump_dps(int argc OVS_UNUSED
, char *argv
[] OVS_UNUSED
)
449 struct svec dpif_names
, dpif_types
;
453 svec_init(&dpif_names
);
454 svec_init(&dpif_types
);
455 dp_enumerate_types(&dpif_types
);
457 for (i
= 0; i
< dpif_types
.n
; i
++) {
461 retval
= dp_enumerate_names(dpif_types
.names
[i
], &dpif_names
);
466 for (j
= 0; j
< dpif_names
.n
; j
++) {
468 if (!dpif_open(dpif_names
.names
[j
], dpif_types
.names
[i
], &dpif
)) {
469 printf("%s\n", dpif_name(dpif
));
475 svec_destroy(&dpif_names
);
476 svec_destroy(&dpif_types
);
483 do_dump_flows(int argc OVS_UNUSED
, char *argv
[])
485 struct dpif_flow_dump dump
;
489 run(parsed_dpif_open(argv
[1], false, &dpif
), "opening datapath");
492 dpif_flow_dump_start(&dump
, dpif
);
494 enum { MAX_ACTIONS
= 4096 }; /* An arbitrary but large number. */
495 uint32_t actions
[MAX_ACTIONS
* sizeof(struct nlattr
) / 4];
496 uint32_t keybuf
[ODPUTIL_FLOW_KEY_U32S
];
499 memset(&f
, 0, sizeof f
);
500 f
.actions
= (struct nlattr
*) actions
;
501 f
.actions_len
= sizeof actions
;
502 f
.key
= (struct nlattr
*) keybuf
;
503 f
.key_len
= sizeof keybuf
;
505 if (!dpif_flow_dump_next(&dump
, &f
)) {
510 format_odp_flow(&ds
, &f
);
511 printf("%s\n", ds_cstr(&ds
));
513 dpif_flow_dump_done(&dump
);
519 do_del_flows(int argc OVS_UNUSED
, char *argv
[])
523 run(parsed_dpif_open(argv
[1], false, &dpif
), "opening datapath");
524 run(dpif_flow_flush(dpif
), "deleting all flows");
529 do_help(int argc OVS_UNUSED
, char *argv
[] OVS_UNUSED
)
534 static const struct command all_commands
[] = {
535 { "add-dp", 1, INT_MAX
, do_add_dp
},
536 { "del-dp", 1, 1, do_del_dp
},
537 { "add-if", 2, INT_MAX
, do_add_if
},
538 { "del-if", 2, INT_MAX
, do_del_if
},
539 { "dump-dps", 0, 0, do_dump_dps
},
540 { "show", 0, INT_MAX
, do_show
},
541 { "dump-flows", 1, 1, do_dump_flows
},
542 { "del-flows", 1, 1, do_del_flows
},
543 { "help", 0, INT_MAX
, do_help
},
544 { NULL
, 0, 0, NULL
},