ProcessLauncherEfl.cpp [plain text]
#include "config.h"
#include "ProcessLauncher.h"
#include "Connection.h"
#include "ProcessExecutablePath.h"
#include <WebCore/AuthenticationChallenge.h>
#include <WebCore/FileSystem.h>
#include <WebCore/NetworkingContext.h>
#include <WebCore/ResourceHandle.h>
#include <sys/socket.h>
#include <wtf/RunLoop.h>
#include <wtf/StdLibExtras.h>
#include <wtf/text/CString.h>
#include <wtf/text/WTFString.h>
using namespace WebCore;
namespace WebKit {
static Vector<std::unique_ptr<char[]>> createArgsArray(const String& prefix, const String& executablePath, const String& socket, const String& pluginPath)
{
ASSERT(!executablePath.isEmpty());
ASSERT(!socket.isEmpty());
Vector<String> splitArgs;
prefix.split(' ', splitArgs);
splitArgs.append(executablePath);
splitArgs.append(socket);
if (!pluginPath.isEmpty())
splitArgs.append(pluginPath);
Vector<std::unique_ptr<char[]>> args;
args.resize(splitArgs.size() + 1);
size_t numArgs = splitArgs.size();
for (size_t i = 0; i < numArgs; ++i) {
CString param = splitArgs[i].utf8();
args[i] = std::make_unique<char[]>(param.length() + 1); strncpy(args[i].get(), param.data(), param.length() + 1); }
args[numArgs] = nullptr;
return args;
}
void ProcessLauncher::launchProcess()
{
int sockets[2];
if (socketpair(AF_UNIX, SOCK_STREAM, 0, sockets) < 0) {
ASSERT_NOT_REACHED();
return;
}
String processCmdPrefix, executablePath, pluginPath;
switch (m_launchOptions.processType) {
case WebProcess:
executablePath = executablePathOfWebProcess();
break;
#if ENABLE(PLUGIN_PROCESS)
case PluginProcess:
executablePath = executablePathOfPluginProcess();
pluginPath = m_launchOptions.extraInitializationData.get("plugin-path");
break;
#endif
#if ENABLE(NETWORK_PROCESS)
case NetworkProcess:
executablePath = executablePathOfNetworkProcess();
break;
#endif
default:
ASSERT_NOT_REACHED();
return;
}
#ifndef NDEBUG
if (!m_launchOptions.processCmdPrefix.isEmpty())
processCmdPrefix = m_launchOptions.processCmdPrefix;
#endif
auto args = createArgsArray(processCmdPrefix, executablePath, String::number(sockets[0]), pluginPath);
pid_t pid = fork();
if (!pid) { close(sockets[1]);
execvp(args.data()[0].get(), reinterpret_cast<char* const*>(args.data()));
} else if (pid > 0) { close(sockets[0]);
m_processIdentifier = pid;
RunLoop::main().dispatch(bind(&ProcessLauncher::didFinishLaunchingProcess, this, pid, sockets[1]));
} else {
ASSERT_NOT_REACHED();
return;
}
}
void ProcessLauncher::terminateProcess()
{
if (m_isLaunching) {
invalidate();
return;
}
if (!m_processIdentifier)
return;
kill(m_processIdentifier, SIGKILL);
m_processIdentifier = 0;
}
void ProcessLauncher::platformInvalidate()
{
}
}