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 "WebErrors.h"
#include <WebCore/ResourceError.h>
namespace WebKit {
using namespace WebCore;
PreconnectTask::PreconnectTask(NetworkSession& networkSession, NetworkLoadParameters&& parameters, CompletionHandler<void(const ResourceError&)>&& completionHandler)
: m_completionHandler(WTFMove(completionHandler))
, m_timeoutTimer([this] { didFinish(ResourceError { String(), 0, m_networkLoad->parameters().request.url(), "Preconnection timed out"_s, ResourceError::Type::Timeout }); })
{
RELEASE_LOG(Network, "%p - PreconnectTask::PreconnectTask()", this);
ASSERT(parameters.shouldPreconnectOnly == PreconnectOnly::Yes);
m_networkLoad = makeUnique<NetworkLoad>(*this, nullptr, WTFMove(parameters), networkSession);
m_timeoutTimer.startOneShot(60000_s);
}
void PreconnectTask::setH2PingCallback(const URL& url, CompletionHandler<void(Expected<WTF::Seconds, WebCore::ResourceError>&&)>&& completionHandler)
{
m_networkLoad->setH2PingCallback(url, WTFMove(completionHandler));
}
void PreconnectTask::start()
{
m_networkLoad->start();
}
PreconnectTask::~PreconnectTask() = default;
void PreconnectTask::willSendRedirectedRequest(ResourceRequest&&, ResourceRequest&& redirectRequest, ResourceResponse&& redirectResponse)
{
}
void PreconnectTask::didReceiveResponse(ResourceResponse&& response, ResponseCompletionHandler&& completionHandler)
{
ASSERT_NOT_REACHED();
completionHandler(PolicyAction::Ignore);
}
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::didFinish(const ResourceError& error)
{
if (m_completionHandler)
m_completionHandler(error);
delete this;
}
}
#endif // ENABLE(SERVER_PRECONNECT)