Merge "master" into "next".
[openvswitch] / vswitchd / ovs-vswitchd.c
1 /* Copyright (c) 2008, 2009, 2010 Nicira Networks
2  *
3  * Licensed under the Apache License, Version 2.0 (the "License");
4  * you may not use this file except in compliance with the License.
5  * You may obtain a copy of the License at:
6  *
7  *     http://www.apache.org/licenses/LICENSE-2.0
8  *
9  * Unless required by applicable law or agreed to in writing, software
10  * distributed under the License is distributed on an "AS IS" BASIS,
11  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12  * See the License for the specific language governing permissions and
13  * limitations under the License.
14  */
15
16 #include <config.h>
17
18 #include <assert.h>
19 #include <errno.h>
20 #include <getopt.h>
21 #include <limits.h>
22 #include <signal.h>
23 #include <stdlib.h>
24 #include <string.h>
25
26 #include "bridge.h"
27 #include "command-line.h"
28 #include "compiler.h"
29 #include "daemon.h"
30 #include "dpif.h"
31 #include "leak-checker.h"
32 #include "netdev.h"
33 #include "ovsdb-idl.h"
34 #include "poll-loop.h"
35 #include "proc-net-compat.h"
36 #include "process.h"
37 #include "signals.h"
38 #include "stream-ssl.h"
39 #include "stream.h"
40 #include "svec.h"
41 #include "timeval.h"
42 #include "unixctl.h"
43 #include "util.h"
44 #include "vconn.h"
45 #include "vswitchd/vswitch-idl.h"
46
47 #include "vlog.h"
48 #define THIS_MODULE VLM_vswitchd
49
50 static const char *parse_options(int argc, char *argv[]);
51 static void usage(void) NO_RETURN;
52
53 int
54 main(int argc, char *argv[])
55 {
56     struct unixctl_server *unixctl;
57     struct signal *sighup;
58     struct ovsdb_idl *idl;
59     const char *remote;
60     bool need_reconfigure;
61     bool inited;
62     unsigned int idl_seqno;
63     int retval;
64
65     proctitle_init(argc, argv);
66     set_program_name(argv[0]);
67     time_init();
68     vlog_init();
69     remote = parse_options(argc, argv);
70     signal(SIGPIPE, SIG_IGN);
71     sighup = signal_register(SIGHUP);
72     process_init();
73     ovsrec_init();
74
75     die_if_already_running();
76     daemonize_start();
77
78     retval = unixctl_server_create(NULL, &unixctl);
79     if (retval) {
80         exit(EXIT_FAILURE);
81     }
82
83     daemonize_complete();
84
85     idl = ovsdb_idl_create(remote, &ovsrec_idl_class);
86     idl_seqno = ovsdb_idl_get_seqno(idl);
87
88     need_reconfigure = false;
89     inited = false;
90     for (;;) {
91         if (signal_poll(sighup)) {
92             vlog_reopen_log_file();
93         }
94         if (inited && bridge_run()) {
95             need_reconfigure = true;
96         }
97         ovsdb_idl_run(idl);
98         if (idl_seqno != ovsdb_idl_get_seqno(idl)) {
99             idl_seqno = ovsdb_idl_get_seqno(idl);
100             need_reconfigure = true;
101         }
102         if (need_reconfigure) {
103             const struct ovsrec_open_vswitch *cfg;
104
105             need_reconfigure = false;
106             cfg = ovsrec_open_vswitch_first(idl);
107             if (cfg) {
108                 if (inited) {
109                     bridge_reconfigure(cfg);
110                 } else {
111                     bridge_init(cfg);
112                     inited = true;
113                 }
114             }
115         }
116         unixctl_server_run(unixctl);
117         dp_run();
118         netdev_run();
119
120         signal_wait(sighup);
121         if (inited) {
122             bridge_wait();
123         }
124         ovsdb_idl_wait(idl);
125         unixctl_server_wait(unixctl);
126         dp_wait();
127         netdev_wait();
128         poll_block();
129     }
130
131     return 0;
132 }
133
134 static const char *
135 parse_options(int argc, char *argv[])
136 {
137     enum {
138         OPT_PEER_CA_CERT = UCHAR_MAX + 1,
139         OPT_FAKE_PROC_NET,
140         VLOG_OPTION_ENUMS,
141         LEAK_CHECKER_OPTION_ENUMS,
142         OPT_BOOTSTRAP_CA_CERT
143     };
144     static struct option long_options[] = {
145         {"help",        no_argument, 0, 'h'},
146         {"version",     no_argument, 0, 'V'},
147         {"fake-proc-net", no_argument, 0, OPT_FAKE_PROC_NET},
148         DAEMON_LONG_OPTIONS,
149         VLOG_LONG_OPTIONS,
150         LEAK_CHECKER_LONG_OPTIONS,
151 #ifdef HAVE_OPENSSL
152         STREAM_SSL_LONG_OPTIONS
153         {"peer-ca-cert", required_argument, 0, OPT_PEER_CA_CERT},
154         {"bootstrap-ca-cert", required_argument, 0, OPT_BOOTSTRAP_CA_CERT},
155 #endif
156         {0, 0, 0, 0},
157     };
158     char *short_options = long_options_to_short_options(long_options);
159     int error;
160
161     for (;;) {
162         int c;
163
164         c = getopt_long(argc, argv, short_options, long_options, NULL);
165         if (c == -1) {
166             break;
167         }
168
169         switch (c) {
170         case 'H':
171         case 'h':
172             usage();
173
174         case 'V':
175             OVS_PRINT_VERSION(OFP_VERSION, OFP_VERSION);
176             exit(EXIT_SUCCESS);
177
178         case OPT_FAKE_PROC_NET:
179             error = proc_net_compat_init();
180             if (error) {
181                 ovs_fatal(error, "failed to initialize /proc/net "
182                           "compatibility");
183             }
184             break;
185
186         VLOG_OPTION_HANDLERS
187         DAEMON_OPTION_HANDLERS
188         LEAK_CHECKER_OPTION_HANDLERS
189
190 #ifdef HAVE_OPENSSL
191         STREAM_SSL_OPTION_HANDLERS
192
193         case OPT_PEER_CA_CERT:
194             stream_ssl_set_peer_ca_cert_file(optarg);
195             break;
196
197         case OPT_BOOTSTRAP_CA_CERT:
198             stream_ssl_set_ca_cert_file(optarg, true);
199             break;
200 #endif
201
202         case '?':
203             exit(EXIT_FAILURE);
204
205         default:
206             abort();
207         }
208     }
209     free(short_options);
210
211     argc -= optind;
212     argv += optind;
213
214     if (argc != 1) {
215         ovs_fatal(0, "database socket is only non-option argument; "
216                 "use --help for usage");
217     }
218
219     return argv[0];
220 }
221
222 static void
223 usage(void)
224 {
225     printf("%s: Open vSwitch daemon\n"
226            "usage: %s [OPTIONS] DATABASE\n"
227            "where DATABASE is a socket on which ovsdb-server is listening.\n",
228            program_name, program_name);
229     stream_usage("DATABASE", true, false, true);
230     daemon_usage();
231     vlog_usage();
232     printf("\nLegacy compatibility options:\n"
233            " --fake-proc-net          simulate some files in /proc/net\n"
234            "\nOther options:\n"
235            "  -h, --help              display this help message\n"
236            "  -V, --version           display version information\n");
237     leak_checker_usage();
238     exit(EXIT_SUCCESS);
239 }