Index: Source/core/fetch/ResourceLoader.cpp |
diff --git a/Source/core/fetch/ResourceLoader.cpp b/Source/core/fetch/ResourceLoader.cpp |
index 087644a9ad5816a44d59e1d5d373088373ea7550..6391043dba2da7b134a5bde694dab745adc33e4d 100644 |
--- a/Source/core/fetch/ResourceLoader.cpp |
+++ b/Source/core/fetch/ResourceLoader.cpp |
@@ -40,6 +40,7 @@ |
#include "platform/network/ResourceError.h" |
#include "public/platform/Platform.h" |
#include "public/platform/WebData.h" |
+#include "public/platform/WebThreadedDataReceiver.h" |
#include "public/platform/WebURLError.h" |
#include "public/platform/WebURLRequest.h" |
#include "public/platform/WebURLResponse.h" |
@@ -179,6 +180,18 @@ void ResourceLoader::setDefersLoading(bool defers) |
} |
} |
+void ResourceLoader::attachThreadedDataReceiver(PassOwnPtr<blink::WebThreadedDataReceiver> threadedDataReceiver) |
+{ |
+ if (m_loader) { |
+ // The implementor of the WebURLLoader assumes ownership of the |
+ // threaded data receiver if it signals that it got successfully |
+ // attached. |
+ blink::WebThreadedDataReceiver* rawThreadedDataReceiver = threadedDataReceiver.leakPtr(); |
+ if (!m_loader->attachThreadedDataReceiver(rawThreadedDataReceiver)) |
+ delete rawThreadedDataReceiver; |
+ } |
+} |
+ |
void ResourceLoader::didDownloadData(blink::WebURLLoader*, int length, int encodedDataLength) |
{ |
RefPtr<ResourceLoader> protect(this); |