#ifndef NetworkProcess_h
#define NetworkProcess_h
#if ENABLE(NETWORK_PROCESS)
#include "CacheModel.h"
#include "ChildProcess.h"
#include "DownloadManager.h"
#include "MessageReceiverMap.h"
#include "NetworkResourceLoadScheduler.h"
#include <wtf/Forward.h>
namespace WebCore {
class RunLoop;
}
namespace WebKit {
class AuthenticationManager;
class NetworkConnectionToWebProcess;
class NetworkProcessSupplement;
class PlatformCertificateInfo;
struct NetworkProcessCreationParameters;
class NetworkProcess : public ChildProcess, private DownloadManager::Client {
WTF_MAKE_NONCOPYABLE(NetworkProcess);
public:
static NetworkProcess& shared();
template <typename T>
T* supplement()
{
return static_cast<T*>(m_supplements.get(T::supplementName()));
}
template <typename T>
void addSupplement()
{
m_supplements.add(T::supplementName(), adoptPtr<NetworkProcessSupplement>(new T(this)));
}
void removeNetworkConnectionToWebProcess(NetworkConnectionToWebProcess*);
NetworkResourceLoadScheduler& networkResourceLoadScheduler() { return m_networkResourceLoadScheduler; }
AuthenticationManager& authenticationManager();
DownloadManager& downloadManager();
private:
NetworkProcess();
~NetworkProcess();
void platformInitializeNetworkProcess(const NetworkProcessCreationParameters&);
virtual void terminate() OVERRIDE;
void platformTerminate();
virtual void initializeProcess(const ChildProcessInitializationParameters&) OVERRIDE;
virtual void initializeProcessName(const ChildProcessInitializationParameters&) OVERRIDE;
virtual void initializeSandbox(const ChildProcessInitializationParameters&, SandboxInitializationParameters&) OVERRIDE;
virtual void initializeConnection(CoreIPC::Connection*) OVERRIDE;
virtual bool shouldTerminate() OVERRIDE;
virtual void didReceiveMessage(CoreIPC::Connection*, CoreIPC::MessageDecoder&) OVERRIDE;
virtual void didReceiveSyncMessage(CoreIPC::Connection*, CoreIPC::MessageDecoder&, OwnPtr<CoreIPC::MessageEncoder>&);
virtual void didClose(CoreIPC::Connection*) OVERRIDE;
virtual void didReceiveInvalidMessage(CoreIPC::Connection*, CoreIPC::StringReference messageReceiverName, CoreIPC::StringReference messageName) OVERRIDE;
virtual void didCreateDownload() OVERRIDE;
virtual void didDestroyDownload() OVERRIDE;
virtual CoreIPC::Connection* downloadProxyConnection() OVERRIDE;
virtual AuthenticationManager& downloadsAuthenticationManager() OVERRIDE;
void didReceiveNetworkProcessMessage(CoreIPC::Connection*, CoreIPC::MessageDecoder&);
void initializeNetworkProcess(const NetworkProcessCreationParameters&);
void createNetworkConnectionToWebProcess();
void ensurePrivateBrowsingSession();
void destroyPrivateBrowsingSession();
void downloadRequest(uint64_t downloadID, const WebCore::ResourceRequest&);
void cancelDownload(uint64_t downloadID);
void setCacheModel(uint32_t);
void allowSpecificHTTPSCertificateForHost(const PlatformCertificateInfo&, const String& host);
void getNetworkProcessStatistics(uint64_t callbackID);
void clearCacheForAllOrigins(uint32_t cachesToClear);
void platformSetCacheModel(CacheModel);
Vector<RefPtr<NetworkConnectionToWebProcess>> m_webProcessConnections;
NetworkResourceLoadScheduler m_networkResourceLoadScheduler;
String m_diskCacheDirectory;
bool m_hasSetCacheModel;
CacheModel m_cacheModel;
typedef HashMap<const char*, OwnPtr<NetworkProcessSupplement>, PtrHash<const char*>> NetworkProcessSupplementMap;
NetworkProcessSupplementMap m_supplements;
#if PLATFORM(MAC)
dispatch_group_t m_clearCacheDispatchGroup;
#endif
};
}
#endif // ENABLE(NETWORK_PROCESS)
#endif // NetworkProcess_h