Skip to content
This repository was archived by the owner on Feb 25, 2025. It is now read-only.

Commit a82c7ee

Browse files
authored
Add async events to pipeline flows. (#7985)
1 parent c3eb7ae commit a82c7ee

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

synchronization/pipeline.h

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@ class Pipeline : public fml::RefCountedThreadSafe<Pipeline<R>> {
5555
TRACE_EVENT_ASYNC_END0("flutter", "PipelineProduce", trace_id_);
5656
// The continuation is being dropped on the floor. End the flow.
5757
TRACE_FLOW_END("flutter", "PipelineItem", trace_id_);
58+
TRACE_EVENT_ASYNC_END0("flutter", "PipelineItem", trace_id_);
5859
}
5960
}
6061

@@ -79,6 +80,7 @@ class Pipeline : public fml::RefCountedThreadSafe<Pipeline<R>> {
7980
ProducerContinuation(Continuation continuation, size_t trace_id)
8081
: continuation_(continuation), trace_id_(trace_id) {
8182
TRACE_FLOW_BEGIN("flutter", "PipelineItem", trace_id_);
83+
TRACE_EVENT_ASYNC_BEGIN0("flutter", "PipelineItem", trace_id_);
8284
TRACE_EVENT_ASYNC_BEGIN0("flutter", "PipelineProduce", trace_id_);
8385
}
8486

@@ -133,6 +135,7 @@ class Pipeline : public fml::RefCountedThreadSafe<Pipeline<R>> {
133135
empty_.Signal();
134136

135137
TRACE_FLOW_END("flutter", "PipelineItem", trace_id);
138+
TRACE_EVENT_ASYNC_END0("flutter", "PipelineItem", trace_id);
136139

137140
return items_count > 0 ? PipelineConsumeResult::MoreAvailable
138141
: PipelineConsumeResult::Done;

0 commit comments

Comments
 (0)