← Back to branch summary

~mmach/netext73/webkit2gtk

« back to all changes in this revision

Viewing changes to Source/WebKit/NetworkProcess/cache/AsyncRevalidation.cpp

  • Committer: mmach
  • Date: 2023-06-16 17:21:37 UTC
  • Revision ID: netbit73@gmail.com-20230616172137-2rqx6yr96ga9g3kp
1

Show diffs side-by-side

added added

removed removed

Lines of Context:
Source/WebKit/NetworkProcess/cache/AsyncRevalidation.cpp
 
1
/*
 
2
 * Copyright (C) 2019 Igalia S.L.
 
3
 *
 
4
 * Redistribution and use in source and binary forms, with or without
 
5
 * modification, are permitted provided that the following conditions
 
6
 * are met:
 
7
 * 1. Redistributions of source code must retain the above copyright
 
8
 *    notice, this list of conditions and the following disclaimer.
 
9
 * 2. Redistributions in binary form must reproduce the above copyright
 
10
 *    notice, this list of conditions and the following disclaimer in the
 
11
 *    documentation and/or other materials provided with the distribution.
 
12
 *
 
13
 * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS''
 
14
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
 
15
 * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
 
16
 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
 
17
 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 
18
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 
19
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 
20
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 
21
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 
22
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
 
23
 * THE POSSIBILITY OF SUCH DAMAGE.
 
24
 */
 
25
 
 
26
#include "config.h"
 
27
#include "AsyncRevalidation.h"
 
28
 
 
29
#if ENABLE(NETWORK_CACHE_STALE_WHILE_REVALIDATE)
 
30
#include <WebCore/CacheValidation.h>
 
31
#include <WebCore/ResourceRequest.h>
 
32
 
 
33
namespace WebKit {
 
34
namespace NetworkCache {
 
35
 
 
36
static inline WebCore::ResourceRequest constructRevalidationRequest(const Key& key, const WebCore::ResourceRequest& request, const Entry& entry)
 
37
{
 
38
    WebCore::ResourceRequest revalidationRequest = request;
 
39
    if (!key.partition().isEmpty())
 
40
        revalidationRequest.setCachePartition(key.partition());
 
41
    ASSERT_WITH_MESSAGE(key.range().isEmpty(), "range is not supported");
 
42
 
 
43
    revalidationRequest.makeUnconditional();
 
44
    auto eTag = entry.response().httpHeaderField(WebCore::HTTPHeaderName::ETag);
 
45
    if (!eTag.isEmpty())
 
46
        revalidationRequest.setHTTPHeaderField(WebCore::HTTPHeaderName::IfNoneMatch, eTag);
 
47
 
 
48
    auto lastModified = entry.response().httpHeaderField(WebCore::HTTPHeaderName::LastModified);
 
49
    if (!lastModified.isEmpty())
 
50
        revalidationRequest.setHTTPHeaderField(WebCore::HTTPHeaderName::IfModifiedSince, lastModified);
 
51
 
 
52
    revalidationRequest.setPriority(WebCore::ResourceLoadPriority::Low);
 
53
 
 
54
    return revalidationRequest;
 
55
}
 
56
 
 
57
void AsyncRevalidation::staleWhileRevalidateEnding()
 
58
{
 
59
    if (m_completionHandler)
 
60
        m_completionHandler(Result::Timeout);
 
61
}
 
62
 
 
63
AsyncRevalidation::AsyncRevalidation(Cache& cache, const GlobalFrameID& frameID, const WebCore::ResourceRequest& request, std::unique_ptr<NetworkCache::Entry>&& entry, CompletionHandler<void(Result)>&& handler)
 
64
    : m_timer(*this, &AsyncRevalidation::staleWhileRevalidateEnding)
 
65
    , m_completionHandler(WTFMove(handler))
 
66
{
 
67
    auto key = entry->key();
 
68
    auto revalidationRequest = constructRevalidationRequest(key, request, *entry.get());
 
69
    auto age = WebCore::computeCurrentAge(entry->response(), entry->timeStamp());
 
70
    auto lifetime = WebCore::computeFreshnessLifetimeForHTTPFamily(entry->response(), entry->timeStamp());
 
71
    auto responseMaxStaleness = entry->response().cacheControlStaleWhileRevalidate();
 
72
    ASSERT(responseMaxStaleness);
 
73
    m_timer.startOneShot(*responseMaxStaleness + (lifetime - age));
 
74
    m_load = makeUnique<SpeculativeLoad>(cache, frameID, WTFMove(revalidationRequest), WTFMove(entry), [this, key, revalidationRequest](auto&& revalidatedEntry) {
 
75
        ASSERT(!revalidatedEntry || !revalidatedEntry->needsValidation());
 
76
        ASSERT(!revalidatedEntry || revalidatedEntry->key() == key);
 
77
        if (m_completionHandler)
 
78
            m_completionHandler(revalidatedEntry ? Result::Success : Result::Failure);
 
79
    });
 
80
}
 
81
 
 
82
} // namespace NetworkCache
 
83
} // namespace WebKit
 
84
 
 
85
#endif // ENABLE(NETWORK_CACHE_STALE_WHILE_REVALIDATE)