Home
last modified time | relevance | path

Searched refs:pending_task (Results 1 – 25 of 32) sorted by relevance

12

/external/chromium_org/base/threading/
Dworker_pool_win.cc23 PendingTask* pending_task = static_cast<PendingTask*>(param); in WorkItemCallback() local
25 "src_file", pending_task->posted_from.file_name(), in WorkItemCallback()
26 "src_func", pending_task->posted_from.function_name()); in WorkItemCallback()
29 tracked_objects::ThreadData::NowForStartOfRun(pending_task->birth_tally); in WorkItemCallback()
32 pending_task->task.Run(); in WorkItemCallback()
36 pending_task->birth_tally, in WorkItemCallback()
37 tracked_objects::TrackedTime(pending_task->time_posted), start_time, in WorkItemCallback()
40 delete pending_task; in WorkItemCallback()
45 bool PostTaskInternal(PendingTask* pending_task, bool task_is_slow) { in PostTaskInternal() argument
50 if (!QueueUserWorkItem(WorkItemCallback, pending_task, flags)) { in PostTaskInternal()
[all …]
Dworker_pool_posix.cc91 PendingTask pending_task = pool_->WaitForTask(); in ThreadMain() local
92 if (pending_task.task.is_null()) in ThreadMain()
95 "src_file", pending_task.posted_from.file_name(), in ThreadMain()
96 "src_func", pending_task.posted_from.function_name()); in ThreadMain()
99 tracked_objects::ThreadData::NowForStartOfRun(pending_task.birth_tally); in ThreadMain()
101 pending_task.task.Run(); in ThreadMain()
104 pending_task.birth_tally, TrackedTime(pending_task.time_posted), in ThreadMain()
151 PendingTask pending_task(from_here, task); in PostTask() local
152 AddTask(&pending_task); in PostTask()
155 void PosixDynamicThreadPool::AddTask(PendingTask* pending_task) { in AddTask() argument
[all …]
Dworker_pool_posix.h75 void AddTask(PendingTask* pending_task);
/external/chromium_org/base/message_loop/
Dmessage_loop.cc471 PendingTask pending_task = deferred_non_nestable_work_queue_.front(); in ProcessNextDelayedNonNestableTask() local
474 RunTask(pending_task); in ProcessNextDelayedNonNestableTask()
478 void MessageLoop::RunTask(const PendingTask& pending_task) { in RunTask() argument
480 tracked_objects::ThreadData::NowForStartOfRun(pending_task.birth_tally); in RunTask()
483 TRACE_ID_MANGLE(GetTaskTraceID(pending_task)), in RunTask()
485 (start_time - pending_task.EffectiveTimePosted()).InMilliseconds()); in RunTask()
490 pending_task.posted_from.function_name(), // Name for memory tracking. in RunTask()
491 "src_file", pending_task.posted_from.file_name(), in RunTask()
492 "src_func", pending_task.posted_from.function_name()); in RunTask()
504 pending_task.posted_from.program_counter(); in RunTask()
[all …]
Dincoming_task_queue.cc26 PendingTask pending_task( in AddToIncomingQueue() local
28 return PostPendingTask(&pending_task); in AddToIncomingQueue()
41 PendingTask pending_task( in TryAddToIncomingQueue() local
43 return PostPendingTask(&pending_task); in TryAddToIncomingQueue()
137 bool IncomingTaskQueue::PostPendingTask(PendingTask* pending_task) { in PostPendingTask() argument
146 pending_task->task.Reset(); in PostPendingTask()
153 pending_task->sequence_num = next_sequence_num_++; in PostPendingTask()
156 TRACE_ID_MANGLE(message_loop_->GetTaskTraceID(*pending_task))); in PostPendingTask()
159 incoming_queue_.push(*pending_task); in PostPendingTask()
160 pending_task->task.Reset(); in PostPendingTask()
Dmessage_loop.h389 virtual void WillProcessTask(const PendingTask& pending_task) = 0;
392 virtual void DidProcessTask(const PendingTask& pending_task) = 0;
480 void RunTask(const PendingTask& pending_task);
484 bool DeferOrRunPendingTask(const PendingTask& pending_task);
487 void AddToDelayedWorkQueue(const PendingTask& pending_task);
Dincoming_task_queue.h77 bool PostPendingTask(PendingTask* pending_task);
Dmessage_loop_unittest.cc818 virtual void WillProcessTask(const PendingTask& pending_task) OVERRIDE { in WillProcessTask() argument
820 EXPECT_TRUE(pending_task.time_posted != TimeTicks()); in WillProcessTask()
825 virtual void DidProcessTask(const PendingTask& pending_task) OVERRIDE { in DidProcessTask() argument
827 EXPECT_TRUE(pending_task.time_posted != TimeTicks()); in DidProcessTask()
/external/chromium/base/
Dmessage_loop.cc383 bool MessageLoop::DeferOrRunPendingTask(const PendingTask& pending_task) { in DeferOrRunPendingTask() argument
384 if (pending_task.nestable || state_->run_depth == 1) { in DeferOrRunPendingTask()
385 RunTask(pending_task.task); in DeferOrRunPendingTask()
393 deferred_non_nestable_work_queue_.push(pending_task); in DeferOrRunPendingTask()
397 void MessageLoop::AddToDelayedWorkQueue(const PendingTask& pending_task) { in AddToDelayedWorkQueue() argument
402 PendingTask new_pending_task(pending_task); in AddToDelayedWorkQueue()
428 PendingTask pending_task = work_queue_.front(); in DeletePendingTasks() local
430 if (!pending_task.delayed_run_time.is_null()) { in DeletePendingTasks()
434 AddToDelayedWorkQueue(pending_task); in DeletePendingTasks()
440 delete pending_task.task; in DeletePendingTasks()
[all …]
Dmessage_loop.h414 bool DeferOrRunPendingTask(const PendingTask& pending_task);
417 void AddToDelayedWorkQueue(const PendingTask& pending_task);
/external/chromium_org/chrome_frame/
Dchrome_frame_delegate.h140 base::PendingTask* pending_task = in PostTask() local
142 PushTask(pending_task); in PostTask()
144 reinterpret_cast<WPARAM>(pending_task)); in PostTask()
175 base::PendingTask* pending_task = in ExecuteTask() local
177 if (pending_task && PopTask(pending_task)) { in ExecuteTask()
178 pending_task->task.Run(); in ExecuteTask()
179 delete pending_task; in ExecuteTask() local
187 inline void PushTask(base::PendingTask* pending_task) { in PushTask() argument
189 pending_tasks_.push(pending_task); in PushTask()
195 inline bool PopTask(base::PendingTask* pending_task) { in PopTask() argument
[all …]
/external/chromium_org/net/spdy/
Dspdy_session_test_util.cc26 const base::PendingTask& pending_task) { in WillProcessTask() argument
30 const base::PendingTask& pending_task) { in DidProcessTask() argument
31 if (EndsWith(pending_task.posted_from.file_name(), file_name_, true) && in DidProcessTask()
32 EndsWith(pending_task.posted_from.function_name(), function_name_, in DidProcessTask()
Dspdy_session_test_util.h32 virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE;
33 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE;
/external/chromium_org/remoting/base/
Dplugin_thread_task_runner.cc99 base::PendingTask pending_task(from_here, task, delayed_run_time, false); in PostDelayedTask() local
106 pending_task.sequence_num = next_sequence_num_++; in PostDelayedTask()
113 incoming_queue_.push(pending_task); in PostDelayedTask()
114 pending_task.task.Reset(); in PostDelayedTask()
185 base::PendingTask pending_task = work_queue.front(); in ProcessIncomingTasks() local
188 if (pending_task.delayed_run_time.is_null()) { in ProcessIncomingTasks()
189 pending_task.task.Run(); in ProcessIncomingTasks()
191 delayed_queue_.push(pending_task); in ProcessIncomingTasks()
/external/chromium_org/base/
Dtracked_objects_unittest.cc167 base::TrackingInfo pending_task(location, kBogusBirthTime); in TEST_F() local
168 TrackedTime start_time(pending_task.time_posted); in TEST_F()
171 ThreadData::TallyRunOnNamedThreadIfTracking(pending_task, start_time, in TEST_F()
347 base::TrackingInfo pending_task(location, kDelayedStartTime); in TEST_F() local
348 pending_task.time_posted = kTimePosted; // Overwrite implied Now(). in TEST_F()
353 ThreadData::TallyRunOnNamedThreadIfTracking(pending_task, in TEST_F()
379 base::TrackingInfo pending_task(location, kDelayedStartTime); in TEST_F() local
380 pending_task.time_posted = kTimePosted; // Overwrite implied Now(). in TEST_F()
389 ThreadData::TallyRunOnNamedThreadIfTracking(pending_task, in TEST_F()
413 base::TrackingInfo pending_task(location, kDelayedStartTime); in TEST_F() local
[all …]
Dbase.target.linux-mips.mk152 base/pending_task.cc \
Dbase.target.darwin-mips.mk152 base/pending_task.cc \
/external/chromium_org/content/renderer/
Drenderer_main.cc82 virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE { in WillProcessTask() argument
86 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE { in DidProcessTask() argument
103 virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE { in WillProcessTask() argument
106 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE { in DidProcessTask() argument
/external/chromium_org/chrome/browser/
Djankometer.cc247 virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE { in WillProcessTask() argument
251 const base::TimeDelta queueing_time = now - pending_task.time_posted; in WillProcessTask()
255 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE { in DidProcessTask() argument
295 virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE { in WillProcessTask() argument
299 const base::TimeDelta queueing_time = now - pending_task.time_posted; in WillProcessTask()
303 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE { in DidProcessTask() argument
/external/chromium_org/chrome/browser/chromeos/drive/
Dtest_util.cc31 virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE { in WillProcessTask() argument
33 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE { in DidProcessTask() argument
/external/chromium_org/content/gpu/
Dgpu_watchdog_thread.h54 const base::PendingTask& pending_task) OVERRIDE;
55 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE;
Dgpu_watchdog_thread.cc99 const base::PendingTask& pending_task) { in WillProcessTask() argument
104 const base::PendingTask& pending_task) { in DidProcessTask() argument
/external/chromium_org/webkit/child/
Dwebthread_impl.cc27 virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE { in WillProcessTask() argument
31 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE { in DidProcessTask() argument
/external/chromium_org/content/browser/
Dbrowser_main_loop.cc289 virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE { in WillProcessTask() argument
292 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE { in DidProcessTask() argument
/external/chromium_org/net/http/
Dhttp_pipelined_network_transaction_unittest.cc756 virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE { in WillProcessTask() argument
764 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE {} in DidProcessTask() argument

12