]>
Commit | Line | Data |
---|---|---|
064af421 | 1 | /* |
9664732f | 2 | * Copyright (c) 2008, 2009, 2010, 2011, 2012, 2014 Nicira, Inc. |
064af421 | 3 | * |
a14bc59f BP |
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: | |
064af421 | 7 | * |
a14bc59f BP |
8 | * http://www.apache.org/licenses/LICENSE-2.0 |
9 | * | |
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. | |
064af421 | 15 | */ |
3fbe1d30 | 16 | |
064af421 | 17 | #include <config.h> |
064af421 | 18 | |
064af421 BP |
19 | #include <errno.h> |
20 | #include <getopt.h> | |
064af421 BP |
21 | #include <stdio.h> |
22 | #include <string.h> | |
23 | #include <stdlib.h> | |
24 | ||
25 | #include "command-line.h" | |
3fbe1d30 BP |
26 | #include "daemon.h" |
27 | #include "dirs.h" | |
28 | #include "dynamic-string.h" | |
bde9f75d | 29 | #include "jsonrpc.h" |
0e15264f | 30 | #include "process.h" |
064af421 BP |
31 | #include "timeval.h" |
32 | #include "unixctl.h" | |
33 | #include "util.h" | |
e6211adc | 34 | #include "openvswitch/vlog.h" |
064af421 | 35 | |
3fbe1d30 BP |
36 | static void usage(void); |
37 | static const char *parse_command_line(int argc, char *argv[]); | |
bde9f75d | 38 | static struct jsonrpc *connect_to_target(const char *target); |
064af421 | 39 | |
3fbe1d30 BP |
40 | int |
41 | main(int argc, char *argv[]) | |
064af421 | 42 | { |
bde9f75d EJ |
43 | char *cmd_result, *cmd_error; |
44 | struct jsonrpc *client; | |
45 | char *cmd, **cmd_argv; | |
3fbe1d30 | 46 | const char *target; |
bde9f75d EJ |
47 | int cmd_argc; |
48 | int error; | |
3fbe1d30 BP |
49 | |
50 | set_program_name(argv[0]); | |
3fbe1d30 BP |
51 | |
52 | /* Parse command line and connect to target. */ | |
53 | target = parse_command_line(argc, argv); | |
54 | client = connect_to_target(target); | |
55 | ||
3fbe1d30 | 56 | /* Transact request and process reply. */ |
bde9f75d EJ |
57 | cmd = argv[optind++]; |
58 | cmd_argc = argc - optind; | |
59 | cmd_argv = cmd_argc ? argv + optind : NULL; | |
60 | error = unixctl_client_transact(client, cmd, cmd_argc, cmd_argv, | |
61 | &cmd_result, &cmd_error); | |
064af421 | 62 | if (error) { |
3fbe1d30 BP |
63 | ovs_fatal(error, "%s: transaction error", target); |
64 | } | |
bde9f75d EJ |
65 | |
66 | if (cmd_error) { | |
156f7a40 | 67 | jsonrpc_close(client); |
bde9f75d EJ |
68 | fputs(cmd_error, stderr); |
69 | ovs_error(0, "%s: server returned an error", target); | |
3fbe1d30 | 70 | exit(2); |
bde9f75d EJ |
71 | } else if (cmd_result) { |
72 | fputs(cmd_result, stdout); | |
73 | } else { | |
428b2edd | 74 | OVS_NOT_REACHED(); |
064af421 | 75 | } |
65f92a50 | 76 | |
bde9f75d EJ |
77 | jsonrpc_close(client); |
78 | free(cmd_result); | |
79 | free(cmd_error); | |
3fbe1d30 | 80 | return 0; |
064af421 BP |
81 | } |
82 | ||
83 | static void | |
3fbe1d30 | 84 | usage(void) |
064af421 | 85 | { |
c1a543a8 BP |
86 | printf("\ |
87 | %s, for querying and controlling Open vSwitch daemon\n\ | |
88 | usage: %s [TARGET] COMMAND [ARG...]\n\ | |
89 | Targets:\n\ | |
90 | -t, --target=TARGET pidfile or socket to contact\n\ | |
91 | Common commands:\n\ | |
91a11f5b | 92 | list-commands List commands supported by the target\n\ |
d5e1e5ed | 93 | version Print version of the target\n\ |
c1a543a8 | 94 | vlog/list List current logging levels\n\ |
2a3e30b2 BP |
95 | vlog/set [SPEC]\n\ |
96 | Set log levels as detailed in SPEC, which may include:\n\ | |
97 | A valid module name (all modules, by default)\n\ | |
98 | 'syslog', 'console', 'file' (all facilities, by default))\n\ | |
99 | 'off', 'emer', 'err', 'warn', 'info', or 'dbg' ('dbg', bydefault)\n\ | |
c1a543a8 BP |
100 | vlog/reopen Make the program reopen its log file\n\ |
101 | Other options:\n\ | |
f4ec6ff4 | 102 | --timeout=SECS wait at most SECS seconds for a response\n\ |
c1a543a8 | 103 | -h, --help Print this helpful information\n\ |
d5e1e5ed | 104 | -V, --version Display ovs-appctl version information\n", |
3fbe1d30 BP |
105 | program_name, program_name); |
106 | exit(EXIT_SUCCESS); | |
064af421 BP |
107 | } |
108 | ||
3fbe1d30 BP |
109 | static const char * |
110 | parse_command_line(int argc, char *argv[]) | |
064af421 | 111 | { |
9664732f | 112 | enum { |
66fa2c88 | 113 | OPT_START = UCHAR_MAX + 1, |
9664732f BP |
114 | VLOG_OPTION_ENUMS |
115 | }; | |
064af421 | 116 | static const struct option long_options[] = { |
064af421 | 117 | {"target", required_argument, NULL, 't'}, |
3fbe1d30 | 118 | {"execute", no_argument, NULL, 'e'}, |
064af421 | 119 | {"help", no_argument, NULL, 'h'}, |
66fa2c88 | 120 | {"option", no_argument, NULL, 'o'}, |
064af421 | 121 | {"version", no_argument, NULL, 'V'}, |
f4ec6ff4 | 122 | {"timeout", required_argument, NULL, 'T'}, |
9664732f | 123 | VLOG_LONG_OPTIONS, |
e3c17733 | 124 | {NULL, 0, NULL, 0}, |
064af421 | 125 | }; |
9664732f BP |
126 | char *short_options_ = long_options_to_short_options(long_options); |
127 | char *short_options = xasprintf("+%s", short_options_); | |
3fbe1d30 BP |
128 | const char *target; |
129 | int e_options; | |
064af421 | 130 | |
3fbe1d30 BP |
131 | target = NULL; |
132 | e_options = 0; | |
064af421 BP |
133 | for (;;) { |
134 | int option; | |
064af421 | 135 | |
9664732f | 136 | option = getopt_long(argc, argv, short_options, long_options, NULL); |
064af421 BP |
137 | if (option == -1) { |
138 | break; | |
139 | } | |
064af421 BP |
140 | switch (option) { |
141 | case 't': | |
3fbe1d30 BP |
142 | if (target) { |
143 | ovs_fatal(0, "-t or --target may be specified only once"); | |
064af421 | 144 | } |
3fbe1d30 | 145 | target = optarg; |
064af421 BP |
146 | break; |
147 | ||
148 | case 'e': | |
3fbe1d30 BP |
149 | /* We ignore -e for compatibility. Older versions specified the |
150 | * command as the argument to -e. Since the current version takes | |
151 | * the command as non-option arguments and we say that -e has no | |
152 | * arguments, this just works in the common case. */ | |
153 | if (e_options++) { | |
154 | ovs_fatal(0, "-e or --execute may be speciifed only once"); | |
064af421 BP |
155 | } |
156 | break; | |
157 | ||
158 | case 'h': | |
3fbe1d30 | 159 | usage(); |
064af421 BP |
160 | break; |
161 | ||
66fa2c88 AW |
162 | case 'o': |
163 | print_options(long_options); | |
164 | exit(EXIT_SUCCESS); | |
165 | ||
f4ec6ff4 EJ |
166 | case 'T': |
167 | time_alarm(atoi(optarg)); | |
168 | break; | |
169 | ||
064af421 | 170 | case 'V': |
55d5bb44 | 171 | ovs_print_version(0, 0); |
064af421 BP |
172 | exit(EXIT_SUCCESS); |
173 | ||
9664732f BP |
174 | VLOG_OPTION_HANDLERS |
175 | ||
064af421 BP |
176 | case '?': |
177 | exit(EXIT_FAILURE); | |
178 | ||
179 | default: | |
428b2edd | 180 | OVS_NOT_REACHED(); |
064af421 BP |
181 | } |
182 | } | |
9664732f BP |
183 | free(short_options_); |
184 | free(short_options); | |
3fbe1d30 BP |
185 | |
186 | if (optind >= argc) { | |
187 | ovs_fatal(0, "at least one non-option argument is required " | |
188 | "(use --help for help)"); | |
189 | } | |
190 | ||
191 | return target ? target : "ovs-vswitchd"; | |
192 | } | |
193 | ||
bde9f75d | 194 | static struct jsonrpc * |
3fbe1d30 BP |
195 | connect_to_target(const char *target) |
196 | { | |
bde9f75d | 197 | struct jsonrpc *client; |
3fbe1d30 BP |
198 | char *socket_name; |
199 | int error; | |
200 | ||
a085daef | 201 | #ifndef _WIN32 |
3fbe1d30 BP |
202 | if (target[0] != '/') { |
203 | char *pidfile_name; | |
3fbe1d30 BP |
204 | pid_t pid; |
205 | ||
b43c6fe2 | 206 | pidfile_name = xasprintf("%s/%s.pid", ovs_rundir(), target); |
3fbe1d30 BP |
207 | pid = read_pidfile(pidfile_name); |
208 | if (pid < 0) { | |
209 | ovs_fatal(-pid, "cannot read pidfile \"%s\"", pidfile_name); | |
210 | } | |
211 | free(pidfile_name); | |
212 | socket_name = xasprintf("%s/%s.%ld.ctl", | |
b43c6fe2 | 213 | ovs_rundir(), target, (long int) pid); |
a085daef GS |
214 | #else |
215 | /* On windows, if the 'target' contains ':', we make an assumption that | |
216 | * it is an absolute path. */ | |
217 | if (!strchr(target, ':')) { | |
218 | socket_name = xasprintf("%s/%s.ctl", ovs_rundir(), target); | |
219 | #endif | |
3fbe1d30 BP |
220 | } else { |
221 | socket_name = xstrdup(target); | |
222 | } | |
223 | ||
224 | error = unixctl_client_create(socket_name, &client); | |
225 | if (error) { | |
226 | ovs_fatal(error, "cannot connect to \"%s\"", socket_name); | |
064af421 | 227 | } |
3fbe1d30 BP |
228 | free(socket_name); |
229 | ||
230 | return client; | |
064af421 | 231 | } |
3fbe1d30 | 232 |