4fb5c90de4f2d0255372000311bad3c0864c6637
[WebKit-https.git] / Source / WebKit2 / UIProcess / Launcher / gtk / ProcessLauncherGtk.cpp
1 /*
2  * Copyright (C) 2010 Apple Inc. All rights reserved.
3  * Portions Copyright (c) 2010 Motorola Mobility, Inc.  All rights reserved.
4  *
5  * Redistribution and use in source and binary forms, with or without
6  * modification, are permitted provided that the following conditions
7  * are met:
8  * 1. Redistributions of source code must retain the above copyright
9  *    notice, this list of conditions and the following disclaimer.
10  * 2. Redistributions in binary form must reproduce the above copyright
11  *    notice, this list of conditions and the following disclaimer in the
12  *    documentation and/or other materials provided with the distribution.
13  *
14  * THIS SOFTWARE IS PROVIDED BY MOTOROLA INC. AND ITS CONTRIBUTORS ``AS IS''
15  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
16  * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
17  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MOTOROLA INC. OR ITS CONTRIBUTORS
18  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
19  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
20  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
21  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
22  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
23  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
24  * THE POSSIBILITY OF SUCH DAMAGE.
25  */
26
27 #include "config.h"
28 #include "ProcessLauncher.h"
29
30 #include "Connection.h"
31 #include "ProcessExecutablePath.h"
32 #include <WebCore/AuthenticationChallenge.h>
33 #include <WebCore/FileSystem.h>
34 #include <WebCore/NetworkingContext.h>
35 #include <WebCore/ResourceHandle.h>
36 #include <errno.h>
37 #include <glib.h>
38 #include <locale.h>
39 #include <wtf/RunLoop.h>
40 #include <wtf/text/CString.h>
41 #include <wtf/text/WTFString.h>
42 #include <wtf/gobject/GOwnPtr.h>
43 #include <wtf/gobject/GUniquePtr.h>
44 #include <wtf/gobject/GlibUtilities.h>
45
46 #if OS(UNIX)
47 #include <sys/socket.h>
48 #endif
49
50 #ifdef SOCK_SEQPACKET
51 #define SOCKET_TYPE SOCK_SEQPACKET
52 #else
53 #define SOCKET_TYPE SOCK_STREAM
54 #endif
55
56 using namespace WebCore;
57
58 namespace WebKit {
59
60 static void childSetupFunction(gpointer userData)
61 {
62     int socket = GPOINTER_TO_INT(userData);
63     close(socket);
64 }
65
66 void ProcessLauncher::launchProcess()
67 {
68     GPid pid = 0;
69
70     int sockets[2];
71     if (socketpair(AF_UNIX, SOCKET_TYPE, 0, sockets) < 0) {
72         g_printerr("Creation of socket failed: %s.\n", g_strerror(errno));
73         ASSERT_NOT_REACHED();
74         return;
75     }
76
77     String executablePath, pluginPath;
78     CString realExecutablePath, realPluginPath;
79     switch (m_launchOptions.processType) {
80     case WebProcess:
81         executablePath = executablePathOfWebProcess();
82         break;
83     case PluginProcess:
84         executablePath = executablePathOfPluginProcess();
85         pluginPath = m_launchOptions.extraInitializationData.get("plugin-path");
86         realPluginPath = fileSystemRepresentation(pluginPath);
87         break;
88 #if ENABLE(NETWORK_PROCESS)
89     case NetworkProcess:
90         executablePath = executablePathOfNetworkProcess();
91         break;
92 #endif
93     default:
94         ASSERT_NOT_REACHED();
95         return;
96     }
97
98     realExecutablePath = fileSystemRepresentation(executablePath);
99     GUniquePtr<gchar> socket(g_strdup_printf("%d", sockets[0]));
100
101     unsigned nargs = 4; // size of the argv array for g_spawn_async()
102
103 #ifndef NDEBUG
104     Vector<CString> prefixArgs;
105     if (!m_launchOptions.processCmdPrefix.isNull()) {
106         Vector<String> splitArgs;
107         m_launchOptions.processCmdPrefix.split(' ', splitArgs);
108         for (auto it = splitArgs.begin(); it != splitArgs.end(); it++)
109             prefixArgs.append(it->utf8());
110         nargs += prefixArgs.size();
111     }
112 #endif
113
114     char** argv = g_newa(char*, nargs);
115     unsigned i = 0;
116 #ifndef NDEBUG
117     // If there's a prefix command, put it before the rest of the args.
118     for (auto it = prefixArgs.begin(); it != prefixArgs.end(); it++)
119         argv[i++] = const_cast<char*>(it->data());
120 #endif
121     argv[i++] = const_cast<char*>(realExecutablePath.data());
122     argv[i++] = socket.get();
123     argv[i++] = const_cast<char*>(realPluginPath.data());
124     argv[i++] = 0;
125
126     GOwnPtr<GError> error;
127     if (!g_spawn_async(0, argv, 0, G_SPAWN_LEAVE_DESCRIPTORS_OPEN, childSetupFunction, GINT_TO_POINTER(sockets[1]), &pid, &error.outPtr())) {
128         g_printerr("Unable to fork a new WebProcess: %s.\n", error->message);
129         ASSERT_NOT_REACHED();
130     }
131
132     close(sockets[0]);
133     m_processIdentifier = pid;
134
135     // We've finished launching the process, message back to the main run loop.
136     RunLoop::main()->dispatch(bind(&ProcessLauncher::didFinishLaunchingProcess, this, m_processIdentifier, sockets[1]));
137 }
138
139 void ProcessLauncher::terminateProcess()
140 {
141     if (m_isLaunching) {
142         invalidate();
143         return;
144     }
145
146     if (!m_processIdentifier)
147         return;
148
149     kill(m_processIdentifier, SIGKILL);
150     m_processIdentifier = 0;
151 }
152
153 void ProcessLauncher::platformInvalidate()
154 {
155 }
156
157 } // namespace WebKit