OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2013 Google, Inc. All Rights Reserved. | 2 * Copyright (C) 2013 Google, Inc. All Rights Reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions | 5 * modification, are permitted provided that the following conditions |
6 * are met: | 6 * are met: |
7 * 1. Redistributions of source code must retain the above copyright | 7 * 1. Redistributions of source code must retain the above copyright |
8 * notice, this list of conditions and the following disclaimer. | 8 * notice, this list of conditions and the following disclaimer. |
9 * 2. Redistributions in binary form must reproduce the above copyright | 9 * 2. Redistributions in binary form must reproduce the above copyright |
10 * notice, this list of conditions and the following disclaimer in the | 10 * notice, this list of conditions and the following disclaimer in the |
(...skipping 17 matching lines...) Expand all Loading... |
28 #include "core/HTMLNames.h" | 28 #include "core/HTMLNames.h" |
29 #include "core/html/parser/HTMLDocumentParser.h" | 29 #include "core/html/parser/HTMLDocumentParser.h" |
30 #include "core/html/parser/TextResourceDecoder.h" | 30 #include "core/html/parser/TextResourceDecoder.h" |
31 #include "core/html/parser/XSSAuditor.h" | 31 #include "core/html/parser/XSSAuditor.h" |
32 #include "platform/CrossThreadFunctional.h" | 32 #include "platform/CrossThreadFunctional.h" |
33 #include "platform/Histogram.h" | 33 #include "platform/Histogram.h" |
34 #include "platform/TraceEvent.h" | 34 #include "platform/TraceEvent.h" |
35 #include "public/platform/Platform.h" | 35 #include "public/platform/Platform.h" |
36 #include "public/platform/WebTaskRunner.h" | 36 #include "public/platform/WebTaskRunner.h" |
37 #include "wtf/CurrentTime.h" | 37 #include "wtf/CurrentTime.h" |
| 38 #include "wtf/Functional.h" |
38 #include "wtf/PtrUtil.h" | 39 #include "wtf/PtrUtil.h" |
39 #include "wtf/text/TextPosition.h" | 40 #include "wtf/text/TextPosition.h" |
40 #include <memory> | 41 #include <memory> |
41 | 42 |
42 namespace blink { | 43 namespace blink { |
43 | 44 |
44 // On a network with high latency and high bandwidth, using a device | 45 // On a network with high latency and high bandwidth, using a device |
45 // with a fast CPU, we could end up speculatively tokenizing | 46 // with a fast CPU, we could end up speculatively tokenizing |
46 // the whole document, well ahead of when the main-thread actually needs it. | 47 // the whole document, well ahead of when the main-thread actually needs it. |
47 // This is a waste of memory (and potentially time if the speculation fails). | 48 // This is a waste of memory (and potentially time if the speculation fails). |
(...skipping 29 matching lines...) Expand all Loading... |
77 } | 78 } |
78 | 79 |
79 static void checkThatXSSInfosAreSafeToSendToAnotherThread(const XSSInfoStream& i
nfos) | 80 static void checkThatXSSInfosAreSafeToSendToAnotherThread(const XSSInfoStream& i
nfos) |
80 { | 81 { |
81 for (size_t i = 0; i < infos.size(); ++i) | 82 for (size_t i = 0; i < infos.size(); ++i) |
82 ASSERT(infos[i]->isSafeToSendToAnotherThread()); | 83 ASSERT(infos[i]->isSafeToSendToAnotherThread()); |
83 } | 84 } |
84 | 85 |
85 #endif | 86 #endif |
86 | 87 |
87 void BackgroundHTMLParser::start(PassRefPtr<WeakReference<BackgroundHTMLParser>>
reference, std::unique_ptr<Configuration> config, const KURL& documentURL, std:
:unique_ptr<CachedDocumentParameters> cachedDocumentParameters, const MediaValue
sCached::MediaValuesCachedData& mediaValuesCachedData, std::unique_ptr<WebTaskRu
nner> loadingTaskRunner) | 88 WeakPtr<BackgroundHTMLParser> BackgroundHTMLParser::create(std::unique_ptr<Confi
guration> config, std::unique_ptr<WebTaskRunner> loadingTaskRunner) |
88 { | 89 { |
89 new BackgroundHTMLParser(reference, std::move(config), documentURL, std::mov
e(cachedDocumentParameters), mediaValuesCachedData, std::move(loadingTaskRunner)
); | 90 auto* backgroundParser = new BackgroundHTMLParser(std::move(config), std::mo
ve(loadingTaskRunner)); |
90 // Caller must free by calling stop(). | 91 return backgroundParser->m_weakFactory.createWeakPtr(); |
91 } | 92 } |
92 | 93 |
| 94 void BackgroundHTMLParser::init(const KURL& documentURL, std::unique_ptr<CachedD
ocumentParameters> cachedDocumentParameters, const MediaValuesCached::MediaValue
sCachedData& mediaValuesCachedData) |
| 95 { |
| 96 m_preloadScanner.reset(new TokenPreloadScanner(documentURL, std::move(cached
DocumentParameters), mediaValuesCachedData)); |
| 97 } |
| 98 |
| 99 |
93 BackgroundHTMLParser::Configuration::Configuration() | 100 BackgroundHTMLParser::Configuration::Configuration() |
94 : outstandingTokenLimit(defaultOutstandingTokenLimit) | 101 : outstandingTokenLimit(defaultOutstandingTokenLimit) |
95 , pendingTokenLimit(defaultPendingTokenLimit) | 102 , pendingTokenLimit(defaultPendingTokenLimit) |
96 , shouldCoalesceChunks(false) | 103 , shouldCoalesceChunks(false) |
97 { | 104 { |
98 } | 105 } |
99 | 106 |
100 BackgroundHTMLParser::BackgroundHTMLParser(PassRefPtr<WeakReference<BackgroundHT
MLParser>> reference, std::unique_ptr<Configuration> config, const KURL& documen
tURL, std::unique_ptr<CachedDocumentParameters> cachedDocumentParameters, const
MediaValuesCached::MediaValuesCachedData& mediaValuesCachedData, std::unique_ptr
<WebTaskRunner> loadingTaskRunner) | 107 BackgroundHTMLParser::BackgroundHTMLParser(std::unique_ptr<Configuration> config
, std::unique_ptr<WebTaskRunner> loadingTaskRunner) |
101 : m_weakFactory(reference, this) | 108 : m_weakFactory(this) |
102 , m_token(wrapUnique(new HTMLToken)) | 109 , m_token(wrapUnique(new HTMLToken)) |
103 , m_tokenizer(HTMLTokenizer::create(config->options)) | 110 , m_tokenizer(HTMLTokenizer::create(config->options)) |
104 , m_treeBuilderSimulator(config->options) | 111 , m_treeBuilderSimulator(config->options) |
105 , m_options(config->options) | 112 , m_options(config->options) |
106 , m_outstandingTokenLimit(config->outstandingTokenLimit) | 113 , m_outstandingTokenLimit(config->outstandingTokenLimit) |
107 , m_parser(config->parser) | 114 , m_parser(config->parser) |
108 , m_pendingTokens(wrapUnique(new CompactHTMLTokenStream)) | 115 , m_pendingTokens(wrapUnique(new CompactHTMLTokenStream)) |
109 , m_pendingTokenLimit(config->pendingTokenLimit) | 116 , m_pendingTokenLimit(config->pendingTokenLimit) |
110 , m_xssAuditor(std::move(config->xssAuditor)) | 117 , m_xssAuditor(std::move(config->xssAuditor)) |
111 , m_preloadScanner(wrapUnique(new TokenPreloadScanner(documentURL, std::move
(cachedDocumentParameters), mediaValuesCachedData))) | |
112 , m_decoder(std::move(config->decoder)) | 118 , m_decoder(std::move(config->decoder)) |
113 , m_loadingTaskRunner(std::move(loadingTaskRunner)) | 119 , m_loadingTaskRunner(std::move(loadingTaskRunner)) |
114 , m_tokenizedChunkQueue(config->tokenizedChunkQueue.release()) | 120 , m_tokenizedChunkQueue(config->tokenizedChunkQueue.release()) |
115 , m_pendingCSPMetaTokenIndex(HTMLDocumentParser::TokenizedChunk::noPendingTo
ken) | 121 , m_pendingCSPMetaTokenIndex(HTMLDocumentParser::TokenizedChunk::noPendingTo
ken) |
116 , m_startingScript(false) | 122 , m_startingScript(false) |
117 , m_lastBytesReceivedTime(0.0) | 123 , m_lastBytesReceivedTime(0.0) |
118 , m_shouldCoalesceChunks(config->shouldCoalesceChunks) | 124 , m_shouldCoalesceChunks(config->shouldCoalesceChunks) |
119 { | 125 { |
120 ASSERT(m_outstandingTokenLimit > 0); | 126 ASSERT(m_outstandingTokenLimit > 0); |
121 ASSERT(m_pendingTokenLimit > 0); | 127 ASSERT(m_pendingTokenLimit > 0); |
(...skipping 230 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
352 void BackgroundHTMLParser::runOnMainThread(FunctionType function, Ps&&... parame
ters) | 358 void BackgroundHTMLParser::runOnMainThread(FunctionType function, Ps&&... parame
ters) |
353 { | 359 { |
354 if (isMainThread()) { | 360 if (isMainThread()) { |
355 (*WTF::bind(function, std::forward<Ps>(parameters)...))(); | 361 (*WTF::bind(function, std::forward<Ps>(parameters)...))(); |
356 } else { | 362 } else { |
357 m_loadingTaskRunner->postTask(BLINK_FROM_HERE, crossThreadBind(function,
std::forward<Ps>(parameters)...)); | 363 m_loadingTaskRunner->postTask(BLINK_FROM_HERE, crossThreadBind(function,
std::forward<Ps>(parameters)...)); |
358 } | 364 } |
359 } | 365 } |
360 | 366 |
361 } // namespace blink | 367 } // namespace blink |
OLD | NEW |