Home
last modified time | relevance | path

Searched refs:lazy_now (Results 1 – 23 of 23) sorted by relevance

/external/libchrome/base/task/sequence_manager/
Dtime_domain.cc36 void TimeDomain::SetNextDelayedDoWork(LazyNow* lazy_now, TimeTicks run_time) { in SetNextDelayedDoWork() argument
37 sequence_manager_->SetNextDelayedDoWork(lazy_now, run_time); in SetNextDelayedDoWork()
47 LazyNow lazy_now(CreateLazyNow()); in UnregisterQueue() local
48 SetNextWakeUpForQueue(queue, nullopt, &lazy_now); in UnregisterQueue()
54 LazyNow* lazy_now) { in SetNextWakeUpForQueue() argument
90 SetNextDelayedDoWork(lazy_now, new_wake_up.value()); in SetNextWakeUpForQueue()
95 SetNextDelayedDoWork(lazy_now, TimeTicks::Max()); in SetNextWakeUpForQueue()
100 void TimeDomain::WakeUpReadyDelayedQueues(LazyNow* lazy_now) { in WakeUpReadyDelayedQueues() argument
106 delayed_wake_up_queue_.Min().wake_up.time <= lazy_now->Now()) { in WakeUpReadyDelayedQueues()
108 queue->WakeUpForDelayedWork(lazy_now); in WakeUpReadyDelayedQueues()
Dthread_controller_with_message_pump_impl.cc61 LazyNow* lazy_now, in SetNextDelayedDoWork() argument
140 LazyNow lazy_now(time_source_); in DoWork() local
142 main_thread_only().task_source->DelayTillNextTask(&lazy_now); in DoWork()
149 SetNextDelayedDoWork(&lazy_now, lazy_now.Now() + do_work_delay); in DoWork()
151 SetNextDelayedDoWork(&lazy_now, TimeTicks::Max()); in DoWork()
Dtime_domain.h56 virtual Optional<TimeDelta> DelayTillNextTask(LazyNow* lazy_now) = 0;
75 virtual void SetNextDelayedDoWork(LazyNow* lazy_now, TimeTicks run_time);
102 LazyNow* lazy_now);
108 void WakeUpReadyDelayedQueues(LazyNow* lazy_now);
Dtime_domain_unittest.cc48 Optional<TimeDelta> DelayTillNextTask(LazyNow* lazy_now) override { in DelayTillNextTask() argument
62 void(LazyNow* lazy_now, TimeTicks run_time));
98 LazyNow lazy_now(now); in TEST_F() local
118 LazyNow lazy_now(now); in TEST_F() local
160 LazyNow lazy_now(now); in TEST_F() local
194 LazyNow lazy_now(now); in TEST_F() local
247 LazyNow lazy_now(now); in TEST_F() local
261 time_domain_->WakeUpReadyDelayedQueues(&lazy_now); in TEST_F()
272 LazyNow lazy_now(now); in TEST_F() local
292 LazyNow lazy_now(now); in TEST_F() local
Dtask_queue_impl.cc257 LazyNow lazy_now(now); in PushOntoDelayedIncomingQueueFromMainThread() local
258 UpdateDelayedWakeUp(&lazy_now); in PushOntoDelayedIncomingQueueFromMainThread()
289 LazyNow lazy_now(time_domain_now); in ScheduleDelayedWorkTask() local
290 WakeUpForDelayedWork(&lazy_now); in ScheduleDelayedWorkTask()
423 void TaskQueueImpl::WakeUpForDelayedWork(LazyNow* lazy_now) { in WakeUpForDelayedWork() argument
433 if (task.delayed_run_time > lazy_now->Now()) in WakeUpForDelayedWork()
451 UpdateDelayedWakeUp(lazy_now); in WakeUpForDelayedWork()
603 LazyNow lazy_now = time_domain->CreateLazyNow(); in SetTimeDomain() local
609 UpdateDelayedWakeUp(&lazy_now); in SetTimeDomain()
834 LazyNow lazy_now = main_thread_only().time_domain->CreateLazyNow(); in EnableOrDisableWithSelector() local
[all …]
Dthread_controller_impl.cc79 void ThreadControllerImpl::SetNextDelayedDoWork(LazyNow* lazy_now, in SetNextDelayedDoWork() argument
108 base::TimeDelta delay = std::max(TimeDelta(), run_time - lazy_now->Now()); in SetNextDelayedDoWork()
193 LazyNow lazy_now(time_source_); in DoWork() local
194 TimeDelta delay_till_next_task = sequence_->DelayTillNextTask(&lazy_now); in DoWork()
204 TimeTicks next_task_at = lazy_now.Now() + delay_till_next_task; in DoWork()
Dsequence_manager_impl.cc238 void SequenceManagerImpl::WakeUpReadyDelayedQueues(LazyNow* lazy_now) { in WakeUpReadyDelayedQueues() argument
244 time_domain->WakeUpReadyDelayedQueues(lazy_now); in WakeUpReadyDelayedQueues()
290 void SequenceManagerImpl::SetNextDelayedDoWork(LazyNow* lazy_now, in SetNextDelayedDoWork() argument
292 controller_->SetNextDelayedDoWork(lazy_now, run_time); in SetNextDelayedDoWork()
318 LazyNow lazy_now(controller_->GetClock()); in TakeTask() local
319 WakeUpReadyDelayedQueues(&lazy_now); in TakeTask()
359 NotifyWillProcessTask(&executing_task, &lazy_now); in TakeTask()
365 LazyNow lazy_now(controller_->GetClock()); in DidRunTask() local
368 NotifyDidProcessTask(&executing_task, &lazy_now); in DidRunTask()
375 TimeDelta SequenceManagerImpl::DelayTillNextTask(LazyNow* lazy_now) { in DelayTillNextTask() argument
[all …]
Dreal_time_domain.cc25 Optional<TimeDelta> RealTimeDomain::DelayTillNextTask(LazyNow* lazy_now) { in DelayTillNextTask() argument
30 TimeTicks now = lazy_now->Now(); in DelayTillNextTask()
Dsequence_manager_impl.h110 TimeDelta DelayTillNextTask(LazyNow* lazy_now) override;
125 void SetNextDelayedDoWork(LazyNow* lazy_now, TimeTicks run_time);
250 void WakeUpReadyDelayedQueues(LazyNow* lazy_now);
Dsequenced_task_source.h30 virtual TimeDelta DelayTillNextTask(LazyNow* lazy_now) = 0;
Dtask_queue_impl.h256 void WakeUpForDelayedWork(LazyNow* lazy_now);
414 void UpdateDelayedWakeUp(LazyNow* lazy_now);
415 void UpdateDelayedWakeUpImpl(LazyNow* lazy_now,
Dreal_time_domain.h24 Optional<TimeDelta> DelayTillNextTask(LazyNow* lazy_now) override;
Dthread_controller.h57 virtual void SetNextDelayedDoWork(LazyNow* lazy_now, TimeTicks run_time) = 0;
Dsequence_manager_perftest.cc36 Optional<TimeDelta> DelayTillNextTask(LazyNow* lazy_now) override { in DelayTillNextTask() argument
45 void SetNextDelayedDoWork(LazyNow* lazy_now, TimeTicks run_time) override { in SetNextDelayedDoWork() argument
Dsequence_manager_impl_unittest.cc129 LazyNow lazy_now(GetTickClock()); in RunUntilManagerIsIdle() local
131 manager_->GetRealTimeDomain()->DelayTillNextTask(&lazy_now); in RunUntilManagerIsIdle()
447 LazyNow lazy_now(GetTickClock()); in TEST_P() local
448 manager_->WakeUpReadyDelayedQueues(&lazy_now); in TEST_P()
1289 LazyNow lazy_now(GetTickClock()); in TEST_P() local
1291 manager_->GetRealTimeDomain()->DelayTillNextTask(&lazy_now)); in TEST_P()
2617 LazyNow lazy_now(GetTickClock()); in TEST_P() local
2618 EXPECT_EQ(TimeDelta::Max(), manager_->DelayTillNextTask(&lazy_now)); in TEST_P()
2623 EXPECT_EQ(TimeDelta::FromSeconds(10), manager_->DelayTillNextTask(&lazy_now)); in TEST_P()
2628 EXPECT_EQ(TimeDelta::FromSeconds(10), manager_->DelayTillNextTask(&lazy_now)); in TEST_P()
[all …]
Dthread_controller_with_message_pump_impl.h35 void SetNextDelayedDoWork(LazyNow* lazy_now, TimeTicks run_time) override;
Dthread_controller_impl.h40 void SetNextDelayedDoWork(LazyNow* lazy_now, TimeTicks run_time) override;
/external/libchrome/base/task/sequence_manager/test/
Dmock_time_domain.cc27 Optional<TimeDelta> MockTimeDomain::DelayTillNextTask(LazyNow* lazy_now) { in DelayTillNextTask() argument
31 void MockTimeDomain::SetNextDelayedDoWork(LazyNow* lazy_now, in SetNextDelayedDoWork() argument
Dmock_time_domain.h25 Optional<TimeDelta> DelayTillNextTask(LazyNow* lazy_now) override;
26 void SetNextDelayedDoWork(LazyNow* lazy_now, TimeTicks run_time) override;
Dlazy_thread_controller_for_test.cc101 void LazyThreadControllerForTest::SetNextDelayedDoWork(LazyNow* lazy_now, in SetNextDelayedDoWork() argument
104 ThreadControllerImpl::SetNextDelayedDoWork(lazy_now, run_time); in SetNextDelayedDoWork()
Dlazy_thread_controller_for_test.h33 void SetNextDelayedDoWork(LazyNow* lazy_now, TimeTicks run_time) override;
/external/openscreen/third_party/chromium_quic/build/base/
DBUILD.gn351 "../../src/base/task/sequence_manager/lazy_now.cc",
352 "../../src/base/task/sequence_manager/lazy_now.h",
/external/libchrome/
DAndroid.bp342 "base/task/sequence_manager/lazy_now.h",