| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (C) 2010 Google, Inc. All Rights Reserved. | 2 * Copyright (C) 2010 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 13 matching lines...) Expand all Loading... |
| 24 */ | 24 */ |
| 25 | 25 |
| 26 #include "core/dom/PendingScript.h" | 26 #include "core/dom/PendingScript.h" |
| 27 | 27 |
| 28 #include "bindings/core/v8/ScriptSourceCode.h" | 28 #include "bindings/core/v8/ScriptSourceCode.h" |
| 29 #include "bindings/core/v8/ScriptState.h" | 29 #include "bindings/core/v8/ScriptState.h" |
| 30 #include "bindings/core/v8/V8BindingForCore.h" | 30 #include "bindings/core/v8/V8BindingForCore.h" |
| 31 #include "core/dom/ClassicScript.h" | 31 #include "core/dom/ClassicScript.h" |
| 32 #include "core/dom/Document.h" | 32 #include "core/dom/Document.h" |
| 33 #include "core/dom/ScriptElementBase.h" | 33 #include "core/dom/ScriptElementBase.h" |
| 34 #include "core/dom/TaskRunnerHelper.h" | |
| 35 #include "core/frame/LocalFrame.h" | |
| 36 #include "core/frame/SubresourceIntegrity.h" | |
| 37 #include "platform/SharedBuffer.h" | |
| 38 #include "platform/wtf/CurrentTime.h" | 34 #include "platform/wtf/CurrentTime.h" |
| 39 | 35 |
| 40 namespace blink { | 36 namespace blink { |
| 41 | 37 |
| 42 PendingScript* PendingScript::Create(ScriptElementBase* element, | |
| 43 ScriptResource* resource) { | |
| 44 return new PendingScript(element, resource, TextPosition()); | |
| 45 } | |
| 46 | |
| 47 PendingScript* PendingScript::Create(ScriptElementBase* element, | |
| 48 const TextPosition& starting_position) { | |
| 49 return new PendingScript(element, nullptr, starting_position); | |
| 50 } | |
| 51 | |
| 52 PendingScript* PendingScript::CreateForTesting(ScriptResource* resource) { | |
| 53 return new PendingScript(nullptr, resource, TextPosition(), true); | |
| 54 } | |
| 55 | |
| 56 PendingScript::PendingScript(ScriptElementBase* element, | 38 PendingScript::PendingScript(ScriptElementBase* element, |
| 57 ScriptResource* resource, | 39 const TextPosition& starting_position) |
| 58 const TextPosition& starting_position, | |
| 59 bool is_for_testing) | |
| 60 : watching_for_load_(false), | 40 : watching_for_load_(false), |
| 61 element_(element), | 41 element_(element), |
| 62 starting_position_(starting_position), | 42 starting_position_(starting_position), |
| 63 integrity_failure_(false), | |
| 64 parser_blocking_load_start_time_(0), | 43 parser_blocking_load_start_time_(0), |
| 65 client_(nullptr), | 44 client_(nullptr) {} |
| 66 is_for_testing_(is_for_testing) { | |
| 67 CheckState(); | |
| 68 SetResource(resource); | |
| 69 MemoryCoordinator::Instance().RegisterClient(this); | |
| 70 } | |
| 71 | 45 |
| 72 PendingScript::~PendingScript() {} | 46 PendingScript::~PendingScript() {} |
| 73 | 47 |
| 74 NOINLINE void PendingScript::CheckState() const { | |
| 75 // TODO(hiroshige): Turn these CHECK()s into DCHECK() before going to beta. | |
| 76 CHECK(is_for_testing_ || element_); | |
| 77 CHECK(GetResource() || !streamer_); | |
| 78 CHECK(!streamer_ || streamer_->GetResource() == GetResource()); | |
| 79 } | |
| 80 | |
| 81 void PendingScript::Dispose() { | 48 void PendingScript::Dispose() { |
| 82 StopWatchingForLoad(); | 49 StopWatchingForLoad(); |
| 83 DCHECK(!client_); | 50 DCHECK(!Client()); |
| 84 DCHECK(!watching_for_load_); | 51 DCHECK(!IsWatchingForLoad()); |
| 85 | 52 |
| 86 MemoryCoordinator::Instance().UnregisterClient(this); | |
| 87 SetResource(nullptr); | |
| 88 starting_position_ = TextPosition::BelowRangePosition(); | 53 starting_position_ = TextPosition::BelowRangePosition(); |
| 89 integrity_failure_ = false; | |
| 90 parser_blocking_load_start_time_ = 0; | 54 parser_blocking_load_start_time_ = 0; |
| 91 if (streamer_) | 55 |
| 92 streamer_->Cancel(); | 56 DisposeInternal(); |
| 93 streamer_ = nullptr; | |
| 94 element_ = nullptr; | 57 element_ = nullptr; |
| 95 } | 58 } |
| 96 | 59 |
| 97 void PendingScript::WatchForLoad(PendingScriptClient* client) { | 60 void PendingScript::WatchForLoad(PendingScriptClient* client) { |
| 98 CheckState(); | 61 CheckState(); |
| 99 | 62 |
| 100 DCHECK(!watching_for_load_); | 63 DCHECK(!IsWatchingForLoad()); |
| 101 // addClient() will call streamingFinished() if the load is complete. Callers | 64 // addClient() will call streamingFinished() if the load is complete. Callers |
| 102 // who do not expect to be re-entered from this call should not call | 65 // who do not expect to be re-entered from this call should not call |
| 103 // watchForLoad for a PendingScript which isReady. We also need to set | 66 // watchForLoad for a PendingScript which isReady. We also need to set |
| 104 // m_watchingForLoad early, since addClient() can result in calling | 67 // m_watchingForLoad early, since addClient() can result in calling |
| 105 // notifyFinished and further stopWatchingForLoad(). | 68 // notifyFinished and further stopWatchingForLoad(). |
| 106 watching_for_load_ = true; | 69 watching_for_load_ = true; |
| 107 client_ = client; | 70 client_ = client; |
| 108 if (IsReady()) | 71 if (IsReady()) |
| 109 client_->PendingScriptFinished(this); | 72 client_->PendingScriptFinished(this); |
| 110 } | 73 } |
| 111 | 74 |
| 112 void PendingScript::StopWatchingForLoad() { | 75 void PendingScript::StopWatchingForLoad() { |
| 113 if (!watching_for_load_) | 76 if (!IsWatchingForLoad()) |
| 114 return; | 77 return; |
| 115 CheckState(); | 78 CheckState(); |
| 116 DCHECK(GetResource()); | 79 DCHECK(IsExternal()); |
| 117 client_ = nullptr; | 80 client_ = nullptr; |
| 118 watching_for_load_ = false; | 81 watching_for_load_ = false; |
| 119 } | 82 } |
| 120 | 83 |
| 121 ScriptElementBase* PendingScript::GetElement() const { | 84 ScriptElementBase* PendingScript::GetElement() const { |
| 122 // As mentioned in the comment at |m_element| declaration, | 85 // As mentioned in the comment at |m_element| declaration, |
| 123 // |m_element| must point to the corresponding ScriptLoader's | 86 // |m_element| must point to the corresponding ScriptLoader's |
| 124 // client. | 87 // client. |
| 125 CHECK(element_); | 88 CHECK(element_); |
| 126 return element_.Get(); | 89 return element_.Get(); |
| 127 } | 90 } |
| 128 | 91 |
| 129 void PendingScript::StreamingFinished() { | |
| 130 CheckState(); | |
| 131 DCHECK(GetResource()); | |
| 132 if (client_) | |
| 133 client_->PendingScriptFinished(this); | |
| 134 } | |
| 135 | |
| 136 void PendingScript::MarkParserBlockingLoadStartTime() { | 92 void PendingScript::MarkParserBlockingLoadStartTime() { |
| 137 DCHECK_EQ(parser_blocking_load_start_time_, 0.0); | 93 DCHECK_EQ(parser_blocking_load_start_time_, 0.0); |
| 138 parser_blocking_load_start_time_ = MonotonicallyIncreasingTime(); | 94 parser_blocking_load_start_time_ = MonotonicallyIncreasingTime(); |
| 139 } | 95 } |
| 140 | 96 |
| 141 // Returns true if SRI check passed. | |
| 142 static bool CheckScriptResourceIntegrity(Resource* resource, | |
| 143 ScriptElementBase* element) { | |
| 144 DCHECK_EQ(resource->GetType(), Resource::kScript); | |
| 145 ScriptResource* script_resource = ToScriptResource(resource); | |
| 146 String integrity_attr = element->IntegrityAttributeValue(); | |
| 147 | |
| 148 // It is possible to get back a script resource with integrity metadata | |
| 149 // for a request with an empty integrity attribute. In that case, the | |
| 150 // integrity check should be skipped, so this check ensures that the | |
| 151 // integrity attribute isn't empty in addition to checking if the | |
| 152 // resource has empty integrity metadata. | |
| 153 if (integrity_attr.IsEmpty() || | |
| 154 script_resource->IntegrityMetadata().IsEmpty()) | |
| 155 return true; | |
| 156 | |
| 157 switch (script_resource->IntegrityDisposition()) { | |
| 158 case ResourceIntegrityDisposition::kPassed: | |
| 159 return true; | |
| 160 | |
| 161 case ResourceIntegrityDisposition::kFailed: | |
| 162 // TODO(jww): This should probably also generate a console | |
| 163 // message identical to the one produced by | |
| 164 // CheckSubresourceIntegrity below. See https://crbug.com/585267. | |
| 165 return false; | |
| 166 | |
| 167 case ResourceIntegrityDisposition::kNotChecked: { | |
| 168 if (!resource->ResourceBuffer()) | |
| 169 return true; | |
| 170 | |
| 171 bool passed = SubresourceIntegrity::CheckSubresourceIntegrity( | |
| 172 script_resource->IntegrityMetadata(), element->GetDocument(), | |
| 173 resource->ResourceBuffer()->Data(), | |
| 174 resource->ResourceBuffer()->size(), resource->Url(), *resource); | |
| 175 script_resource->SetIntegrityDisposition( | |
| 176 passed ? ResourceIntegrityDisposition::kPassed | |
| 177 : ResourceIntegrityDisposition::kFailed); | |
| 178 return passed; | |
| 179 } | |
| 180 } | |
| 181 | |
| 182 NOTREACHED(); | |
| 183 return true; | |
| 184 } | |
| 185 | |
| 186 void PendingScript::NotifyFinished(Resource* resource) { | |
| 187 // The following SRI checks need to be here because, unfortunately, fetches | |
| 188 // are not done purely according to the Fetch spec. In particular, | |
| 189 // different requests for the same resource do not have different | |
| 190 // responses; the memory cache can (and will) return the exact same | |
| 191 // Resource object. | |
| 192 // | |
| 193 // For different requests, the same Resource object will be returned and | |
| 194 // will not be associated with the particular request. Therefore, when the | |
| 195 // body of the response comes in, there's no way to validate the integrity | |
| 196 // of the Resource object against a particular request (since there may be | |
| 197 // several pending requests all tied to the identical object, and the | |
| 198 // actual requests are not stored). | |
| 199 // | |
| 200 // In order to simulate the correct behavior, Blink explicitly does the SRI | |
| 201 // checks here, when a PendingScript tied to a particular request is | |
| 202 // finished (and in the case of a StyleSheet, at the point of execution), | |
| 203 // while having proper Fetch checks in the fetch module for use in the | |
| 204 // fetch JavaScript API. In a future world where the ResourceFetcher uses | |
| 205 // the Fetch algorithm, this should be fixed by having separate Response | |
| 206 // objects (perhaps attached to identical Resource objects) per request. | |
| 207 // | |
| 208 // See https://crbug.com/500701 for more information. | |
| 209 CheckState(); | |
| 210 if (element_) { | |
| 211 integrity_failure_ = !CheckScriptResourceIntegrity(resource, element_); | |
| 212 } | |
| 213 | |
| 214 // If script streaming is in use, the client will be notified in | |
| 215 // streamingFinished. | |
| 216 if (streamer_) | |
| 217 streamer_->NotifyFinished(resource); | |
| 218 else if (client_) | |
| 219 client_->PendingScriptFinished(this); | |
| 220 } | |
| 221 | |
| 222 void PendingScript::NotifyAppendData(ScriptResource* resource) { | |
| 223 if (streamer_) | |
| 224 streamer_->NotifyAppendData(resource); | |
| 225 } | |
| 226 | |
| 227 DEFINE_TRACE(PendingScript) { | 97 DEFINE_TRACE(PendingScript) { |
| 228 visitor->Trace(element_); | 98 visitor->Trace(element_); |
| 229 visitor->Trace(streamer_); | |
| 230 visitor->Trace(client_); | 99 visitor->Trace(client_); |
| 231 ResourceOwner<ScriptResource>::Trace(visitor); | |
| 232 MemoryCoordinatorClient::Trace(visitor); | |
| 233 } | |
| 234 | |
| 235 ClassicScript* PendingScript::GetSource(const KURL& document_url, | |
| 236 bool& error_occurred) const { | |
| 237 CheckState(); | |
| 238 | |
| 239 error_occurred = this->ErrorOccurred(); | |
| 240 if (GetResource()) { | |
| 241 DCHECK(GetResource()->IsLoaded()); | |
| 242 if (streamer_ && !streamer_->StreamingSuppressed()) | |
| 243 return ClassicScript::Create(ScriptSourceCode(streamer_, GetResource())); | |
| 244 return ClassicScript::Create(ScriptSourceCode(GetResource())); | |
| 245 } | |
| 246 | |
| 247 return ClassicScript::Create(ScriptSourceCode( | |
| 248 element_->TextContent(), document_url, StartingPosition())); | |
| 249 } | |
| 250 | |
| 251 void PendingScript::SetStreamer(ScriptStreamer* streamer) { | |
| 252 DCHECK(!streamer_); | |
| 253 DCHECK(!watching_for_load_); | |
| 254 streamer_ = streamer; | |
| 255 CheckState(); | |
| 256 } | |
| 257 | |
| 258 bool PendingScript::IsReady() const { | |
| 259 CheckState(); | |
| 260 if (GetResource()) { | |
| 261 return GetResource()->IsLoaded() && (!streamer_ || streamer_->IsFinished()); | |
| 262 } | |
| 263 | |
| 264 return true; | |
| 265 } | |
| 266 | |
| 267 bool PendingScript::ErrorOccurred() const { | |
| 268 CheckState(); | |
| 269 if (GetResource()) | |
| 270 return GetResource()->ErrorOccurred() || integrity_failure_; | |
| 271 | |
| 272 return false; | |
| 273 } | |
| 274 | |
| 275 void PendingScript::OnPurgeMemory() { | |
| 276 CheckState(); | |
| 277 if (!streamer_) | |
| 278 return; | |
| 279 streamer_->Cancel(); | |
| 280 streamer_ = nullptr; | |
| 281 } | |
| 282 | |
| 283 void PendingScript::StartStreamingIfPossible( | |
| 284 Document* document, | |
| 285 ScriptStreamer::Type streamer_type) { | |
| 286 if (!document->GetFrame()) | |
| 287 return; | |
| 288 | |
| 289 ScriptState* script_state = ToScriptStateForMainWorld(document->GetFrame()); | |
| 290 if (!script_state) | |
| 291 return; | |
| 292 | |
| 293 ScriptStreamer::StartStreaming( | |
| 294 this, streamer_type, document->GetFrame()->GetSettings(), script_state, | |
| 295 TaskRunnerHelper::Get(TaskType::kNetworking, document)); | |
| 296 } | 100 } |
| 297 | 101 |
| 298 } // namespace blink | 102 } // namespace blink |
| OLD | NEW |