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 "sky/engine/config.h" | 5 #include "sky/engine/config.h" |
6 #include "sky/engine/core/loader/CanvasImageLoader.h" | 6 #include "sky/engine/core/loader/CanvasImageDecoder.h" |
7 #include "sky/engine/core/painting/CanvasImage.h" | 7 #include "sky/engine/core/painting/CanvasImage.h" |
8 #include "sky/engine/core/script/dom_dart_state.h" | 8 #include "sky/engine/core/script/dom_dart_state.h" |
9 #include "sky/engine/platform/SharedBuffer.h" | 9 #include "sky/engine/platform/SharedBuffer.h" |
10 #include "sky/engine/platform/image-decoders/ImageDecoder.h" | 10 #include "sky/engine/platform/image-decoders/ImageDecoder.h" |
11 | 11 |
12 namespace blink { | 12 namespace blink { |
13 | 13 |
14 CanvasImageLoader::CanvasImageLoader(const String& src, PassOwnPtr<ImageLoaderCa
llback> callback) | 14 PassRefPtr<CanvasImageDecoder> CanvasImageDecoder::create( |
15 : callback_(callback) { | 15 mojo::ScopedDataPipeConsumerHandle handle, |
16 KURL url = KURL(DOMDartState::Current()->url(), src); | 16 PassOwnPtr<ImageDecoderCallback> callback) |
17 fetcher_ = adoptPtr(new MojoFetcher(this, url)); | 17 { |
| 18 return adoptRef(new CanvasImageDecoder(handle.Pass(), callback)); |
18 } | 19 } |
19 | 20 |
20 CanvasImageLoader::~CanvasImageLoader() { | 21 CanvasImageDecoder::CanvasImageDecoder(mojo::ScopedDataPipeConsumerHandle handle
, PassOwnPtr<ImageDecoderCallback> callback) |
| 22 : callback_(callback) { |
| 23 buffer_ = SharedBuffer::create(); |
| 24 drainer_ = adoptPtr(new mojo::common::DataPipeDrainer(this, handle.Pass())); |
21 } | 25 } |
22 | 26 |
23 void CanvasImageLoader::OnReceivedResponse(mojo::URLResponsePtr response) { | 27 CanvasImageDecoder::~CanvasImageDecoder() { |
24 if (response->status_code != 200) { | |
25 callback_->handleEvent(nullptr); | |
26 return; | |
27 } | |
28 buffer_ = SharedBuffer::create(); | |
29 drainer_ = | |
30 adoptPtr(new mojo::common::DataPipeDrainer(this, response->body.Pass())); | |
31 } | 28 } |
32 | 29 |
33 void CanvasImageLoader::OnDataAvailable(const void* data, size_t num_bytes) { | 30 void CanvasImageDecoder::OnDataAvailable(const void* data, size_t num_bytes) { |
34 buffer_->append(static_cast<const char*>(data), num_bytes); | 31 buffer_->append(static_cast<const char*>(data), num_bytes); |
35 } | 32 } |
36 | 33 |
37 void CanvasImageLoader::OnDataComplete() { | 34 void CanvasImageDecoder::OnDataComplete() { |
38 OwnPtr<ImageDecoder> decoder = | 35 OwnPtr<ImageDecoder> decoder = |
39 ImageDecoder::create(*buffer_.get(), ImageSource::AlphaPremultiplied, | 36 ImageDecoder::create(*buffer_.get(), ImageSource::AlphaPremultiplied, |
40 ImageSource::GammaAndColorProfileIgnored); | 37 ImageSource::GammaAndColorProfileIgnored); |
41 decoder->setData(buffer_.get(), true); | 38 decoder->setData(buffer_.get(), true); |
42 if (!decoder->failed() && decoder->frameCount() > 0) { | 39 if (!decoder->failed() && decoder->frameCount() > 0) { |
43 RefPtr<CanvasImage> resultImage = CanvasImage::create(); | 40 RefPtr<CanvasImage> resultImage = CanvasImage::create(); |
44 resultImage->setBitmap(decoder->frameBufferAtIndex(0)->getSkBitmap()); | 41 resultImage->setBitmap(decoder->frameBufferAtIndex(0)->getSkBitmap()); |
45 callback_->handleEvent(resultImage.get()); | 42 callback_->handleEvent(resultImage.get()); |
46 } else { | 43 } else { |
47 callback_->handleEvent(nullptr); | 44 callback_->handleEvent(nullptr); |
48 } | 45 } |
49 } | 46 } |
50 | 47 |
51 } // namespace blink | 48 } // namespace blink |
OLD | NEW |