frederik
/
xserver
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
xserver/hw/xquartz/mach-startup/bundle-main.c

810 lines
23 KiB
C
Raw Blame History

/* main.c -- X application launcher
* Copyright (c) 2007 Jeremy Huddleston
* Copyright (c) 2007-2012 Apple Inc. All rights reserved.
*
* Permission is hereby granted, free of charge, to any person
* obtaining a copy of this software and associated documentation files
* (the "Software"), to deal in the Software without restriction,
* including without limitation the rights to use, copy, modify, merge,
* publish, distribute, sublicense, and/or sell copies of the Software,
* and to permit persons to whom the Software is furnished to do so,
* subject to the following conditions:
*
* The above copyright notice and this permission notice shall be
* included in all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
* NONINFRINGEMENT. IN NO EVENT SHALL THE ABOVE LISTED COPYRIGHT
* HOLDER(S) BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
* WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
* DEALINGS IN THE SOFTWARE.
*
* Except as contained in this notice, the name(s) of the above
* copyright holders shall not be used in advertising or otherwise to
* promote the sale, use or other dealings in this Software without
* prior written authorization.
*/
#include <CoreFoundation/CoreFoundation.h>
#include <dix-config.h>
#include <errno.h>
#include <X11/Xlib.h>
#include <X11/Xfuncproto.h>
#include <assert.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <stdbool.h>
#include <signal.h>
#include <dispatch/dispatch.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <fcntl.h>
#include <mach/mach.h>
#include <mach/mach_error.h>
#include <servers/bootstrap.h>
#include "mach_startup.h"
#include "mach_startupServer.h"
#include <asl.h>
/* From darwinEvents.c ... but don't want to pull in all the server cruft */
void
DarwinListenOnOpenFD(int fd);
extern aslclient aslc;
/* Ditto, from os/log.c */
extern void
ErrorF(const char *f, ...) _X_ATTRIBUTE_PRINTF(1, 2);
extern void
FatalError(const char *f, ...) _X_ATTRIBUTE_PRINTF(1, 2) _X_NORETURN;
extern int noPanoramiXExtension;
#ifdef COMPOSITE
extern Bool noCompositeExtension;
#endif
#define DEFAULT_CLIENT X11BINDIR "/xterm"
#define DEFAULT_STARTX X11BINDIR "/startx -- " X11BINDIR "/Xquartz"
#define DEFAULT_SHELL "/bin/sh"
#define _STRINGIZE(s) #s
#define STRINGIZE(s) _STRINGIZE(s)
#ifndef XSERVER_VERSION
#define XSERVER_VERSION "?"
#endif
static char __crashreporter_info_buff__[4096] = { 0 };
static const char *__crashreporter_info__ __attribute__((__used__)) =
&__crashreporter_info_buff__[0];
// This line just tells the linker to never strip this symbol (such as for space optimization)
asm (".desc ___crashreporter_info__, 0x10");
static const char *__crashreporter_info__base =
"X.Org X Server " XSERVER_VERSION;
char *bundle_id_prefix = NULL;
static char *server_bootstrap_name = NULL;
#define DEBUG 1
/* This is in quartzStartup.c */
int
server_main(int argc, char **argv, char **envp);
static int
execute(const char *command);
static char *
command_from_prefs(const char *key, const char *default_value);
static char *pref_app_to_run;
static char *pref_login_shell;
static char *pref_startx_script;
/*** Mach-O IPC Stuffs ***/
union MaxMsgSize {
union __RequestUnion__mach_startup_subsystem req;
union __ReplyUnion__mach_startup_subsystem rep;
};
static mach_port_t
checkin_or_register(char *bname)
{
kern_return_t kr;
mach_port_t mp;
/* If we're started by launchd or the old mach_init */
kr = bootstrap_check_in(bootstrap_port, bname, &mp);
if (kr == KERN_SUCCESS)
return mp;
/* We probably were not started by launchd or the old mach_init */
kr = mach_port_allocate(mach_task_self(), MACH_PORT_RIGHT_RECEIVE, &mp);
if (kr != KERN_SUCCESS) {
ErrorF("mach_port_allocate(): %s\n", mach_error_string(kr));
exit(EXIT_FAILURE);
}
kr = mach_port_insert_right(
mach_task_self(), mp, mp, MACH_MSG_TYPE_MAKE_SEND);
if (kr != KERN_SUCCESS) {
ErrorF("mach_port_insert_right(): %s\n", mach_error_string(kr));
exit(EXIT_FAILURE);
}
#ifdef __clang__
#pragma clang diagnostic push
#pragma clang diagnostic ignored "-Wdeprecated-declarations" // bootstrap_register
#endif
kr = bootstrap_register(bootstrap_port, bname, mp);
#ifdef __clang__
#pragma clang diagnostic pop
#endif
if (kr != KERN_SUCCESS) {
ErrorF("bootstrap_register(): %s\n", mach_error_string(kr));
exit(EXIT_FAILURE);
}
return mp;
}
/*** $DISPLAY handoff ***/
static int
accept_fd_handoff(int connected_fd)
{
int launchd_fd;
char databuf[] = "display";
struct iovec iov[1];
union {
struct cmsghdr hdr;
char bytes[CMSG_SPACE(sizeof(int))];
} buf;
struct msghdr msg;
struct cmsghdr *cmsg;
iov[0].iov_base = databuf;
iov[0].iov_len = sizeof(databuf);
msg.msg_iov = iov;
msg.msg_iovlen = 1;
msg.msg_control = buf.bytes;
msg.msg_controllen = sizeof(buf);
msg.msg_name = 0;
msg.msg_namelen = 0;
msg.msg_flags = 0;
cmsg = CMSG_FIRSTHDR(&msg);
cmsg->cmsg_level = SOL_SOCKET;
cmsg->cmsg_type = SCM_RIGHTS;
cmsg->cmsg_len = CMSG_LEN(sizeof(int));
msg.msg_controllen = cmsg->cmsg_len;
*((int *)CMSG_DATA(cmsg)) = -1;
if (recvmsg(connected_fd, &msg, 0) < 0) {
ErrorF(
"X11.app: Error receiving $DISPLAY file descriptor. recvmsg() error: %s\n",
strerror(errno));
return -1;
}
launchd_fd = *((int *)CMSG_DATA(cmsg));
return launchd_fd;
}
typedef struct {
int fd;
string_t filename;
} socket_handoff_t;
/* This thread accepts an incoming connection and hands off the file
* descriptor for the new connection to accept_fd_handoff()
*/
static void
socket_handoff(socket_handoff_t *handoff_data)
{
int launchd_fd = -1;
int connected_fd;
/* Now actually get the passed file descriptor from this connection
* If we encounter an error, keep listening.
*/
while (launchd_fd == -1) {
connected_fd = accept(handoff_data->fd, NULL, NULL);
if (connected_fd == -1) {
ErrorF(
"X11.app: Failed to accept incoming connection on socket (fd=%d): %s\n",
handoff_data->fd, strerror(errno));
sleep(2);
continue;
}
launchd_fd = accept_fd_handoff(connected_fd);
if (launchd_fd == -1)
ErrorF(
"X11.app: Error receiving $DISPLAY file descriptor, no descriptor received? Waiting for another connection.\n");
close(connected_fd);
}
close(handoff_data->fd);
unlink(handoff_data->filename);
free(handoff_data);
ErrorF(
"X11.app Handing off fd to server thread via DarwinListenOnOpenFD(%d)\n",
launchd_fd);
DarwinListenOnOpenFD(launchd_fd);
}
static int
create_socket(char *filename_out)
{
struct sockaddr_un servaddr_un;
struct sockaddr *servaddr;
socklen_t servaddr_len;
int ret_fd;
size_t try, try_max;
for (try = 0, try_max = 5; try < try_max; try++) {
tmpnam(filename_out);
/* Setup servaddr_un */
memset(&servaddr_un, 0, sizeof(struct sockaddr_un));
servaddr_un.sun_family = AF_UNIX;
strlcpy(servaddr_un.sun_path, filename_out,
sizeof(servaddr_un.sun_path));
servaddr = (struct sockaddr *)&servaddr_un;
servaddr_len = sizeof(struct sockaddr_un) -
sizeof(servaddr_un.sun_path) + strlen(filename_out);
ret_fd = socket(PF_UNIX, SOCK_STREAM, 0);
if (ret_fd == -1) {
ErrorF(
"X11.app: Failed to create socket (try %d / %d): %s - %s\n",
(int)try + 1, (int)try_max, filename_out, strerror(errno));
continue;
}
if (bind(ret_fd, servaddr, servaddr_len) != 0) {
ErrorF("X11.app: Failed to bind socket: %d - %s\n", errno,
strerror(
errno));
close(ret_fd);
return 0;
}
if (listen(ret_fd, 10) != 0) {
ErrorF("X11.app: Failed to listen to socket: %s - %d - %s\n",
filename_out, errno, strerror(
errno));
close(ret_fd);
return 0;
}
#ifdef DEBUG
ErrorF("X11.app: Listening on socket for fd handoff: (%d) %s\n",
ret_fd,
filename_out);
#endif
return ret_fd;
}
return 0;
}
static int launchd_socket_handed_off = 0;
kern_return_t
do_request_fd_handoff_socket(mach_port_t port, string_t filename)
{
socket_handoff_t *handoff_data;
launchd_socket_handed_off = 1;
handoff_data = (socket_handoff_t *)calloc(1, sizeof(socket_handoff_t));
if (!handoff_data) {
ErrorF("X11.app: Error allocating memory for handoff_data\n");
return KERN_FAILURE;
}
handoff_data->fd = create_socket(handoff_data->filename);
if (!handoff_data->fd) {
free(handoff_data);
return KERN_FAILURE;
}
strlcpy(filename, handoff_data->filename, STRING_T_SIZE);
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,
0), ^ {
socket_handoff(handoff_data);
});
#ifdef DEBUG
ErrorF(
"X11.app: Thread created for handoff. Returning success to tell caller to connect and push the fd.\n");
#endif
return KERN_SUCCESS;
}
kern_return_t
do_request_pid(mach_port_t port, int *my_pid)
{
*my_pid = getpid();
return KERN_SUCCESS;
}
/*** Server Startup ***/
kern_return_t
do_start_x11_server(mach_port_t port, string_array_t argv,
mach_msg_type_number_t argvCnt,
string_array_t envp,
mach_msg_type_number_t envpCnt)
{
/* And now back to char ** */
char **_argv = alloca((argvCnt + 1) * sizeof(char *));
char **_envp = alloca((envpCnt + 1) * sizeof(char *));
size_t i;
/* If we didn't get handed a launchd DISPLAY socket, we should
* unset DISPLAY or we can run into problems with pbproxy
*/
if (!launchd_socket_handed_off) {
ErrorF("X11.app: No launchd socket handed off, unsetting DISPLAY\n");
unsetenv("DISPLAY");
}
if (!_argv || !_envp) {
return KERN_FAILURE;
}
ErrorF("X11.app: do_start_x11_server(): argc=%d\n", argvCnt);
for (i = 0; i < argvCnt; i++) {
_argv[i] = argv[i];
ErrorF("\targv[%u] = %s\n", (unsigned)i, argv[i]);
}
_argv[argvCnt] = NULL;
for (i = 0; i < envpCnt; i++) {
_envp[i] = envp[i];
}
_envp[envpCnt] = NULL;
if (server_main(argvCnt, _argv, _envp) == 0)
return KERN_SUCCESS;
else
return KERN_FAILURE;
}
static int
startup_trigger(int argc, char **argv, char **envp)
{
Display *display;
const char *s;
/* Take care of the case where we're called like a normal DDX */
if (argc > 1 && argv[1][0] == ':') {
size_t i;
kern_return_t kr;
mach_port_t mp;
string_array_t newenvp;
string_array_t newargv;
/* We need to count envp */
int envpc;
for (envpc = 0; envp[envpc]; envpc++) ;
/* We have fixed-size string lengths due to limitations in IPC,
* so we need to copy our argv and envp.
*/
newargv = (string_array_t)alloca(argc * sizeof(string_t));
newenvp = (string_array_t)alloca(envpc * sizeof(string_t));
if (!newargv || !newenvp) {
ErrorF("Memory allocation failure\n");
exit(EXIT_FAILURE);
}
for (i = 0; i < argc; i++) {
strlcpy(newargv[i], argv[i], STRING_T_SIZE);
}
for (i = 0; i < envpc; i++) {
strlcpy(newenvp[i], envp[i], STRING_T_SIZE);
}
kr = bootstrap_look_up(bootstrap_port, server_bootstrap_name, &mp);
if (kr != KERN_SUCCESS) {
ErrorF("bootstrap_look_up(%s): %s\n", server_bootstrap_name,
bootstrap_strerror(
kr));
exit(EXIT_FAILURE);
}
kr = start_x11_server(mp, newargv, argc, newenvp, envpc);
if (kr != KERN_SUCCESS) {
ErrorF("start_x11_server: %s\n", mach_error_string(kr));
exit(EXIT_FAILURE);
}
exit(EXIT_SUCCESS);
}
/* If we have a process serial number and it's our only arg, act as if
* the user double clicked the app bundle: launch app_to_run if possible
*/
if (argc == 1 || (argc == 2 && !strncmp(argv[1], "-psn_", 5))) {
/* Now, try to open a display, if so, run the launcher */
display = XOpenDisplay(NULL);
if (display) {
/* Could open the display, start the launcher */
XCloseDisplay(display);
return execute(pref_app_to_run);
}
}
/* Start the server */
if ((s = getenv("DISPLAY"))) {
ErrorF(
"X11.app: Could not connect to server (DISPLAY=\"%s\", unsetting). Starting X server.\n",
s);
unsetenv("DISPLAY");
}
else {
ErrorF(
"X11.app: Could not connect to server (DISPLAY is not set). Starting X server.\n");
}
return execute(pref_startx_script);
}
/** Setup the environment we want our child processes to inherit */
static void
ensure_path(const char *dir)
{
char buf[1024], *temp;
/* Make sure /usr/X11/bin is in the $PATH */
temp = getenv("PATH");
if (temp == NULL || temp[0] == 0) {
snprintf(buf, sizeof(buf),
"/bin:/sbin:/usr/bin:/usr/sbin:/usr/local/bin:%s",
dir);
setenv("PATH", buf, TRUE);
}
else if (strnstr(temp, X11BINDIR, sizeof(temp)) == NULL) {
snprintf(buf, sizeof(buf), "%s:%s", temp, dir);
setenv("PATH", buf, TRUE);
}
}
static void
setup_console_redirect(const char *bundle_id)
{
char *asl_sender;
char *asl_facility;
asprintf(&asl_sender, "%s.server", bundle_id);
assert(asl_sender);
asl_facility = strdup(bundle_id);
assert(asl_facility);
if (strcmp(asl_facility + strlen(asl_facility) - 4, ".X11") == 0)
asl_facility[strlen(asl_facility) - 4] = '\0';
assert(aslc = asl_open(asl_sender, asl_facility, ASL_OPT_NO_DELAY));
free(asl_sender);
free(asl_facility);
asl_set_filter(aslc, ASL_FILTER_MASK_UPTO(ASL_LEVEL_WARNING));
asl_log_descriptor(aslc, NULL, ASL_LEVEL_INFO, STDOUT_FILENO, ASL_LOG_DESCRIPTOR_WRITE);
asl_log_descriptor(aslc, NULL, ASL_LEVEL_NOTICE, STDERR_FILENO, ASL_LOG_DESCRIPTOR_WRITE);
}
static void
setup_env(void)
{
char *temp;
const char *pds = NULL;
const char *disp = getenv("DISPLAY");
size_t len;
/* Pass on our prefs domain to startx and its inheritors (mainly for
* quartz-wm and the Xquartz stub's MachIPC)
*/
CFBundleRef bundle = CFBundleGetMainBundle();
if (bundle) {
CFStringRef pd = CFBundleGetIdentifier(bundle);
if (pd) {
pds = CFStringGetCStringPtr(pd, 0);
}
}
/* fallback to hardcoded value if we can't discover it */
if (!pds) {
pds = BUNDLE_ID_PREFIX ".X11";
}
setup_console_redirect(pds);
server_bootstrap_name = strdup(pds);
if (!server_bootstrap_name) {
ErrorF("X11.app: Memory allocation error.\n");
exit(1);
}
setenv("X11_PREFS_DOMAIN", server_bootstrap_name, 1);
len = strlen(server_bootstrap_name);
bundle_id_prefix = malloc(sizeof(char) * (len - 3));
if (!bundle_id_prefix) {
ErrorF("X11.app: Memory allocation error.\n");
exit(1);
}
strlcpy(bundle_id_prefix, server_bootstrap_name, len - 3);
/* We need to unset DISPLAY if it is not our socket */
if (disp) {
/* s = basename(disp) */
const char *d, *s;
for (s = NULL, d = disp; *d; d++) {
if (*d == '/')
s = d + 1;
}
if (s && *s) {
if (strcmp(bundle_id_prefix,
"org.x") == 0 && strcmp(s, ":0") == 0) {
ErrorF(
"X11.app: Detected old style launchd DISPLAY, please update xinit.\n");
}
else {
temp = (char *)malloc(sizeof(char) * len);
if (!temp) {
ErrorF(
"X11.app: Memory allocation error creating space for socket name test.\n");
exit(1);
}
strlcpy(temp, bundle_id_prefix, len);
strlcat(temp, ":0", len);
if (strcmp(temp, s) != 0) {
/* If we don't have a match, unset it. */
ErrorF(
"X11.app: DISPLAY (\"%s\") does not match our id (\"%s\"), unsetting.\n",
disp, bundle_id_prefix);
unsetenv("DISPLAY");
}
free(temp);
}
}
else {
/* The DISPLAY environment variable is not formatted like a launchd socket, so reset. */
ErrorF(
"X11.app: DISPLAY does not look like a launchd set variable, unsetting.\n");
unsetenv("DISPLAY");
}
}
/* Make sure PATH is right */
ensure_path(X11BINDIR);
/* cd $HOME */
temp = getenv("HOME");
if (temp != NULL && temp[0] != '\0')
chdir(temp);
}
/*** Main ***/
int
main(int argc, char **argv, char **envp)
{
Bool listenOnly = FALSE;
int i;
mach_msg_size_t mxmsgsz = sizeof(union MaxMsgSize) + MAX_TRAILER_SIZE;
mach_port_t mp;
kern_return_t kr;
/* Ignore SIGPIPE */
signal(SIGPIPE, SIG_IGN);
/* Setup our environment for our children */
setup_env();
/* The server must not run the PanoramiX operations. */
noPanoramiXExtension = TRUE;
#ifdef COMPOSITE
/* https://gitlab.freedesktop.org/xorg/xserver/-/issues/1409 */
noCompositeExtension = TRUE;
#endif
/* Setup the initial crasherporter info */
strlcpy(__crashreporter_info_buff__, __crashreporter_info__base,
sizeof(__crashreporter_info_buff__));
ErrorF("X11.app: main(): argc=%d\n", argc);
for (i = 0; i < argc; i++) {
ErrorF("\targv[%u] = %s\n", (unsigned)i, argv[i]);
if (!strcmp(argv[i], "--listenonly")) {
listenOnly = TRUE;
}
}
mp = checkin_or_register(server_bootstrap_name);
if (mp == MACH_PORT_NULL) {
ErrorF("NULL mach service: %s", server_bootstrap_name);
return EXIT_FAILURE;
}
/* Check if we need to do something other than listen, and make another
* thread handle it.
*/
if (!listenOnly) {
pid_t child1, child2;
int status;
pref_app_to_run = command_from_prefs("app_to_run", DEFAULT_CLIENT);
assert(pref_app_to_run);
pref_login_shell = command_from_prefs("login_shell", DEFAULT_SHELL);
assert(pref_login_shell);
pref_startx_script = command_from_prefs("startx_script",
DEFAULT_STARTX);
assert(pref_startx_script);
/* Do the fork-twice trick to avoid having to reap zombies */
child1 = fork();
switch (child1) {
case -1: /* error */
FatalError("fork() failed: %s\n", strerror(errno));
case 0: /* child1 */
child2 = fork();
switch (child2) {
int max_files;
case -1: /* error */
FatalError("fork() failed: %s\n", strerror(errno));
case 0: /* child2 */
/* close all open files except for standard streams */
max_files = sysconf(_SC_OPEN_MAX);
for (i = 3; i < max_files; i++)
close(i);
/* ensure stdin is on /dev/null */
close(0);
open("/dev/null", O_RDONLY);
return startup_trigger(argc, argv, envp);
default: /* parent (child1) */
_exit(0);
}
break;
default: /* parent */
waitpid(child1, &status, 0);
}
free(pref_app_to_run);
free(pref_login_shell);
free(pref_startx_script);
}
/* Main event loop */
ErrorF("Waiting for startup parameters via Mach IPC.\n");
kr = mach_msg_server(mach_startup_server, mxmsgsz, mp, 0);
if (kr != KERN_SUCCESS) {
ErrorF("%s.X11(mp): %s\n", BUNDLE_ID_PREFIX, mach_error_string(kr));
return EXIT_FAILURE;
}
return EXIT_SUCCESS;
}
static int
execute(const char *command)
{
const char *newargv[4];
const char **p;
newargv[0] = pref_login_shell;
newargv[1] = "-c";
newargv[2] = command;
newargv[3] = NULL;
ErrorF("X11.app: Launching %s:\n", command);
for (p = newargv; *p; p++) {
ErrorF("\targv[%ld] = %s\n", (long int)(p - newargv), *p);
}
execvp(newargv[0], (char *const *)newargv);
perror("X11.app: Couldn't exec.");
return 1;
}
static char *
command_from_prefs(const char *key, const char *default_value)
{
char *command = NULL;
CFStringRef cfKey;
CFPropertyListRef PlistRef;
if (!key)
return NULL;
cfKey = CFStringCreateWithCString(NULL, key, kCFStringEncodingASCII);
if (!cfKey)
return NULL;
PlistRef = CFPreferencesCopyAppValue(cfKey,
kCFPreferencesCurrentApplication);
if ((PlistRef == NULL) ||
(CFGetTypeID(PlistRef) != CFStringGetTypeID())) {
CFStringRef cfDefaultValue = CFStringCreateWithCString(
NULL, default_value, kCFStringEncodingASCII);
int len = strlen(default_value) + 1;
if (!cfDefaultValue)
goto command_from_prefs_out;
CFPreferencesSetAppValue(cfKey, cfDefaultValue,
kCFPreferencesCurrentApplication);
CFPreferencesAppSynchronize(kCFPreferencesCurrentApplication);
CFRelease(cfDefaultValue);
command = (char *)malloc(len * sizeof(char));
if (!command)
goto command_from_prefs_out;
strcpy(command, default_value);
}
else {
int len = CFStringGetLength((CFStringRef)PlistRef) + 1;
command = (char *)malloc(len * sizeof(char));
if (!command)
goto command_from_prefs_out;
CFStringGetCString((CFStringRef)PlistRef, command, len,
kCFStringEncodingASCII);
}
command_from_prefs_out:
if (PlistRef)
CFRelease(PlistRef);
if (cfKey)
CFRelease(cfKey);
return command;
}
Reference in New Issue View Git Blame Copy Permalink