#include "config.h"
#include "ChildProcess.h"
#include "Logging.h"
#include "SandboxInitializationParameters.h"
#include <WebCore/SchemeRegistry.h>
#include <pal/SessionID.h>
#include <unistd.h>
using namespace WebCore;
namespace WebKit {
ChildProcess::ChildProcess()
: 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 = 10_s;
WorkQueue::create("com.apple.WebKit.ChildProcess.WatchDogQueue")->dispatchAfter(watchdogDelay, [] {
RELEASE_LOG_ERROR(IPC, "Exiting process early due to unacknowledged closed-connection");
_exit(EXIT_FAILURE);
});
}
void ChildProcess::initialize(const ChildProcessInitializationParameters& parameters)
{
RELEASE_ASSERT_WITH_MESSAGE(parameters.processIdentifier, "Unable to initialize child process without a WebCore process identifier");
Process::setIdentifier(*parameters.processIdentifier);
platformInitialize();
#if PLATFORM(COCOA)
m_priorityBoostMessage = parameters.priorityBoostMessage;
#endif
initializeProcess(parameters);
initializeProcessName(parameters);
SandboxInitializationParameters sandboxParameters;
initializeSandbox(parameters, sandboxParameters);
PAL::SessionID::enableGenerationProtection();
m_connection = IPC::Connection::createClientConnection(parameters.connectionIdentifier, *this);
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::removeMessageReceiver(IPC::StringReference messageReceiverName)
{
m_messageReceiverMap.removeMessageReceiver(messageReceiverName);
}
void ChildProcess::removeMessageReceiver(IPC::MessageReceiver& messageReceiver)
{
m_messageReceiverMap.removeMessageReceiver(messageReceiver);
}
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()
{
platformStopRunLoop();
}
#if !PLATFORM(IOS)
void ChildProcess::platformStopRunLoop()
{
RunLoop::main().stop();
}
#endif
void ChildProcess::terminate()
{
m_connection->invalidate();
stopRunLoop();
}
void ChildProcess::shutDown()
{
terminate();
}
void ChildProcess::registerURLSchemeServiceWorkersCanHandle(const String& urlScheme) const
{
WebCore::SchemeRegistry::registerURLSchemeServiceWorkersCanHandle(urlScheme);
}
#if !PLATFORM(COCOA)
void ChildProcess::platformInitialize()
{
}
void ChildProcess::initializeSandbox(const ChildProcessInitializationParameters&, SandboxInitializationParameters&)
{
}
void ChildProcess::didReceiveInvalidMessage(IPC::Connection&, IPC::StringReference messageReceiverName, IPC::StringReference messageName)
{
WTFLogAlways("Received invalid message: '%s::%s'", messageReceiverName.toString().data(), messageName.toString().data());
CRASH();
}
#endif
}