| OLD | NEW | 
|---|
|  | (Empty) | 
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. |  | 
| 2 // Use of this source code is governed by a BSD-style license that can be |  | 
| 3 // found in the LICENSE file. |  | 
| 4 |  | 
| 5 #ifndef CHROME_BROWSER_FEEDBACK_FEEDBACK_UPLOADER_H_ |  | 
| 6 #define CHROME_BROWSER_FEEDBACK_FEEDBACK_UPLOADER_H_ |  | 
| 7 |  | 
| 8 #include <queue> |  | 
| 9 #include <string> |  | 
| 10 |  | 
| 11 #include "base/basictypes.h" |  | 
| 12 #include "base/file_util.h" |  | 
| 13 #include "base/memory/scoped_ptr.h" |  | 
| 14 #include "base/memory/weak_ptr.h" |  | 
| 15 #include "base/time/time.h" |  | 
| 16 #include "base/timer/timer.h" |  | 
| 17 |  | 
| 18 namespace feedback { |  | 
| 19 |  | 
| 20 typedef base::Callback<void(const std::string&)> ReportDataCallback; |  | 
| 21 |  | 
| 22 class FeedbackReport; |  | 
| 23 |  | 
| 24 // FeedbackUploader is used to add a feedback report to the queue of reports |  | 
| 25 // being uploaded. In case uploading a report fails, it is written to disk and |  | 
| 26 // tried again when it's turn comes up next in the queue. |  | 
| 27 class FeedbackUploader : public base::SupportsWeakPtr<FeedbackUploader> { |  | 
| 28  public: |  | 
| 29   explicit FeedbackUploader(const base::FilePath& path, |  | 
| 30                             base::SequencedWorkerPool* pool); |  | 
| 31   virtual ~FeedbackUploader(); |  | 
| 32 |  | 
| 33   // Queues a report for uploading. |  | 
| 34   void QueueReport(const std::string& data); |  | 
| 35 |  | 
| 36   base::FilePath GetFeedbackReportsPath() { return report_path_; } |  | 
| 37 |  | 
| 38  protected: |  | 
| 39   friend class FeedbackUploaderTest; |  | 
| 40   struct ReportsUploadTimeComparator { |  | 
| 41     bool operator()(FeedbackReport* a, FeedbackReport* b) const; |  | 
| 42   }; |  | 
| 43 |  | 
| 44   // Dispatches the report to be uploaded. |  | 
| 45   virtual void DispatchReport(const std::string& data) = 0; |  | 
| 46 |  | 
| 47   // Update our timer for uploading the next report. |  | 
| 48   void UpdateUploadTimer(); |  | 
| 49 |  | 
| 50   // Requeue this report with a delay. |  | 
| 51   void RetryReport(const std::string& data); |  | 
| 52 |  | 
| 53   void QueueReportWithDelay(const std::string& data, base::TimeDelta delay); |  | 
| 54 |  | 
| 55   void setup_for_test(const ReportDataCallback& dispatch_callback, |  | 
| 56                       const base::TimeDelta& retry_delay); |  | 
| 57 |  | 
| 58   base::FilePath report_path_; |  | 
| 59   // Timer to upload the next report at. |  | 
| 60   base::OneShotTimer<FeedbackUploader> upload_timer_; |  | 
| 61   // Priority queue of reports prioritized by the time the report is supposed |  | 
| 62   // to be uploaded at. |  | 
| 63   std::priority_queue<scoped_refptr<FeedbackReport>, |  | 
| 64                       std::vector<scoped_refptr<FeedbackReport> >, |  | 
| 65                       ReportsUploadTimeComparator> reports_queue_; |  | 
| 66 |  | 
| 67   ReportDataCallback dispatch_callback_; |  | 
| 68   base::TimeDelta retry_delay_; |  | 
| 69   std::string url_; |  | 
| 70   base::SequencedWorkerPool* pool_; |  | 
| 71 |  | 
| 72   DISALLOW_COPY_AND_ASSIGN(FeedbackUploader); |  | 
| 73 }; |  | 
| 74 |  | 
| 75 }  // namespace feedback |  | 
| 76 |  | 
| 77 #endif  // CHROME_BROWSER_FEEDBACK_FEEDBACK_UPLOADER_H_ |  | 
| OLD | NEW | 
|---|