WIP: Implement 5xx Error handling.

chrome/browser/google_apis/gdata_wapi_operations.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_GDATA_WAPI_OPERATIONS_H_
 #define CHROME_BROWSER_GOOGLE_APIS_GDATA_WAPI_OPERATIONS_H_
 
 #include <string>
 #include <vector>
 
@@ skipping 495 matching lines @@
 
 // Struct for passing params needed for DriveServiceInterface::ResumeUpload()
 // calls.
 struct ResumeUploadParams {
   ResumeUploadParams(UploadMode upload_mode,
                      int64 start_position,
                      int64 end_position,
                      int64 content_length,
                      const std::string& content_type,
                      scoped_refptr<net::IOBuffer> buf,
+                     const int64 buffer_offset,
                      const GURL& upload_location,
                      const FilePath& drive_file_path);
   ~ResumeUploadParams();
 
   const UploadMode upload_mode;  // Mode of the upload.
   // Start of range of contents currently stored in |buf|.
   const int64 start_position;
   // End of range of contents currently stored in |buf|. This is exclusive.
   // For instance, if you are to upload the first 500 bytes of data,
   // |start_position| is 0 and |end_position| is 500.
   const int64 end_position;
   const int64 content_length;  // File content-Length.
   const std::string content_type;   // Content-Type of file.
   // Holds current content to be uploaded.
   const scoped_refptr<net::IOBuffer> buf;
+  const int64 buffer_offset;
   const GURL upload_location;   // Url of where to upload the file to.
   // Drive file path of the file seen in the UI. Not necessary for
   // resuming an upload, but used for adding an entry to OperationRegistry.
   // TODO(satorux): Remove the drive file path hack. crbug.com/163296
   const FilePath drive_file_path;
 };
 
 // Callback type for DocumentServiceInterface::ResumeUpload.
 typedef base::Callback<void(
     const ResumeUploadResponse& response,
@@ skipping 43 matching lines @@
   const ResumeUploadCallback callback_;
   const ResumeUploadParams params_;
   bool last_chunk_completed_;
 
   // 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<ResumeUploadOperation> weak_ptr_factory_;
   DISALLOW_COPY_AND_ASSIGN(ResumeUploadOperation);
 };
 
+class GetUploadStateOperation : public UrlFetchOperationBase {
+ public:
+  GetUploadStateOperation(
+      OperationRegistry* registry,
+      net::URLRequestContextGetter* url_request_context_getter,
+      const ResumeUploadCallback& callback,
+      UploadMode upload_mode,
+      const FilePath& drive_file_path,
+      const GURL& upload_url,
+      int64 content_length);
+  virtual ~GetUploadStateOperation();
+
+ protected:
+  virtual GURL GetURL() const OVERRIDE;
+  virtual net::URLFetcher::RequestType GetRequestType() const OVERRIDE;
+  virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
+  virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE;
+  virtual std::vector<std::string> GetExtraRequestHeaders() const OVERRIDE;
+
+ private:
+  // Called when ParseJson() is completed.
+  void OnDataParsed(GDataErrorCode code, scoped_ptr<base::Value> value);
+
+  const ResumeUploadCallback callback_;
+  const UploadMode upload_mode_;
+  const FilePath drive_file_path_;
+  const GURL upload_url_;
+  const int64 content_length_;
+
+  // 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<GetUploadStateOperation> weak_ptr_factory_;
+  DISALLOW_COPY_AND_ASSIGN(GetUploadStateOperation);
+};
+
 }  // namespace google_apis
 
 #endif  // CHROME_BROWSER_GOOGLE_APIS_GDATA_WAPI_OPERATIONS_H_