]>
Commit | Line | Data |
---|---|---|
a75eb03b DM |
1 | /* |
2 | * Copyright 6WIND S.A., 2014 | |
3 | * | |
4 | * This work is licensed under the terms of the GNU GPL, version 2 or | |
5 | * (at your option) any later version. See the COPYING file in the | |
6 | * top-level directory. | |
7 | */ | |
8 | ||
ccd241b5 | 9 | #include "qemu/osdep.h" |
a75eb03b DM |
10 | #include "qemu-common.h" |
11 | ||
12 | #include "ivshmem-server.h" | |
13 | ||
14 | #define IVSHMEM_SERVER_DEFAULT_VERBOSE 0 | |
15 | #define IVSHMEM_SERVER_DEFAULT_FOREGROUND 0 | |
16 | #define IVSHMEM_SERVER_DEFAULT_PID_FILE "/var/run/ivshmem-server.pid" | |
17 | #define IVSHMEM_SERVER_DEFAULT_UNIX_SOCK_PATH "/tmp/ivshmem_socket" | |
18 | #define IVSHMEM_SERVER_DEFAULT_SHM_PATH "ivshmem" | |
19 | #define IVSHMEM_SERVER_DEFAULT_SHM_SIZE (4*1024*1024) | |
20 | #define IVSHMEM_SERVER_DEFAULT_N_VECTORS 1 | |
21 | ||
22 | /* used to quit on signal SIGTERM */ | |
23 | static int ivshmem_server_quit; | |
24 | ||
25 | /* arguments given by the user */ | |
26 | typedef struct IvshmemServerArgs { | |
27 | bool verbose; | |
28 | bool foreground; | |
29 | const char *pid_file; | |
30 | const char *unix_socket_path; | |
31 | const char *shm_path; | |
32 | uint64_t shm_size; | |
33 | unsigned n_vectors; | |
34 | } IvshmemServerArgs; | |
35 | ||
36 | /* show ivshmem_server_usage and exit with given error code */ | |
37 | static void | |
38 | ivshmem_server_usage(const char *name, int code) | |
39 | { | |
40 | fprintf(stderr, "%s [opts]\n", name); | |
41 | fprintf(stderr, " -h: show this help\n"); | |
42 | fprintf(stderr, " -v: verbose mode\n"); | |
43 | fprintf(stderr, " -F: foreground mode (default is to daemonize)\n"); | |
44 | fprintf(stderr, " -p <pid_file>: path to the PID file (used in daemon\n" | |
45 | " mode only).\n" | |
46 | " Default=%s\n", IVSHMEM_SERVER_DEFAULT_SHM_PATH); | |
47 | fprintf(stderr, " -S <unix_socket_path>: path to the unix socket\n" | |
48 | " to listen to.\n" | |
49 | " Default=%s\n", IVSHMEM_SERVER_DEFAULT_UNIX_SOCK_PATH); | |
50 | fprintf(stderr, " -m <shm_path>: path to the shared memory.\n" | |
1e21feb6 MAL |
51 | " The path corresponds to a POSIX shm name or a\n" |
52 | " hugetlbfs mount point.\n" | |
a75eb03b DM |
53 | " default=%s\n", IVSHMEM_SERVER_DEFAULT_SHM_PATH); |
54 | fprintf(stderr, " -l <size>: size of shared memory in bytes. The suffix\n" | |
55 | " K, M and G can be used (ex: 1K means 1024).\n" | |
56 | " default=%u\n", IVSHMEM_SERVER_DEFAULT_SHM_SIZE); | |
57 | fprintf(stderr, " -n <n_vects>: number of vectors.\n" | |
58 | " default=%u\n", IVSHMEM_SERVER_DEFAULT_N_VECTORS); | |
59 | ||
60 | exit(code); | |
61 | } | |
62 | ||
63 | /* parse the program arguments, exit on error */ | |
64 | static void | |
65 | ivshmem_server_parse_args(IvshmemServerArgs *args, int argc, char *argv[]) | |
66 | { | |
67 | int c; | |
68 | unsigned long long v; | |
533fdaed | 69 | Error *err = NULL; |
a75eb03b DM |
70 | |
71 | while ((c = getopt(argc, argv, | |
72 | "h" /* help */ | |
73 | "v" /* verbose */ | |
74 | "F" /* foreground */ | |
75 | "p:" /* pid_file */ | |
76 | "S:" /* unix_socket_path */ | |
77 | "m:" /* shm_path */ | |
78 | "l:" /* shm_size */ | |
79 | "n:" /* n_vectors */ | |
80 | )) != -1) { | |
81 | ||
82 | switch (c) { | |
83 | case 'h': /* help */ | |
84 | ivshmem_server_usage(argv[0], 0); | |
85 | break; | |
86 | ||
87 | case 'v': /* verbose */ | |
88 | args->verbose = 1; | |
89 | break; | |
90 | ||
91 | case 'F': /* foreground */ | |
92 | args->foreground = 1; | |
93 | break; | |
94 | ||
95 | case 'p': /* pid_file */ | |
45b00c44 | 96 | args->pid_file = optarg; |
a75eb03b DM |
97 | break; |
98 | ||
99 | case 'S': /* unix_socket_path */ | |
45b00c44 | 100 | args->unix_socket_path = optarg; |
a75eb03b DM |
101 | break; |
102 | ||
103 | case 'm': /* shm_path */ | |
45b00c44 | 104 | args->shm_path = optarg; |
a75eb03b DM |
105 | break; |
106 | ||
107 | case 'l': /* shm_size */ | |
533fdaed MA |
108 | parse_option_size("shm_size", optarg, &args->shm_size, &err); |
109 | if (err) { | |
110 | error_report_err(err); | |
a75eb03b DM |
111 | ivshmem_server_usage(argv[0], 1); |
112 | } | |
113 | break; | |
114 | ||
115 | case 'n': /* n_vectors */ | |
116 | if (parse_uint_full(optarg, &v, 0) < 0) { | |
117 | fprintf(stderr, "cannot parse n_vectors\n"); | |
118 | ivshmem_server_usage(argv[0], 1); | |
119 | } | |
120 | args->n_vectors = v; | |
121 | break; | |
122 | ||
123 | default: | |
124 | ivshmem_server_usage(argv[0], 1); | |
125 | break; | |
126 | } | |
127 | } | |
128 | ||
129 | if (args->n_vectors > IVSHMEM_SERVER_MAX_VECTORS) { | |
130 | fprintf(stderr, "too many requested vectors (max is %d)\n", | |
131 | IVSHMEM_SERVER_MAX_VECTORS); | |
132 | ivshmem_server_usage(argv[0], 1); | |
133 | } | |
134 | ||
135 | if (args->verbose == 1 && args->foreground == 0) { | |
136 | fprintf(stderr, "cannot use verbose in daemon mode\n"); | |
137 | ivshmem_server_usage(argv[0], 1); | |
138 | } | |
139 | } | |
140 | ||
141 | /* wait for events on listening server unix socket and connected client | |
142 | * sockets */ | |
143 | static int | |
144 | ivshmem_server_poll_events(IvshmemServer *server) | |
145 | { | |
146 | fd_set fds; | |
147 | int ret = 0, maxfd; | |
148 | ||
149 | while (!ivshmem_server_quit) { | |
150 | ||
151 | FD_ZERO(&fds); | |
152 | maxfd = 0; | |
153 | ivshmem_server_get_fds(server, &fds, &maxfd); | |
154 | ||
155 | ret = select(maxfd, &fds, NULL, NULL, NULL); | |
156 | ||
157 | if (ret < 0) { | |
158 | if (errno == EINTR) { | |
159 | continue; | |
160 | } | |
161 | ||
162 | fprintf(stderr, "select error: %s\n", strerror(errno)); | |
163 | break; | |
164 | } | |
165 | if (ret == 0) { | |
166 | continue; | |
167 | } | |
168 | ||
169 | if (ivshmem_server_handle_fds(server, &fds, maxfd) < 0) { | |
170 | fprintf(stderr, "ivshmem_server_handle_fds() failed\n"); | |
171 | break; | |
172 | } | |
173 | } | |
174 | ||
175 | return ret; | |
176 | } | |
177 | ||
178 | static void | |
179 | ivshmem_server_quit_cb(int signum) | |
180 | { | |
181 | ivshmem_server_quit = 1; | |
182 | } | |
183 | ||
184 | int | |
185 | main(int argc, char *argv[]) | |
186 | { | |
187 | IvshmemServer server; | |
188 | struct sigaction sa, sa_quit; | |
189 | IvshmemServerArgs args = { | |
190 | .verbose = IVSHMEM_SERVER_DEFAULT_VERBOSE, | |
191 | .foreground = IVSHMEM_SERVER_DEFAULT_FOREGROUND, | |
192 | .pid_file = IVSHMEM_SERVER_DEFAULT_PID_FILE, | |
193 | .unix_socket_path = IVSHMEM_SERVER_DEFAULT_UNIX_SOCK_PATH, | |
194 | .shm_path = IVSHMEM_SERVER_DEFAULT_SHM_PATH, | |
195 | .shm_size = IVSHMEM_SERVER_DEFAULT_SHM_SIZE, | |
196 | .n_vectors = IVSHMEM_SERVER_DEFAULT_N_VECTORS, | |
197 | }; | |
198 | int ret = 1; | |
199 | ||
200 | /* parse arguments, will exit on error */ | |
201 | ivshmem_server_parse_args(&args, argc, argv); | |
202 | ||
203 | /* Ignore SIGPIPE, see this link for more info: | |
204 | * http://www.mail-archive.com/libevent-users@monkey.org/msg01606.html */ | |
205 | sa.sa_handler = SIG_IGN; | |
206 | sa.sa_flags = 0; | |
207 | if (sigemptyset(&sa.sa_mask) == -1 || | |
208 | sigaction(SIGPIPE, &sa, 0) == -1) { | |
209 | perror("failed to ignore SIGPIPE; sigaction"); | |
210 | goto err; | |
211 | } | |
212 | ||
213 | sa_quit.sa_handler = ivshmem_server_quit_cb; | |
214 | sa_quit.sa_flags = 0; | |
215 | if (sigemptyset(&sa_quit.sa_mask) == -1 || | |
216 | sigaction(SIGTERM, &sa_quit, 0) == -1) { | |
217 | perror("failed to add SIGTERM handler; sigaction"); | |
218 | goto err; | |
219 | } | |
220 | ||
221 | /* init the ivshms structure */ | |
222 | if (ivshmem_server_init(&server, args.unix_socket_path, args.shm_path, | |
223 | args.shm_size, args.n_vectors, args.verbose) < 0) { | |
224 | fprintf(stderr, "cannot init server\n"); | |
225 | goto err; | |
226 | } | |
227 | ||
228 | /* start the ivshmem server (open shm & unix socket) */ | |
229 | if (ivshmem_server_start(&server) < 0) { | |
230 | fprintf(stderr, "cannot bind\n"); | |
231 | goto err; | |
232 | } | |
233 | ||
234 | /* daemonize if asked to */ | |
235 | if (!args.foreground) { | |
236 | FILE *fp; | |
237 | ||
238 | if (qemu_daemon(1, 1) < 0) { | |
239 | fprintf(stderr, "cannot daemonize: %s\n", strerror(errno)); | |
240 | goto err_close; | |
241 | } | |
242 | ||
243 | /* write pid file */ | |
244 | fp = fopen(args.pid_file, "w"); | |
245 | if (fp == NULL) { | |
246 | fprintf(stderr, "cannot write pid file: %s\n", strerror(errno)); | |
247 | goto err_close; | |
248 | } | |
249 | ||
250 | fprintf(fp, "%d\n", (int) getpid()); | |
251 | fclose(fp); | |
252 | } | |
253 | ||
254 | ivshmem_server_poll_events(&server); | |
255 | fprintf(stdout, "server disconnected\n"); | |
256 | ret = 0; | |
257 | ||
258 | err_close: | |
259 | ivshmem_server_close(&server); | |
260 | err: | |
261 | return ret; | |
262 | } |