ProcessLauncherQt.cpp [plain text]
#include "config.h"
#include "ProcessLauncher.h"
#include "Connection.h"
#include "ProcessExecutablePath.h"
#include "WebProcess.h"
#include <QDebug>
#include <QLocalServer>
#include <QMetaType>
#include <QProcess>
#include <QString>
#include <QtCore/qglobal.h>
#include <WebCore/NotImplemented.h>
#include <WebCore/RunLoop.h>
#include <errno.h>
#include <fcntl.h>
#include <runtime/InitializeThreading.h>
#include <string>
#include <sys/resource.h>
#include <sys/socket.h>
#include <unistd.h>
#include <wtf/HashSet.h>
#include <wtf/PassRefPtr.h>
#include <wtf/Threading.h>
#include <wtf/text/WTFString.h>
#if defined(Q_OS_LINUX)
#include <sys/prctl.h>
#include <signal.h>
#endif
#if OS(DARWIN)
#include <mach/mach_init.h>
#include <servers/bootstrap.h>
extern "C" kern_return_t bootstrap_register2(mach_port_t, name_t, mach_port_t, uint64_t);
#endif
#if defined(SOCK_SEQPACKET) && !defined(Q_OS_MACX)
#define SOCKET_TYPE SOCK_SEQPACKET
#else
#define SOCKET_TYPE SOCK_DGRAM
#endif
using namespace WebCore;
namespace WebKit {
class QtWebProcess : public QProcess
{
Q_OBJECT
public:
QtWebProcess(QObject* parent = 0)
: QProcess(parent)
{
}
protected:
virtual void setupChildProcess();
};
void QtWebProcess::setupChildProcess()
{
#if defined(Q_OS_LINUX)
#ifndef NDEBUG
if (qgetenv("QT_WEBKIT2_DEBUG") == "1")
return;
#endif
prctl(PR_SET_PDEATHSIG, SIGKILL);
#endif
#if defined(Q_OS_MACX)
qputenv("QT_MAC_DISABLE_FOREGROUND_APPLICATION_TRANSFORM", QByteArray("1"));
#endif
}
void ProcessLauncher::launchProcess()
{
QString commandLine = QLatin1String("%1 %2");
commandLine = commandLine.arg(m_launchOptions.processType == WebProcess ?
executablePathOfWebProcess() : executablePathOfPluginProcess());
#if OS(DARWIN)
mach_port_t connector;
mach_port_allocate(mach_task_self(), MACH_PORT_RIGHT_RECEIVE, &connector);
mach_port_insert_right(mach_task_self(), connector, connector, MACH_MSG_TYPE_MAKE_SEND);
QString serviceName = QString("com.nokia.Qt.WebKit.QtWebProcess-%1-%2");
serviceName = serviceName.arg(QString().setNum(getpid()), QString().setNum((size_t)this));
kern_return_t kr = bootstrap_register2(bootstrap_port, const_cast<char*>(serviceName.toUtf8().data()), connector, 0);
ASSERT_UNUSED(kr, kr == KERN_SUCCESS);
commandLine = commandLine.arg(serviceName);
#else
int sockets[2];
if (socketpair(AF_UNIX, SOCKET_TYPE, 0, sockets) == -1) {
qDebug() << "Creation of socket failed with errno:" << errno;
ASSERT_NOT_REACHED();
return;
}
while (fcntl(sockets[1], F_SETFD, FD_CLOEXEC) == -1) {
if (errno != EINTR) {
ASSERT_NOT_REACHED();
while (close(sockets[0]) == -1 && errno == EINTR) { }
while (close(sockets[1]) == -1 && errno == EINTR) { }
return;
}
}
int connector = sockets[1];
commandLine = commandLine.arg(sockets[0]);
#endif
QProcess* webProcess = new QtWebProcess();
webProcess->setProcessChannelMode(QProcess::ForwardedChannels);
webProcess->start(commandLine);
#if !OS(DARWIN)
while (fcntl(sockets[0], F_SETFD, FD_CLOEXEC) == -1) {
if (errno != EINTR) {
ASSERT_NOT_REACHED();
delete webProcess;
return;
}
}
#endif
if (!webProcess->waitForStarted()) {
qDebug() << "Failed to start" << commandLine;
ASSERT_NOT_REACHED();
#if OS(DARWIN)
mach_port_deallocate(mach_task_self(), connector);
mach_port_mod_refs(mach_task_self(), connector, MACH_PORT_RIGHT_RECEIVE, -1);
#endif
delete webProcess;
return;
}
setpriority(PRIO_PROCESS, webProcess->pid(), 10);
RunLoop::main()->dispatch(bind(&WebKit::ProcessLauncher::didFinishLaunchingProcess, this, webProcess, connector));
}
void ProcessLauncher::terminateProcess()
{
if (!m_processIdentifier)
return;
QObject::connect(m_processIdentifier, SIGNAL(finished(int)), m_processIdentifier, SLOT(deleteLater()), Qt::QueuedConnection);
m_processIdentifier->terminate();
}
void ProcessLauncher::platformInvalidate()
{
}
}
#include "ProcessLauncherQt.moc"