Index: third_party/WebKit/Source/core/loader/DocumentThreadableLoader.cpp |
diff --git a/third_party/WebKit/Source/core/loader/DocumentThreadableLoader.cpp b/third_party/WebKit/Source/core/loader/DocumentThreadableLoader.cpp |
index c5c8920707bf514f3416c356622eff7f0d3a801f..593c806a974ebfc1e1b984e4e34c984f7b91679b 100644 |
--- a/third_party/WebKit/Source/core/loader/DocumentThreadableLoader.cpp |
+++ b/third_party/WebKit/Source/core/loader/DocumentThreadableLoader.cpp |
@@ -421,6 +421,8 @@ void DocumentThreadableLoader::redirectReceived(Resource* resource, ResourceRequ |
ASSERT_UNUSED(resource, resource == this->resource()); |
ASSERT(m_async); |
+ m_checker.redirectReceived(); |
+ |
if (!m_actualRequest.isNull()) { |
reportResponseReceived(resource->identifier(), redirectResponse); |
@@ -555,6 +557,8 @@ void DocumentThreadableLoader::redirectReceived(Resource* resource, ResourceRequ |
void DocumentThreadableLoader::redirectBlocked() |
{ |
+ m_checker.redirectBlocked(); |
+ |
// Tells the client that a redirect was received but not followed (for an unknown reason). |
ThreadableLoaderClient* client = m_client; |
clear(); |
@@ -567,6 +571,7 @@ void DocumentThreadableLoader::dataSent(Resource* resource, unsigned long long b |
ASSERT_UNUSED(resource, resource == this->resource()); |
ASSERT(m_async); |
+ m_checker.dataSent(); |
m_client->didSendData(bytesSent, totalBytesToBeSent); |
} |
@@ -577,6 +582,7 @@ void DocumentThreadableLoader::dataDownloaded(Resource* resource, int dataLength |
ASSERT(m_actualRequest.isNull()); |
ASSERT(m_async); |
+ m_checker.dataDownloaded(); |
m_client->didDownloadData(dataLength); |
} |
@@ -594,6 +600,8 @@ void DocumentThreadableLoader::responseReceived(Resource* resource, const Resour |
ASSERT_UNUSED(resource, resource == this->resource()); |
ASSERT(m_async); |
+ m_checker.responseReceived(); |
+ |
if (handle) |
m_isUsingDataConsumerHandle = true; |
@@ -701,6 +709,8 @@ void DocumentThreadableLoader::handleResponse(unsigned long identifier, const Re |
void DocumentThreadableLoader::setSerializedCachedMetadata(Resource*, const char* data, size_t size) |
{ |
+ m_checker.setSerializedCachedMetadata(); |
+ |
if (!m_actualRequest.isNull()) |
return; |
m_client->didReceiveCachedMetadata(data, size); |
@@ -711,6 +721,8 @@ void DocumentThreadableLoader::dataReceived(Resource* resource, const char* data |
ASSERT_UNUSED(resource, resource == this->resource()); |
ASSERT(m_async); |
+ m_checker.dataReceived(); |
+ |
if (m_isUsingDataConsumerHandle) |
return; |
@@ -738,6 +750,8 @@ void DocumentThreadableLoader::notifyFinished(Resource* resource) |
ASSERT(resource == this->resource()); |
ASSERT(m_async); |
+ m_checker.notifyFinished(resource); |
+ |
if (resource->errorOccurred()) { |
handleError(resource->resourceError()); |
} else { |