#include "config.h"
#include "ChildProcess.h"
#include "SandboxInitializationParameters.h"
#include <unistd.h>
namespace WebKit {
ChildProcess::ChildProcess()
: m_terminationTimeout(0)
, m_terminationCounter(0)
, m_terminationTimer(RunLoop::main(), this, &ChildProcess::terminationTimerFired)
, m_processSuppressionDisabled("Process Suppression Disabled by UIProcess")
{
}
ChildProcess::~ChildProcess()
{
}
static void didCloseOnConnectionWorkQueue(IPC::Connection*)
{
auto watchdogDelay = std::chrono::seconds(10);
WorkQueue::create("com.apple.WebKit.ChildProcess.WatchDogQueue")->dispatchAfter(watchdogDelay, []{
_exit(EXIT_FAILURE);
});
}
void ChildProcess::initialize(const ChildProcessInitializationParameters& parameters)
{
platformInitialize();
initializeProcess(parameters);
initializeProcessName(parameters);
SandboxInitializationParameters sandboxParameters;
initializeSandbox(parameters, sandboxParameters);
m_connection = IPC::Connection::createClientConnection(parameters.connectionIdentifier, this, RunLoop::main());
m_connection->setDidCloseOnConnectionWorkQueueCallback(didCloseOnConnectionWorkQueue);
initializeConnection(m_connection.get());
m_connection->open();
}
void ChildProcess::setProcessSuppressionEnabled(bool enabled)
{
if (enabled)
m_processSuppressionDisabled.stop();
else
m_processSuppressionDisabled.start();
}
void ChildProcess::initializeProcess(const ChildProcessInitializationParameters&)
{
}
void ChildProcess::initializeProcessName(const ChildProcessInitializationParameters&)
{
}
void ChildProcess::initializeConnection(IPC::Connection*)
{
}
void ChildProcess::addMessageReceiver(IPC::StringReference messageReceiverName, IPC::MessageReceiver& messageReceiver)
{
m_messageReceiverMap.addMessageReceiver(messageReceiverName, messageReceiver);
}
void ChildProcess::addMessageReceiver(IPC::StringReference messageReceiverName, uint64_t destinationID, IPC::MessageReceiver& messageReceiver)
{
m_messageReceiverMap.addMessageReceiver(messageReceiverName, destinationID, messageReceiver);
}
void ChildProcess::removeMessageReceiver(IPC::StringReference messageReceiverName, uint64_t destinationID)
{
m_messageReceiverMap.removeMessageReceiver(messageReceiverName, destinationID);
}
void ChildProcess::disableTermination()
{
m_terminationCounter++;
m_terminationTimer.stop();
}
void ChildProcess::enableTermination()
{
ASSERT(m_terminationCounter > 0);
m_terminationCounter--;
if (m_terminationCounter)
return;
if (!m_terminationTimeout) {
terminationTimerFired();
return;
}
m_terminationTimer.startOneShot(m_terminationTimeout);
}
IPC::Connection* ChildProcess::messageSenderConnection()
{
return m_connection.get();
}
uint64_t ChildProcess::messageSenderDestinationID()
{
return 0;
}
void ChildProcess::terminationTimerFired()
{
if (!shouldTerminate())
return;
terminate();
}
void ChildProcess::stopRunLoop()
{
RunLoop::main().stop();
}
void ChildProcess::terminate()
{
m_connection->invalidate();
stopRunLoop();
}
#if !PLATFORM(COCOA)
void ChildProcess::platformInitialize()
{
}
void ChildProcess::initializeSandbox(const ChildProcessInitializationParameters&, SandboxInitializationParameters&)
{
}
#endif
}