1*4882a593Smuzhiyun /*
2*4882a593Smuzhiyun * Copyright © 2016 Broadcom
3*4882a593Smuzhiyun *
4*4882a593Smuzhiyun * Permission is hereby granted, free of charge, to any person obtaining a
5*4882a593Smuzhiyun * copy of this software and associated documentation files (the "Software"),
6*4882a593Smuzhiyun * to deal in the Software without restriction, including without limitation
7*4882a593Smuzhiyun * the rights to use, copy, modify, merge, publish, distribute, sublicense,
8*4882a593Smuzhiyun * and/or sell copies of the Software, and to permit persons to whom the
9*4882a593Smuzhiyun * Software is furnished to do so, subject to the following conditions:
10*4882a593Smuzhiyun *
11*4882a593Smuzhiyun * The above copyright notice and this permission notice (including the next
12*4882a593Smuzhiyun * paragraph) shall be included in all copies or substantial portions of the
13*4882a593Smuzhiyun * Software.
14*4882a593Smuzhiyun *
15*4882a593Smuzhiyun * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
16*4882a593Smuzhiyun * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17*4882a593Smuzhiyun * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
18*4882a593Smuzhiyun * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
19*4882a593Smuzhiyun * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
20*4882a593Smuzhiyun * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
21*4882a593Smuzhiyun * IN THE SOFTWARE.
22*4882a593Smuzhiyun */
23*4882a593Smuzhiyun
24*4882a593Smuzhiyun #ifdef HAVE_DIX_CONFIG_H
25*4882a593Smuzhiyun #include <dix-config.h>
26*4882a593Smuzhiyun #endif
27*4882a593Smuzhiyun
28*4882a593Smuzhiyun #include <errno.h>
29*4882a593Smuzhiyun #include <signal.h>
30*4882a593Smuzhiyun #include <stdbool.h>
31*4882a593Smuzhiyun #include <stdio.h>
32*4882a593Smuzhiyun #include <stdlib.h>
33*4882a593Smuzhiyun #include <string.h>
34*4882a593Smuzhiyun #include <sys/wait.h>
35*4882a593Smuzhiyun #include <unistd.h>
36*4882a593Smuzhiyun
37*4882a593Smuzhiyun static void
kill_server(int server_pid)38*4882a593Smuzhiyun kill_server(int server_pid)
39*4882a593Smuzhiyun {
40*4882a593Smuzhiyun int ret = kill(server_pid, SIGTERM);
41*4882a593Smuzhiyun int wstatus;
42*4882a593Smuzhiyun
43*4882a593Smuzhiyun if (ret) {
44*4882a593Smuzhiyun fprintf(stderr, "Failed to send kill to the server: %s\n",
45*4882a593Smuzhiyun strerror(errno));
46*4882a593Smuzhiyun exit(1);
47*4882a593Smuzhiyun }
48*4882a593Smuzhiyun
49*4882a593Smuzhiyun ret = waitpid(server_pid, &wstatus, 0);
50*4882a593Smuzhiyun if (ret < 0) {
51*4882a593Smuzhiyun fprintf(stderr, "Failed to wait for X to die: %s\n", strerror(errno));
52*4882a593Smuzhiyun exit(1);
53*4882a593Smuzhiyun }
54*4882a593Smuzhiyun }
55*4882a593Smuzhiyun
56*4882a593Smuzhiyun static void
usage(int argc,char ** argv)57*4882a593Smuzhiyun usage(int argc, char **argv)
58*4882a593Smuzhiyun {
59*4882a593Smuzhiyun fprintf(stderr, "%s <client command> -- <server command>\n", argv[0]);
60*4882a593Smuzhiyun exit(1);
61*4882a593Smuzhiyun }
62*4882a593Smuzhiyun
63*4882a593Smuzhiyun /* Starts the X server, returning its pid. */
64*4882a593Smuzhiyun static int
start_server(char * const * server_args)65*4882a593Smuzhiyun start_server(char *const *server_args)
66*4882a593Smuzhiyun {
67*4882a593Smuzhiyun int server_pid = fork();
68*4882a593Smuzhiyun
69*4882a593Smuzhiyun if (server_pid == -1) {
70*4882a593Smuzhiyun fprintf(stderr, "Fork failed: %s\n", strerror(errno));
71*4882a593Smuzhiyun exit(1);
72*4882a593Smuzhiyun } else if (server_pid != 0) {
73*4882a593Smuzhiyun /* Continue along the main process that will exec the client. */
74*4882a593Smuzhiyun return server_pid;
75*4882a593Smuzhiyun }
76*4882a593Smuzhiyun
77*4882a593Smuzhiyun /* Execute the server. This only returns if an error occurred. */
78*4882a593Smuzhiyun execvp(server_args[0], server_args);
79*4882a593Smuzhiyun fprintf(stderr, "Error starting the server: %s\n", strerror(errno));
80*4882a593Smuzhiyun exit(1);
81*4882a593Smuzhiyun }
82*4882a593Smuzhiyun
83*4882a593Smuzhiyun /* Reads the display number out of the started server's display socket. */
84*4882a593Smuzhiyun static int
get_display(int displayfd)85*4882a593Smuzhiyun get_display(int displayfd)
86*4882a593Smuzhiyun {
87*4882a593Smuzhiyun char display_string[10];
88*4882a593Smuzhiyun ssize_t ret;
89*4882a593Smuzhiyun
90*4882a593Smuzhiyun ret = read(displayfd, display_string, sizeof(display_string) - 1);
91*4882a593Smuzhiyun if (ret <= 0) {
92*4882a593Smuzhiyun fprintf(stderr, "Failed reading displayfd: %s\n", strerror(errno));
93*4882a593Smuzhiyun exit(1);
94*4882a593Smuzhiyun }
95*4882a593Smuzhiyun
96*4882a593Smuzhiyun /* We've read in the display number as a string terminated by
97*4882a593Smuzhiyun * '\n', but not '\0'. Cap it and parse the number.
98*4882a593Smuzhiyun */
99*4882a593Smuzhiyun display_string[ret] = '\0';
100*4882a593Smuzhiyun return atoi(display_string);
101*4882a593Smuzhiyun }
102*4882a593Smuzhiyun
103*4882a593Smuzhiyun static int
start_client(char * const * client_args,int display)104*4882a593Smuzhiyun start_client(char *const *client_args, int display)
105*4882a593Smuzhiyun {
106*4882a593Smuzhiyun char *display_string;
107*4882a593Smuzhiyun int ret;
108*4882a593Smuzhiyun int client_pid;
109*4882a593Smuzhiyun
110*4882a593Smuzhiyun ret = asprintf(&display_string, ":%d", display);
111*4882a593Smuzhiyun if (ret < 0) {
112*4882a593Smuzhiyun fprintf(stderr, "asprintf fail\n");
113*4882a593Smuzhiyun exit(1);
114*4882a593Smuzhiyun }
115*4882a593Smuzhiyun
116*4882a593Smuzhiyun ret = setenv("DISPLAY", display_string, true);
117*4882a593Smuzhiyun if (ret) {
118*4882a593Smuzhiyun fprintf(stderr, "Failed to set DISPLAY\n");
119*4882a593Smuzhiyun exit(1);
120*4882a593Smuzhiyun }
121*4882a593Smuzhiyun
122*4882a593Smuzhiyun client_pid = fork();
123*4882a593Smuzhiyun if (client_pid == -1) {
124*4882a593Smuzhiyun fprintf(stderr, "Fork failed: %s\n", strerror(errno));
125*4882a593Smuzhiyun exit(1);
126*4882a593Smuzhiyun } else if (client_pid) {
127*4882a593Smuzhiyun int wstatus;
128*4882a593Smuzhiyun
129*4882a593Smuzhiyun ret = waitpid(client_pid, &wstatus, 0);
130*4882a593Smuzhiyun if (ret < 0) {
131*4882a593Smuzhiyun fprintf(stderr, "Error waiting for client to start: %s\n",
132*4882a593Smuzhiyun strerror(errno));
133*4882a593Smuzhiyun return 1;
134*4882a593Smuzhiyun }
135*4882a593Smuzhiyun
136*4882a593Smuzhiyun if (!WIFEXITED(wstatus))
137*4882a593Smuzhiyun return 1;
138*4882a593Smuzhiyun
139*4882a593Smuzhiyun return WEXITSTATUS(wstatus);
140*4882a593Smuzhiyun } else {
141*4882a593Smuzhiyun execvp(client_args[0], client_args);
142*4882a593Smuzhiyun /* exec only returns if an error occurred. */
143*4882a593Smuzhiyun fprintf(stderr, "Error starting the client: %s\n", strerror(errno));
144*4882a593Smuzhiyun exit(1);
145*4882a593Smuzhiyun }
146*4882a593Smuzhiyun }
147*4882a593Smuzhiyun
148*4882a593Smuzhiyun /* Splits the incoming argc/argv into a pair of NULL-terminated arrays
149*4882a593Smuzhiyun * of args.
150*4882a593Smuzhiyun */
151*4882a593Smuzhiyun static void
parse_args(int argc,char ** argv,char * const ** out_client_args,char * const ** out_server_args,int displayfd)152*4882a593Smuzhiyun parse_args(int argc, char **argv,
153*4882a593Smuzhiyun char * const **out_client_args,
154*4882a593Smuzhiyun char * const **out_server_args,
155*4882a593Smuzhiyun int displayfd)
156*4882a593Smuzhiyun {
157*4882a593Smuzhiyun /* We're stripping the -- and the program name, inserting two
158*4882a593Smuzhiyun * NULLs, and also the -displayfd and fd number.
159*4882a593Smuzhiyun */
160*4882a593Smuzhiyun char **args_storage = calloc(argc + 2, sizeof(char *));
161*4882a593Smuzhiyun char *const *client_args;
162*4882a593Smuzhiyun char *const *server_args = NULL;
163*4882a593Smuzhiyun char **next_arg = args_storage;
164*4882a593Smuzhiyun bool parsing_client = true;
165*4882a593Smuzhiyun int i, ret;
166*4882a593Smuzhiyun char *displayfd_string;
167*4882a593Smuzhiyun
168*4882a593Smuzhiyun if (!args_storage)
169*4882a593Smuzhiyun exit(1);
170*4882a593Smuzhiyun
171*4882a593Smuzhiyun client_args = args_storage;
172*4882a593Smuzhiyun for (i = 1; i < argc; i++) {
173*4882a593Smuzhiyun if (strcmp(argv[i], "--") == 0) {
174*4882a593Smuzhiyun if (!parsing_client)
175*4882a593Smuzhiyun usage(argc, argv);
176*4882a593Smuzhiyun
177*4882a593Smuzhiyun /* Cap the client list */
178*4882a593Smuzhiyun *next_arg = NULL;
179*4882a593Smuzhiyun next_arg++;
180*4882a593Smuzhiyun
181*4882a593Smuzhiyun /* Move to adding into server_args. */
182*4882a593Smuzhiyun server_args = next_arg;
183*4882a593Smuzhiyun parsing_client = false;
184*4882a593Smuzhiyun continue;
185*4882a593Smuzhiyun }
186*4882a593Smuzhiyun
187*4882a593Smuzhiyun *next_arg = argv[i];
188*4882a593Smuzhiyun next_arg++;
189*4882a593Smuzhiyun }
190*4882a593Smuzhiyun
191*4882a593Smuzhiyun if (client_args[0] == NULL || !server_args || server_args[0] == NULL)
192*4882a593Smuzhiyun usage(argc, argv);
193*4882a593Smuzhiyun
194*4882a593Smuzhiyun /* Give the server -displayfd X */
195*4882a593Smuzhiyun *next_arg = (char *)"-displayfd";
196*4882a593Smuzhiyun next_arg++;
197*4882a593Smuzhiyun
198*4882a593Smuzhiyun ret = asprintf(&displayfd_string, "%d", displayfd);
199*4882a593Smuzhiyun if (ret < 0) {
200*4882a593Smuzhiyun fprintf(stderr, "asprintf fail\n");
201*4882a593Smuzhiyun exit(1);
202*4882a593Smuzhiyun }
203*4882a593Smuzhiyun *next_arg = displayfd_string;
204*4882a593Smuzhiyun next_arg++;
205*4882a593Smuzhiyun
206*4882a593Smuzhiyun *out_client_args = client_args;
207*4882a593Smuzhiyun *out_server_args = server_args;
208*4882a593Smuzhiyun }
209*4882a593Smuzhiyun
210*4882a593Smuzhiyun int
main(int argc,char ** argv)211*4882a593Smuzhiyun main(int argc, char **argv)
212*4882a593Smuzhiyun {
213*4882a593Smuzhiyun char * const *client_args;
214*4882a593Smuzhiyun char * const *server_args;
215*4882a593Smuzhiyun int displayfd_pipe[2];
216*4882a593Smuzhiyun int display, server_pid;
217*4882a593Smuzhiyun int ret;
218*4882a593Smuzhiyun
219*4882a593Smuzhiyun ret = pipe(displayfd_pipe);
220*4882a593Smuzhiyun if (ret) {
221*4882a593Smuzhiyun fprintf(stderr, "Pipe creation failure: %s", strerror(errno));
222*4882a593Smuzhiyun exit(1);
223*4882a593Smuzhiyun }
224*4882a593Smuzhiyun
225*4882a593Smuzhiyun parse_args(argc, argv, &client_args, &server_args, displayfd_pipe[1]);
226*4882a593Smuzhiyun server_pid = start_server(server_args);
227*4882a593Smuzhiyun display = get_display(displayfd_pipe[0]);
228*4882a593Smuzhiyun ret = start_client(client_args, display);
229*4882a593Smuzhiyun kill_server(server_pid);
230*4882a593Smuzhiyun
231*4882a593Smuzhiyun exit(ret);
232*4882a593Smuzhiyun }
233