NetworkCacheSubresourcesEntry.cpp [plain text]
#include "config.h"
#if ENABLE(NETWORK_CACHE_SPECULATIVE_REVALIDATION)
#include "NetworkCacheSubresourcesEntry.h"
#include "Logging.h"
#include "NetworkCacheCoders.h"
#include "NetworkCacheDecoder.h"
#include "NetworkCacheEncoder.h"
namespace WebKit {
namespace NetworkCache {
void SubresourceInfo::encode(Encoder& encoder) const
{
encoder << m_isTransient;
if (m_isTransient)
return;
encoder << m_firstPartyForCookies;
encoder << m_requestHeaders;
}
bool SubresourceInfo::decode(Decoder& decoder, SubresourceInfo& info)
{
if (!decoder.decode(info.m_isTransient))
return false;
if (info.m_isTransient)
return true;
if (!decoder.decode(info.m_firstPartyForCookies))
return false;
if (!decoder.decode(info.m_requestHeaders))
return false;
return true;
}
Storage::Record SubresourcesEntry::encodeAsStorageRecord() const
{
Encoder encoder;
encoder << m_subresources;
encoder.encodeChecksum();
return { m_key, m_timeStamp, { encoder.buffer(), encoder.bufferSize() } , { } };
}
std::unique_ptr<SubresourcesEntry> SubresourcesEntry::decodeStorageRecord(const Storage::Record& storageEntry)
{
auto entry = std::make_unique<SubresourcesEntry>(storageEntry);
Decoder decoder(storageEntry.header.data(), storageEntry.header.size());
if (!decoder.decode(entry->m_subresources))
return nullptr;
if (!decoder.verifyChecksum()) {
LOG(NetworkCache, "(NetworkProcess) checksum verification failure\n");
return nullptr;
}
return entry;
}
SubresourcesEntry::SubresourcesEntry(const Storage::Record& storageEntry)
: m_key(storageEntry.key)
, m_timeStamp(storageEntry.timeStamp)
{
ASSERT(m_key.type() == "SubResources");
}
SubresourcesEntry::SubresourcesEntry(Key&& key, const Vector<std::unique_ptr<SubresourceLoad>>& subresourceLoads)
: m_key(WTFMove(key))
, m_timeStamp(std::chrono::system_clock::now())
{
ASSERT(m_key.type() == "SubResources");
for (auto& subresourceLoad : subresourceLoads)
m_subresources.add(subresourceLoad->key, SubresourceInfo(subresourceLoad->request));
}
void SubresourcesEntry::updateSubresourceLoads(const Vector<std::unique_ptr<SubresourceLoad>>& subresourceLoads)
{
auto oldSubresources = WTFMove(m_subresources);
for (auto& subresourceLoad : subresourceLoads) {
bool isTransient = !oldSubresources.contains(subresourceLoad->key);
m_subresources.add(subresourceLoad->key, SubresourceInfo(subresourceLoad->request, isTransient));
}
}
} }
#endif // ENABLE(NETWORK_CACHE_SPECULATIVE_REVALIDATION)