AuxiliaryProcess.h [plain text]
#pragma once
#include "Connection.h"
#include "MessageReceiverMap.h"
#include "MessageSender.h"
#include <WebCore/ProcessIdentifier.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 AuxiliaryProcessInitializationParameters;
class AuxiliaryProcess : protected IPC::Connection::Client, public IPC::MessageSender {
WTF_MAKE_NONCOPYABLE(AuxiliaryProcess);
public:
enum class ProcessType : uint8_t {
WebContent,
Network,
Plugin,
#if ENABLE(GPU_PROCESS)
GPU,
#endif
#if ENABLE(WEB_AUTHN)
WebAuthn
#endif
};
void initialize(const AuxiliaryProcessInitializationParameters&);
void disableTermination();
void enableTermination();
void addMessageReceiver(IPC::ReceiverName, IPC::MessageReceiver&);
void addMessageReceiver(IPC::ReceiverName, uint64_t destinationID, IPC::MessageReceiver&);
void removeMessageReceiver(IPC::ReceiverName, uint64_t destinationID);
void removeMessageReceiver(IPC::ReceiverName);
void removeMessageReceiver(IPC::MessageReceiver&);
template <typename T>
void addMessageReceiver(IPC::ReceiverName messageReceiverName, ObjectIdentifier<T> destinationID, IPC::MessageReceiver& receiver)
{
addMessageReceiver(messageReceiverName, destinationID.toUInt64(), receiver);
}
template <typename T>
void removeMessageReceiver(IPC::ReceiverName messageReceiverName, ObjectIdentifier<T> destinationID)
{
removeMessageReceiver(messageReceiverName, destinationID.toUInt64());
}
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
#if PLATFORM(COCOA)
bool parentProcessHasEntitlement(const char* entitlement);
#endif
protected:
explicit AuxiliaryProcess();
virtual ~AuxiliaryProcess();
void setTerminationTimeout(Seconds seconds) { m_terminationTimeout = seconds; }
virtual void initializeProcess(const AuxiliaryProcessInitializationParameters&);
virtual void initializeProcessName(const AuxiliaryProcessInitializationParameters&);
virtual void initializeSandbox(const AuxiliaryProcessInitializationParameters&, 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;
#if OS(LINUX)
void didReceiveMemoryPressureEvent(bool isCritical);
#endif
static Optional<std::pair<IPC::Connection::Identifier, IPC::Attachment>> createIPCConnectionPair();
private:
virtual bool shouldOverrideQuarantine() { return true; }
IPC::Connection* messageSenderConnection() const override;
uint64_t messageSenderDestinationID() const override;
void didReceiveInvalidMessage(IPC::Connection&, IPC::MessageName) final;
void didClose(IPC::Connection&) override;
void shutDown();
void terminationTimerFired();
void platformInitialize();
void platformStopRunLoop();
Seconds m_terminationTimeout;
unsigned m_terminationCounter;
RunLoop::Timer<AuxiliaryProcess> 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 AuxiliaryProcessInitializationParameters {
String uiProcessName;
String clientIdentifier;
Optional<WebCore::ProcessIdentifier> processIdentifier;
IPC::Connection::Identifier connectionIdentifier;
HashMap<String, String> extraInitializationData;
AuxiliaryProcess::ProcessType processType;
#if PLATFORM(COCOA)
OSObjectPtr<xpc_object_t> priorityBoostMessage;
#endif
};
}