Index: base/task_scheduler/utils.cc |
diff --git a/base/task_scheduler/utils.cc b/base/task_scheduler/utils.cc |
index 342c8a2a13b03c1f845db37fe14dcb179c3fa8ef..30ca46171a26e88331d0096782736fd65869f3dc 100644 |
--- a/base/task_scheduler/utils.cc |
+++ b/base/task_scheduler/utils.cc |
@@ -8,6 +8,7 @@ |
#include "base/logging.h" |
#include "base/memory/ptr_util.h" |
+#include "base/task_scheduler/delayed_task_manager.h" |
#include "base/task_scheduler/priority_queue.h" |
#include "base/task_scheduler/scheduler_task_executor.h" |
#include "base/task_scheduler/sequence_sort_key.h" |
@@ -20,19 +21,24 @@ namespace internal { |
bool PostTaskToExecutor(std::unique_ptr<Task> task, |
scoped_refptr<Sequence> sequence, |
SchedulerTaskExecutor* executor, |
- TaskTracker* task_tracker) { |
+ TaskTracker* task_tracker, |
+ DelayedTaskManager* delayed_task_manager) { |
DCHECK(task); |
DCHECK(sequence); |
DCHECK(executor); |
DCHECK(task_tracker); |
- |
- // TODO(fdoray): Support delayed tasks. |
- DCHECK(task->delayed_run_time.is_null()); |
+ DCHECK(delayed_task_manager); |
if (!task_tracker->WillPostTask(task.get())) |
return false; |
- executor->PostTaskWithSequence(std::move(task), std::move(sequence)); |
+ if (task->delayed_run_time.is_null()) { |
+ executor->PostTaskWithSequence(std::move(task), std::move(sequence)); |
+ } else { |
+ delayed_task_manager->AddDelayedTask(std::move(task), std::move(sequence), |
+ executor); |
+ } |
+ |
return true; |
} |