Home
last modified time | relevance | path

Searched refs:task_queue_ (Results 1 – 25 of 111) sorted by relevance

12345

/external/webrtc/call/
Drtp_transport_controller_send.h133 void MaybeCreateControllers() RTC_RUN_ON(task_queue_);
135 RTC_RUN_ON(task_queue_);
137 void StartProcessPeriodicTasks() RTC_RUN_ON(task_queue_);
138 void UpdateControllerWithTimeInterval() RTC_RUN_ON(task_queue_);
144 void UpdateStreamsConfig() RTC_RUN_ON(task_queue_);
147 RTC_RUN_ON(task_queue_);
148 void PostUpdates(NetworkControlUpdate update) RTC_RUN_ON(task_queue_);
149 void UpdateControlState() RTC_RUN_ON(task_queue_);
150 void UpdateCongestedState() RTC_RUN_ON(task_queue_);
165 TargetTransferRateObserver* observer_ RTC_GUARDED_BY(task_queue_);
[all …]
Drtp_transport_controller_send.cc115 task_queue_(*config.trials, in RtpTransportControllerSend()
135 if (task_queue_.IsCurrent()) { in ~RtpTransportControllerSend()
202 return &task_queue_; in GetWorkerQueue()
225 RTC_DCHECK_RUN_ON(&task_queue_); in SetAllocatedSendBitrateLimits()
232 RTC_DCHECK_RUN_ON(&task_queue_); in SetPacingFactor()
246 task_queue_.RunOrPost([this, observer] { in RegisterTargetTransferRateObserver()
247 RTC_DCHECK_RUN_ON(&task_queue_); in RegisterTargetTransferRateObserver()
306 task_queue_.RunOrPost([this, network_route] { in OnNetworkRouteChanged()
307 RTC_DCHECK_RUN_ON(&task_queue_); in OnNetworkRouteChanged()
335 task_queue_.RunOrPost([this, msg, network_route] { in OnNetworkRouteChanged()
[all …]
/external/webrtc/logging/rtc_event_log/
Drtc_event_log_impl.h53 void LogToMemory(std::unique_ptr<RtcEvent> event) RTC_RUN_ON(task_queue_);
54 void LogEventsFromMemoryToOutput() RTC_RUN_ON(task_queue_);
56 void StopOutput() RTC_RUN_ON(task_queue_);
60 RTC_RUN_ON(task_queue_);
61 void WriteToOutput(absl::string_view output_string) RTC_RUN_ON(task_queue_);
63 void StopLoggingInternal() RTC_RUN_ON(task_queue_);
65 void ScheduleOutput() RTC_RUN_ON(task_queue_);
69 RTC_GUARDED_BY(*task_queue_);
72 std::deque<std::unique_ptr<RtcEvent>> history_ RTC_GUARDED_BY(*task_queue_);
75 RTC_GUARDED_BY(*task_queue_);
[all …]
Drtc_event_log_impl.cc64 task_queue_( in RtcEventLogImpl()
78 rtc::TaskQueue* tq = task_queue_.get(); in ~RtcEventLogImpl()
80 task_queue_.release(); in ~RtcEventLogImpl()
101 task_queue_->PostTask([this, output_period_ms, timestamp_us, utc_time_us, in StartLogging()
103 RTC_DCHECK_RUN_ON(task_queue_.get()); in StartLogging()
130 task_queue_->PostTask([this, callback] { in StopLogging()
131 RTC_DCHECK_RUN_ON(task_queue_.get()); in StopLogging()
145 task_queue_->PostTask([this, event = std::move(event)]() mutable { in Log()
146 RTC_DCHECK_RUN_ON(task_queue_.get()); in Log()
174 RTC_DCHECK_RUN_ON(task_queue_.get()); in ScheduleOutput()
[all …]
/external/webrtc/modules/pacing/
Dtask_queue_paced_sender.cc77 task_queue_(field_trials, "TaskQueuePacedSender", task_queue_factory) { in TaskQueuePacedSender()
103 task_queue_.RunOrPost([&]() { in ~TaskQueuePacedSender()
104 RTC_DCHECK_RUN_ON(&task_queue_); in ~TaskQueuePacedSender()
110 task_queue_.RunOrPost([this]() { in EnsureStarted()
111 RTC_DCHECK_RUN_ON(&task_queue_); in EnsureStarted()
119 task_queue_.RunOrPost( in CreateProbeClusters()
121 RTC_DCHECK_RUN_ON(&task_queue_); in CreateProbeClusters()
128 task_queue_.RunOrPost([this]() { in Pause()
129 RTC_DCHECK_RUN_ON(&task_queue_); in Pause()
135 task_queue_.RunOrPost([this]() { in Resume()
[all …]
Dtask_queue_paced_sender.h138 void UpdateStats() RTC_RUN_ON(task_queue_);
176 PacingController pacing_controller_ RTC_GUARDED_BY(task_queue_);
183 Timestamp next_process_time_ RTC_GUARDED_BY(task_queue_);
187 bool is_started_ RTC_GUARDED_BY(task_queue_);
192 bool is_shutdown_ RTC_GUARDED_BY(task_queue_);
195 rtc::ExpFilter packet_size_ RTC_GUARDED_BY(task_queue_);
196 bool include_overhead_ RTC_GUARDED_BY(task_queue_);
204 MaybeWorkerThread task_queue_; variable
/external/cronet/stable/base/task/sequence_manager/
Dtask_queue.cc25 : task_queue_(std::move(task_queue)) { in QueueEnabledVoter()
26 task_queue_->AddQueueEnabledVoter(enabled_, *this); in QueueEnabledVoter()
30 if (task_queue_) { in ~QueueEnabledVoter()
31 task_queue_->RemoveQueueEnabledVoter(enabled_, *this); in ~QueueEnabledVoter()
40 if (task_queue_) { in SetVoteToEnable()
41 task_queue_->OnQueueEnabledVoteChanged(enabled_); in SetVoteToEnable()
71 : task_queue_(std::move(task_queue)), in Handle()
72 sequence_manager_(task_queue_->GetSequenceManagerWeakPtr()) {} in Handle()
81 return task_queue_.get(); in get()
85 return task_queue_.get(); in operator ->()
[all …]
Dwake_up_queue_unittest.cc83 task_queue_ = std::make_unique<TaskQueueImplForTest>( in SetUp()
88 if (task_queue_) in TearDown()
89 task_queue_->UnregisterTaskQueue(); in TearDown()
93 std::unique_ptr<TaskQueueImplForTest> task_queue_; member in base::sequence_manager::internal::WakeUpQueueTest
105 task_queue_->SetNextWakeUp(&lazy_now, WakeUp{delayed_runtime}); in TEST_F()
110 EXPECT_EQ(task_queue_.get(), wake_up_queue_->NextScheduledTaskQueue()); in TEST_F()
127 task_queue_->SetNextWakeUp(&lazy_now, WakeUp{delayed_runtime1}); in TEST_F()
137 task_queue_->SetNextWakeUp(&lazy_now, WakeUp{delayed_runtime2}); in TEST_F()
158 task_queue_->SetNextWakeUp( in TEST_F()
173 task_queue_->SetNextWakeUp( in TEST_F()
[all …]
/external/cronet/tot/base/task/sequence_manager/
Dtask_queue.cc25 : task_queue_(std::move(task_queue)) { in QueueEnabledVoter()
26 task_queue_->AddQueueEnabledVoter(enabled_, *this); in QueueEnabledVoter()
30 if (task_queue_) { in ~QueueEnabledVoter()
31 task_queue_->RemoveQueueEnabledVoter(enabled_, *this); in ~QueueEnabledVoter()
40 if (task_queue_) { in SetVoteToEnable()
41 task_queue_->OnQueueEnabledVoteChanged(enabled_); in SetVoteToEnable()
71 : task_queue_(std::move(task_queue)), in Handle()
72 sequence_manager_(task_queue_->GetSequenceManagerWeakPtr()) {} in Handle()
81 return task_queue_.get(); in get()
85 return task_queue_.get(); in operator ->()
[all …]
Dwake_up_queue_unittest.cc83 task_queue_ = std::make_unique<TaskQueueImplForTest>( in SetUp()
88 if (task_queue_) in TearDown()
89 task_queue_->UnregisterTaskQueue(); in TearDown()
93 std::unique_ptr<TaskQueueImplForTest> task_queue_; member in base::sequence_manager::internal::WakeUpQueueTest
105 task_queue_->SetNextWakeUp(&lazy_now, WakeUp{delayed_runtime}); in TEST_F()
110 EXPECT_EQ(task_queue_.get(), wake_up_queue_->NextScheduledTaskQueue()); in TEST_F()
127 task_queue_->SetNextWakeUp(&lazy_now, WakeUp{delayed_runtime1}); in TEST_F()
137 task_queue_->SetNextWakeUp(&lazy_now, WakeUp{delayed_runtime2}); in TEST_F()
158 task_queue_->SetNextWakeUp( in TEST_F()
173 task_queue_->SetNextWakeUp( in TEST_F()
[all …]
/external/pigweed/pw_async_basic/
Ddispatcher.cc71 if (task_queue_.empty() || task_queue_.front().due_time_ > now()) { in MaybeSleepUntil()
75 if (!task_queue_.empty()) { in MaybeSleepUntil()
76 auto task_due_time = task_queue_.front().due_time_; in MaybeSleepUntil()
96 while (!task_queue_.empty() && task_queue_.front().due_time_ <= now() && in ExecuteDueTasks()
98 backend::NativeTask& task = task_queue_.front(); in ExecuteDueTasks()
99 task_queue_.pop_front(); in ExecuteDueTasks()
116 while (!task_queue_.empty()) { in DrainTaskQueue()
117 backend::NativeTask& task = task_queue_.front(); in DrainTaskQueue()
118 task_queue_.pop_front(); in DrainTaskQueue()
132 return task_queue_.remove(task.native_type()); in Cancel()
[all …]
Dfake_dispatcher.cc42 while (!task_queue_.empty() && task_queue_.front().due_time() <= end_time && in RunUntil()
44 now_ = task_queue_.front().due_time(); in RunUntil()
65 while (!task_queue_.empty() && task_queue_.front().due_time() <= now() && in ExecuteDueTasks()
67 ::pw::async::backend::NativeTask& task = task_queue_.front(); in ExecuteDueTasks()
68 task_queue_.pop_front(); in ExecuteDueTasks()
85 while (!task_queue_.empty()) { in DrainTaskQueue()
86 ::pw::async::backend::NativeTask& task = task_queue_.front(); in DrainTaskQueue()
87 task_queue_.pop_front(); in DrainTaskQueue()
112 return task_queue_.remove(task.native_type()); in Cancel()
128 auto it_front = task_queue_.begin(); in PostTaskInternal()
[all …]
/external/webrtc/modules/video_coding/utility/
Dquality_scaler_unittest.cc73 task_queue_("QualityScalerTestQueue"), in QualityScalerTest()
75 task_queue_.SendTask( in QualityScalerTest()
83 task_queue_.SendTask([this] { qs_ = nullptr; }); in ~QualityScalerTest()
109 TaskQueueForTest task_queue_; member in webrtc::QualityScalerTest
122 task_queue_.SendTask([this] { TriggerScale(kScaleDown); }); in TEST_P()
129 task_queue_.SendTask([this] { TriggerScale(kKeepScaleAtHighQp); }); in TEST_P()
136 task_queue_.SendTask([this] { TriggerScale(kScaleDownAboveHighQp); }); in TEST_P()
143 task_queue_.SendTask([this] { in TEST_P()
156 task_queue_.SendTask([this] { in TEST_P()
170 task_queue_.SendTask([this] { in TEST_P()
[all …]
/external/webrtc/video/
Dcall_stats2.cc74 task_queue_(task_queue) { in CallStats()
75 RTC_DCHECK(task_queue_); in CallStats()
76 RTC_DCHECK_RUN_ON(task_queue_); in CallStats()
80 RTC_DCHECK_RUN_ON(task_queue_); in ~CallStats()
89 RTC_DCHECK_RUN_ON(task_queue_); in EnsureStarted()
91 RepeatingTaskHandle::DelayedStart(task_queue_, kUpdateInterval, [this]() { in EnsureStarted()
98 RTC_DCHECK_RUN_ON(task_queue_); in UpdateAndReport()
116 RTC_DCHECK_RUN_ON(task_queue_); in RegisterStatsObserver()
122 RTC_DCHECK_RUN_ON(task_queue_); in DeregisterStatsObserver()
127 RTC_DCHECK_RUN_ON(task_queue_); in LastProcessedRtt()
[all …]
Dcall_stats2.h108 RepeatingTaskHandle repeating_task_ RTC_GUARDED_BY(task_queue_);
111 int64_t max_rtt_ms_ RTC_GUARDED_BY(task_queue_);
114 int64_t avg_rtt_ms_ RTC_GUARDED_BY(task_queue_);
116 int64_t sum_avg_rtt_ms_ RTC_GUARDED_BY(task_queue_);
117 int64_t num_avg_rtt_ RTC_GUARDED_BY(task_queue_);
118 int64_t time_of_first_rtt_ms_ RTC_GUARDED_BY(task_queue_);
121 std::list<RttTime> reports_ RTC_GUARDED_BY(task_queue_);
124 std::list<CallStatsObserver*> observers_ RTC_GUARDED_BY(task_queue_);
126 TaskQueueBase* const task_queue_; variable
/external/webrtc/modules/rtp_rtcp/source/
Drtcp_transceiver.cc28 task_queue_(config.task_queue), in RtcpTransceiver()
30 RTC_DCHECK(task_queue_); in RtcpTransceiver()
37 task_queue_->PostTask([rtcp_transceiver = std::move(rtcp_transceiver)] { in ~RtcpTransceiver()
47 task_queue_->PostTask( in Stop()
58 task_queue_->PostTask([ptr, remote_ssrc, observer] { in AddMediaReceiverRtcpObserver()
70 task_queue_->PostTask( in RemoveMediaReceiverRtcpObserver()
79 task_queue_->PostTask([ptr, ready] { ptr->SetReadyToSend(ready); }); in SetReadyToSend()
86 task_queue_->PostTask( in ReceivePacket()
93 task_queue_->PostTask([ptr] { ptr->SendCompoundPacket(); }); in SendCompoundPacket()
100 task_queue_->PostTask([ptr, bitrate_bps, ssrcs = std::move(ssrcs)]() mutable { in SetRemb()
[all …]
/external/webrtc/call/adaptation/
Dresource_adaptation_processor.h99 TaskQueueBase* task_queue_;
100 ResourceAdaptationProcessor* processor_ RTC_GUARDED_BY(task_queue_);
129 RTC_RUN_ON(task_queue_);
138 FindMostLimitedResources() const RTC_RUN_ON(task_queue_);
143 TaskQueueBase* task_queue_; variable
150 RTC_GUARDED_BY(task_queue_);
154 adaptation_limits_by_resources_ RTC_GUARDED_BY(task_queue_);
156 VideoStreamAdapter* const stream_adapter_ RTC_GUARDED_BY(task_queue_);
158 RTC_GUARDED_BY(task_queue_);
162 RTC_GUARDED_BY(task_queue_);
Dresource_adaptation_processor.cc29 : task_queue_(TaskQueueBase::Current()), processor_(processor) { in ResourceListenerDelegate()
30 RTC_DCHECK(task_queue_); in ResourceListenerDelegate()
35 RTC_DCHECK_RUN_ON(task_queue_); in OnProcessorDestroyed()
42 if (!task_queue_->IsCurrent()) { in OnResourceUsageStateMeasured()
43 task_queue_->PostTask( in OnResourceUsageStateMeasured()
50 RTC_DCHECK_RUN_ON(task_queue_); in OnResourceUsageStateMeasured()
67 : task_queue_(TaskQueueBase::Current()), in ResourceAdaptationProcessor()
74 RTC_DCHECK(task_queue_); in ResourceAdaptationProcessor()
79 RTC_DCHECK_RUN_ON(task_queue_); in ~ResourceAdaptationProcessor()
89 RTC_DCHECK_RUN_ON(task_queue_); in AddResourceLimitationsListener()
[all …]
/external/libchrome/base/task/sequence_manager/
Dtime_domain_unittest.cc76 task_queue_ = std::make_unique<TaskQueueImplForTest>( in SetUp()
81 if (task_queue_) in TearDown()
82 task_queue_->UnregisterTaskQueue(); in TearDown()
90 std::unique_ptr<TaskQueueImplForTest> task_queue_; member in base::sequence_manager::TimeDomainTest
99 task_queue_->SetDelayedWakeUpForTesting( in TEST_F()
104 EXPECT_EQ(task_queue_.get(), time_domain_->NextScheduledTaskQueue()); in TEST_F()
119 task_queue_->SetDelayedWakeUpForTesting( in TEST_F()
129 task_queue_->SetDelayedWakeUpForTesting( in TEST_F()
162 task_queue_->SetDelayedWakeUpForTesting( in TEST_F()
197 task_queue_->SetDelayedWakeUpForTesting( in TEST_F()
[all …]
Dwork_queue.cc16 : task_queue_(task_queue), name_(name), queue_type_(queue_type) {} in WorkQueue()
26 DCHECK(!work_queue_sets_) << task_queue_->GetName() << " : " in ~WorkQueue()
57 << task_queue_->GetName() << " : " << work_queue_sets_->GetName() << " : " in GetFrontTaskEnqueueOrder()
95 << task_queue_->GetName() << " : " << work_queue_sets_->GetName() in PushNonNestableTaskToFront()
120 task_queue_->ReloadEmptyImmediateQueue(&tasks_); in ReloadEmptyImmediateQueue()
138 task_queue_->ReloadEmptyImmediateQueue(&tasks_); in TakeTaskFromWorkQueue()
144 task_queue_->TraceQueueSize(); in TakeTaskFromWorkQueue()
160 task_queue_->ReloadEmptyImmediateQueue(&tasks_); in RemoveAllCanceledTasksFromFront()
163 task_queue_->TraceQueueSize(); in RemoveAllCanceledTasksFromFront()
/external/webrtc/test/pc/e2e/
Dtest_activities_executor.cc26 task_queue_ = task_queue; in Start()
36 if (task_queue_ == nullptr) { in Stop()
40 SendTask(task_queue_, [this]() { in Stop()
46 task_queue_ = nullptr; in Stop()
84 task_queue_, [activity, start_time, this]() { in PostActivity()
91 task_queue_, remaining_delay, [activity, start_time, this]() { in PostActivity()
99 task_queue_->PostTask( in PostActivity()
104 task_queue_->PostDelayedTask( in PostActivity()
/external/webrtc/video/adaptation/
Dpixel_limit_resource.cc37 : task_queue_(task_queue), in PixelLimitResource()
40 RTC_DCHECK(task_queue_); in PixelLimitResource()
50 RTC_DCHECK_RUN_ON(task_queue_); in SetMaxPixels()
55 RTC_DCHECK_RUN_ON(task_queue_); in SetResourceListener()
59 repeating_task_ = RepeatingTaskHandle::Start(task_queue_, [&] { in SetResourceListener()
60 RTC_DCHECK_RUN_ON(task_queue_); in SetResourceListener()
Dpixel_limit_resource.h51 TaskQueueBase* const task_queue_;
53 absl::optional<int> max_pixels_ RTC_GUARDED_BY(task_queue_);
54 webrtc::ResourceListener* listener_ RTC_GUARDED_BY(task_queue_);
55 RepeatingTaskHandle repeating_task_ RTC_GUARDED_BY(task_queue_);
/external/webrtc/modules/video_coding/codecs/test/
Dvideoprocessor.h95 task_queue_(TaskQueueBase::Current()) { in VideoProcessorEncodeCompleteCallback()
97 RTC_DCHECK(task_queue_); in VideoProcessorEncodeCompleteCallback()
106 if (!task_queue_->IsCurrent()) { in OnEncodedImage()
108 task_queue_->PostTask([video_processor, encoded_image, in OnEncodedImage()
121 TaskQueueBase* const task_queue_; variable
132 task_queue_(TaskQueueBase::Current()) { in VideoProcessorDecodeCompleteCallback()
134 RTC_DCHECK(task_queue_); in VideoProcessorDecodeCompleteCallback()
153 TaskQueueBase* const task_queue_; variable
/external/webrtc/test/network/
Dnetwork_emulation.h153 task_queue_(task_queue), in LinkEmulation()
168 void Process(Timestamp at_time) RTC_RUN_ON(task_queue_);
171 rtc::TaskQueue* const task_queue_; variable
173 RTC_GUARDED_BY(task_queue_);
176 RepeatingTaskHandle process_task_ RTC_GUARDED_BY(task_queue_);
177 std::deque<StoredPacket> packets_ RTC_GUARDED_BY(task_queue_);
178 uint64_t next_packet_id_ RTC_GUARDED_BY(task_queue_) = 1;
180 EmulatedNetworkNodeStatsBuilder stats_builder_ RTC_GUARDED_BY(task_queue_);
203 rtc::TaskQueue* const task_queue_;
205 RTC_GUARDED_BY(task_queue_);
[all …]

12345