Redirect HTML resource bytes directly to parser thread (Blink side CL)

Source/core/fetch/ResourceLoader.cpp

 /*
  * Copyright (C) 2006, 2007, 2010, 2011 Apple Inc. All rights reserved.
  *           (C) 2007 Graham Dennis (graham.dennis@gmail.com)
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1.  Redistributions of source code must retain the above copyright
  *     notice, this list of conditions and the following disclaimer.
@@ skipping 162 matching lines @@
     m_defersLoading = defers;
     if (m_loader)
         m_loader->setDefersLoading(defers);
     if (!defers && !m_deferredRequest.isNull()) {
         m_request = m_deferredRequest;
         m_deferredRequest = ResourceRequest();
         start();
     }
 }
 
+void ResourceLoader::attachThreadedDataReceiver(blink::WebThreadedDataReceiver* threadedDataReceiver)
+{
+    if (m_loader)

[abarth-chromium, 2014/03/10 21:52:20]

Should this be an error if m_loader isn't truthy?  What does the caller expect
to happen in that case?

[oystein (OOO til 10th of July), 2014/03/17 21:19:11]

Since the use of a threaded data receiver is an optional thing, I think it's OK
if the object just gets deleted (leaked before, but should now be OK).
Alternatively we could add a canUseThreadedDataReceiver() function and pass
through the whole stack, if we want to avoid the redundant object creation in
these cases?

+        m_loader->attachThreadedDataReceiver(threadedDataReceiver);
+}
+
 void ResourceLoader::didDownloadData(blink::WebURLLoader*, int length, int encodedDataLength)
 {
     RefPtr<ResourceLoader> protect(this);
     RELEASE_ASSERT(m_connectionState == ConnectionStateReceivedResponse);
     m_host->didDownloadData(m_resource, length, encodedDataLength);
     m_resource->didDownloadData(length);
 }
 
 void ResourceLoader::didFinishLoadingOnePart(double finishTime, int64 encodedDataLength)
 {
@@ skipping 277 matching lines @@
     if (m_state == Terminated)
         return;
     RefPtr<ResourceLoadInfo> resourceLoadInfo = responseOut.toResourceResponse().resourceLoadInfo();
     int64 encodedDataLength = resourceLoadInfo ? resourceLoadInfo->encodedDataLength : blink::WebURLLoaderClient::kUnknownEncodedDataLength;
     m_host->didReceiveData(m_resource, dataOut.data(), dataOut.size(), encodedDataLength);
     m_resource->setResourceBuffer(dataOut);
     didFinishLoading(0, monotonicallyIncreasingTime(), encodedDataLength);
 }
 
 }