Live the dream

sky/engine/core/html/parser/BackgroundHTMLParser.cpp

 /*
  * Copyright (C) 2013 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.
  * 2. Redistributions in binary form must reproduce the above copyright
  *    notice, this list of conditions and the following disclaimer in the
@@ skipping 44 matching lines @@
     BackgroundHTMLParser* parser = new BackgroundHTMLParser(config);
     return parser->m_weakFactory.GetWeakPtr();
 }
 
 BackgroundHTMLParser::BackgroundHTMLParser(PassOwnPtr<Configuration> config)
     : m_token(adoptPtr(new HTMLToken))
     , m_tokenizer(HTMLTokenizer::create(config->options))
     , m_parser(config->parser)
     , m_pendingTokens(adoptPtr(new CompactHTMLTokenStream))
     , m_decoder(TextResourceDecoder::create())
+    , m_source(config->source.Pass())
     , m_weakFactory(this)
 {
 }
 
 BackgroundHTMLParser::~BackgroundHTMLParser()
 {
 }
 
-void BackgroundHTMLParser::appendRawBytesFromMainThread(PassOwnPtr<Vector<char> > buffer)
+void BackgroundHTMLParser::start()
 {
-    updateDocument(m_decoder->decode(buffer->data(), buffer->size()));
-}
-
-void BackgroundHTMLParser::appendDecodedBytes(const String& input)
-{
-    ASSERT(!m_input.isClosed());
-    m_input.append(SegmentedString(input));
-    pumpTokenizer();
-}
-
-void BackgroundHTMLParser::flush()
-{
-    updateDocument(m_decoder->flush());
-}
-
-void BackgroundHTMLParser::updateDocument(const String& decodedData)
-{
-    if (decodedData.isEmpty())
-        return;
-
-    appendDecodedBytes(decodedData);
-}
-
-void BackgroundHTMLParser::finish()
-{
-    markEndOfFile();
-    pumpTokenizer();
+    m_drainer = adoptPtr(new DataPipeDrainer(this, m_source.Pass()));
 }
 
 void BackgroundHTMLParser::stop()
 {
     delete this;
 }
 
+void BackgroundHTMLParser::OnDataAvailable(const void* data, size_t numberOfBytes)
+{
+    ASSERT(!m_input.isClosed());
+    String input = m_decoder->decode(static_cast<const char*>(data), numberOfBytes);
+    m_input.append(SegmentedString(input));
+    pumpTokenizer();
+}
+
+void BackgroundHTMLParser::OnDataComplete()
+{
+    ASSERT(!m_input.isClosed());
+    finish();
+}
+
+void BackgroundHTMLParser::finish()
+{
+    m_input.append(SegmentedString(m_decoder->flush()));
+    markEndOfFile();
+    pumpTokenizer();
+}
+
 void BackgroundHTMLParser::markEndOfFile()
 {
     ASSERT(!m_input.isClosed());
     m_input.append(SegmentedString(String(&kEndOfFileMarker, 1)));
     m_input.close();
 }
 
 bool BackgroundHTMLParser::updateTokenizerState(const CompactHTMLToken& token)
 {
     if (token.type() == HTMLToken::StartTag) {
@@ skipping 47 matching lines @@
 #endif
 
     OwnPtr<HTMLDocumentParser::ParsedChunk> chunk = adoptPtr(new HTMLDocumentParser::ParsedChunk);
     chunk->tokens = m_pendingTokens.release();
     callOnMainThread(bind(&HTMLDocumentParser::didReceiveParsedChunkFromBackgroundParser, m_parser, chunk.release()));
 
     m_pendingTokens = adoptPtr(new CompactHTMLTokenStream);
 }
 
 }