Implement retry flow on DriveUploader.

chrome/browser/google_apis/gdata_wapi_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/google_apis/gdata_wapi_operations.h"
 
 #include "base/string_number_conversions.h"
 #include "base/stringprintf.h"
 #include "base/values.h"
 #include "chrome/browser/google_apis/gdata_wapi_parser.h"
@@ skipping 70 matching lines @@
 InitiateUploadParams::~InitiateUploadParams() {
 }
 
 ResumeUploadParams::ResumeUploadParams(
     UploadMode upload_mode,
     int64 start_position,
     int64 end_position,
     int64 content_length,
     const std::string& content_type,
     scoped_refptr<net::IOBuffer> buf,
+    int64 buf_offset,
     const GURL& upload_location,
     const FilePath& drive_file_path) : upload_mode(upload_mode),
                                     start_position(start_position),
                                     end_position(end_position),
                                     content_length(content_length),
                                     content_type(content_type),
                                     buf(buf),
+                                    buf_offset(buf_offset),
                                     upload_location(upload_location),
                                     drive_file_path(drive_file_path) {
 }
 
 ResumeUploadParams::~ResumeUploadParams() {
 }
 
 //============================ GetResourceListOperation ========================
 
 GetResourceListOperation::GetResourceListOperation(
@@ skipping 656 matching lines @@
       base::Int64ToString(params_.start_position) + "-" +
       base::Int64ToString(params_.end_position - 1) + "/" +
       (params_.content_length == -1 ? "*" :
           base::Int64ToString(params_.content_length)));
   return headers;
 }
 
 bool ResumeUploadOperation::GetContentData(std::string* upload_content_type,
                                            std::string* upload_content) {
   *upload_content_type = params_.content_type;
-  *upload_content = std::string(params_.buf->data(),
+  *upload_content = std::string(params_.buf->data() + params_.buf_offset,
                                 params_.end_position - params_.start_position);
   return true;
 }
 
 void ResumeUploadOperation::OnURLFetchUploadProgress(
     const URLFetcher* source, int64 current, int64 total) {
   // Adjust the progress values according to the range currently uploaded.
   NotifyProgress(params_.start_position + current, params_.content_length);
 }
 
@@ skipping 28 matching lines @@
   DCHECK_GE(content_length_, -1);
 
   std::vector<std::string> headers;
   headers.push_back(
       std::string(kUploadContentRange) + "*/" +
       (content_length_ == -1 ? "*" : base::Int64ToString(content_length_)));
   return headers;
 }
 
 }  // namespace google_apis