RAPPOR implementation

components/rappor/log_uploader.h

Index: components/rappor/log_uploader.h
diff --git a/components/rappor/log_uploader.h b/components/rappor/log_uploader.h
new file mode 100644
index 0000000000000000000000000000000000000000..4cfa3f292cdf764b2b0006ae6b5e318d3c4034c3
--- /dev/null
+++ b/components/rappor/log_uploader.h
@@ -0,0 +1,76 @@
+// Copyright (c) 2013 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 COMPONENTS_RAPPOR_LOG_UPLOADER_H_
+#define COMPONENTS_RAPPOR_LOG_UPLOADER_H_
+
+#include <queue>
+#include <string>
+
+#include "base/memory/weak_ptr.h"
+#include "base/time/time.h"
+#include "base/timer/timer.h"
+#include "net/url_request/url_fetcher.h"
+#include "net/url_request/url_fetcher_delegate.h"
+#include "net/url_request/url_request_context_getter.h"
+
+namespace rappor {
+
+// Handles uploading logs to an external server.
+class LogUploader : public net::URLFetcherDelegate {
+ public:
+  LogUploader(const char* server_url, const char* mime_type);

[Alexei Svitkine (slow), 2014/01/09 19:23:09]

Document params. Add explicit destructor, define in .cc file.

[Steven Holte, 2014/01/09 22:03:01]

Done.

+
+  void SetRequestContext(net::URLRequestContextGetter* request_context);

[Alexei Svitkine (slow), 2014/01/09 19:23:09]

Any reason this shouldn't be a ctor param?

[Steven Holte, 2014/01/09 22:03:01]

Done.

+
+  void QueueLog(const std::string& logData);

[Alexei Svitkine (slow), 2014/01/09 19:23:09]

log_data. Also, document these.

[Steven Holte, 2014/01/09 22:03:01]

Done.

+
+ private:
+  // Starts transmission of the next log.
+  void StartScheduledUpload();
+
+  // Schedules a future call to StartScheduledUpload if one isn't already
+  // pending.
+  void ScheduleNextUpload();
+
+  // Increases the upload interval each time it's called, to handle the case
+  // where the server is having issues.
+  void BackOffUploadInterval();
+
+  // Implementation of net::URLFetcherDelegate. Called after transmission
+  // completes (either successfully or with failure).
+  virtual void OnURLFetchComplete(const net::URLFetcher* source) OVERRIDE;
+
+  // Called when the upload is completed.
+  void UploadFinished(bool server_is_healthy, bool more_logs_remaining);
+
+  // The server URL to upload logs to.
+  const char* server_url_;
+
+  // The mime type to specify on uploaded logs.
+  const char* mime_type_;
+
+  net::URLRequestContextGetter* request_context_;
+
+  // The outstanding transmission appears as a URL Fetch operation.
+  scoped_ptr<net::URLFetcher> current_fetch_;
+
+  // The logs that still need to be uploaded.
+  std::queue<std::string> queued_logs_;
+
+  base::OneShotTimer<LogUploader> upload_timer_;
+
+  // Indicates that the last triggered upload hasn't resolved yet.
+  bool callback_pending_;
+
+  // The interval between being told an upload is done and starting the next
+  // upload.
+  base::TimeDelta upload_interval_;
+
+  DISALLOW_COPY_AND_ASSIGN(LogUploader);
+};
+
+}  // namespace rappor
+
+#endif  // COMPONENTS_RAPPOR_LOG_UPLOADER_H_