| 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 |