Added logic that will return the result of the first chunk of root feed and continue fetching the r…

chrome/browser/chromeos/gdata/gdata_operations.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/chromeos/gdata/gdata_operations.h"
 
 #include "base/bind.h"
 #include "base/json/json_reader.h"
 #include "base/string_number_conversions.h"
 #include "base/values.h"
@@ skipping 138 matching lines @@
 
 //============================ UrlFetchOperationBase ===========================
 
 UrlFetchOperationBase::UrlFetchOperationBase(GDataOperationRegistry* registry,
                                              Profile* profile)
     : GDataOperationRegistry::Operation(registry),
       profile_(profile),
       // MessageLoopProxy is used to run |callback| on the origin thread.
       relay_proxy_(base::MessageLoopProxy::current()),
       re_authenticate_count_(0),
-      save_temp_file_(false) {
+      save_temp_file_(false),
+      started_(false) {
 }
 
 UrlFetchOperationBase::UrlFetchOperationBase(
     GDataOperationRegistry* registry,
     GDataOperationRegistry::OperationType type,
     const FilePath& path,
     Profile* profile)
     : GDataOperationRegistry::Operation(registry, type, path),
       profile_(profile),
       relay_proxy_(base::MessageLoopProxy::current()),
@@ skipping 41 matching lines @@
   std::string upload_content_type;
   std::string upload_content;
   if (GetContentData(&upload_content_type, &upload_content)) {
     url_fetcher_->SetUploadData(upload_content_type, upload_content);
   }
 
   // Register to operation registry.
   NotifyStart();
 
   url_fetcher_->Start();
+  started_ = true;
 }
 
 void UrlFetchOperationBase::SetReAuthenticateCallback(
     const ReAuthenticateCallback& callback) {
   DCHECK(re_authenticate_callback_.is_null());
 
   re_authenticate_callback_ = callback;
 }
 
 URLFetcher::RequestType UrlFetchOperationBase::GetRequestType() const {
@@ skipping 31 matching lines @@
   }
 
   // Overridden by each specialization
   bool success = ProcessURLFetchResults(source);
   NotifyFinish(success ? GDataOperationRegistry::OPERATION_COMPLETED
                        : GDataOperationRegistry::OPERATION_FAILED);
 }
 
 void UrlFetchOperationBase::OnAuthFailed(GDataErrorCode code) {
   RunCallbackOnPrematureFailure(code);
+  // Check if this failed before we even started fetching. If so, register
+  // for start so we can properly unregister with finish.
+  if (!started_)
+    NotifyStart();
+
   NotifyFinish(GDataOperationRegistry::OPERATION_FAILED);
 }
 
 std::string UrlFetchOperationBase::GetResponseHeadersAsString(
     const URLFetcher* url_fetcher) {
   // net::HttpResponseHeaders::raw_headers(), as the name implies, stores
   // all headers in their raw format, i.e each header is null-terminated.
   // So logging raw_headers() only shows the first header, which is probably
   // the status line.  GetNormalizedHeaders, on the other hand, will show all
   // the headers, one per line, which is probably what we want.
@@ skipping 657 matching lines @@
 }
 
 void ResumeUploadOperation::OnURLFetchUploadProgress(
     const content::URLFetcher* source, int64 current, int64 total) {
   // Adjust the progress values according to the range currently uploaded.
   NotifyProgress(params_.start_range + current, params_.content_length);
 }
 
 
 }  // namespace gdata