Mojo interface/service for Leak Detector on remote process

chrome/browser/metrics/leak_detector/leak_detector_remote_controller.cc

Index: chrome/browser/metrics/leak_detector/leak_detector_remote_controller.cc
diff --git a/chrome/browser/metrics/leak_detector/leak_detector_remote_controller.cc b/chrome/browser/metrics/leak_detector/leak_detector_remote_controller.cc
new file mode 100644
index 0000000000000000000000000000000000000000..07c890a704365b08c4c866f5b547b58b7667d544
--- /dev/null
+++ b/chrome/browser/metrics/leak_detector/leak_detector_remote_controller.cc
@@ -0,0 +1,71 @@
+// 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.
+
+#include "chrome/browser/metrics/leak_detector/leak_detector_remote_controller.h"
+
+#include "components/metrics/leak_detector/protobuf_to_mojo_converter.h"
+#include "content/public/browser/browser_thread.h"
+
+namespace metrics {
+
+namespace {
+
+// All instances of LeakDetectorRemoteController will need to reference a single
+// LocalController instance, referenced by this pointer. All remote LeakDetector
+// clients will get their params from and send leak reports to this instance.
+LeakDetectorRemoteController::LocalController* g_local_controller = nullptr;
+
+}  // namespace
+
+LeakDetectorRemoteController::~LeakDetectorRemoteController() {}
+
+// static
+void LeakDetectorRemoteController::Create(mojom::LeakDetectorRequest request) {
+  DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
+  new LeakDetectorRemoteController(std::move(request));

[jochen (gone - plz use gerrit), 2016/07/18 11:40:55]

who owns this?

[Simon Que, 2016/07/18 18:50:21]

The Mojo system calls this function and takes ownership of the created object,
in response to a connection request from LeakDetectorRemoteClient. See:
http://dev.chromium.org/developers/design-documents/mojo#TOC-Exposing-Service...

+}
+
+void LeakDetectorRemoteController::GetParams(
+    const mojom::LeakDetector::GetParamsCallback& callback) {
+  // If no controller exists, send an empty param protobuf. The remote caller
+  // should not initialize anything if the params are empty.
+  MemoryLeakReportProto_Params params;
+  if (g_local_controller) {
+    params = g_local_controller->GetParams();
+  }
+
+  mojo::StructPtr<mojom::LeakDetectorParams> mojo_params =
+      mojom::LeakDetectorParams::New();
+  leak_detector::ProtobufToMojoConverter::ParamsToMojo(params,
+                                                       mojo_params.get());
+
+  callback.Run(std::move(mojo_params));
+}
+
+void LeakDetectorRemoteController::SendLeakReports(
+    mojo::Array<mojom::MemoryLeakReportPtr> reports) {
+  std::vector<MemoryLeakReportProto> report_protos;
+  report_protos.reserve(reports.size());
+
+  for (const mojom::MemoryLeakReportPtr& report : reports) {
+    report_protos.push_back(MemoryLeakReportProto());
+    MemoryLeakReportProto* proto = &report_protos.back();
+
+    leak_detector::ProtobufToMojoConverter::MojoToReport(*report, proto);
+  }
+  DCHECK(g_local_controller);
+  g_local_controller->SendLeakReports(report_protos);
+}
+
+LeakDetectorRemoteController::LeakDetectorRemoteController(
+    mojom::LeakDetectorRequest request)
+    : binding_(this, std::move(request)) {}
+
+// static
+void LeakDetectorRemoteController::SetLocalControllerInstance(
+    LocalController* controller) {
+  g_local_controller = controller;
+}
+
+}  // namespace metrics