Commit f45b3b2c authored by Alexander Timin's avatar Alexander Timin Committed by Commit Bot

[tracing] Fold ipc.flow into toplevel.flow.

Mojo messages are already covered by toplevel.flow.
Move legacy IPC there as well to centralise tracing for all async
work in a single place.

R=skyostil@chromium.org,rockot@google.com

Change-Id: Iba3d3a25bbb8bb05a8a7e5617312415e15126371
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/1985970Reviewed-by: default avatarKen Rockot <rockot@google.com>
Reviewed-by: default avatarSami Kyöstilä <skyostil@chromium.org>
Commit-Queue: Alexander Timin <altimin@chromium.org>
Cr-Commit-Position: refs/heads/master@{#730222}
parent 181b158e
...@@ -184,7 +184,6 @@ ...@@ -184,7 +184,6 @@
X(TRACE_DISABLED_BY_DEFAULT("gpu.device")) \ X(TRACE_DISABLED_BY_DEFAULT("gpu.device")) \
X(TRACE_DISABLED_BY_DEFAULT("gpu.service")) \ X(TRACE_DISABLED_BY_DEFAULT("gpu.service")) \
X(TRACE_DISABLED_BY_DEFAULT("histogram_samples")) \ X(TRACE_DISABLED_BY_DEFAULT("histogram_samples")) \
X(TRACE_DISABLED_BY_DEFAULT("ipc.flow")) \
X(TRACE_DISABLED_BY_DEFAULT("java-heap-profiler")) \ X(TRACE_DISABLED_BY_DEFAULT("java-heap-profiler")) \
X(TRACE_DISABLED_BY_DEFAULT("layer-element")) \ X(TRACE_DISABLED_BY_DEFAULT("layer-element")) \
X(TRACE_DISABLED_BY_DEFAULT("lifecycles")) \ X(TRACE_DISABLED_BY_DEFAULT("lifecycles")) \
......
...@@ -38,13 +38,13 @@ const base::FilePath::CharType kAndroidTraceConfigFile[] = ...@@ -38,13 +38,13 @@ const base::FilePath::CharType kAndroidTraceConfigFile[] =
FILE_PATH_LITERAL("/data/local/chrome-trace-config.json"); FILE_PATH_LITERAL("/data/local/chrome-trace-config.json");
const char kDefaultStartupCategories[] = const char kDefaultStartupCategories[] =
"startup,browser,toplevel,disabled-by-default-toplevel.flow,ipc,disabled-" "startup,browser,toplevel,disabled-by-default-toplevel.flow,ipc,EarlyJava,"
"by-default-ipc.flow,EarlyJava,cc,Java,navigation,loading,gpu," "cc,Java,navigation,loading,gpu,disabled-by-default-cpu_profiler,download_"
"disabled-by-default-cpu_profiler,download_service,-*"; "service,-*";
#else #else
const char kDefaultStartupCategories[] = const char kDefaultStartupCategories[] =
"benchmark,toplevel,startup,disabled-by-default-file,disabled-by-default-" "benchmark,toplevel,startup,disabled-by-default-file,disabled-by-default-"
"toplevel.flow,disabled-by-default-ipc.flow,download_service,-*"; "toplevel.flow,download_service,-*";
#endif #endif
// String parameters that can be used to parse the trace config file content. // String parameters that can be used to parse the trace config file content.
......
...@@ -212,9 +212,8 @@ bool ChannelNacl::Send(Message* message) { ...@@ -212,9 +212,8 @@ bool ChannelNacl::Send(Message* message) {
Logging::GetInstance()->OnSendMessage(message_ptr.get()); Logging::GetInstance()->OnSendMessage(message_ptr.get());
#endif // BUILDFLAG(IPC_MESSAGE_LOG_ENABLED) #endif // BUILDFLAG(IPC_MESSAGE_LOG_ENABLED)
TRACE_EVENT_WITH_FLOW0(TRACE_DISABLED_BY_DEFAULT("ipc.flow"), TRACE_EVENT_WITH_FLOW0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"),
"ChannelNacl::Send", "ChannelNacl::Send", message->header()->flags,
message->header()->flags,
TRACE_EVENT_FLAG_FLOW_OUT); TRACE_EVENT_FLAG_FLOW_OUT);
output_queue_.push_back(std::move(message_ptr)); output_queue_.push_back(std::move(message_ptr));
if (!waiting_connect_) if (!waiting_connect_)
......
...@@ -51,7 +51,7 @@ void MessagePipeReader::Close() { ...@@ -51,7 +51,7 @@ void MessagePipeReader::Close() {
bool MessagePipeReader::Send(std::unique_ptr<Message> message) { bool MessagePipeReader::Send(std::unique_ptr<Message> message) {
CHECK(message->IsValid()); CHECK(message->IsValid());
TRACE_EVENT_WITH_FLOW0(TRACE_DISABLED_BY_DEFAULT("ipc.flow"), TRACE_EVENT_WITH_FLOW0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"),
"MessagePipeReader::Send", message->flags(), "MessagePipeReader::Send", message->flags(),
TRACE_EVENT_FLAG_FLOW_OUT); TRACE_EVENT_FLAG_FLOW_OUT);
base::Optional<std::vector<mojo::native::SerializedHandlePtr>> handles; base::Optional<std::vector<mojo::native::SerializedHandlePtr>> handles;
...@@ -101,9 +101,8 @@ void MessagePipeReader::Receive(MessageView message_view) { ...@@ -101,9 +101,8 @@ void MessagePipeReader::Receive(MessageView message_view) {
return; return;
} }
TRACE_EVENT_WITH_FLOW0(TRACE_DISABLED_BY_DEFAULT("ipc.flow"), TRACE_EVENT_WITH_FLOW0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"),
"MessagePipeReader::Receive", "MessagePipeReader::Receive", message.flags(),
message.flags(),
TRACE_EVENT_FLAG_FLOW_IN); TRACE_EVENT_FLAG_FLOW_IN);
delegate_->OnMessageReceived(message); delegate_->OnMessageReceived(message);
} }
......
...@@ -457,9 +457,9 @@ bool SyncChannel::SyncContext::TryToUnblockListener(const Message* msg) { ...@@ -457,9 +457,9 @@ bool SyncChannel::SyncContext::TryToUnblockListener(const Message* msg) {
} }
base::WaitableEvent* done_event = deserializers_.back().done_event; base::WaitableEvent* done_event = deserializers_.back().done_event;
TRACE_EVENT_FLOW_BEGIN0( TRACE_EVENT_FLOW_BEGIN0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"),
TRACE_DISABLED_BY_DEFAULT("ipc.flow"), "SyncChannel::SyncContext::TryToUnblockListener",
"SyncChannel::SyncContext::TryToUnblockListener", done_event); done_event);
done_event->Signal(); done_event->Signal();
...@@ -522,7 +522,7 @@ void SyncChannel::SyncContext::CancelPendingSends() { ...@@ -522,7 +522,7 @@ void SyncChannel::SyncContext::CancelPendingSends() {
PendingSyncMessageQueue::iterator iter; PendingSyncMessageQueue::iterator iter;
DVLOG(1) << "Canceling pending sends"; DVLOG(1) << "Canceling pending sends";
for (iter = deserializers_.begin(); iter != deserializers_.end(); iter++) { for (iter = deserializers_.begin(); iter != deserializers_.end(); iter++) {
TRACE_EVENT_FLOW_BEGIN0(TRACE_DISABLED_BY_DEFAULT("ipc.flow"), TRACE_EVENT_FLOW_BEGIN0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"),
"SyncChannel::SyncContext::CancelPendingSends", "SyncChannel::SyncContext::CancelPendingSends",
iter->done_event); iter->done_event);
iter->done_event->Signal(); iter->done_event->Signal();
...@@ -644,7 +644,7 @@ bool SyncChannel::Send(Message* message) { ...@@ -644,7 +644,7 @@ bool SyncChannel::Send(Message* message) {
scoped_refptr<mojo::SyncHandleRegistry> registry = sync_handle_registry_; scoped_refptr<mojo::SyncHandleRegistry> registry = sync_handle_registry_;
WaitForReply(registry.get(), context.get(), pump_messages); WaitForReply(registry.get(), context.get(), pump_messages);
TRACE_EVENT_FLOW_END0(TRACE_DISABLED_BY_DEFAULT("ipc.flow"), TRACE_EVENT_FLOW_END0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"),
"SyncChannel::Send", context->GetSendDoneEvent()); "SyncChannel::Send", context->GetSendDoneEvent());
return context->Pop(); return context->Pop();
......
...@@ -81,7 +81,7 @@ bool SyncMessageFilter::Send(Message* message) { ...@@ -81,7 +81,7 @@ bool SyncMessageFilter::Send(Message* message) {
const bool* stop_flags[] = { &done, &shutdown }; const bool* stop_flags[] = { &done, &shutdown };
registry->Wait(stop_flags, 2); registry->Wait(stop_flags, 2);
if (done) { if (done) {
TRACE_EVENT_FLOW_END0(TRACE_DISABLED_BY_DEFAULT("ipc.flow"), TRACE_EVENT_FLOW_END0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"),
"SyncMessageFilter::Send", &done_event); "SyncMessageFilter::Send", &done_event);
} }
...@@ -131,7 +131,7 @@ bool SyncMessageFilter::OnMessageReceived(const Message& message) { ...@@ -131,7 +131,7 @@ bool SyncMessageFilter::OnMessageReceived(const Message& message) {
(*iter)->send_result = (*iter)->send_result =
(*iter)->deserializer->SerializeOutputParameters(message); (*iter)->deserializer->SerializeOutputParameters(message);
} }
TRACE_EVENT_FLOW_BEGIN0(TRACE_DISABLED_BY_DEFAULT("ipc.flow"), TRACE_EVENT_FLOW_BEGIN0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"),
"SyncMessageFilter::OnMessageReceived", "SyncMessageFilter::OnMessageReceived",
(*iter)->done_event); (*iter)->done_event);
(*iter)->done_event->Signal(); (*iter)->done_event->Signal();
...@@ -169,7 +169,7 @@ void SyncMessageFilter::SignalAllEvents() { ...@@ -169,7 +169,7 @@ void SyncMessageFilter::SignalAllEvents() {
lock_.AssertAcquired(); lock_.AssertAcquired();
for (PendingSyncMessages::iterator iter = pending_sync_messages_.begin(); for (PendingSyncMessages::iterator iter = pending_sync_messages_.begin();
iter != pending_sync_messages_.end(); ++iter) { iter != pending_sync_messages_.end(); ++iter) {
TRACE_EVENT_FLOW_BEGIN0(TRACE_DISABLED_BY_DEFAULT("ipc.flow"), TRACE_EVENT_FLOW_BEGIN0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"),
"SyncMessageFilter::SignalAllEvents", "SyncMessageFilter::SignalAllEvents",
(*iter)->done_event); (*iter)->done_event);
(*iter)->done_event->Signal(); (*iter)->done_event->Signal();
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment