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

Source/core/loader/DocumentLoader.cpp

 /*
  * Copyright (C) 2006, 2007, 2008 Apple Inc. All rights reserved.
  * Copyright (C) 2011 Google Inc. All rights reserved.
  *
  * 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 42 matching lines @@
 #include "core/frame/Settings.h"
 #include "platform/Logging.h"
 #include "platform/UserGestureIndicator.h"
 #include "platform/mhtml/ArchiveResourceCollection.h"
 #include "platform/mhtml/MHTMLArchive.h"
 #include "platform/plugins/PluginData.h"
 #include "platform/weborigin/SchemeRegistry.h"
 #include "platform/weborigin/SecurityPolicy.h"
 #include "public/platform/Platform.h"
 #include "public/platform/WebMimeRegistry.h"
+#include "public/platform/WebParserResourceBridge.h"
 #include "wtf/Assertions.h"
 #include "wtf/text/WTFString.h"
 
 namespace WebCore {
 
 static bool isArchiveMIMEType(const String& mimeType)
 {
     return mimeType == "multipart/related";
 }
 
@@ skipping 539 matching lines @@
     if (isArchiveMIMEType(response().mimeType()))
         return;
     commitData(data, length);
 
     // If we are sending data to MediaDocument, we should stop here
     // and cancel the request.
     if (m_frame && m_frame->document()->isMediaDocument())
         cancelMainResourceLoad(ResourceError::cancelledError(m_request.url()));
 }
 
+void DocumentLoader::parserResourceMessageFilterAdded(Resource* resource)
+{
+    ASSERT_UNUSED(resource, resource == m_mainResource);
+    m_writer->parserResourceMessageFilterAdded();
+}
+
 void DocumentLoader::checkLoadComplete()
 {
     if (!m_frame || isLoading())
         return;
     // FIXME: This ASSERT is always triggered.
     // See https://bugs.webkit.org/show_bug.cgi?id=110937
     // ASSERT(this == frameLoader()->activeDocumentLoader())
     m_frame->domWindow()->finishedLoading();
 }
 
@@ skipping 240 matching lines @@
     RefPtr<DocumentLoader> protect(this);
     ResourceError error = resourceError.isNull() ? ResourceError::cancelledError(m_request.url()) : resourceError;
 
     m_dataLoadTimer.stop();
     if (mainResourceLoader())
         mainResourceLoader()->cancel(error);
 
     mainReceivedError(error);
 }
 
+PassOwnPtr<blink::WebParserResourceBridge> DocumentLoader::constructParserResourceBridge()
+{
+    if (mainResourceLoader())
+        return mainResourceLoader()->constructParserResourceBridge();
+
+    return OwnPtr<blink::WebParserResourceBridge>().release();

[abarth-chromium, 2013/12/18 18:28:49]

return nullptr;

+}
+
 DocumentWriter* DocumentLoader::beginWriting(const AtomicString& mimeType, const AtomicString& encoding, const KURL& url)
 {
     m_writer = createWriterFor(m_frame, 0, url, mimeType, encoding, false, true);
     return m_writer.get();
 }
 
 void DocumentLoader::endWriting(DocumentWriter* writer)
 {
     ASSERT_UNUSED(writer, m_writer == writer);
     m_writer->end();
@@ skipping 56 matching lines @@
 void DocumentLoader::replaceDocument(const String& source, Document* ownerDocument)
 {
     m_frame->loader().stopAllLoaders();
     m_writer = createWriterFor(m_frame, ownerDocument, m_frame->document()->url(), mimeType(), m_writer ? m_writer->encoding() : emptyAtom,  m_writer ? m_writer->encodingWasChosenByUser() : false, true);
     if (!source.isNull())
         m_writer->appendReplacingData(source);
     endWriting(m_writer.get());
 }
 
 } // namespace WebCore