Home
last modified time | relevance | path

Searched refs:RepeatingTaskHandle (Results 1 – 25 of 53) sorted by relevance

123

/external/webrtc/rtc_base/task_utils/
Drepeating_task.h40 class RepeatingTaskHandle {
42 RepeatingTaskHandle() = default;
43 ~RepeatingTaskHandle() = default;
44 RepeatingTaskHandle(RepeatingTaskHandle&& other) = default;
45 RepeatingTaskHandle& operator=(RepeatingTaskHandle&& other) = default;
46 RepeatingTaskHandle(const RepeatingTaskHandle&) = delete;
47 RepeatingTaskHandle& operator=(const RepeatingTaskHandle&) = delete;
55 static RepeatingTaskHandle Start(TaskQueueBase* task_queue,
63 static RepeatingTaskHandle DelayedStart(
82 explicit RepeatingTaskHandle( in RepeatingTaskHandle() function
Drepeating_task_unittest.cc149 auto handle = RepeatingTaskHandle::Start( in TEST()
178 RepeatingTaskHandle::Start( in TEST()
201 RepeatingTaskHandle::Start( in TEST()
225 auto handle = RepeatingTaskHandle::DelayedStart( in TEST()
239 RepeatingTaskHandle::Start(task_queue.Get(), MoveOnlyClosure(&mock)); in TEST()
249 RepeatingTaskHandle handle = RepeatingTaskHandle::Start(&task_queue, [&] { in TEST()
264 RepeatingTaskHandle handle = RepeatingTaskHandle::Start(&task_queue, [&] { in TEST()
284 RepeatingTaskHandle::Start(task_queue.Get(), MoveOnlyClosure(&closure)); in TEST()
299 RepeatingTaskHandle::Start(task_queue.Get(), closure.AsStdFunction()); in TEST()
308 void StartPeriodicTask(RepeatingTaskHandle* handle, in TEST()
[all …]
Drepeating_task.cc84 RepeatingTaskHandle RepeatingTaskHandle::Start( in Start()
93 return RepeatingTaskHandle(std::move(alive_flag)); in Start()
98 RepeatingTaskHandle RepeatingTaskHandle::DelayedStart( in DelayedStart()
111 return RepeatingTaskHandle(std::move(alive_flag)); in DelayedStart()
114 void RepeatingTaskHandle::Stop() { in Stop()
121 bool RepeatingTaskHandle::Running() const { in Running()
/external/webrtc/test/time_controller/
Dsimulated_time_controller_unittest.cc45 auto handle = RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
70 RepeatingTaskHandle handle; in TEST()
72 handle = RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
87 void StartPeriodicTask(RepeatingTaskHandle* handle, in TEST()
89 *handle = RepeatingTaskHandle::Start(task_queue->Get(), [this] { in TEST()
101 RepeatingTaskHandle handle; in TEST()
Dexternal_time_controller_unittest.cc95 auto handle = RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
121 RepeatingTaskHandle handle; in TEST()
123 handle = RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
/external/webrtc/test/pc/e2e/
Dtest_activities_executor.cc83 repeating_task_handles_.push_back(RepeatingTaskHandle::Start( in PostActivity()
90 repeating_task_handles_.push_back(RepeatingTaskHandle::DelayedStart( in PostActivity()
Dtest_activities_executor.h78 std::vector<RepeatingTaskHandle> repeating_task_handles_
/external/webrtc/test/network/
Dnetwork_emulation_manager.h101 std::pair<std::unique_ptr<CrossTrafficGenerator>, RepeatingTaskHandle>;
111 RepeatingTaskHandle process_task_handle_;
/external/webrtc/video/adaptation/
Dpixel_limit_resource.h55 RepeatingTaskHandle repeating_task_ RTC_GUARDED_BY(task_queue_);
Dpixel_limit_resource.cc59 repeating_task_ = RepeatingTaskHandle::Start(task_queue_, [&] { in SetResourceListener()
Doveruse_frame_detector.h144 RepeatingTaskHandle check_overuse_task_ RTC_GUARDED_BY(task_checker_);
/external/webrtc/call/
Drtp_transport_controller_send.h197 RepeatingTaskHandle pacer_queue_update_task_ RTC_GUARDED_BY(task_queue_);
198 RepeatingTaskHandle controller_task_ RTC_GUARDED_BY(task_queue_);
/external/webrtc/video/
Drtp_streams_synchronizer2.h68 RepeatingTaskHandle repeating_task_ RTC_GUARDED_BY(main_checker_);
Dvideo_receive_stream_timeout_tracker.h62 RepeatingTaskHandle timeout_task_;
Dvideo_receive_stream_timeout_tracker.cc50 RepeatingTaskHandle::DelayedStart(bookkeeping_queue_, timeout_delay, in Start()
Dcall_stats2.h108 RepeatingTaskHandle repeating_task_ RTC_GUARDED_BY(task_queue_);
Dvideo_send_stream_impl.h143 RepeatingTaskHandle check_encoder_activity_task_
/external/webrtc/test/
Ddirect_transport.h74 RepeatingTaskHandle next_process_task_ RTC_GUARDED_BY(&process_lock_);
Dframe_generator_capturer.cc168 frame_task_ = RepeatingTaskHandle::DelayedStart( in Init()
231 frame_task_ = RepeatingTaskHandle::Start( in Start()
Ddirect_transport.cc109 next_process_task_ = RepeatingTaskHandle::DelayedStart( in ProcessPackets()
/external/webrtc/audio/
Daudio_state.h80 RepeatingTaskHandle null_audio_poller_ RTC_GUARDED_BY(&thread_checker_);
/external/webrtc/pc/test/
Dfake_periodic_video_source.h53 RepeatingTaskHandle::Start(task_queue_->Get(), [this, frame_interval] { in FakePeriodicVideoSource()
/external/webrtc/modules/video_coding/
Dnack_requester.h53 RepeatingTaskHandle repeating_task_ RTC_GUARDED_BY(sequence_);
Dframe_buffer2.h165 RepeatingTaskHandle callback_task_ RTC_GUARDED_BY(mutex_);
/external/webrtc/test/scenario/
Dscenario.cc251 RepeatingTaskHandle::DelayedStart( in Every()
260 RepeatingTaskHandle::DelayedStart( in Every()

123