blob: bb6fd6545d25a720d467a7dd7dbb7222fa62f727 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
// Copyright 2017 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 "content/browser/tracing/cros_tracing_agent.h"
#include <utility>
#include "base/bind.h"
#include "base/bind_helpers.h"
#include "base/logging.h"
#include "base/memory/ref_counted_memory.h"
#include "base/task_scheduler/post_task.h"
#include "base/trace_event/trace_config.h"
#include "chromeos/dbus/dbus_thread_manager.h"
#include "chromeos/dbus/debug_daemon_client.h"
#include "services/service_manager/public/cpp/connector.h"
namespace content {
namespace {
const char kCrOSTraceLabel[] = "systemTraceEvents";
} // namespace
CrOSTracingAgent::CrOSTracingAgent(service_manager::Connector* connector)
: BaseAgent(connector,
kCrOSTraceLabel,
tracing::mojom::TraceDataType::STRING,
false /* supports_explicit_clock_sync */) {}
CrOSTracingAgent::~CrOSTracingAgent() = default;
// tracing::mojom::Agent. Called by Mojo internals on the UI thread.
void CrOSTracingAgent::StartTracing(
const std::string& config,
base::TimeTicks coordinator_time,
const Agent::StartTracingCallback& callback) {
base::trace_event::TraceConfig trace_config(config);
debug_daemon_ = chromeos::DBusThreadManager::Get()->GetDebugDaemonClient();
if (!trace_config.IsSystraceEnabled() || !debug_daemon_) {
callback.Run(false /* success */);
return;
}
start_tracing_callback_ = std::move(callback);
debug_daemon_->SetStopAgentTracingTaskRunner(
base::CreateSequencedTaskRunnerWithTraits({base::MayBlock()}));
debug_daemon_->StartAgentTracing(
trace_config,
base::BindRepeating(&CrOSTracingAgent::StartTracingCallbackProxy,
base::Unretained(this)));
}
void CrOSTracingAgent::StopAndFlush(tracing::mojom::RecorderPtr recorder) {
DCHECK(debug_daemon_);
recorder_ = std::move(recorder);
debug_daemon_->StopAgentTracing(base::BindRepeating(
&CrOSTracingAgent::RecorderProxy, base::Unretained(this)));
}
void CrOSTracingAgent::StartTracingCallbackProxy(const std::string& agent_name,
bool success) {
start_tracing_callback_.Run(success);
}
void CrOSTracingAgent::RecorderProxy(
const std::string& event_name,
const std::string& events_label,
const scoped_refptr<base::RefCountedString>& events) {
if (events && !events->data().empty())
recorder_->AddChunk(events->data());
recorder_.reset();
}
} // namespace content
|
