OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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.h" | 5 #include "base/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 479 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
490 TimeTicks start_of_run = tracked_objects::ThreadData::Now(); | 490 TimeTicks start_of_run = tracked_objects::ThreadData::Now(); |
491 #endif // defined(TRACK_ALL_TASK_OBJECTS) | 491 #endif // defined(TRACK_ALL_TASK_OBJECTS) |
492 | 492 |
493 FOR_EACH_OBSERVER(TaskObserver, task_observers_, | 493 FOR_EACH_OBSERVER(TaskObserver, task_observers_, |
494 WillProcessTask(pending_task.time_posted)); | 494 WillProcessTask(pending_task.time_posted)); |
495 pending_task.task.Run(); | 495 pending_task.task.Run(); |
496 FOR_EACH_OBSERVER(TaskObserver, task_observers_, | 496 FOR_EACH_OBSERVER(TaskObserver, task_observers_, |
497 DidProcessTask(pending_task.time_posted)); | 497 DidProcessTask(pending_task.time_posted)); |
498 #if defined(TRACK_ALL_TASK_OBJECTS) | 498 #if defined(TRACK_ALL_TASK_OBJECTS) |
499 tracked_objects::ThreadData::TallyADeathIfActive(pending_task.post_births, | 499 tracked_objects::ThreadData::TallyADeathIfActive(pending_task.post_births, |
500 pending_task.time_posted, pending_task.delayed_run_time, start_of_run); | 500 pending_task.time_posted, pending_task.delayed_run_time, start_of_run, |
| 501 tracked_objects::ThreadData::Now()); |
501 #endif // defined(TRACK_ALL_TASK_OBJECTS) | 502 #endif // defined(TRACK_ALL_TASK_OBJECTS) |
502 | 503 |
503 nestable_tasks_allowed_ = true; | 504 nestable_tasks_allowed_ = true; |
504 } | 505 } |
505 | 506 |
506 bool MessageLoop::DeferOrRunPendingTask(const PendingTask& pending_task) { | 507 bool MessageLoop::DeferOrRunPendingTask(const PendingTask& pending_task) { |
507 if (pending_task.nestable || state_->run_depth == 1) { | 508 if (pending_task.nestable || state_->run_depth == 1) { |
508 RunTask(pending_task); | 509 RunTask(pending_task); |
509 // Show that we ran a task (Note: a new one might arrive as a | 510 // Show that we ran a task (Note: a new one might arrive as a |
510 // consequence!). | 511 // consequence!). |
(...skipping 359 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
870 Watcher *delegate) { | 871 Watcher *delegate) { |
871 return pump_libevent()->WatchFileDescriptor( | 872 return pump_libevent()->WatchFileDescriptor( |
872 fd, | 873 fd, |
873 persistent, | 874 persistent, |
874 static_cast<base::MessagePumpLibevent::Mode>(mode), | 875 static_cast<base::MessagePumpLibevent::Mode>(mode), |
875 controller, | 876 controller, |
876 delegate); | 877 delegate); |
877 } | 878 } |
878 | 879 |
879 #endif | 880 #endif |
OLD | NEW |