Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(90)

Side by Side Diff: third_party/WebKit/Source/modules/serviceworkers/FetchEvent.cpp

Issue 2815313002: Reland of Move ScriptState::GetExecutionContext (Part 5) (Closed)
Patch Set: Created 3 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "modules/serviceworkers/FetchEvent.h" 5 #include "modules/serviceworkers/FetchEvent.h"
6 6
7 #include "bindings/core/v8/ScriptState.h" 7 #include "bindings/core/v8/ScriptState.h"
8 #include "bindings/core/v8/ToV8ForCore.h" 8 #include "bindings/core/v8/ToV8ForCore.h"
9 #include "bindings/core/v8/V8PrivateProperty.h" 9 #include "bindings/core/v8/V8PrivateProperty.h"
10 #include "core/dom/ExecutionContext.h"
10 #include "modules/fetch/BytesConsumerForDataConsumerHandle.h" 11 #include "modules/fetch/BytesConsumerForDataConsumerHandle.h"
11 #include "modules/fetch/Request.h" 12 #include "modules/fetch/Request.h"
12 #include "modules/fetch/Response.h" 13 #include "modules/fetch/Response.h"
13 #include "modules/serviceworkers/FetchRespondWithObserver.h" 14 #include "modules/serviceworkers/FetchRespondWithObserver.h"
14 #include "modules/serviceworkers/ServiceWorkerError.h" 15 #include "modules/serviceworkers/ServiceWorkerError.h"
15 #include "modules/serviceworkers/ServiceWorkerGlobalScope.h" 16 #include "modules/serviceworkers/ServiceWorkerGlobalScope.h"
16 #include "platform/network/NetworkUtils.h" 17 #include "platform/network/NetworkUtils.h"
17 #include "platform/wtf/PtrUtil.h" 18 #include "platform/wtf/PtrUtil.h"
18 #include "platform/wtf/RefPtr.h" 19 #include "platform/wtf/RefPtr.h"
19 #include "public/platform/WebURLResponse.h" 20 #include "public/platform/WebURLResponse.h"
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after
68 69
69 FetchEvent::FetchEvent(ScriptState* script_state, 70 FetchEvent::FetchEvent(ScriptState* script_state,
70 const AtomicString& type, 71 const AtomicString& type,
71 const FetchEventInit& initializer, 72 const FetchEventInit& initializer,
72 FetchRespondWithObserver* respond_with_observer, 73 FetchRespondWithObserver* respond_with_observer,
73 WaitUntilObserver* wait_until_observer, 74 WaitUntilObserver* wait_until_observer,
74 bool navigation_preload_sent) 75 bool navigation_preload_sent)
75 : ExtendableEvent(type, initializer, wait_until_observer), 76 : ExtendableEvent(type, initializer, wait_until_observer),
76 observer_(respond_with_observer), 77 observer_(respond_with_observer),
77 preload_response_property_(new PreloadResponseProperty( 78 preload_response_property_(new PreloadResponseProperty(
78 script_state->GetExecutionContext(), 79 ExecutionContext::From(script_state),
79 this, 80 this,
80 PreloadResponseProperty::kPreloadResponse)) { 81 PreloadResponseProperty::kPreloadResponse)) {
81 if (!navigation_preload_sent) 82 if (!navigation_preload_sent)
82 preload_response_property_->ResolveWithUndefined(); 83 preload_response_property_->ResolveWithUndefined();
83 84
84 client_id_ = initializer.clientId(); 85 client_id_ = initializer.clientId();
85 is_reload_ = initializer.isReload(); 86 is_reload_ = initializer.isReload();
86 if (initializer.hasRequest()) { 87 if (initializer.hasRequest()) {
87 ScriptState::Scope scope(script_state); 88 ScriptState::Scope scope(script_state);
88 request_ = initializer.request(); 89 request_ = initializer.request();
(...skipping 22 matching lines...) Expand all
111 std::unique_ptr<WebURLResponse> response, 112 std::unique_ptr<WebURLResponse> response,
112 std::unique_ptr<WebDataConsumerHandle> data_consume_handle) { 113 std::unique_ptr<WebDataConsumerHandle> data_consume_handle) {
113 if (!script_state->ContextIsValid()) 114 if (!script_state->ContextIsValid())
114 return; 115 return;
115 DCHECK(preload_response_property_); 116 DCHECK(preload_response_property_);
116 ScriptState::Scope scope(script_state); 117 ScriptState::Scope scope(script_state);
117 FetchResponseData* response_data = 118 FetchResponseData* response_data =
118 data_consume_handle 119 data_consume_handle
119 ? FetchResponseData::CreateWithBuffer(new BodyStreamBuffer( 120 ? FetchResponseData::CreateWithBuffer(new BodyStreamBuffer(
120 script_state, new BytesConsumerForDataConsumerHandle( 121 script_state, new BytesConsumerForDataConsumerHandle(
121 script_state->GetExecutionContext(), 122 ExecutionContext::From(script_state),
122 std::move(data_consume_handle)))) 123 std::move(data_consume_handle))))
123 : FetchResponseData::Create(); 124 : FetchResponseData::Create();
124 Vector<KURL> url_list(1); 125 Vector<KURL> url_list(1);
125 url_list[0] = response->Url(); 126 url_list[0] = response->Url();
126 response_data->SetURLList(url_list); 127 response_data->SetURLList(url_list);
127 response_data->SetStatus(response->HttpStatusCode()); 128 response_data->SetStatus(response->HttpStatusCode());
128 response_data->SetStatusMessage(response->HttpStatusText()); 129 response_data->SetStatusMessage(response->HttpStatusText());
129 response_data->SetResponseTime(response->ToResourceResponse().ResponseTime()); 130 response_data->SetResponseTime(response->ToResourceResponse().ResponseTime());
130 const HTTPHeaderMap& headers( 131 const HTTPHeaderMap& headers(
131 response->ToResourceResponse().HttpHeaderFields()); 132 response->ToResourceResponse().HttpHeaderFields());
132 for (const auto& header : headers) { 133 for (const auto& header : headers) {
133 response_data->HeaderList()->Append(header.key, header.value); 134 response_data->HeaderList()->Append(header.key, header.value);
134 } 135 }
135 FetchResponseData* tainted_response = 136 FetchResponseData* tainted_response =
136 NetworkUtils::IsRedirectResponseCode(response->HttpStatusCode()) 137 NetworkUtils::IsRedirectResponseCode(response->HttpStatusCode())
137 ? response_data->CreateOpaqueRedirectFilteredResponse() 138 ? response_data->CreateOpaqueRedirectFilteredResponse()
138 : response_data->CreateBasicFilteredResponse(); 139 : response_data->CreateBasicFilteredResponse();
139 preload_response_property_->Resolve( 140 preload_response_property_->Resolve(
140 Response::Create(script_state->GetExecutionContext(), tainted_response)); 141 Response::Create(ExecutionContext::From(script_state), tainted_response));
141 } 142 }
142 143
143 void FetchEvent::OnNavigationPreloadError( 144 void FetchEvent::OnNavigationPreloadError(
144 ScriptState* script_state, 145 ScriptState* script_state,
145 std::unique_ptr<WebServiceWorkerError> error) { 146 std::unique_ptr<WebServiceWorkerError> error) {
146 if (!script_state->ContextIsValid()) 147 if (!script_state->ContextIsValid())
147 return; 148 return;
148 DCHECK(preload_response_property_); 149 DCHECK(preload_response_property_);
149 preload_response_property_->Reject( 150 preload_response_property_->Reject(
150 ServiceWorkerError::Take(nullptr, *error.get())); 151 ServiceWorkerError::Take(nullptr, *error.get()));
151 } 152 }
152 153
153 DEFINE_TRACE(FetchEvent) { 154 DEFINE_TRACE(FetchEvent) {
154 visitor->Trace(observer_); 155 visitor->Trace(observer_);
155 visitor->Trace(request_); 156 visitor->Trace(request_);
156 visitor->Trace(preload_response_property_); 157 visitor->Trace(preload_response_property_);
157 ExtendableEvent::Trace(visitor); 158 ExtendableEvent::Trace(visitor);
158 } 159 }
159 160
160 } // namespace blink 161 } // namespace blink
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698