WIP: Browser image decoding using Mojo.

chrome/browser/extensions/webstore_install_helper.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/extensions/webstore_install_helper.h"
 
 #include <string>
 
 #include "base/bind.h"
 #include "base/values.h"
+#include "chrome/browser/image_decoder.h"
 #include "chrome/common/chrome_utility_messages.h"
 #include "chrome/common/extensions/chrome_utility_extensions_messages.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/utility_process_host.h"
+#include "content/public/common/service_registry.h"
 #include "net/base/load_flags.h"
 #include "net/url_request/url_fetcher.h"
 #include "net/url_request/url_request_context_getter.h"
 #include "net/url_request/url_request_status.h"
 
 using content::BrowserThread;
 using content::UtilityProcessHost;
 
 namespace {
 
@@ skipping 41 matching lines @@
     url_fetcher_->SetRequestContext(context_getter_);
     url_fetcher_->SetLoadFlags(net::LOAD_DO_NOT_SAVE_COOKIES |
                                net::LOAD_DO_NOT_SEND_COOKIES);
 
     url_fetcher_->Start();
     // We'll get called back in OnURLFetchComplete.
   }
 }
 
 void WebstoreInstallHelper::StartWorkOnIOThread() {
+  LOG(INFO) << "WebstoreInstallHelper::StartWorkOnIOThread";
   CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   utility_host_ = UtilityProcessHost::Create(
       this, base::MessageLoopProxy::current().get())->AsWeakPtr();
+  utility_host_->StartMojoMode();
   utility_host_->StartBatchMode();
+  content::ServiceRegistry* service_registry =
+      utility_host_->GetServiceRegistry();
+  service_registry->ConnectToRemoteService(&image_decoder_);
 
-  if (!icon_base64_data_.empty())
-    utility_host_->Send(
-        new ChromeUtilityMsg_DecodeImageBase64(icon_base64_data_));
+  if (!icon_base64_data_.empty()) {
+    LOG(INFO) << "DecodeImageBase64";
+    image_decoder_->DecodeImageBase64(
+        icon_base64_data_,
+        base::Bind(&WebstoreInstallHelper::OnDecodeImageDone, this));
+  }
 
   utility_host_->Send(new ChromeUtilityMsg_ParseJSON(manifest_));
 }
 
 void WebstoreInstallHelper::OnURLFetchComplete(
     const net::URLFetcher* source) {
   CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   CHECK(source == url_fetcher_.get());
   int response_code =
       source->GetStatus().is_success() ? source->GetResponseCode() : 0;
   if (!source->GetStatus().is_success() ||
       response_code / 100 == 4 || response_code / 100 == 5) {
     BrowserThread::PostTask(
         BrowserThread::IO,
         FROM_HERE,
-        base::Bind(&WebstoreInstallHelper::OnDecodeImageFailed, this));
+        base::Bind(&WebstoreInstallHelper::OnDecodeImageDone,
+                   this,
+                   false,
+                   nullptr));
   } else {
     std::string response_data;
     source->GetResponseAsString(&response_data);
     fetched_icon_data_.insert(fetched_icon_data_.begin(),
                               response_data.begin(),
                               response_data.end());
     BrowserThread::PostTask(
         BrowserThread::IO,
         FROM_HERE,
         base::Bind(&WebstoreInstallHelper::StartFetchedImageDecode, this));
   }
   url_fetcher_.reset();
 }
 
 void WebstoreInstallHelper::StartFetchedImageDecode() {
   CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   CHECK(utility_host_.get());
-  utility_host_->Send(new ChromeUtilityMsg_DecodeImage(fetched_icon_data_,
-                                                       false));
+  image_decoder_->DecodeImage(
+      mojo::Array<uint8_t>::From(fetched_icon_data_),
+      false,
+      false,
+      base::Bind(&WebstoreInstallHelper::OnDecodeImageDone, this));
 }
 
 
 bool WebstoreInstallHelper::OnMessageReceived(const IPC::Message& message) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(WebstoreInstallHelper, message)
-    IPC_MESSAGE_HANDLER(ChromeUtilityHostMsg_DecodeImage_Succeeded,
-                        OnDecodeImageSucceeded)
-    IPC_MESSAGE_HANDLER(ChromeUtilityHostMsg_DecodeImage_Failed,
-                        OnDecodeImageFailed)
     IPC_MESSAGE_HANDLER(ChromeUtilityHostMsg_ParseJSON_Succeeded,
                         OnJSONParseSucceeded)
     IPC_MESSAGE_HANDLER(ChromeUtilityHostMsg_ParseJSON_Failed,
                         OnJSONParseFailed)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
 
-
-void WebstoreInstallHelper::OnDecodeImageSucceeded(
-    const SkBitmap& decoded_image) {
+void WebstoreInstallHelper::OnDecodeImageDone(bool success,
+                                              content::ImageDataPtr image) {
+  LOG(INFO) << "WebstoreInstallHelper::OnDecodeImageDone: " << success;
   CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
-  icon_ = decoded_image;
+  if (success && image) {
+    icon_ = image.To<SkBitmap>();
+  } else {
+    error_ = kImageDecodeError;
+    parse_error_ = Delegate::ICON_ERROR;
+  }
   icon_decode_complete_ = true;
   ReportResultsIfComplete();
 }
 
-void WebstoreInstallHelper::OnDecodeImageFailed() {
-  CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
-  icon_decode_complete_ = true;
-  error_ = kImageDecodeError;
-  parse_error_ = Delegate::ICON_ERROR;
-  ReportResultsIfComplete();
-}
-
 void WebstoreInstallHelper::OnJSONParseSucceeded(
     const base::ListValue& wrapper) {
   CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   manifest_parse_complete_ = true;
   const base::Value* value = NULL;
   CHECK(wrapper.Get(0, &value));
   if (value->IsType(base::Value::TYPE_DICTIONARY)) {
     parsed_manifest_.reset(
         static_cast<const base::DictionaryValue*>(value)->DeepCopy());
   } else {
@@ skipping 14 matching lines @@
 void WebstoreInstallHelper::ReportResultsIfComplete() {
   CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 
   if (!icon_decode_complete_ || !manifest_parse_complete_)
     return;
 
   // The utility_host_ will take care of deleting itself after this call.
   if (utility_host_.get()) {
     utility_host_->EndBatchMode();
     utility_host_.reset();
+    image_decoder_.reset();
   }
 
   BrowserThread::PostTask(
       BrowserThread::UI,
       FROM_HERE,
       base::Bind(&WebstoreInstallHelper::ReportResultFromUIThread, this));
 }
 
 void WebstoreInstallHelper::ReportResultFromUIThread() {
   CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   if (error_.empty() && parsed_manifest_)
     delegate_->OnWebstoreParseSuccess(id_, icon_, parsed_manifest_.release());
   else
     delegate_->OnWebstoreParseFailure(id_, parse_error_, error_);
 }
 
 }  // namespace extensions