| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/DataConsumerTee.h" | 5 #include "modules/fetch/DataConsumerTee.h" |
| 6 | 6 |
| 7 #include "core/dom/ActiveDOMObject.h" | 7 #include "core/dom/ActiveDOMObject.h" |
| 8 #include "core/dom/ExecutionContext.h" | 8 #include "core/dom/ExecutionContext.h" |
| 9 #include "modules/fetch/DataConsumerHandleUtil.h" | 9 #include "modules/fetch/DataConsumerHandleUtil.h" |
| 10 #include "modules/fetch/FetchBlobDataConsumerHandle.h" | 10 #include "modules/fetch/FetchBlobDataConsumerHandle.h" |
| (...skipping 307 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 318 private: | 318 private: |
| 319 DestinationHandle(PassRefPtr<DestinationContext::Proxy> contextProxy) : m_co
ntextProxy(contextProxy) { } | 319 DestinationHandle(PassRefPtr<DestinationContext::Proxy> contextProxy) : m_co
ntextProxy(contextProxy) { } |
| 320 DestinationReader* obtainReaderInternal(Client* client) { return new Destina
tionReader(m_contextProxy, client); } | 320 DestinationReader* obtainReaderInternal(Client* client) { return new Destina
tionReader(m_contextProxy, client); } |
| 321 const char* debugName() const override { return "DestinationHandle"; } | 321 const char* debugName() const override { return "DestinationHandle"; } |
| 322 | 322 |
| 323 RefPtr<DestinationContext::Proxy> m_contextProxy; | 323 RefPtr<DestinationContext::Proxy> m_contextProxy; |
| 324 }; | 324 }; |
| 325 | 325 |
| 326 // Bound to the created thread. | 326 // Bound to the created thread. |
| 327 class SourceContext final : public GarbageCollectedFinalized<SourceContext>, pub
lic ActiveDOMObject, public WebDataConsumerHandle::Client { | 327 class SourceContext final : public GarbageCollectedFinalized<SourceContext>, pub
lic ActiveDOMObject, public WebDataConsumerHandle::Client { |
| 328 WILL_BE_USING_GARBAGE_COLLECTED_MIXIN(SourceContext); | 328 USING_GARBAGE_COLLECTED_MIXIN(SourceContext); |
| 329 public: | 329 public: |
| 330 SourceContext( | 330 SourceContext( |
| 331 PassRefPtr<TeeRootObject> root, | 331 PassRefPtr<TeeRootObject> root, |
| 332 PassOwnPtr<WebDataConsumerHandle> src, | 332 PassOwnPtr<WebDataConsumerHandle> src, |
| 333 PassRefPtr<DestinationContext> dest1, | 333 PassRefPtr<DestinationContext> dest1, |
| 334 PassRefPtr<DestinationContext> dest2, | 334 PassRefPtr<DestinationContext> dest2, |
| 335 ExecutionContext* executionContext) | 335 ExecutionContext* executionContext) |
| 336 : ActiveDOMObject(executionContext) | 336 : ActiveDOMObject(executionContext) |
| 337 , m_root(root) | 337 , m_root(root) |
| 338 , m_reader(src->obtainReader(this)) | 338 , m_reader(src->obtainReader(this)) |
| (...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 424 } | 424 } |
| 425 | 425 |
| 426 OwnPtr<WebDataConsumerHandle> webDest1, webDest2; | 426 OwnPtr<WebDataConsumerHandle> webDest1, webDest2; |
| 427 DataConsumerTee::create(executionContext, static_cast<PassOwnPtr<WebDataCons
umerHandle>>(src), &webDest1, &webDest2); | 427 DataConsumerTee::create(executionContext, static_cast<PassOwnPtr<WebDataCons
umerHandle>>(src), &webDest1, &webDest2); |
| 428 *dest1 = createFetchDataConsumerHandleFromWebHandle(webDest1.release()); | 428 *dest1 = createFetchDataConsumerHandleFromWebHandle(webDest1.release()); |
| 429 *dest2 = createFetchDataConsumerHandleFromWebHandle(webDest2.release()); | 429 *dest2 = createFetchDataConsumerHandleFromWebHandle(webDest2.release()); |
| 430 return; | 430 return; |
| 431 } | 431 } |
| 432 | 432 |
| 433 } // namespace blink | 433 } // namespace blink |
| OLD | NEW |