Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(130)

Side by Side Diff: chrome/renderer/leak_detector/leak_detector_remote_client.cc

Issue 2062743002: Randomly enable leak detector based on probability parameter (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Use RenderThreadObserver interface to shutdown remote client on same thread Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "chrome/renderer/leak_detector/leak_detector_remote_client.h" 5 #include "chrome/renderer/leak_detector/leak_detector_remote_client.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/threading/thread_task_runner_handle.h" 8 #include "base/threading/thread_task_runner_handle.h"
9 #include "components/metrics/leak_detector/protobuf_to_mojo_converter.h" 9 #include "components/metrics/leak_detector/protobuf_to_mojo_converter.h"
10 #include "components/metrics/proto/memory_leak_report.pb.h" 10 #include "components/metrics/proto/memory_leak_report.pb.h"
(...skipping 10 matching lines...) Expand all
21 // |remote_service_|. See example at: 21 // |remote_service_|. See example at:
22 // https://www.chromium.org/developers/design-documents/mojo/validation 22 // https://www.chromium.org/developers/design-documents/mojo/validation
23 remote_service_->GetParams(base::Bind( 23 remote_service_->GetParams(base::Bind(
24 &LeakDetectorRemoteClient::OnParamsReceived, base::Unretained(this))); 24 &LeakDetectorRemoteClient::OnParamsReceived, base::Unretained(this)));
25 } 25 }
26 26
27 LeakDetectorRemoteClient::~LeakDetectorRemoteClient() { 27 LeakDetectorRemoteClient::~LeakDetectorRemoteClient() {
28 metrics::LeakDetector::GetInstance()->RemoveObserver(this); 28 metrics::LeakDetector::GetInstance()->RemoveObserver(this);
29 } 29 }
30 30
31 void LeakDetectorRemoteClient::OnParamsReceived(
32 mojo::StructPtr<metrics::mojom::LeakDetectorParams> result) {
33 metrics::MemoryLeakReportProto::Params params;
34 metrics::leak_detector::protobuf_to_mojo_converter::MojoToParams(*result,
35 &params);
36
37 metrics::LeakDetector* detector = metrics::LeakDetector::GetInstance();
38 detector->AddObserver(this);
39 detector->Init(params, base::ThreadTaskRunnerHandle::Get());
40 }
41
42 void LeakDetectorRemoteClient::OnLeaksFound( 31 void LeakDetectorRemoteClient::OnLeaksFound(
43 const std::vector<metrics::MemoryLeakReportProto>& reports) { 32 const std::vector<metrics::MemoryLeakReportProto>& reports) {
44 std::vector<mojo::StructPtr<metrics::mojom::MemoryLeakReport>> result; 33 std::vector<mojo::StructPtr<metrics::mojom::MemoryLeakReport>> result;
45 34
46 for (const metrics::MemoryLeakReportProto& report : reports) { 35 for (const metrics::MemoryLeakReportProto& report : reports) {
47 metrics::mojom::MemoryLeakReportPtr mojo_report = 36 metrics::mojom::MemoryLeakReportPtr mojo_report =
48 metrics::mojom::MemoryLeakReport::New(); 37 metrics::mojom::MemoryLeakReport::New();
49 metrics::leak_detector::protobuf_to_mojo_converter::ReportToMojo( 38 metrics::leak_detector::protobuf_to_mojo_converter::ReportToMojo(
50 report, mojo_report.get()); 39 report, mojo_report.get());
51 result.push_back(std::move(mojo_report)); 40 result.push_back(std::move(mojo_report));
52 } 41 }
53 42
54 remote_service_->SendLeakReports(std::move(result)); 43 remote_service_->SendLeakReports(std::move(result));
55 } 44 }
45
46 void LeakDetectorRemoteClient::OnRenderProcessShutdown() {
47 remote_service_.reset();
48 }
49
50 void LeakDetectorRemoteClient::OnParamsReceived(
51 mojo::StructPtr<metrics::mojom::LeakDetectorParams> result) {
52 metrics::MemoryLeakReportProto::Params params;
53 metrics::leak_detector::protobuf_to_mojo_converter::MojoToParams(*result,
54 &params);
55
56 if (params.sampling_rate() > 0) {
57 metrics::LeakDetector* detector = metrics::LeakDetector::GetInstance();
58 detector->AddObserver(this);
59 detector->Init(params, base::ThreadTaskRunnerHandle::Get());
60 }
61 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698