| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "chrome/browser/image_decoder.h" | 5 #include "components/image_fetcher/content/image_decoder.h" |
| 6 | 6 |
| 7 #include <memory> |
| 7 #include <utility> | 8 #include <utility> |
| 8 | 9 |
| 9 #include "base/bind.h" | 10 #include "base/bind.h" |
| 10 #include "base/callback.h" | 11 #include "base/callback.h" |
| 11 #include "base/threading/thread_task_runner_handle.h" | 12 #include "base/threading/thread_task_runner_handle.h" |
| 12 #include "build/build_config.h" | 13 #include "build/build_config.h" |
| 13 #include "content/public/browser/browser_thread.h" | 14 #include "content/public/browser/browser_thread.h" |
| 14 #include "content/public/common/service_manager_connection.h" | 15 #include "content/public/common/service_manager_connection.h" |
| 15 #include "ipc/ipc_channel.h" | 16 #include "ipc/ipc_channel.h" |
| 16 #include "services/data_decoder/public/cpp/decode_image.h" | 17 #include "services/data_decoder/public/cpp/decode_image.h" |
| (...skipping 20 matching lines...) Expand all Loading... |
| 37 } | 38 } |
| 38 | 39 |
| 39 void BindToBrowserConnector(service_manager::mojom::ConnectorRequest request) { | 40 void BindToBrowserConnector(service_manager::mojom::ConnectorRequest request) { |
| 40 if (!content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)) { | 41 if (!content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)) { |
| 41 content::BrowserThread::PostTask( | 42 content::BrowserThread::PostTask( |
| 42 content::BrowserThread::UI, FROM_HERE, | 43 content::BrowserThread::UI, FROM_HERE, |
| 43 base::Bind(&BindToBrowserConnector, base::Passed(&request))); | 44 base::Bind(&BindToBrowserConnector, base::Passed(&request))); |
| 44 return; | 45 return; |
| 45 } | 46 } |
| 46 | 47 |
| 47 content::ServiceManagerConnection::GetForProcess()->GetConnector() | 48 content::ServiceManagerConnection::GetForProcess() |
| 49 ->GetConnector() |
| 48 ->BindConnectorRequest(std::move(request)); | 50 ->BindConnectorRequest(std::move(request)); |
| 49 } | 51 } |
| 50 | 52 |
| 51 void RunDecodeCallbackOnTaskRunner( | 53 void RunDecodeCallbackOnTaskRunner( |
| 52 const data_decoder::mojom::ImageDecoder::DecodeImageCallback& callback, | 54 const data_decoder::mojom::ImageDecoder::DecodeImageCallback& callback, |
| 53 scoped_refptr<base::SequencedTaskRunner> task_runner, | 55 scoped_refptr<base::SequencedTaskRunner> task_runner, |
| 54 const SkBitmap& image) { | 56 const SkBitmap& image) { |
| 55 task_runner->PostTask(FROM_HERE, base::Bind(callback, image)); | 57 task_runner->PostTask(FROM_HERE, base::Bind(callback, image)); |
| 56 } | 58 } |
| 57 | 59 |
| (...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 189 for (auto it = image_request_id_map_.begin(); | 191 for (auto it = image_request_id_map_.begin(); |
| 190 it != image_request_id_map_.end();) { | 192 it != image_request_id_map_.end();) { |
| 191 if (it->second == image_request) { | 193 if (it->second == image_request) { |
| 192 image_request_id_map_.erase(it++); | 194 image_request_id_map_.erase(it++); |
| 193 } else { | 195 } else { |
| 194 ++it; | 196 ++it; |
| 195 } | 197 } |
| 196 } | 198 } |
| 197 } | 199 } |
| 198 | 200 |
| 199 void ImageDecoder::OnDecodeImageSucceeded( | 201 void ImageDecoder::OnDecodeImageSucceeded(const SkBitmap& decoded_image, |
| 200 const SkBitmap& decoded_image, | 202 int request_id) { |
| 201 int request_id) { | |
| 202 ImageRequest* image_request; | 203 ImageRequest* image_request; |
| 203 { | 204 { |
| 204 base::AutoLock lock(map_lock_); | 205 base::AutoLock lock(map_lock_); |
| 205 auto it = image_request_id_map_.find(request_id); | 206 auto it = image_request_id_map_.find(request_id); |
| 206 if (it == image_request_id_map_.end()) | 207 if (it == image_request_id_map_.end()) |
| 207 return; | 208 return; |
| 208 image_request = it->second; | 209 image_request = it->second; |
| 209 image_request_id_map_.erase(it); | 210 image_request_id_map_.erase(it); |
| 210 } | 211 } |
| 211 | 212 |
| 212 DCHECK(image_request->task_runner()->RunsTasksOnCurrentThread()); | 213 DCHECK(image_request->task_runner()->RunsTasksOnCurrentThread()); |
| 213 image_request->OnImageDecoded(decoded_image); | 214 image_request->OnImageDecoded(decoded_image); |
| 214 } | 215 } |
| 215 | 216 |
| 216 void ImageDecoder::OnDecodeImageFailed(int request_id) { | 217 void ImageDecoder::OnDecodeImageFailed(int request_id) { |
| 217 ImageRequest* image_request; | 218 ImageRequest* image_request; |
| 218 { | 219 { |
| 219 base::AutoLock lock(map_lock_); | 220 base::AutoLock lock(map_lock_); |
| 220 auto it = image_request_id_map_.find(request_id); | 221 auto it = image_request_id_map_.find(request_id); |
| 221 if (it == image_request_id_map_.end()) | 222 if (it == image_request_id_map_.end()) |
| 222 return; | 223 return; |
| 223 image_request = it->second; | 224 image_request = it->second; |
| 224 image_request_id_map_.erase(it); | 225 image_request_id_map_.erase(it); |
| 225 } | 226 } |
| 226 | 227 |
| 227 DCHECK(image_request->task_runner()->RunsTasksOnCurrentThread()); | 228 DCHECK(image_request->task_runner()->RunsTasksOnCurrentThread()); |
| 228 image_request->OnDecodeImageFailed(); | 229 image_request->OnDecodeImageFailed(); |
| 229 } | 230 } |
| OLD | NEW |