Index: threading/sequenced_worker_pool.cc |
diff --git a/threading/sequenced_worker_pool.cc b/threading/sequenced_worker_pool.cc |
index 7bbca92a2fb22d4bde9a50185a045faac004dea8..772cc0150ef101b35f93d1c77cc3883f66ce4908 100644 |
--- a/threading/sequenced_worker_pool.cc |
+++ b/threading/sequenced_worker_pool.cc |
@@ -619,9 +619,11 @@ bool SequencedWorkerPool::Inner::PostTask( |
// The trace_id is used for identifying the task in about:tracing. |
sequenced.trace_id = trace_id_++; |
- TRACE_EVENT_FLOW_BEGIN0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"), |
- "SequencedWorkerPool::PostTask", |
- TRACE_ID_MANGLE(GetTaskTraceID(sequenced, static_cast<void*>(this)))); |
+ TRACE_EVENT_WITH_FLOW0( |
+ TRACE_DISABLED_BY_DEFAULT("toplevel.flow"), |
+ "SequencedWorkerPool::Inner::PostTask", |
+ TRACE_ID_MANGLE(GetTaskTraceID(sequenced, static_cast<void*>(this))), |
+ TRACE_EVENT_FLAG_FLOW_OUT); |
sequenced.sequence_task_number = LockedGetNextSequenceTaskNumber(); |
@@ -754,12 +756,12 @@ void SequencedWorkerPool::Inner::ThreadLoop(Worker* this_worker) { |
GetWorkStatus status = |
GetWork(&task, &wait_time, &delete_these_outside_lock); |
if (status == GET_WORK_FOUND) { |
- TRACE_EVENT_FLOW_END0(TRACE_DISABLED_BY_DEFAULT("toplevel.flow"), |
- "SequencedWorkerPool::PostTask", |
- TRACE_ID_MANGLE(GetTaskTraceID(task, static_cast<void*>(this)))); |
- TRACE_EVENT2("toplevel", "SequencedWorkerPool::ThreadLoop", |
- "src_file", task.posted_from.file_name(), |
- "src_func", task.posted_from.function_name()); |
+ TRACE_EVENT_WITH_FLOW2( |
+ TRACE_DISABLED_BY_DEFAULT("toplevel.flow"), |
+ "SequencedWorkerPool::Inner::ThreadLoop", |
+ TRACE_ID_MANGLE(GetTaskTraceID(task, static_cast<void*>(this))), |
+ TRACE_EVENT_FLAG_FLOW_IN, "src_file", task.posted_from.file_name(), |
+ "src_func", task.posted_from.function_name()); |
int new_thread_id = WillRunWorkerTask(task); |
{ |
AutoUnlock unlock(lock_); |