| 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_);
|
|
|