gdrive: Get JSON feeds parsing off the UI thread.

BUG=128378
TEST=unit_tests:GData* and browser_tests:GData* passes.

using TBR for gyp changes
TBR=thakis@chromium.org


Committed: http://src.chromium.org/viewvc/chrome?view=rev&revision=148990

Review URL: https://chromiumcodereview.appspot.com/10808027

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@149140 0039d316-1c4b-4281-b951-d872f2087c98

chrome/browser/chromeos/gdata/gdata_documents_service_browsertest.cc

@@ -15,6 +15,8 @@
 #include "net/test/test_server.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
+namespace gdata {
+
 namespace {
 
 class GDataTest : public InProcessBrowserTest {
@@ -144,3 +146,5 @@ IN_PROC_BROWSER_TEST_F(GDataTest, GetDocumentsFailure) {
   EXPECT_EQ(gdata::GDATA_PARSE_ERROR, result);
   EXPECT_FALSE(result_data);
 }
+
+}  // namespace gdata

chrome/browser/chromeos/gdata/gdata_operations.cc

@@ -274,8 +274,7 @@ void DownloadFileOperation::OnURLFetchDownloadData(
     get_download_data_callback_.Run(HTTP_SUCCESS, download_data.Pass());
 }
 
-bool DownloadFileOperation::ProcessURLFetchResults(
-    const URLFetcher* source) {
+void DownloadFileOperation::ProcessURLFetchResults(const URLFetcher* source) {
   GDataErrorCode code = GetErrorCode(source);
 
   // Take over the ownership of the the downloaded temp file.
@@ -288,7 +287,7 @@ bool DownloadFileOperation::ProcessURLFetchResults(
 
   if (!download_action_callback_.is_null())
     download_action_callback_.Run(code, document_url_, temp_file);
-  return code == HTTP_SUCCESS;
+  OnProcessURLFetchResultsComplete(code == HTTP_SUCCESS);
 }
 
 void DownloadFileOperation::RunCallbackOnPrematureFailure(GDataErrorCode code) {
@@ -490,11 +489,10 @@ AuthorizeAppsOperation::GetExtraRequestHeaders() const {
   return headers;
 }
 
-bool AuthorizeAppsOperation::ProcessURLFetchResults(
-    const URLFetcher* source) {
+void AuthorizeAppsOperation::ProcessURLFetchResults(const URLFetcher* source) {
   std::string data;
   source->GetResponseAsString(&data);
-  return GetDataOperation::ProcessURLFetchResults(source);
+  GetDataOperation::ProcessURLFetchResults(source);
 }
 
 bool AuthorizeAppsOperation::GetContentData(std::string* upload_content_type,
@@ -515,7 +513,9 @@ bool AuthorizeAppsOperation::GetContentData(std::string* upload_content_type,
   return true;
 }
 
-base::Value* AuthorizeAppsOperation::ParseResponse(const std::string& data) {
+void AuthorizeAppsOperation::ParseResponse(
+    GDataErrorCode fetch_error_code,
+    const std::string& data) {
   // Parse entry XML.
   XmlReader xml_reader;
   scoped_ptr<DocumentEntry> entry;
@@ -544,7 +544,9 @@ base::Value* AuthorizeAppsOperation::ParseResponse(const std::string& data) {
     }
   }
 
-  return link_list.release();
+  RunCallback(fetch_error_code, link_list.PassAs<base::Value>());
+  const bool success = true;
+  OnProcessURLFetchResultsComplete(success);
 }
 
 GURL AuthorizeAppsOperation::GetURL() const {
@@ -657,7 +659,7 @@ GURL InitiateUploadOperation::GetURL() const {
   return initiate_upload_url_;
 }
 
-bool InitiateUploadOperation::ProcessURLFetchResults(
+void InitiateUploadOperation::ProcessURLFetchResults(
     const URLFetcher* source) {
   GDataErrorCode code = GetErrorCode(source);
 
@@ -674,7 +676,7 @@ bool InitiateUploadOperation::ProcessURLFetchResults(
 
   if (!callback_.is_null())
     callback_.Run(code, GURL(upload_location));
-  return code == HTTP_SUCCESS;
+  OnProcessURLFetchResultsComplete(code == HTTP_SUCCESS);
 }
 
 void InitiateUploadOperation::NotifySuccessToOperationRegistry() {
@@ -761,8 +763,7 @@ GURL ResumeUploadOperation::GetURL() const {
   return params_.upload_location;
 }
 
-bool ResumeUploadOperation::ProcessURLFetchResults(
-    const URLFetcher* source) {
+void ResumeUploadOperation::ProcessURLFetchResults(const URLFetcher* source) {
   GDataErrorCode code = GetErrorCode(source);
   net::HttpResponseHeaders* hdrs = source->GetResponseHeaders();
   int64 start_range_received = -1;
@@ -823,7 +824,8 @@ bool ResumeUploadOperation::ProcessURLFetchResults(
     last_chunk_completed_ = true;
   }
 
-  return last_chunk_completed_ || code == HTTP_RESUME_INCOMPLETE;
+  OnProcessURLFetchResultsComplete(
+      last_chunk_completed_ || code == HTTP_RESUME_INCOMPLETE);
 }
 
 void ResumeUploadOperation::NotifyStartToOperationRegistry() {
@@ -931,13 +933,13 @@ GURL GetContactPhotoOperation::GetURL() const {
   return photo_url_;
 }
 
-bool GetContactPhotoOperation::ProcessURLFetchResults(
+void GetContactPhotoOperation::ProcessURLFetchResults(
     const net::URLFetcher* source) {
   GDataErrorCode code = static_cast<GDataErrorCode>(source->GetResponseCode());
   scoped_ptr<std::string> data(new std::string);
   source->GetResponseAsString(data.get());
   callback_.Run(code, data.Pass());
-  return code == HTTP_SUCCESS;
+  OnProcessURLFetchResultsComplete(code == HTTP_SUCCESS);
 }
 
 void GetContactPhotoOperation::RunCallbackOnPrematureFailure(

chrome/browser/chromeos/gdata/gdata_operations.h

@@ -100,7 +100,7 @@ class DownloadFileOperation : public UrlFetchOperationBase {
  protected:
   // Overridden from UrlFetchOperationBase.
   virtual GURL GetURL() const OVERRIDE;
-  virtual bool ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
+  virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
   virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE;
 
   // Overridden from net::URLFetcherDelegate.
@@ -249,11 +249,12 @@ class AuthorizeAppsOperation : public GetDataOperation {
 
   // Overridden from GetDataOperation.
   virtual GURL GetURL() const OVERRIDE;
-  virtual bool ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
+  virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
 
   // Must override GetDataOperation's ParseResponse because the response is XML
   // not JSON.
-  virtual base::Value* ParseResponse(const std::string& data) OVERRIDE;
+  virtual void ParseResponse(GDataErrorCode fetch_error_code,
+                             const std::string& data) OVERRIDE;
  private:
   std::string app_id_;
   GURL document_url_;
@@ -328,7 +329,7 @@ class InitiateUploadOperation : public UrlFetchOperationBase {
  protected:
   // Overridden from UrlFetchOperationBase.
   virtual GURL GetURL() const OVERRIDE;
-  virtual bool ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
+  virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
   virtual void NotifySuccessToOperationRegistry() OVERRIDE;
   virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE;
 
@@ -360,7 +361,7 @@ class ResumeUploadOperation : public UrlFetchOperationBase {
  protected:
   // Overridden from UrlFetchOperationBase.
   virtual GURL GetURL() const OVERRIDE;
-  virtual bool ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
+  virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
   virtual void NotifyStartToOperationRegistry() OVERRIDE;
   virtual void NotifySuccessToOperationRegistry() OVERRIDE;
   virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE;
@@ -427,7 +428,7 @@ class GetContactPhotoOperation : public UrlFetchOperationBase {
  protected:
   // Overridden from UrlFetchOperationBase.
   virtual GURL GetURL() const OVERRIDE;
-  virtual bool ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
+  virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
   virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE;
 
  private:

chrome/browser/chromeos/gdata/gdata_operations_unittest.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 "base/memory/scoped_ptr.h"
+#include "base/message_loop.h"
+#include "base/values.h"
+#include "chrome/browser/chromeos/gdata/gdata_operations.h"
+#include "chrome/browser/chromeos/gdata/gdata_operation_runner.h"
+#include "chrome/browser/chromeos/gdata/gdata_test_util.h"
+#include "chrome/test/base/testing_profile.h"
+#include "content/public/browser/browser_thread.h"
+#include "content/public/test/test_browser_thread.h"
+#include "testing/gtest/include/gtest/gtest.h"
+
+namespace gdata {
+
+namespace {
+
+class JsonParseTestGetDataOperation : public GetDataOperation {
+ public:
+  JsonParseTestGetDataOperation(GDataOperationRegistry* registry,
+                                Profile* profile,
+                                const GetDataCallback& callback)
+      : GetDataOperation(registry, profile, callback) {
+  }
+
+  virtual ~JsonParseTestGetDataOperation() {
+  }
+
+  void NotifyStart() {
+    NotifyStartToOperationRegistry();
+  }
+
+  void NotifySuccess() {
+    NotifySuccessToOperationRegistry();
+  }
+
+  void NotifyFailure() {
+    NotifyFinish(GDataOperationRegistry::OPERATION_FAILED);
+  }
+
+ protected:
+  // GetDataOperation overrides:
+  virtual GURL GetURL() const OVERRIDE {
+    // This method is never called because this test does not fetch json from
+    // network.
+    NOTREACHED();
+    return GURL();
+  }
+};
+
+void GetDataOperationParseJsonCallback(GDataErrorCode* error_out,
+                                       scoped_ptr<base::Value>* value_out,
+                                       GDataErrorCode error_in,
+                                       scoped_ptr<base::Value> value_in) {
+  value_out->swap(value_in);
+  *error_out = error_in;
+}
+
+}  // namespace
+
+class GDataOperationsTest : public testing::Test {
+ protected:
+  GDataOperationsTest()
+      : ui_thread_(content::BrowserThread::UI, &message_loop_) {
+  }
+
+  virtual void SetUp() OVERRIDE {
+    profile_.reset(new TestingProfile);
+    runner_.reset(new GDataOperationRunner(profile_.get()));
+    runner_->Initialize();
+  }
+
+ protected:
+  MessageLoopForUI message_loop_;
+  content::TestBrowserThread ui_thread_;
+  scoped_ptr<TestingProfile> profile_;
+  scoped_ptr<GDataOperationRunner> runner_;
+};
+
+TEST_F(GDataOperationsTest, GetDataOperationParseJson) {
+  scoped_ptr<base::Value> value;
+  GDataErrorCode error;
+  gdata::GetDataCallback cb = base::Bind(&GetDataOperationParseJsonCallback,
+                                         &error,
+                                         &value);
+  JsonParseTestGetDataOperation* getData =
+      new JsonParseTestGetDataOperation(runner_->operation_registry(),
+                                        profile_.get(),
+                                        cb);
+  getData->NotifyStart();
+
+  // Parses a valid json string.
+  {
+    std::string valid_json_str =
+        "{"
+        "  \"test\": {"
+        "    \"foo\": true,"
+        "    \"bar\": 3.14,"
+        "    \"baz\": \"bat\","
+        "    \"moo\": \"cow\""
+        "  },"
+        "  \"list\": ["
+        "    \"a\","
+        "    \"b\""
+        "  ]"
+        "}";
+
+    getData->ParseResponse(HTTP_SUCCESS, valid_json_str);
+    test_util::RunBlockingPoolTask();
+
+    EXPECT_EQ(HTTP_SUCCESS, error);
+    ASSERT_TRUE(value.get());
+
+    DictionaryValue* root_dict = NULL;
+    ASSERT_TRUE(value->GetAsDictionary(&root_dict));
+
+    DictionaryValue* dict = NULL;
+    ListValue* list = NULL;
+    ASSERT_TRUE(root_dict->GetDictionary("test", &dict));
+    ASSERT_TRUE(root_dict->GetList("list", &list));
+
+    Value* dict_literals[2] = {0};
+    Value* dict_strings[2] = {0};
+    Value* list_values[2] = {0};
+    EXPECT_TRUE(dict->Get("foo", &dict_literals[0]));
+    EXPECT_TRUE(dict->Get("bar", &dict_literals[1]));
+    EXPECT_TRUE(dict->Get("baz", &dict_strings[0]));
+    EXPECT_TRUE(dict->Get("moo", &dict_strings[1]));
+    ASSERT_EQ(2u, list->GetSize());
+    EXPECT_TRUE(list->Get(0, &list_values[0]));
+    EXPECT_TRUE(list->Get(1, &list_values[1]));
+
+    bool b = false;
+    double d = 0;
+    std::string s;
+    EXPECT_TRUE(dict_literals[0]->GetAsBoolean(&b));
+    EXPECT_TRUE(b);
+    EXPECT_TRUE(dict_literals[1]->GetAsDouble(&d));
+    EXPECT_EQ(3.14, d);
+    EXPECT_TRUE(dict_strings[0]->GetAsString(&s));
+    EXPECT_EQ("bat", s);
+    EXPECT_TRUE(dict_strings[1]->GetAsString(&s));
+    EXPECT_EQ("cow", s);
+    EXPECT_TRUE(list_values[0]->GetAsString(&s));
+    EXPECT_EQ("a", s);
+    EXPECT_TRUE(list_values[1]->GetAsString(&s));
+    EXPECT_EQ("b", s);
+  }
+}
+
+TEST_F(GDataOperationsTest, GetDataOperationParseInvalidJson) {
+  scoped_ptr<base::Value> value;
+  GDataErrorCode error;
+  gdata::GetDataCallback cb = base::Bind(&GetDataOperationParseJsonCallback,
+                                         &error,
+                                         &value);
+  JsonParseTestGetDataOperation* getData =
+      new JsonParseTestGetDataOperation(runner_->operation_registry(),
+                                        profile_.get(),
+                                        cb);
+  getData->NotifyStart();
+
+  // Parses an invalid json string.
+  {
+    std::string invalid_json_str =
+        "/* hogehoge *"
+        "  \"test\": {"
+        "    \"moo\": \"cow"
+        "  "
+        "  \"list\": ["
+        "    \"foo\","
+        "    \"bar\""
+        "  ]";
+
+    getData->ParseResponse(HTTP_SUCCESS, invalid_json_str);
+    test_util::RunBlockingPoolTask();
+
+    EXPECT_EQ(GDATA_PARSE_ERROR, error);
+    ASSERT_TRUE(value.get() == NULL);
+  }
+}
+
+} // namespace gdata

chrome/browser/chromeos/gdata/operations_base.cc

@@ -52,6 +52,28 @@ const char kContactsScope[] = "https://www.google.com/m8/feeds/";
 // OAuth scope for Drive API.
 const char kDriveAppsScope[] = "https://www.googleapis.com/auth/drive.apps";
 
+// Parse JSON string to base::Value object.
+void ParseJsonOnBlockingPool(const std::string& data,
+                             scoped_ptr<base::Value>* value) {
+  DCHECK(!BrowserThread::CurrentlyOn(BrowserThread::UI));
+
+  int error_code = -1;
+  std::string error_message;
+  value->reset(base::JSONReader::ReadAndReturnError(data,
+                                                    base::JSON_PARSE_RFC,
+                                                    &error_code,
+                                                    &error_message));
+
+  if (!value->get()) {
+    LOG(ERROR) << "Error while parsing entry response: "
+               << error_message
+               << ", code: "
+               << error_code
+               << ", data:\n"
+               << data;
+  }
+}
+
 }  // namespace
 
 namespace gdata {
@@ -240,6 +262,13 @@ GDataErrorCode UrlFetchOperationBase::GetErrorCode(
   return code;
 }
 
+void UrlFetchOperationBase::OnProcessURLFetchResultsComplete(bool result) {
+  if (result)
+    NotifySuccessToOperationRegistry();
+  else
+    NotifyFinish(GDataOperationRegistry::OPERATION_FAILED);
+}
+
 void UrlFetchOperationBase::OnURLFetchComplete(const URLFetcher* source) {
   GDataErrorCode code = GetErrorCode(source);
   DVLOG(1) << "Response headers:\n" << GetResponseHeadersAsString(source);
@@ -256,11 +285,7 @@ void UrlFetchOperationBase::OnURLFetchComplete(const URLFetcher* source) {
   }
 
   // Overridden by each specialization
-  bool success = ProcessURLFetchResults(source);
-  if (success)
-    NotifySuccessToOperationRegistry();
-  else
-    NotifyFinish(GDataOperationRegistry::OPERATION_FAILED);
+  ProcessURLFetchResults(source);
 }
 
 void UrlFetchOperationBase::NotifySuccessToOperationRegistry() {
@@ -320,13 +345,13 @@ EntryActionOperation::EntryActionOperation(GDataOperationRegistry* registry,
 
 EntryActionOperation::~EntryActionOperation() {}
 
-bool EntryActionOperation::ProcessURLFetchResults(
-    const URLFetcher* source) {
+void EntryActionOperation::ProcessURLFetchResults(const URLFetcher* source) {
   if (!callback_.is_null()) {
     GDataErrorCode code = GetErrorCode(source);
     callback_.Run(code, document_url_);
   }
-  return true;
+  const bool success = true;
+  OnProcessURLFetchResultsComplete(success);
 }
 
 void EntryActionOperation::RunCallbackOnPrematureFailure(GDataErrorCode code) {
@@ -339,57 +364,86 @@ void EntryActionOperation::RunCallbackOnPrematureFailure(GDataErrorCode code) {
 GetDataOperation::GetDataOperation(GDataOperationRegistry* registry,
                                    Profile* profile,
                                    const GetDataCallback& callback)
-    : UrlFetchOperationBase(registry, profile), callback_(callback) {
+    : UrlFetchOperationBase(registry, profile),
+      callback_(callback),
+      weak_ptr_factory_(this) {
 }
 
 GetDataOperation::~GetDataOperation() {}
 
-bool GetDataOperation::ProcessURLFetchResults(const URLFetcher* source) {
+void GetDataOperation::ProcessURLFetchResults(const URLFetcher* source) {
   std::string data;
   source->GetResponseAsString(&data);
   scoped_ptr<base::Value> root_value;
-  GDataErrorCode code = GetErrorCode(source);
+  GDataErrorCode fetch_error_code = GetErrorCode(source);
 
-  switch (code) {
+  switch (fetch_error_code) {
     case HTTP_SUCCESS:
-    case HTTP_CREATED: {
-      root_value.reset(ParseResponse(data));
-      if (!root_value.get())
-        code = GDATA_PARSE_ERROR;
-
+    case HTTP_CREATED:
+      ParseResponse(fetch_error_code, data);
       break;
-    }
     default:
+      RunCallback(fetch_error_code, scoped_ptr<base::Value>());
+      const bool success = false;
+      OnProcessURLFetchResultsComplete(success);
       break;
   }
-
-  if (!callback_.is_null())
-    callback_.Run(code, root_value.Pass());
-  return root_value.get() != NULL;
 }
 
-void GetDataOperation::RunCallbackOnPrematureFailure(GDataErrorCode code) {
+void GetDataOperation::RunCallbackOnPrematureFailure(
+    GDataErrorCode fetch_error_code) {
   if (!callback_.is_null()) {
     scoped_ptr<base::Value> root_value;
-    callback_.Run(code, root_value.Pass());
+    callback_.Run(fetch_error_code, root_value.Pass());
   }
 }
 
-base::Value* GetDataOperation::ParseResponse(const std::string& data) {
-  int error_code = -1;
-  std::string error_message;
-  scoped_ptr<base::Value> root_value(base::JSONReader::ReadAndReturnError(
-      data, base::JSON_PARSE_RFC, &error_code, &error_message));
-  if (!root_value.get()) {
-    LOG(ERROR) << "Error while parsing entry response: "
-               << error_message
-               << ", code: "
-               << error_code
-               << ", data:\n"
-               << data;
-    return NULL;
+void GetDataOperation::ParseResponse(GDataErrorCode fetch_error_code,
+                                     const std::string& data) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+
+  // Uses this hack to avoid deep-copy of json object because json might be so
+  // big. This pointer of scped_ptr is to ensure a deletion of the parsed json
+  // value object.
+  scoped_ptr<base::Value>* parsed_value = new scoped_ptr<base::Value>();
+
+  BrowserThread::PostBlockingPoolTaskAndReply(
+      FROM_HERE,
+      base::Bind(&ParseJsonOnBlockingPool,
+                 data,
+                 parsed_value),
+      base::Bind(&GetDataOperation::OnDataParsed,
+                 weak_ptr_factory_.GetWeakPtr(),
+                 fetch_error_code,
+                 base::Owned(parsed_value)));
+}
+
+void GetDataOperation::OnDataParsed(
+    gdata::GDataErrorCode fetch_error_code,
+    scoped_ptr<base::Value>* value) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+
+  bool success = true;
+  if (!value->get()) {
+    fetch_error_code = gdata::GDATA_PARSE_ERROR;
+    success = false;
   }
-  return root_value.release();
+
+  // The ownership of the parsed json object is transfered to RunCallBack(),
+  // keeping the ownership of the |value| here.
+  RunCallback(fetch_error_code, value->Pass());
+
+  DCHECK(!value->get());
+
+  OnProcessURLFetchResultsComplete(success);
+  // |value| will be deleted after return beause it is base::Owned()'d.
+}
+
+void GetDataOperation::RunCallback(GDataErrorCode fetch_error_code,
+                                   scoped_ptr<base::Value> value) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  if (!callback_.is_null())
+    callback_.Run(fetch_error_code, value.Pass());
 }
 
 }  // namespace gdata

chrome/browser/chromeos/gdata/operations_base.h

@@ -112,7 +112,7 @@ class UrlFetchOperationBase : public GDataOperationInterface,
 
   // Invoked by OnURLFetchComplete when the operation completes without an
   // authentication error. Must be implemented by a derived class.
-  virtual bool ProcessURLFetchResults(const net::URLFetcher* source) = 0;
+  virtual void ProcessURLFetchResults(const net::URLFetcher* source) = 0;
 
   // Invoked when it needs to notify the status. Chunked operations that
   // constructs a logically single operation from multiple physical operations
@@ -133,6 +133,9 @@ class UrlFetchOperationBase : public GDataOperationInterface,
   // Overridden from GDataOperationInterface.
   virtual void OnAuthFailed(GDataErrorCode code) OVERRIDE;
 
+  // Invoked when ProcessURLFetchResults() is completed.
+  void OnProcessURLFetchResultsComplete(bool result);
+
   // Returns an appropriate GDataErrorCode based on the HTTP response code and
   // the status of the URLFetcher.
   GDataErrorCode GetErrorCode(const net::URLFetcher* source) const;
@@ -163,7 +166,7 @@ class EntryActionOperation : public UrlFetchOperationBase {
 
  protected:
   // Overridden from UrlFetchOperationBase.
-  virtual bool ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
+  virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
   virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE;
 
   const GURL& document_url() const { return document_url_; }
@@ -186,15 +189,24 @@ class GetDataOperation : public UrlFetchOperationBase {
   virtual ~GetDataOperation();
 
   // Parse GData JSON response.
-  virtual base::Value* ParseResponse(const std::string& data);
+  virtual void ParseResponse(GDataErrorCode fetch_error_code,
+                             const std::string& data);
 
  protected:
   // Overridden from UrlFetchOperationBase.
-  virtual bool ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
-  virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE;
+  virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
+  virtual void RunCallbackOnPrematureFailure(
+      GDataErrorCode fetch_error_code) OVERRIDE;
+  void RunCallback(GDataErrorCode fetch_error_code,
+                   scoped_ptr<base::Value> value);
 
  private:
+  // Called when ParseJsonOnBlockingPool() is completed.
+  void OnDataParsed(gdata::GDataErrorCode fetch_error_code,
+                    scoped_ptr<base::Value>* value);
+
   GetDataCallback callback_;
+  base::WeakPtrFactory<GetDataOperation> weak_ptr_factory_;
   DISALLOW_COPY_AND_ASSIGN(GetDataOperation);
 };
 

chrome/chrome_tests.gypi

@@ -1106,6 +1106,7 @@
         'browser/chromeos/gdata/gdata_file_system_unittest.cc',
         'browser/chromeos/gdata/gdata_files_unittest.cc',
         'browser/chromeos/gdata/gdata_operation_registry_unittest.cc',
+        'browser/chromeos/gdata/gdata_operations_unittest.cc',
         'browser/chromeos/gdata/gdata_sync_client_unittest.cc',
         'browser/chromeos/gdata/gdata_test_util.cc',
         'browser/chromeos/gdata/gdata_test_util.h',