WebResourceLoadStatisticsStore.h [plain text]
#ifndef WebResourceLoadStatisticsStore_h
#define WebResourceLoadStatisticsStore_h
#include "APIObject.h"
#include "Connection.h"
#include <WebCore/ResourceLoadStatisticsStore.h>
#include <wtf/HashMap.h>
#include <wtf/Vector.h>
#include <wtf/text/WTFString.h>
namespace WTF {
class WorkQueue;
}
namespace WebCore {
class KeyedDecoder;
class KeyedEncoder;
struct ResourceLoadStatistics;
}
namespace WebKit {
class WebProcessPool;
class WebProcessProxy;
class WebResourceLoadStatisticsStore : public IPC::Connection::WorkQueueMessageReceiver {
public:
static Ref<WebResourceLoadStatisticsStore> create(const String&);
virtual ~WebResourceLoadStatisticsStore();
void setResourceLoadStatisticsEnabled(bool);
bool resourceLoadStatisticsEnabled() const;
void resourceLoadStatisticsUpdated(const Vector<WebCore::ResourceLoadStatistics>& origins);
void processWillOpenConnection(WebProcessProxy&, IPC::Connection&);
void processDidCloseConnection(WebProcessProxy&, IPC::Connection&);
void applicationWillTerminate();
void readDataFromDiskIfNeeded();
void mergeStatistics(const Vector<WebCore::ResourceLoadStatistics>&);
WebCore::ResourceLoadStatisticsStore& coreStore() { return m_resourceStatisticsStore.get(); }
const WebCore::ResourceLoadStatisticsStore& coreStore() const { return m_resourceStatisticsStore.get(); }
private:
explicit WebResourceLoadStatisticsStore(const String&);
String persistentStoragePath(const String& label) const;
void didReceiveMessage(IPC::Connection&, IPC::MessageDecoder&) override;
void writeEncoderToDisk(WebCore::KeyedEncoder&, const String& label) const;
std::unique_ptr<WebCore::KeyedDecoder> createDecoderFromDisk(const String& label) const;
Ref<WebCore::ResourceLoadStatisticsStore> m_resourceStatisticsStore;
Ref<WTF::WorkQueue> m_statisticsQueue;
String m_storagePath;
bool m_resourceLoadStatisticsEnabled { false };
};
}
#endif // WebResourceLoadStatisticsStore_h