#include "config.h"
#include "ChildProcess.h"
#include "SandboxInitializationParameters.h"
#if !OS(WINDOWS)
#include <unistd.h>
#endif
using namespace WebCore;
namespace WebKit {
ChildProcess::ChildProcess()
: m_terminationTimeout(0)
, m_terminationCounter(0)
, m_terminationTimer(RunLoop::main(), this, &ChildProcess::terminationTimerFired)
#if PLATFORM(MAC)
, m_activeTaskCount(0)
, m_shouldSuspend(false)
, m_suspensionHysteresisTimer(RunLoop::main(), this, &ChildProcess::suspensionHysteresisTimerFired)
#endif
{
}
ChildProcess::~ChildProcess()
{
}
NO_RETURN static void watchdogCallback()
{
_exit(EXIT_FAILURE);
}
static void didCloseOnConnectionWorkQueue(CoreIPC::Connection*)
{
const double watchdogDelay = 10;
WorkQueue::create("com.apple.WebKit.ChildProcess.WatchDogQueue")->dispatchAfterDelay(bind(static_cast<void(*)()>(watchdogCallback)), watchdogDelay);
}
void ChildProcess::initialize(const ChildProcessInitializationParameters& parameters)
{
platformInitialize();
initializeProcess(parameters);
initializeProcessName(parameters);
SandboxInitializationParameters sandboxParameters;
initializeSandbox(parameters, sandboxParameters);
m_connection = CoreIPC::Connection::createClientConnection(parameters.connectionIdentifier, this, RunLoop::main());
m_connection->setDidCloseOnConnectionWorkQueueCallback(didCloseOnConnectionWorkQueue);
initializeConnection(m_connection.get());
m_connection->open();
}
void ChildProcess::initializeProcess(const ChildProcessInitializationParameters&)
{
}
void ChildProcess::initializeProcessName(const ChildProcessInitializationParameters&)
{
}
void ChildProcess::initializeConnection(CoreIPC::Connection*)
{
}
void ChildProcess::addMessageReceiver(CoreIPC::StringReference messageReceiverName, CoreIPC::MessageReceiver* messageReceiver)
{
m_messageReceiverMap.addMessageReceiver(messageReceiverName, messageReceiver);
}
void ChildProcess::addMessageReceiver(CoreIPC::StringReference messageReceiverName, uint64_t destinationID, CoreIPC::MessageReceiver* messageReceiver)
{
m_messageReceiverMap.addMessageReceiver(messageReceiverName, destinationID, messageReceiver);
}
void ChildProcess::removeMessageReceiver(CoreIPC::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);
}
CoreIPC::Connection* ChildProcess::messageSenderConnection()
{
return m_connection.get();
}
uint64_t ChildProcess::messageSenderDestinationID()
{
return 0;
}
void ChildProcess::terminationTimerFired()
{
if (!shouldTerminate())
return;
terminate();
}
void ChildProcess::terminate()
{
m_connection->invalidate();
RunLoop::main()->stop();
}
#if !PLATFORM(MAC)
void ChildProcess::platformInitialize()
{
}
void ChildProcess::initializeSandbox(const ChildProcessInitializationParameters&, SandboxInitializationParameters&)
{
}
#endif
}