xserver git update 11/6/2010

1 files changed, 692 insertions, 692 deletions

diff --git a/xorg-server/hw/xquartz/mach-startup/bundle-main.c b/xorg-server/hw/xquartz/mach-startup/bundle-main.c
index 63a185fc8..6dc7f9094 100644
--- a/xorg-server/hw/xquartz/mach-startup/bundle-main.c
+++ b/xorg-server/hw/xquartz/mach-startup/bundle-main.c
@@ -1,692 +1,692 @@
-/* main.c -- X application launcher
- 
- Copyright (c) 2007 Jeremy Huddleston
- Copyright (c) 2007 Apple Inc
- 
- 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 <AvailabilityMacros.h>
-
-#ifdef HAVE_DIX_CONFIG_H
-#include <dix-config.h>
-#endif
-
-#include <X11/Xlib.h>
-#include <unistd.h>
-#include <stdio.h>
-#include <string.h>
-#include <stdlib.h>
-#include <pthread.h>
-#include <stdbool.h>
-#include <signal.h>
-
-#include <sys/socket.h>
-#include <sys/un.h>
-
-#include <sys/time.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 "launchd_fd.h"
-/* From darwinEvents.c ... but don't want to pull in all the server cruft */
-void DarwinListenOnOpenFD(int fd);
-
-extern int noPanoramiXExtension;
-
-#define DEFAULT_CLIENT X11BINDIR "/xterm"
-#define DEFAULT_STARTX X11BINDIR "/startx"
-#define DEFAULT_SHELL  "/bin/sh"
-
-#ifndef BUILD_DATE
-#define BUILD_DATE ""
-#endif
-#ifndef XSERVER_VERSION
-#define XSERVER_VERSION "?"
-#endif
-
-static char __crashreporter_info_buff__[4096] = {0};
-static const char *__crashreporter_info__ = &__crashreporter_info_buff__[0];
-#if MAC_OS_X_VERSION_MIN_REQUIRED >= 1050
-// This is actually a toolchain requirement, but I'm not sure the correct check,
-// but it should be fine to just only include it for Leopard and later.  This line
-// just tells the linker to never strip this symbol (such as for space optimization)
-asm (".desc ___crashreporter_info__, 0x10");
-#endif
-
-static const char *__crashreporter_info__base = "X.Org X Server " XSERVER_VERSION " Build Date: " BUILD_DATE;
-
-static char *launchd_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);
-
-/*** Pthread Magics ***/
-static pthread_t create_thread(void *func, void *arg) {
-    pthread_attr_t attr;
-    pthread_t tid;
-	
-    pthread_attr_init (&attr);
-    pthread_attr_setscope (&attr, PTHREAD_SCOPE_SYSTEM);
-    pthread_attr_setdetachstate (&attr, PTHREAD_CREATE_DETACHED);
-    pthread_create (&tid, &attr, func, arg);
-    pthread_attr_destroy (&attr);
-	
-    return tid;
-}
-
-/*** 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) {
-        fprintf(stderr, "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) {
-        fprintf(stderr, "mach_port_insert_right(): %s\n", mach_error_string(kr));
-        exit(EXIT_FAILURE);
-    }
-
-    kr = bootstrap_register(bootstrap_port, bname, mp);
-    if (kr != KERN_SUCCESS) {
-        fprintf(stderr, "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) {
-        fprintf(stderr, "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_thread(void *arg) {
-    socket_handoff_t *handoff_data = (socket_handoff_t *)arg;
-    int launchd_fd = -1;
-    int connected_fd;
-    unsigned remain;
-
-    /* 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) {
-            fprintf(stderr, "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)
-            fprintf(stderr, "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);
-    
-    /* TODO: Clean up this race better... giving xinitrc time to run... need to wait for 1.5 branch:
-     *
-     * From ajax:
-     * There's already an internal callback chain for setting selection [in 1.5]
-     * ownership.  See the CallSelectionCallback at the bottom of
-     * ProcSetSelectionOwner, and xfixes/select.c for an example of how to hook
-     * into it.
-     */
-    
-    remain = 3000000;
-    fprintf(stderr, "X11.app: Received new $DISPLAY fd: %d ... sleeping to allow xinitrc to catchup.\n", launchd_fd);
-    while((remain = usleep(remain)) > 0);
-    
-    fprintf(stderr, "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) {
-            fprintf(stderr, "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) {
-            fprintf(stderr, "X11.app: Failed to bind socket: %d - %s\n", errno, strerror(errno));
-            close(ret_fd);
-            return 0;
-        }
-        
-        if(listen(ret_fd, 10) != 0) {
-            fprintf(stderr, "X11.app: Failed to listen to socket: %s - %d - %s\n", filename_out, errno, strerror(errno));
-            close(ret_fd);
-            return 0;
-        }
-        
-#ifdef DEBUG
-        fprintf(stderr, "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) {
-        fprintf(stderr, "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);
-    
-    create_thread(socket_handoff_thread, handoff_data);
-    
-#ifdef DEBUG
-    fprintf(stderr, "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) {
-        fprintf(stderr, "X11.app: No launchd socket handed off, unsetting DISPLAY\n");
-        unsetenv("DISPLAY");
-    }
-    
-    if(!_argv || !_envp) {
-        return KERN_FAILURE;
-    }
-
-    fprintf(stderr, "X11.app: do_start_x11_server(): argc=%d\n", argvCnt);
-    for(i=0; i < argvCnt; i++) {
-        _argv[i] = argv[i];
-        fprintf(stderr, "\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) {
-            fprintf(stderr, "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) {
-#if MAC_OS_X_VERSION_MIN_REQUIRED >= 1050
-            fprintf(stderr, "bootstrap_look_up(%s): %s\n", server_bootstrap_name, bootstrap_strerror(kr));
-#else
-            fprintf(stderr, "bootstrap_look_up(%s): %ul\n", server_bootstrap_name, (unsigned long)kr);
-#endif
-            exit(EXIT_FAILURE);
-        }
-
-        kr = start_x11_server(mp, newargv, argc, newenvp, envpc);
-        if (kr != KERN_SUCCESS) {
-            fprintf(stderr, "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(command_from_prefs("app_to_run", DEFAULT_CLIENT));
-        }
-    }
-
-    /* Start the server */
-    if((s = getenv("DISPLAY"))) {
-        fprintf(stderr, "X11.app: Could not connect to server (DISPLAY=\"%s\", unsetting).  Starting X server.\n", s);
-        unsetenv("DISPLAY");
-    } else {
-        fprintf(stderr, "X11.app: Could not connect to server (DISPLAY is not set).  Starting X server.\n");
-    }
-    return execute(command_from_prefs("startx_script", DEFAULT_STARTX));
-}
-
-/** 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_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 = LAUNCHD_ID_PREFIX".X11";
-    }
-
-    server_bootstrap_name = malloc(sizeof(char) * (strlen(pds) + 1));
-    if(!server_bootstrap_name) {
-        fprintf(stderr, "X11.app: Memory allocation error.\n");
-        exit(1);
-    }
-    strcpy(server_bootstrap_name, pds);
-    setenv("X11_PREFS_DOMAIN", server_bootstrap_name, 1);
-    
-    len = strlen(server_bootstrap_name);
-    launchd_id_prefix = malloc(sizeof(char) * (len - 3));
-    if(!launchd_id_prefix) {
-        fprintf(stderr, "X11.app: Memory allocation error.\n");
-        exit(1);
-    }
-    strlcpy(launchd_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(launchd_id_prefix, "org.x") == 0 && strcmp(s, ":0") == 0) {
-                fprintf(stderr, "X11.app: Detected old style launchd DISPLAY, please update xinit.\n");
-            } else {
-                temp = (char *)malloc(sizeof(char) * len);
-                if(!temp) {
-                    fprintf(stderr, "X11.app: Memory allocation error creating space for socket name test.\n");
-                    exit(1);
-                }
-                strlcpy(temp, launchd_id_prefix, len);
-                strlcat(temp, ":0", len);
-            
-                if(strcmp(temp, s) != 0) {
-                    /* If we don't have a match, unset it. */
-                    fprintf(stderr, "X11.app: DISPLAY (\"%s\") does not match our id (\"%s\"), unsetting.\n", disp, launchd_id_prefix);
-                    unsetenv("DISPLAY");
-                }
-                free(temp);
-            }
-        } else {
-            /* The DISPLAY environment variable is not formatted like a launchd socket, so reset. */
-            fprintf(stderr, "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;
-
-    /* Setup our environment for our children */
-    setup_env();
-    
-    /* The server must not run the PanoramiX operations. */
-    noPanoramiXExtension = TRUE;
-
-    /* Setup the initial crasherporter info */
-    strlcpy(__crashreporter_info_buff__, __crashreporter_info__base, sizeof(__crashreporter_info_buff__));
-    
-    fprintf(stderr, "X11.app: main(): argc=%d\n", argc);
-    for(i=0; i < argc; i++) {
-        fprintf(stderr, "\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) {
-        fprintf(stderr, "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;
-
-        /* Do the fork-twice trick to avoid having to reap zombies */
-        child1 = fork();
-        switch (child1) {
-            case -1:                                /* error */
-                break;
-
-            case 0:                                 /* child1 */
-                child2 = fork();
-
-                switch (child2) {
-                    int max_files, i;
-
-                    case -1:                            /* error */
-                        break;
-
-                    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);
-        }
-    }
-    
-    /* Main event loop */
-    fprintf(stderr, "Waiting for startup parameters via Mach IPC.\n");
-    kr = mach_msg_server(mach_startup_server, mxmsgsz, mp, 0);
-    if (kr != KERN_SUCCESS) {
-        fprintf(stderr, "%s.X11(mp): %s\n", LAUNCHD_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] = command_from_prefs("login_shell", DEFAULT_SHELL);
-    newargv[1] = "-c";
-    newargv[2] = command;
-    newargv[3] = NULL;
-    
-    fprintf(stderr, "X11.app: Launching %s:\n", command);
-    for(p=newargv; *p; p++) {
-        fprintf(stderr, "\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;
-}
+/* main.c -- X application launcher

+ 

+ Copyright (c) 2007 Jeremy Huddleston

+ Copyright (c) 2007 Apple Inc

+ 

+ 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 <AvailabilityMacros.h>

+

+#ifdef HAVE_DIX_CONFIG_H

+#include <dix-config.h>

+#endif

+

+#include <X11/Xlib.h>

+#include <unistd.h>

+#include <stdio.h>

+#include <string.h>

+#include <stdlib.h>

+#include <pthread.h>

+#include <stdbool.h>

+#include <signal.h>

+

+#include <sys/socket.h>

+#include <sys/un.h>

+

+#include <sys/time.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 "launchd_fd.h"

+/* From darwinEvents.c ... but don't want to pull in all the server cruft */

+void DarwinListenOnOpenFD(int fd);

+

+extern int noPanoramiXExtension;

+

+#define DEFAULT_CLIENT X11BINDIR "/xterm"

+#define DEFAULT_STARTX X11BINDIR "/startx"

+#define DEFAULT_SHELL  "/bin/sh"

+

+#ifndef BUILD_DATE

+#define BUILD_DATE ""

+#endif

+#ifndef XSERVER_VERSION

+#define XSERVER_VERSION "?"

+#endif

+

+static char __crashreporter_info_buff__[4096] = {0};

+static const char *__crashreporter_info__ = &__crashreporter_info_buff__[0];

+#if MAC_OS_X_VERSION_MIN_REQUIRED >= 1050

+// This is actually a toolchain requirement, but I'm not sure the correct check,

+// but it should be fine to just only include it for Leopard and later.  This line

+// just tells the linker to never strip this symbol (such as for space optimization)

+asm (".desc ___crashreporter_info__, 0x10");

+#endif

+

+static const char *__crashreporter_info__base = "X.Org X Server " XSERVER_VERSION " Build Date: " BUILD_DATE;

+

+static char *launchd_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);

+

+/*** Pthread Magics ***/

+static pthread_t create_thread(void *func, void *arg) {

+    pthread_attr_t attr;

+    pthread_t tid;

+	

+    pthread_attr_init (&attr);

+    pthread_attr_setscope (&attr, PTHREAD_SCOPE_SYSTEM);

+    pthread_attr_setdetachstate (&attr, PTHREAD_CREATE_DETACHED);

+    pthread_create (&tid, &attr, func, arg);

+    pthread_attr_destroy (&attr);

+	

+    return tid;

+}

+

+/*** 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) {

+        fprintf(stderr, "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) {

+        fprintf(stderr, "mach_port_insert_right(): %s\n", mach_error_string(kr));

+        exit(EXIT_FAILURE);

+    }

+

+    kr = bootstrap_register(bootstrap_port, bname, mp);

+    if (kr != KERN_SUCCESS) {

+        fprintf(stderr, "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) {

+        fprintf(stderr, "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_thread(void *arg) {

+    socket_handoff_t *handoff_data = (socket_handoff_t *)arg;

+    int launchd_fd = -1;

+    int connected_fd;

+    unsigned remain;

+

+    /* 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) {

+            fprintf(stderr, "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)

+            fprintf(stderr, "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);

+    

+    /* TODO: Clean up this race better... giving xinitrc time to run... need to wait for 1.5 branch:

+     *

+     * From ajax:

+     * There's already an internal callback chain for setting selection [in 1.5]

+     * ownership.  See the CallSelectionCallback at the bottom of

+     * ProcSetSelectionOwner, and xfixes/select.c for an example of how to hook

+     * into it.

+     */

+    

+    remain = 3000000;

+    fprintf(stderr, "X11.app: Received new $DISPLAY fd: %d ... sleeping to allow xinitrc to catchup.\n", launchd_fd);

+    while((remain = usleep(remain)) > 0);

+    

+    fprintf(stderr, "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) {

+            fprintf(stderr, "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) {

+            fprintf(stderr, "X11.app: Failed to bind socket: %d - %s\n", errno, strerror(errno));

+            close(ret_fd);

+            return 0;

+        }

+        

+        if(listen(ret_fd, 10) != 0) {

+            fprintf(stderr, "X11.app: Failed to listen to socket: %s - %d - %s\n", filename_out, errno, strerror(errno));

+            close(ret_fd);

+            return 0;

+        }

+        

+#ifdef DEBUG

+        fprintf(stderr, "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) {

+        fprintf(stderr, "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);

+    

+    create_thread(socket_handoff_thread, handoff_data);

+    

+#ifdef DEBUG

+    fprintf(stderr, "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) {

+        fprintf(stderr, "X11.app: No launchd socket handed off, unsetting DISPLAY\n");

+        unsetenv("DISPLAY");

+    }

+    

+    if(!_argv || !_envp) {

+        return KERN_FAILURE;

+    }

+

+    fprintf(stderr, "X11.app: do_start_x11_server(): argc=%d\n", argvCnt);

+    for(i=0; i < argvCnt; i++) {

+        _argv[i] = argv[i];

+        fprintf(stderr, "\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) {

+            fprintf(stderr, "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) {

+#if MAC_OS_X_VERSION_MIN_REQUIRED >= 1050

+            fprintf(stderr, "bootstrap_look_up(%s): %s\n", server_bootstrap_name, bootstrap_strerror(kr));

+#else

+            fprintf(stderr, "bootstrap_look_up(%s): %ul\n", server_bootstrap_name, (unsigned long)kr);

+#endif

+            exit(EXIT_FAILURE);

+        }

+

+        kr = start_x11_server(mp, newargv, argc, newenvp, envpc);

+        if (kr != KERN_SUCCESS) {

+            fprintf(stderr, "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(command_from_prefs("app_to_run", DEFAULT_CLIENT));

+        }

+    }

+

+    /* Start the server */

+    if((s = getenv("DISPLAY"))) {

+        fprintf(stderr, "X11.app: Could not connect to server (DISPLAY=\"%s\", unsetting).  Starting X server.\n", s);

+        unsetenv("DISPLAY");

+    } else {

+        fprintf(stderr, "X11.app: Could not connect to server (DISPLAY is not set).  Starting X server.\n");

+    }

+    return execute(command_from_prefs("startx_script", DEFAULT_STARTX));

+}

+

+/** 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_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 = LAUNCHD_ID_PREFIX".X11";

+    }

+

+    server_bootstrap_name = malloc(sizeof(char) * (strlen(pds) + 1));

+    if(!server_bootstrap_name) {

+        fprintf(stderr, "X11.app: Memory allocation error.\n");

+        exit(1);

+    }

+    strcpy(server_bootstrap_name, pds);

+    setenv("X11_PREFS_DOMAIN", server_bootstrap_name, 1);

+    

+    len = strlen(server_bootstrap_name);

+    launchd_id_prefix = malloc(sizeof(char) * (len - 3));

+    if(!launchd_id_prefix) {

+        fprintf(stderr, "X11.app: Memory allocation error.\n");

+        exit(1);

+    }

+    strlcpy(launchd_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(launchd_id_prefix, "org.x") == 0 && strcmp(s, ":0") == 0) {

+                fprintf(stderr, "X11.app: Detected old style launchd DISPLAY, please update xinit.\n");

+            } else {

+                temp = (char *)malloc(sizeof(char) * len);

+                if(!temp) {

+                    fprintf(stderr, "X11.app: Memory allocation error creating space for socket name test.\n");

+                    exit(1);

+                }

+                strlcpy(temp, launchd_id_prefix, len);

+                strlcat(temp, ":0", len);

+            

+                if(strcmp(temp, s) != 0) {

+                    /* If we don't have a match, unset it. */

+                    fprintf(stderr, "X11.app: DISPLAY (\"%s\") does not match our id (\"%s\"), unsetting.\n", disp, launchd_id_prefix);

+                    unsetenv("DISPLAY");

+                }

+                free(temp);

+            }

+        } else {

+            /* The DISPLAY environment variable is not formatted like a launchd socket, so reset. */

+            fprintf(stderr, "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;

+

+    /* Setup our environment for our children */

+    setup_env();

+    

+    /* The server must not run the PanoramiX operations. */

+    noPanoramiXExtension = TRUE;

+

+    /* Setup the initial crasherporter info */

+    strlcpy(__crashreporter_info_buff__, __crashreporter_info__base, sizeof(__crashreporter_info_buff__));

+    

+    fprintf(stderr, "X11.app: main(): argc=%d\n", argc);

+    for(i=0; i < argc; i++) {

+        fprintf(stderr, "\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) {

+        fprintf(stderr, "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;

+

+        /* Do the fork-twice trick to avoid having to reap zombies */

+        child1 = fork();

+        switch (child1) {

+            case -1:                                /* error */

+                break;

+

+            case 0:                                 /* child1 */

+                child2 = fork();

+

+                switch (child2) {

+                    int max_files, i;

+

+                    case -1:                            /* error */

+                        break;

+

+                    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);

+        }

+    }

+    

+    /* Main event loop */

+    fprintf(stderr, "Waiting for startup parameters via Mach IPC.\n");

+    kr = mach_msg_server(mach_startup_server, mxmsgsz, mp, 0);

+    if (kr != KERN_SUCCESS) {

+        fprintf(stderr, "%s.X11(mp): %s\n", LAUNCHD_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] = command_from_prefs("login_shell", DEFAULT_SHELL);

+    newargv[1] = "-c";

+    newargv[2] = command;

+    newargv[3] = NULL;

+    

+    fprintf(stderr, "X11.app: Launching %s:\n", command);

+    for(p=newargv; *p; p++) {

+        fprintf(stderr, "\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;

+}