#ifndef ChildProcess_h
#define ChildProcess_h
#include "Connection.h"
#include "MessageReceiverMap.h"
#include "MessageSender.h"
#include <WebCore/UserActivity.h>
#include <wtf/HashMap.h>
#include <wtf/RetainPtr.h>
#include <wtf/RunLoop.h>
#include <wtf/text/StringHash.h>
#include <wtf/text/WTFString.h>
namespace WebKit {
class SandboxInitializationParameters;
struct ChildProcessInitializationParameters {
String uiProcessName;
String clientIdentifier;
IPC::Connection::Identifier connectionIdentifier;
HashMap<String, String> extraInitializationData;
};
class ChildProcess : protected IPC::Connection::Client, public IPC::MessageSender {
WTF_MAKE_NONCOPYABLE(ChildProcess);
public:
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 setProcessSuppressionEnabled(bool);
#if PLATFORM(COCOA)
void setApplicationIsDaemon();
void setQOS(int latencyQOS, int throughputQOS);
#endif
IPC::Connection* parentProcessConnection() const { return m_connection.get(); }
IPC::MessageReceiverMap& messageReceiverMap() { return m_messageReceiverMap; }
protected:
explicit ChildProcess();
virtual ~ChildProcess();
void setTerminationTimeout(double 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
private:
virtual IPC::Connection* messageSenderConnection() override;
virtual uint64_t messageSenderDestinationID() override;
void terminationTimerFired();
void platformInitialize();
double m_terminationTimeout;
unsigned m_terminationCounter;
RunLoop::Timer<ChildProcess> m_terminationTimer;
RefPtr<IPC::Connection> m_connection;
IPC::MessageReceiverMap m_messageReceiverMap;
UserActivity m_processSuppressionDisabled;
};
}
#endif // ChildProcess_h