OLD | NEW |
1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2006-2008 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/compiler_specific.h" | 9 #include "base/compiler_specific.h" |
10 #include "base/lazy_instance.h" | 10 #include "base/lazy_instance.h" |
(...skipping 347 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
358 while (!work_queue_.empty()) { | 358 while (!work_queue_.empty()) { |
359 PendingTask pending_task = work_queue_.front(); | 359 PendingTask pending_task = work_queue_.front(); |
360 work_queue_.pop(); | 360 work_queue_.pop(); |
361 if (!pending_task.delayed_run_time.is_null()) { | 361 if (!pending_task.delayed_run_time.is_null()) { |
362 // We want to delete delayed tasks in the same order in which they would | 362 // We want to delete delayed tasks in the same order in which they would |
363 // normally be deleted in case of any funny dependencies between delayed | 363 // normally be deleted in case of any funny dependencies between delayed |
364 // tasks. | 364 // tasks. |
365 AddToDelayedWorkQueue(pending_task); | 365 AddToDelayedWorkQueue(pending_task); |
366 } else { | 366 } else { |
367 // TODO(darin): Delete all tasks once it is safe to do so. | 367 // TODO(darin): Delete all tasks once it is safe to do so. |
368 //delete task; | 368 // Until it is totally safe, just do it when running purify. |
| 369 #ifdef PURIFY |
| 370 delete task; |
| 371 #endif // PURIFY |
369 } | 372 } |
370 } | 373 } |
371 did_work |= !deferred_non_nestable_work_queue_.empty(); | 374 did_work |= !deferred_non_nestable_work_queue_.empty(); |
372 while (!deferred_non_nestable_work_queue_.empty()) { | 375 while (!deferred_non_nestable_work_queue_.empty()) { |
| 376 Task* task = deferred_non_nestable_work_queue_.front().task; |
| 377 deferred_non_nestable_work_queue_.pop(); |
373 // TODO(darin): Delete all tasks once it is safe to do so. | 378 // TODO(darin): Delete all tasks once it is safe to do so. |
374 //Task* task = deferred_non_nestable_work_queue_.front().task; | 379 // Until it is totaly safe, just delete them to keep purify happy. |
375 deferred_non_nestable_work_queue_.pop(); | 380 #ifdef PURIFY |
376 //delete task; | 381 delete task; |
| 382 #endif |
377 } | 383 } |
378 did_work |= !delayed_work_queue_.empty(); | 384 did_work |= !delayed_work_queue_.empty(); |
379 while (!delayed_work_queue_.empty()) { | 385 while (!delayed_work_queue_.empty()) { |
380 Task* task = delayed_work_queue_.top().task; | 386 Task* task = delayed_work_queue_.top().task; |
381 delayed_work_queue_.pop(); | 387 delayed_work_queue_.pop(); |
382 delete task; | 388 delete task; |
383 } | 389 } |
384 return did_work; | 390 return did_work; |
385 } | 391 } |
386 | 392 |
(...skipping 213 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
600 Watcher *delegate) { | 606 Watcher *delegate) { |
601 return pump_libevent()->WatchFileDescriptor( | 607 return pump_libevent()->WatchFileDescriptor( |
602 fd, | 608 fd, |
603 persistent, | 609 persistent, |
604 static_cast<base::MessagePumpLibevent::Mode>(mode), | 610 static_cast<base::MessagePumpLibevent::Mode>(mode), |
605 controller, | 611 controller, |
606 delegate); | 612 delegate); |
607 } | 613 } |
608 | 614 |
609 #endif | 615 #endif |
OLD | NEW |