Basic UkmService implementation

components/ukm/ukm_service.h

Index: components/ukm/ukm_service.h
diff --git a/components/ukm/ukm_service.h b/components/ukm/ukm_service.h
new file mode 100644
index 0000000000000000000000000000000000000000..3fc86f0fc81e84189d088f56a78e965d4a95fbf8
--- /dev/null
+++ b/components/ukm/ukm_service.h
@@ -0,0 +1,101 @@
+// Copyright 2016 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_UKM_UKM_SERVICE_H_
+#define COMPONENTS_UKM_UKM_SERVICE_H_
+
+#include <stddef.h>
+
+#include "base/macros.h"
+#include "base/memory/weak_ptr.h"
+#include "base/threading/thread_checker.h"
+#include "components/metrics/metrics_reporting_scheduler.h"
+#include "components/metrics/persisted_logs.h"
+
+class PrefRegistrySimple;
+class PrefService;
+
+namespace metrics {
+class MetricsLogUploader;
+class MetricsServiceClient;
+}
+
+namespace ukm {
+
+// Manages the generation and uploading of UKM reports.
+class UkmService : public base::SupportsWeakPtr<UkmService> {
+ public:
+  // Constructs a UkmService.
+  // Calling code is responsible for ensuring that the lifetime of
+  // |pref_service| is longer than the lifetime of UkmService.
+  UkmService(
+    PrefService* pref_service,
+    metrics::MetricsServiceClient* client);
+  virtual ~UkmService();
+
+  // Initializes the UKM service.
+  void Initialize();
+
+  // Enable/disable transmission of accumulated logs.

[rkaplow, 2017/01/02 23:23:04]

it may be worth mentioning what would happen to logs that have already been
collected in the meanwhile, would they persist to the next enabling, etc.

[Steven Holte, 2017/01/03 21:16:04]

Done.

+  void EnableReporting();
+  void DisableReporting();
+
+  // Registers the names of all of the preferences used by UkmService in
+  // the provided PrefRegistry.
+  static void RegisterPrefs(PrefRegistrySimple* registry);
+
+ private:
+  // Start metrics client initialization.
+  void StartInitTask();
+
+  // Called when initialization tasks are complete.

[rkaplow, 2017/01/02 23:23:04]

Prefer if this described what this method actually does rather than when it
should be used, or at least in addition to

[Steven Holte, 2017/01/03 21:16:04]

Done.

+  void FinishedInitTask();
+
+  // Periodically called by scheduler_ to advance processing of logs.
+  void RotateLog();
+
+  // Constructs a new Report from available data and stores it in
+  // persisted_logs_.
+  void BuildAndStoreLog();
+
+  // Start an upload of the next log from persisted_logs_.
+  void StartScheduledUpload();
+
+  // Called by log_uploader_ when the an upload is completed.
+  void OnLogUploadComplete(int response_code);
+
+  // A weak pointer to the PrefService used to read and write preferences.
+  PrefService* pref_service_;
+
+  // The UKM client id stored in prefs.
+  uint64_t client_id_;
+
+  // Used to interact with the embedder. Weak pointer; must outlive |this|
+  // instance.
+  metrics::MetricsServiceClient* const client_;
+
+  // Logs that have not yet been sent.
+  metrics::PersistedLogs persisted_logs_;
+
+  // The scheduler for determining when uploads should happen.
+  std::unique_ptr<metrics::MetricsReportingScheduler> scheduler_;
+
+  base::ThreadChecker thread_checker_;
+
+  // Instance of the helper class for uploading logs.
+  std::unique_ptr<metrics::MetricsLogUploader> log_uploader_;
+
+  bool initialize_started_;
+  bool log_upload_in_progress_;
+
+  // Weak pointers factory used to post task on different threads. All weak
+  // pointers managed by this factory have the same lifetime as UkmService.
+  base::WeakPtrFactory<UkmService> self_ptr_factory_;
+
+  DISALLOW_COPY_AND_ASSIGN(UkmService);
+};
+
+}  // namespace ukm
+
+#endif  // COMPONENTS_UKM_UKM_SERVICE_H_