#ifndef ChildProcess_h
#define ChildProcess_h
#include "Connection.h"
#include "MessageReceiverMap.h"
#include "MessageSender.h"
#include <WebCore/Process.h>
#include <WebCore/UserActivity.h>
#include <wtf/HashMap.h>
#include <wtf/RunLoop.h>
#include <wtf/text/StringHash.h>
#include <wtf/text/WTFString.h>
namespace WebKit {
class SandboxInitializationParameters;
struct ChildProcessInitializationParameters;
class ChildProcess : protected IPC::Connection::Client, public IPC::MessageSender {
WTF_MAKE_NONCOPYABLE(ChildProcess);
public:
enum class ProcessType : uint8_t {
WebContent,
Network,
Plugin
};
void initialize(const ChildProcessInitializationParameters&);
void disableTermination();
void enableTermination();
void addMessageReceiver(IPC::StringReference messageReceiverName, IPC::MessageReceiver&);
void addMessageReceiver(IPC::StringReference messageReceiverName, uint64_t destinationID, IPC::MessageReceiver&);
void removeMessageReceiver(IPC::StringReference messageReceiverName, uint64_t destinationID);
void removeMessageReceiver(IPC::StringReference messageReceiverName);
void removeMessageReceiver(IPC::MessageReceiver&);
void setProcessSuppressionEnabled(bool);
#if PLATFORM(COCOA)
void setApplicationIsDaemon();
void launchServicesCheckIn();
void setQOS(int latencyQOS, int throughputQOS);
#endif
IPC::Connection* parentProcessConnection() const { return m_connection.get(); }
IPC::MessageReceiverMap& messageReceiverMap() { return m_messageReceiverMap; }
#if PLATFORM(MAC)
static bool isSystemWebKit();
#endif
protected:
explicit ChildProcess();
virtual ~ChildProcess();
void setTerminationTimeout(Seconds seconds) { m_terminationTimeout = seconds; }
virtual void initializeProcess(const ChildProcessInitializationParameters&);
virtual void initializeProcessName(const ChildProcessInitializationParameters&);
virtual void initializeSandbox(const ChildProcessInitializationParameters&, SandboxInitializationParameters&);
virtual void initializeConnection(IPC::Connection*);
virtual bool shouldTerminate() = 0;
virtual void terminate();
virtual void stopRunLoop();
#if USE(APPKIT)
static void stopNSAppRunLoop();
#endif
#if PLATFORM(MAC) && ENABLE(WEBPROCESS_NSRUNLOOP)
static void stopNSRunLoop();
#endif
void didReceiveMessage(IPC::Connection&, IPC::Decoder&) override;
void registerURLSchemeServiceWorkersCanHandle(const String&) const;
#if OS(LINUX)
void didReceiveMemoryPressureEvent(bool isCritical);
#endif
private:
virtual bool shouldOverrideQuarantine() { return true; }
IPC::Connection* messageSenderConnection() override;
uint64_t messageSenderDestinationID() override;
void didReceiveInvalidMessage(IPC::Connection&, IPC::StringReference messageReceiverName, IPC::StringReference messageName) final;
void didClose(IPC::Connection&) override;
void shutDown();
void terminationTimerFired();
void platformInitialize();
void platformStopRunLoop();
Seconds m_terminationTimeout;
unsigned m_terminationCounter;
RunLoop::Timer<ChildProcess> m_terminationTimer;
RefPtr<IPC::Connection> m_connection;
IPC::MessageReceiverMap m_messageReceiverMap;
UserActivity m_processSuppressionDisabled;
#if PLATFORM(COCOA)
OSObjectPtr<xpc_object_t> m_priorityBoostMessage;
#endif
};
struct ChildProcessInitializationParameters {
String uiProcessName;
String clientIdentifier;
Optional<WebCore::ProcessIdentifier> processIdentifier;
IPC::Connection::Identifier connectionIdentifier;
HashMap<String, String> extraInitializationData;
ChildProcess::ProcessType processType;
#if PLATFORM(COCOA)
OSObjectPtr<xpc_object_t> priorityBoostMessage;
#endif
};
}
#endif // ChildProcess_h