PreconnectTask.cpp [plain text]
#include "config.h"
#include "PreconnectTask.h"
#if ENABLE(SERVER_PRECONNECT)
#include "Logging.h"
#include "NetworkLoad.h"
#include "NetworkLoadParameters.h"
#include "NetworkProcess.h"
#include "SessionTracker.h"
#include "WebErrors.h"
#include <WebCore/ResourceError.h>
namespace WebKit {
using namespace WebCore;
PreconnectTask::PreconnectTask(NetworkLoadParameters&& parameters, WTF::CompletionHandler<void(const ResourceError&)>&& completionHandler)
: m_completionHandler(WTFMove(completionHandler))
, m_timeoutTimer([this] { didFinish(ResourceError { String(), 0, m_networkLoad->parameters().request.url(), ASCIILiteral("Preconnection timed out"), ResourceError::Type::Timeout }); })
{
RELEASE_LOG(Network, "%p - PreconnectTask::PreconnectTask()", this);
auto* networkSession = SessionTracker::networkSession(parameters.sessionID);
if (!networkSession) {
ASSERT_NOT_REACHED();
m_completionHandler(internalError(parameters.request.url()));
return;
}
ASSERT(parameters.shouldPreconnectOnly == PreconnectOnly::Yes);
m_networkLoad = std::make_unique<NetworkLoad>(*this, WTFMove(parameters), *networkSession);
m_timeoutTimer.startOneShot(60000_s);
}
PreconnectTask::~PreconnectTask()
{
}
void PreconnectTask::willSendRedirectedRequest(ResourceRequest&&, ResourceRequest&& redirectRequest, ResourceResponse&& redirectResponse)
{
ASSERT_NOT_REACHED();
}
auto PreconnectTask::didReceiveResponse(ResourceResponse&&) -> ShouldContinueDidReceiveResponse
{
ASSERT_NOT_REACHED();
return ShouldContinueDidReceiveResponse::No;
}
void PreconnectTask::didReceiveBuffer(Ref<SharedBuffer>&&, int reportedEncodedDataLength)
{
ASSERT_NOT_REACHED();
}
void PreconnectTask::didFinishLoading(const NetworkLoadMetrics&)
{
RELEASE_LOG(Network, "%p - PreconnectTask::didFinishLoading", this);
didFinish({ });
}
void PreconnectTask::didFailLoading(const ResourceError& error)
{
RELEASE_LOG(Network, "%p - PreconnectTask::didFailLoading, error_code: %d", this, error.errorCode());
didFinish(error);
}
void PreconnectTask::didSendData(unsigned long long bytesSent, unsigned long long totalBytesToBeSent)
{
ASSERT_NOT_REACHED();
}
void PreconnectTask::canAuthenticateAgainstProtectionSpaceAsync(const ProtectionSpace& protectionSpace)
{
if (!pageID()) {
continueCanAuthenticateAgainstProtectionSpace(false);
return;
}
NetworkProcess::singleton().canAuthenticateAgainstProtectionSpace(*this, protectionSpace);
}
void PreconnectTask::continueCanAuthenticateAgainstProtectionSpace(bool result)
{
m_networkLoad->continueCanAuthenticateAgainstProtectionSpace(result);
}
void PreconnectTask::didFinish(const ResourceError& error)
{
if (m_completionHandler)
m_completionHandler(error);
delete this;
}
uint64_t PreconnectTask::frameID() const
{
return m_networkLoad->parameters().webFrameID;
}
uint64_t PreconnectTask::pageID() const
{
return m_networkLoad->parameters().webPageID;
}
}
#endif // ENABLE(SERVER_PRECONNECT)