Upstream oodles of Chrome for Android code into Chromium.

chrome/browser/android/history_report/usage_reports_buffer_service.cc

Index: chrome/browser/android/history_report/usage_reports_buffer_service.cc
diff --git a/chrome/browser/android/history_report/usage_reports_buffer_service.cc b/chrome/browser/android/history_report/usage_reports_buffer_service.cc
new file mode 100644
index 0000000000000000000000000000000000000000..620e2626ef0e7cacedc15b828987395f76926a7f
--- /dev/null
+++ b/chrome/browser/android/history_report/usage_reports_buffer_service.cc
@@ -0,0 +1,166 @@
+// Copyright 2015 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.
+
+#include "chrome/browser/android/history_report/usage_reports_buffer_service.h"
+
+#include "base/bind.h"
+#include "base/files/file_path.h"
+#include "base/synchronization/waitable_event.h"
+#include "chrome/browser/android/history_report/usage_reports_buffer_backend.h"
+#include "chrome/browser/android/proto/delta_file.pb.h"
+#include "content/public/browser/browser_thread.h"
+
+
+namespace {
+
+void DoInit(history_report::UsageReportsBufferBackend* backend) {
+  backend->Init();
+}
+
+void DoAddVisit(history_report::UsageReportsBufferBackend* backend,
+                const std::string id,
+                int64 timestamp_ms,
+                bool typed_visit) {
+  backend->AddVisit(id, timestamp_ms, typed_visit);
+}
+
+void DoRemove(history_report::UsageReportsBufferBackend* backend,
+              const std::vector<std::string>* reports,
+              base::WaitableEvent* finished) {
+  backend->Remove(*reports);
+  finished->Signal();
+}
+
+void DoGetUsageReportsBatch(
+    history_report::UsageReportsBufferBackend* backend,
+    int32 batch_size,
+    base::WaitableEvent* finished,
+    scoped_ptr<std::vector<history_report::UsageReport> >* result) {
+  *result = backend->GetUsageReportsBatch(batch_size).Pass();
+  finished->Signal();
+}
+
+void DoClear(
+    history_report::UsageReportsBufferBackend* backend,
+    base::WaitableEvent* finished) {
+  backend->Clear();
+  finished->Signal();
+}
+
+void DoDump(
+    history_report::UsageReportsBufferBackend* backend,
+    base::WaitableEvent* finished,
+    std::string* result) {
+  result->append(backend->Dump());
+  finished->Signal();
+}
+
+}  // namespace
+
+namespace history_report {
+
+using content::BrowserThread;
+
+UsageReportsBufferService::UsageReportsBufferService(const base::FilePath& dir)
+    : worker_pool_token_(BrowserThread::GetBlockingPool()->GetSequenceToken()),
+      backend_(new UsageReportsBufferBackend(dir)) {
+}
+
+UsageReportsBufferService::~UsageReportsBufferService() {}
+
+void UsageReportsBufferService::Init() {
+  base::SequencedWorkerPool* pool = BrowserThread::GetBlockingPool();
+  pool->PostSequencedWorkerTaskWithShutdownBehavior(
+      worker_pool_token_,
+      FROM_HERE,
+      base::Bind(&DoInit, base::Unretained(backend_.get())),
+      base::SequencedWorkerPool::SKIP_ON_SHUTDOWN);
+}
+
+void UsageReportsBufferService::AddVisit(const std::string& id,
+    int64 timestamp_ms,
+    bool typed_visit) {
+  base::SequencedWorkerPool* pool = BrowserThread::GetBlockingPool();
+  pool->PostSequencedWorkerTaskWithShutdownBehavior(
+      worker_pool_token_,
+      FROM_HERE,
+      base::Bind(&DoAddVisit,
+                 base::Unretained(backend_.get()),
+                 id,
+                 timestamp_ms,
+                 typed_visit),
+      base::SequencedWorkerPool::BLOCK_SHUTDOWN);
+}
+
+scoped_ptr<std::vector<UsageReport> >
+UsageReportsBufferService::GetUsageReportsBatch(int32 batch_size) {
+  scoped_ptr<std::vector<UsageReport> > result;
+  base::WaitableEvent finished(false, false);
+  base::SequencedWorkerPool* pool = BrowserThread::GetBlockingPool();
+  // It's ok to pass unretained pointers here because this is a synchronous
+  // call.
+  pool->PostSequencedWorkerTaskWithShutdownBehavior(
+      worker_pool_token_,
+      FROM_HERE,
+      base::Bind(&DoGetUsageReportsBatch,
+                 base::Unretained(backend_.get()),
+                 batch_size,
+                 base::Unretained(&finished),
+                 base::Unretained(&result)),
+      base::SequencedWorkerPool::SKIP_ON_SHUTDOWN);
+  finished.Wait();
+  return result.Pass();
+}
+
+void UsageReportsBufferService::Remove(
+    const std::vector<std::string>& report_ids) {
+  base::WaitableEvent finished(false, false);
+  base::SequencedWorkerPool* pool = BrowserThread::GetBlockingPool();
+  // It's ok to pass unretained pointers here because this is a synchronous
+  // call.
+  pool->PostSequencedWorkerTaskWithShutdownBehavior(
+      worker_pool_token_,
+      FROM_HERE,
+      base::Bind(&DoRemove,
+                 base::Unretained(backend_.get()),
+                 base::Unretained(&report_ids),
+                 base::Unretained(&finished)),
+      base::SequencedWorkerPool::BLOCK_SHUTDOWN);
+  finished.Wait();
+}
+
+void UsageReportsBufferService::Clear() {
+  base::WaitableEvent finished(false, false);
+  base::SequencedWorkerPool* pool = BrowserThread::GetBlockingPool();
+  // It's ok to pass unretained pointers here because this is a synchronous
+  // call.
+  pool->PostSequencedWorkerTaskWithShutdownBehavior(
+      worker_pool_token_,
+      FROM_HERE,
+      base::Bind(&DoClear,
+                 base::Unretained(backend_.get()),
+                 base::Unretained(&finished)),
+      base::SequencedWorkerPool::BLOCK_SHUTDOWN);
+  finished.Wait();
+}
+
+std::string UsageReportsBufferService::Dump() {
+  std::string dump;
+  base::WaitableEvent finished(false, false);
+  base::SequencedWorkerPool* pool = BrowserThread::GetBlockingPool();
+  // It's ok to pass unretained pointers here because this is a synchronous
+  // call.
+  pool->PostSequencedWorkerTaskWithShutdownBehavior(
+      worker_pool_token_,
+      FROM_HERE,
+      base::Bind(&DoDump,
+                 base::Unretained(backend_.get()),
+                 base::Unretained(&finished),
+                 base::Unretained(&dump)),
+      base::SequencedWorkerPool::BLOCK_SHUTDOWN);
+  finished.Wait();
+  return dump;
+}
+
+}  // namespace history_report