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 "config.h" | 5 #include "config.h" |
6 #include "modules/fetch/Body.h" | 6 #include "modules/fetch/Body.h" |
7 | 7 |
8 #include "bindings/core/v8/ExceptionState.h" | 8 #include "bindings/core/v8/ExceptionState.h" |
9 #include "bindings/core/v8/ScriptPromiseResolver.h" | 9 #include "bindings/core/v8/ScriptPromiseResolver.h" |
10 #include "bindings/core/v8/ScriptState.h" | 10 #include "bindings/core/v8/ScriptState.h" |
(...skipping 17 matching lines...) Expand all Loading... |
28 explicit BlobHandleReceiver(Body* body) | 28 explicit BlobHandleReceiver(Body* body) |
29 : m_body(body) | 29 : m_body(body) |
30 { | 30 { |
31 } | 31 } |
32 void didCreateBlobHandle(PassRefPtr<BlobDataHandle> handle) override | 32 void didCreateBlobHandle(PassRefPtr<BlobDataHandle> handle) override |
33 { | 33 { |
34 ASSERT(m_body); | 34 ASSERT(m_body); |
35 m_body->readAsyncFromBlob(handle); | 35 m_body->readAsyncFromBlob(handle); |
36 m_body = nullptr; | 36 m_body = nullptr; |
37 } | 37 } |
38 void didFail(PassRefPtrWillBeRawPtr<DOMException> exception) override | 38 void didFail(DOMException* exception) override |
39 { | 39 { |
40 ASSERT(m_body); | 40 ASSERT(m_body); |
41 m_body->didBlobHandleReceiveError(exception); | 41 m_body->didBlobHandleReceiveError(exception); |
42 m_body = nullptr; | 42 m_body = nullptr; |
43 } | 43 } |
44 DEFINE_INLINE_VIRTUAL_TRACE() | 44 DEFINE_INLINE_VIRTUAL_TRACE() |
45 { | 45 { |
46 BodyStreamBuffer::BlobHandleCreatorClient::trace(visitor); | 46 BodyStreamBuffer::BlobHandleCreatorClient::trace(visitor); |
47 visitor->trace(m_body); | 47 visitor->trace(m_body); |
48 } | 48 } |
(...skipping 205 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
254 m_bodyStreamBuffer->cancel(); | 254 m_bodyStreamBuffer->cancel(); |
255 // We should not close the stream here, because it is canceller's | 255 // We should not close the stream here, because it is canceller's |
256 // responsibility. | 256 // responsibility. |
257 } else { | 257 } else { |
258 if (m_loader) | 258 if (m_loader) |
259 m_loader->cancel(); | 259 m_loader->cancel(); |
260 close(); | 260 close(); |
261 } | 261 } |
262 } | 262 } |
263 | 263 |
264 PassRefPtrWillBeRawPtr<DOMException> exception() | 264 DOMException* exception() |
265 { | 265 { |
266 if (m_state != Errored) | 266 if (m_state != Errored) |
267 return nullptr; | 267 return nullptr; |
268 if (m_bodyStreamBuffer) { | 268 if (m_bodyStreamBuffer) { |
269 ASSERT(m_bodyStreamBuffer->exception()); | 269 ASSERT(m_bodyStreamBuffer->exception()); |
270 return m_bodyStreamBuffer->exception(); | 270 return m_bodyStreamBuffer->exception(); |
271 } | 271 } |
272 return DOMException::create(NetworkError, "network error"); | 272 return DOMException::create(NetworkError, "network error"); |
273 } | 273 } |
274 | 274 |
(...skipping 303 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
578 return; | 578 return; |
579 | 579 |
580 m_streamSource->error(); | 580 m_streamSource->error(); |
581 if (m_resolver) { | 581 if (m_resolver) { |
582 // FIXME: We should reject the promise. | 582 // FIXME: We should reject the promise. |
583 m_resolver->resolve(""); | 583 m_resolver->resolve(""); |
584 m_resolver.clear(); | 584 m_resolver.clear(); |
585 } | 585 } |
586 } | 586 } |
587 | 587 |
588 void Body::didBlobHandleReceiveError(PassRefPtrWillBeRawPtr<DOMException> except
ion) | 588 void Body::didBlobHandleReceiveError(DOMException* exception) |
589 { | 589 { |
590 if (!m_resolver) | 590 if (!m_resolver) |
591 return; | 591 return; |
592 m_streamSource->error(); | 592 m_streamSource->error(); |
593 m_resolver->reject(exception); | 593 m_resolver->reject(exception); |
594 m_resolver.clear(); | 594 m_resolver.clear(); |
595 } | 595 } |
596 | 596 |
597 } // namespace blink | 597 } // namespace blink |
OLD | NEW |