WIP: Implement 5xx Error handling.

chrome/browser/google_apis/drive_uploader.h

 // 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.
 
 #ifndef CHROME_BROWSER_GOOGLE_APIS_DRIVE_UPLOADER_H_
 #define CHROME_BROWSER_GOOGLE_APIS_DRIVE_UPLOADER_H_
 
 #include <string>
 
 #include "base/basictypes.h"
@@ skipping 98 matching lines @@
   // net::FileStream::Open completion callback. The result of the file open
   // operation is passed as |result|, and the size is stored in |file_size|.
   void OpenCompletionCallback(scoped_ptr<UploadFileInfo> upload_file_info,
                               int64 file_size);
 
   // DriveService callback for InitiateUpload.
   void OnUploadLocationReceived(scoped_ptr<UploadFileInfo> upload_file_info,
                                 GDataErrorCode code,
                                 const GURL& upload_location);
 
+  // Uploads the remaining data in the current chunk.
+  // The |restart_position| is the file's position to be restart for uploading.
+  void UploadCurrentChunk(
+    scoped_ptr<UploadFileInfo> upload_file_info, int64 restart_position);
+
   // Uploads the next chunk of data from the file.
   void UploadNextChunk(scoped_ptr<UploadFileInfo> upload_file_info);
 
   // net::FileStream::Read completion callback.
   void ReadCompletionCallback(scoped_ptr<UploadFileInfo> upload_file_info,
                               int bytes_to_read,
                               int bytes_read);
 
   // Calls DriveService's ResumeUpload with the current upload info.
   void ResumeUpload(scoped_ptr<UploadFileInfo> upload_file_info,
                     int bytes_to_send);
 
-  // DriveService callback for ResumeUpload.
+  // DriveService callback for ResumeUpload and GetUploadState.
   void OnResumeUploadResponseReceived(
       scoped_ptr<UploadFileInfo> upload_file_info,
       const ResumeUploadResponse& response,
       scoped_ptr<ResourceEntry> entry);
 
+  // Resumes the uploading interrupted by HTTP 5xx response.
+  // To avoid receiving the server errors repeatedly, this method waits
+  // for a while before actual resuming.
+  void ResumeInterruptedUpload(
+      scoped_ptr<UploadFileInfo> upload_file_info);
+
+  // This method processes the remaining tasks to resume the uploading
+  // after waiting followed by ResumeInterruptedUpload.
+  void ResumeInterruptedUploadAfterWaiting(
+      scoped_ptr<UploadFileInfo> upload_file_info);
+
   // Handle failed uploads.
   void UploadFailed(scoped_ptr<UploadFileInfo> upload_file_info,
                     DriveUploadError error);
 
   // Pointers to DriveServiceInterface object owned by DriveSystemService.
   // The lifetime of this object is guaranteed to exceed that of the
   // DriveUploader instance.
   DriveServiceInterface* drive_service_;
 
   // TaskRunner for opening, reading, and closing files.
   scoped_refptr<base::SequencedTaskRunner> blocking_task_runner_;
 
   // Note: This should remain the last member so it'll be destroyed and
   // invalidate its weak pointers before any other members are destroyed.
   base::WeakPtrFactory<DriveUploader> weak_ptr_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(DriveUploader);
 };
 
 }  // namespace google_apis
 
 #endif  // CHROME_BROWSER_GOOGLE_APIS_DRIVE_UPLOADER_H_