OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "base/message_loop/message_loop.h" | 5 #include "base/message_loop/message_loop.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
(...skipping 438 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
449 return false; | 449 return false; |
450 | 450 |
451 PendingTask pending_task = deferred_non_nestable_work_queue_.front(); | 451 PendingTask pending_task = deferred_non_nestable_work_queue_.front(); |
452 deferred_non_nestable_work_queue_.pop(); | 452 deferred_non_nestable_work_queue_.pop(); |
453 | 453 |
454 RunTask(pending_task); | 454 RunTask(pending_task); |
455 return true; | 455 return true; |
456 } | 456 } |
457 | 457 |
458 void MessageLoop::RunTask(const PendingTask& pending_task) { | 458 void MessageLoop::RunTask(const PendingTask& pending_task) { |
459 TRACE_EVENT_FLOW_END0("task", "MessageLoop::PostTask", | 459 tracked_objects::TrackedTime start_time = |
460 TRACE_ID_MANGLE(GetTaskTraceID(pending_task, this))); | 460 tracked_objects::ThreadData::NowForStartOfRun(pending_task.birth_tally); |
| 461 |
| 462 TRACE_EVENT_FLOW_END1("task", "MessageLoop::PostTask", |
| 463 TRACE_ID_MANGLE(GetTaskTraceID(pending_task, this)), |
| 464 "queue_duration", |
| 465 (start_time - pending_task.EffectiveTimePosted()).InMilliseconds()); |
461 TRACE_EVENT2("task", "MessageLoop::RunTask", | 466 TRACE_EVENT2("task", "MessageLoop::RunTask", |
462 "src_file", pending_task.posted_from.file_name(), | 467 "src_file", pending_task.posted_from.file_name(), |
463 "src_func", pending_task.posted_from.function_name()); | 468 "src_func", pending_task.posted_from.function_name()); |
| 469 |
464 DCHECK(nestable_tasks_allowed_); | 470 DCHECK(nestable_tasks_allowed_); |
465 // Execute the task and assume the worst: It is probably not reentrant. | 471 // Execute the task and assume the worst: It is probably not reentrant. |
466 nestable_tasks_allowed_ = false; | 472 nestable_tasks_allowed_ = false; |
467 | 473 |
468 // Before running the task, store the program counter where it was posted | 474 // Before running the task, store the program counter where it was posted |
469 // and deliberately alias it to ensure it is on the stack if the task | 475 // and deliberately alias it to ensure it is on the stack if the task |
470 // crashes. Be careful not to assume that the variable itself will have the | 476 // crashes. Be careful not to assume that the variable itself will have the |
471 // expected value when displayed by the optimizer in an optimized build. | 477 // expected value when displayed by the optimizer in an optimized build. |
472 // Look at a memory dump of the stack. | 478 // Look at a memory dump of the stack. |
473 const void* program_counter = | 479 const void* program_counter = |
474 pending_task.posted_from.program_counter(); | 480 pending_task.posted_from.program_counter(); |
475 debug::Alias(&program_counter); | 481 debug::Alias(&program_counter); |
476 | 482 |
477 HistogramEvent(kTaskRunEvent); | 483 HistogramEvent(kTaskRunEvent); |
478 | 484 |
479 tracked_objects::TrackedTime start_time = | |
480 tracked_objects::ThreadData::NowForStartOfRun(pending_task.birth_tally); | |
481 | |
482 FOR_EACH_OBSERVER(TaskObserver, task_observers_, | 485 FOR_EACH_OBSERVER(TaskObserver, task_observers_, |
483 WillProcessTask(pending_task)); | 486 WillProcessTask(pending_task)); |
484 pending_task.task.Run(); | 487 pending_task.task.Run(); |
485 FOR_EACH_OBSERVER(TaskObserver, task_observers_, | 488 FOR_EACH_OBSERVER(TaskObserver, task_observers_, |
486 DidProcessTask(pending_task)); | 489 DidProcessTask(pending_task)); |
487 | 490 |
488 tracked_objects::ThreadData::TallyRunOnNamedThreadIfTracking(pending_task, | 491 tracked_objects::ThreadData::TallyRunOnNamedThreadIfTracking(pending_task, |
489 start_time, tracked_objects::ThreadData::NowForEndOfRun()); | 492 start_time, tracked_objects::ThreadData::NowForEndOfRun()); |
490 | 493 |
491 nestable_tasks_allowed_ = true; | 494 nestable_tasks_allowed_ = true; |
(...skipping 333 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
825 fd, | 828 fd, |
826 persistent, | 829 persistent, |
827 mode, | 830 mode, |
828 controller, | 831 controller, |
829 delegate); | 832 delegate); |
830 } | 833 } |
831 | 834 |
832 #endif | 835 #endif |
833 | 836 |
834 } // namespace base | 837 } // namespace base |
OLD | NEW |