| OLD | NEW |
| 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/fetch/FetchManager.h" | 5 #include "modules/fetch/FetchManager.h" |
| 6 | 6 |
| 7 #include "bindings/core/v8/ExceptionState.h" | 7 #include "bindings/core/v8/ExceptionState.h" |
| 8 #include "bindings/core/v8/ScriptPromiseResolver.h" | 8 #include "bindings/core/v8/ScriptPromiseResolver.h" |
| 9 #include "bindings/core/v8/ScriptState.h" | 9 #include "bindings/core/v8/ScriptState.h" |
| 10 #include "bindings/core/v8/V8ThrowException.h" | 10 #include "bindings/core/v8/V8ThrowException.h" |
| (...skipping 273 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 284 // opaque redirect response. | 284 // opaque redirect response. |
| 285 case WebServiceWorkerResponseTypeError: | 285 case WebServiceWorkerResponseTypeError: |
| 286 // When ServiceWorker respond to the request from fetch() with an | 286 // When ServiceWorker respond to the request from fetch() with an |
| 287 // error response, FetchManager::Loader::didFail() must be called | 287 // error response, FetchManager::Loader::didFail() must be called |
| 288 // instead. | 288 // instead. |
| 289 RELEASE_NOTREACHED(); | 289 RELEASE_NOTREACHED(); |
| 290 break; | 290 break; |
| 291 } | 291 } |
| 292 } | 292 } |
| 293 | 293 |
| 294 ScriptState* scriptState = m_resolver->getScriptState(); | |
| 295 FetchResponseData* responseData = nullptr; | 294 FetchResponseData* responseData = nullptr; |
| 296 CompositeDataConsumerHandle::Updater* updater = nullptr; | 295 CompositeDataConsumerHandle::Updater* updater = nullptr; |
| 297 if (m_request->integrity().isEmpty()) | 296 if (m_request->integrity().isEmpty()) |
| 298 responseData = FetchResponseData::createWithBuffer(new BodyStreamBuffer(
scriptState, createFetchDataConsumerHandleFromWebHandle(handle))); | 297 responseData = FetchResponseData::createWithBuffer(new BodyStreamBuffer(
createFetchDataConsumerHandleFromWebHandle(handle))); |
| 299 else | 298 else |
| 300 responseData = FetchResponseData::createWithBuffer(new BodyStreamBuffer(
scriptState, createFetchDataConsumerHandleFromWebHandle(CompositeDataConsumerHan
dle::create(createWaitingDataConsumerHandle(), &updater)))); | 299 responseData = FetchResponseData::createWithBuffer(new BodyStreamBuffer(
createFetchDataConsumerHandleFromWebHandle(CompositeDataConsumerHandle::create(c
reateWaitingDataConsumerHandle(), &updater)))); |
| 301 responseData->setStatus(response.httpStatusCode()); | 300 responseData->setStatus(response.httpStatusCode()); |
| 302 responseData->setStatusMessage(response.httpStatusText()); | 301 responseData->setStatusMessage(response.httpStatusText()); |
| 303 for (auto& it : response.httpHeaderFields()) | 302 for (auto& it : response.httpHeaderFields()) |
| 304 responseData->headerList()->append(it.key, it.value); | 303 responseData->headerList()->append(it.key, it.value); |
| 305 responseData->setURL(response.url()); | 304 responseData->setURL(response.url()); |
| 306 responseData->setMIMEType(response.mimeType()); | 305 responseData->setMIMEType(response.mimeType()); |
| 307 responseData->setResponseTime(response.responseTime()); | 306 responseData->setResponseTime(response.responseTime()); |
| 308 | 307 |
| 309 FetchResponseData* taintedResponse = nullptr; | 308 FetchResponseData* taintedResponse = nullptr; |
| 310 | 309 |
| (...skipping 249 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 560 request.setHTTPMethod(m_request->method()); | 559 request.setHTTPMethod(m_request->method()); |
| 561 request.setFetchRequestMode(m_request->mode()); | 560 request.setFetchRequestMode(m_request->mode()); |
| 562 request.setFetchCredentialsMode(m_request->credentials()); | 561 request.setFetchCredentialsMode(m_request->credentials()); |
| 563 const Vector<OwnPtr<FetchHeaderList::Header>>& list = m_request->headerList(
)->list(); | 562 const Vector<OwnPtr<FetchHeaderList::Header>>& list = m_request->headerList(
)->list(); |
| 564 for (size_t i = 0; i < list.size(); ++i) { | 563 for (size_t i = 0; i < list.size(); ++i) { |
| 565 request.addHTTPHeaderField(AtomicString(list[i]->first), AtomicString(li
st[i]->second)); | 564 request.addHTTPHeaderField(AtomicString(list[i]->first), AtomicString(li
st[i]->second)); |
| 566 } | 565 } |
| 567 | 566 |
| 568 if (m_request->method() != HTTPNames::GET && m_request->method() != HTTPName
s::HEAD) { | 567 if (m_request->method() != HTTPNames::GET && m_request->method() != HTTPName
s::HEAD) { |
| 569 if (m_request->buffer()) | 568 if (m_request->buffer()) |
| 570 request.setHTTPBody(m_request->buffer()->drainAsFormData()); | 569 request.setHTTPBody(m_request->buffer()->drainAsFormData(m_execution
Context)); |
| 571 if (m_request->attachedCredential()) | 570 if (m_request->attachedCredential()) |
| 572 request.setAttachedCredential(m_request->attachedCredential()); | 571 request.setAttachedCredential(m_request->attachedCredential()); |
| 573 } | 572 } |
| 574 request.setFetchRedirectMode(m_request->redirect()); | 573 request.setFetchRedirectMode(m_request->redirect()); |
| 575 request.setUseStreamOnResponse(true); | 574 request.setUseStreamOnResponse(true); |
| 576 request.setExternalRequestStateFromRequestorAddressSpace(m_executionContext-
>securityContext().addressSpace()); | 575 request.setExternalRequestStateFromRequestorAddressSpace(m_executionContext-
>securityContext().addressSpace()); |
| 577 | 576 |
| 578 // "2. Append `Referer`/empty byte sequence, if |HTTPRequest|'s |referrer| | 577 // "2. Append `Referer`/empty byte sequence, if |HTTPRequest|'s |referrer| |
| 579 // is none, and `Referer`/|HTTPRequest|'s referrer, serialized and utf-8 | 578 // is none, and `Referer`/|HTTPRequest|'s referrer, serialized and utf-8 |
| 580 // encoded, otherwise, to HTTPRequest's header list. | 579 // encoded, otherwise, to HTTPRequest's header list. |
| (...skipping 159 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 740 loader->dispose(); | 739 loader->dispose(); |
| 741 } | 740 } |
| 742 | 741 |
| 743 DEFINE_TRACE(FetchManager) | 742 DEFINE_TRACE(FetchManager) |
| 744 { | 743 { |
| 745 visitor->trace(m_loaders); | 744 visitor->trace(m_loaders); |
| 746 ContextLifecycleObserver::trace(visitor); | 745 ContextLifecycleObserver::trace(visitor); |
| 747 } | 746 } |
| 748 | 747 |
| 749 } // namespace blink | 748 } // namespace blink |
| OLD | NEW |