/aosp_15_r20/external/webrtc/api/task_queue/ |
H A D | task_queue_base.cc | 23 ABSL_CONST_INIT thread_local TaskQueueBase* current = nullptr; 27 TaskQueueBase* TaskQueueBase::Current() { in Current() 31 TaskQueueBase::CurrentTaskQueueSetter::CurrentTaskQueueSetter( in CurrentTaskQueueSetter() 32 TaskQueueBase* task_queue) in CurrentTaskQueueSetter() 37 TaskQueueBase::CurrentTaskQueueSetter::~CurrentTaskQueueSetter() { in ~CurrentTaskQueueSetter() 63 TaskQueueBase* TaskQueueBase::Current() { in Current() 64 return static_cast<TaskQueueBase*>(pthread_getspecific(GetQueuePtrTls())); in Current() 67 TaskQueueBase::CurrentTaskQueueSetter::CurrentTaskQueueSetter( in CurrentTaskQueueSetter() 68 TaskQueueBase* task_queue) in CurrentTaskQueueSetter() 69 : previous_(TaskQueueBase::Current()) { in CurrentTaskQueueSetter() [all …]
|
H A D | task_queue_base.h | 27 class RTC_LOCKABLE RTC_EXPORT TaskQueueBase { 124 static TaskQueueBase* Current(); 130 explicit CurrentTaskQueueSetter(TaskQueueBase* task_queue); 136 TaskQueueBase* const previous_; 141 virtual ~TaskQueueBase() = default; 145 void operator()(TaskQueueBase* task_queue) const { task_queue->Delete(); } in operator()
|
H A D | pending_task_safety_flag_unittest.cc | 62 Owner() : tq_main_(TaskQueueBase::Current()) { RTC_DCHECK(tq_main_); } in TEST() 81 TaskQueueBase* const tq_main_; in TEST() 108 : tq_main_(TaskQueueBase::Current()), stuff_done_(stuff_done) { in TEST() 121 TaskQueueBase* const tq_main_; in TEST()
|
/aosp_15_r20/external/webrtc/rtc_base/task_utils/ |
H A D | repeating_task.cc | 22 RepeatingTask(TaskQueueBase* task_queue, 23 TaskQueueBase::DelayPrecision precision, 35 TaskQueueBase* const task_queue_; 36 const TaskQueueBase::DelayPrecision precision_; 46 TaskQueueBase* task_queue, in RepeatingTask() 47 TaskQueueBase::DelayPrecision precision, in RepeatingTask() 85 TaskQueueBase* task_queue, in Start() 87 TaskQueueBase::DelayPrecision precision, in Start() 99 TaskQueueBase* task_queue, in DelayedStart() 102 TaskQueueBase::DelayPrecision precision, in DelayedStart()
|
H A D | repeating_task_unittest.cc | 44 class MockTaskQueue : public TaskQueueBase { 63 class FakeTaskQueue : public TaskQueueBase { 79 last_precision_ = TaskQueueBase::DelayPrecision::kLow; in PostDelayedTask() 86 last_precision_ = TaskQueueBase::DelayPrecision::kHigh; in PostDelayedHighPrecisionTask() 107 absl::optional<TaskQueueBase::DelayPrecision> last_precision() const { in last_precision() 116 absl::optional<TaskQueueBase::DelayPrecision> last_precision_; 155 TaskQueueBase::DelayPrecision::kLow, &clock); in TEST() 186 TaskQueueBase::DelayPrecision::kLow, &clock); in TEST() 209 TaskQueueBase::DelayPrecision::kLow, &clock); in TEST() 309 TaskQueueBase* task_queue) { in TEST() [all …]
|
H A D | repeating_task.h | 55 static RepeatingTaskHandle Start(TaskQueueBase* task_queue, 57 TaskQueueBase::DelayPrecision precision = 58 TaskQueueBase::DelayPrecision::kLow, 64 TaskQueueBase* task_queue, 67 TaskQueueBase::DelayPrecision precision = 68 TaskQueueBase::DelayPrecision::kLow,
|
/aosp_15_r20/external/webrtc/call/ |
H A D | degraded_call.h | 98 TaskQueueBase* network_thread() const override; 99 TaskQueueBase* worker_thread() const override; 124 TaskQueueBase* task_queue, 144 TaskQueueBase* const task_queue_; 152 ThreadedPacketReceiver(webrtc::TaskQueueBase* worker_thread, 153 webrtc::TaskQueueBase* network_thread, 163 webrtc::TaskQueueBase* const worker_thread_; 164 webrtc::TaskQueueBase* const network_thread_;
|
H A D | call_perf_tests.cc | 114 explicit VideoRtcpAndSyncObserver(TaskQueueBase* task_queue, in VideoRtcpAndSyncObserver() 157 RTC_DCHECK_EQ(task_queue_, TaskQueueBase::Current()); in set_receive_stream() 175 TaskQueueBase* const task_queue_; 416 TaskQueueBase* task_queue, in TestCaptureNtpTime() 427 TaskQueueBase* task_queue) override { in TestCaptureNtpTime() 677 TaskQueueBase* task_queue) in TestMinTransmitBitrate() 755 TaskQueueBase* task_queue_; in TestMinTransmitBitrate() 804 explicit BitrateObserver(TaskQueueBase* task_queue) in TEST_F() 902 TaskQueueBase* task_queue_; in TEST_F() 938 TaskQueueBase* task_queue) in TestMinAudioVideoBitrate() [all …]
|
H A D | rampup_tests.h | 51 TaskQueueBase* task_queue); 97 TaskQueueBase* task_queue, 122 TaskQueueBase* const task_queue_; 137 TaskQueueBase* task_queue);
|
/aosp_15_r20/external/webrtc/test/time_controller/ |
H A D | simulated_time_controller.h | 42 virtual TaskQueueBase* GetAsTaskQueue() = 0; 51 std::unique_ptr<TaskQueueBase, TaskQueueDeleter> CreateTaskQueue( 81 void StartYield(TaskQueueBase* yielding_from); 83 void StopYield(TaskQueueBase* yielding_from); 98 std::unordered_set<TaskQueueBase*> yielded_; 103 class TokenTaskQueue : public TaskQueueBase { 106 using CurrentTaskQueueSetter = TaskQueueBase::CurrentTaskQueueSetter;
|
H A D | external_time_controller.cc | 30 class ExternalTimeController::TaskQueueWrapper : public TaskQueueBase { 33 std::unique_ptr<TaskQueueBase, TaskQueueDeleter> base) in TaskQueueWrapper() argument 68 std::unique_ptr<TaskQueueBase, TaskQueueDeleter> base_; 103 std::unique_ptr<TaskQueueBase, TaskQueueDeleter> 107 return std::unique_ptr<TaskQueueBase, TaskQueueDeleter>( in CreateTaskQueue()
|
H A D | simulated_time_controller.cc | 44 std::unique_ptr<TaskQueueBase, TaskQueueDeleter> 67 TaskQueueBase* yielding_from = TaskQueueBase::Current(); in YieldExecution() 155 void SimulatedTimeControllerImpl::StartYield(TaskQueueBase* yielding_from) { in StartYield() 160 void SimulatedTimeControllerImpl::StopYield(TaskQueueBase* yielding_from) { in StopYield()
|
/aosp_15_r20/external/webrtc/net/dcsctp/timer/ |
H A D | task_queue_timeout.h | 40 TaskQueueTimeoutFactory(webrtc::TaskQueueBase& task_queue, in TaskQueueTimeoutFactory() 49 webrtc::TaskQueueBase::DelayPrecision precision = 50 webrtc::TaskQueueBase::DelayPrecision::kLow) { 58 webrtc::TaskQueueBase::DelayPrecision precision); 66 const webrtc::TaskQueueBase::DelayPrecision precision_; 86 webrtc::TaskQueueBase& task_queue_;
|
H A D | timer.h | 60 webrtc::TaskQueueBase::DelayPrecision::kLow) {} in TimerOptions() 65 webrtc::TaskQueueBase::DelayPrecision precision) in TimerOptions() 83 const webrtc::TaskQueueBase::DelayPrecision precision; 190 webrtc::TaskQueueBase::DelayPrecision)> create_timeout) in TimerManager() 204 webrtc::TaskQueueBase::DelayPrecision)>
|
H A D | timer_test.cc | 29 manager_([this](webrtc::TaskQueueBase::DelayPrecision precision) { in __anon4d5868470302() 431 absl::optional<webrtc::TaskQueueBase::DelayPrecision> create_timer_precison; in TEST() 432 TimerManager manager([&](webrtc::TaskQueueBase::DelayPrecision precision) { in TEST() 440 EXPECT_EQ(create_timer_precison, webrtc::TaskQueueBase::DelayPrecision::kLow); in TEST() 446 webrtc::TaskQueueBase::DelayPrecision::kHigh)); in TEST() 448 webrtc::TaskQueueBase::DelayPrecision::kHigh); in TEST() 454 webrtc::TaskQueueBase::DelayPrecision::kLow)); in TEST() 455 EXPECT_EQ(create_timer_precison, webrtc::TaskQueueBase::DelayPrecision::kLow); in TEST()
|
/aosp_15_r20/external/webrtc/rtc_base/synchronization/ |
H A D | sequence_checker_internal.cc | 39 valid_queue_(TaskQueueBase::Current()), in SequenceCheckerImpl() 43 const TaskQueueBase* const current_queue = TaskQueueBase::Current(); in IsCurrent() 72 const TaskQueueBase* const current_queue = TaskQueueBase::Current(); in ExpectationToString()
|
/aosp_15_r20/external/webrtc/modules/utility/ |
H A D | maybe_worker_thread.h | 58 TaskQueueBase* TaskQueueForDelayedTasks() const; 62 TaskQueueBase* TaskQueueForPost() const; 80 std::unique_ptr<TaskQueueBase, TaskQueueDeleter> owned_task_queue_; 81 TaskQueueBase* const worker_thread_;
|
/aosp_15_r20/external/webrtc/video/end_to_end_tests/ |
H A D | bandwidth_tests.cc | 87 BandwidthStatsTest(bool send_side_bwe, TaskQueueBase* task_queue) in BandwidthStatsTest() 175 TaskQueueBase* const task_queue_; 196 explicit BweObserver(TaskQueueBase* task_queue) in TEST_F() 210 TaskQueueBase* task_queue) override { in TEST_F() 307 TaskQueueBase* const task_queue_; in TEST_F() 322 explicit EncoderRateStatsTest(TaskQueueBase* task_queue) in TEST_F() 397 TaskQueueBase* const task_queue_; in TEST_F()
|
H A D | stats_tests.cc | 232 TaskQueueBase* task_queue, in TEST_F() 294 task_queue_ = TaskQueueBase::Current(); in TEST_F() 344 TaskQueueBase* task_queue_ = nullptr; in TEST_F() 376 task_queue_ = TaskQueueBase::Current(); in TEST_F() 397 TaskQueueBase* task_queue_ = nullptr; in TEST_F() 407 explicit ReceivedRtpStatsObserver(TaskQueueBase* task_queue) in TEST_F() 442 TaskQueueBase* const task_queue_; in TEST_F() 590 explicit NackObserver(TaskQueueBase* task_queue) in TEST_F() 681 TaskQueueBase* const task_queue_; in TEST_F()
|
/aosp_15_r20/external/webrtc/p2p/base/ |
H A D | stun_request.h | 43 webrtc::TaskQueueBase* thread, 77 webrtc::TaskQueueBase* network_thread() const { return thread_; } in network_thread() 84 webrtc::TaskQueueBase* const thread_; 139 webrtc::TaskQueueBase* network_thread() const { in network_thread()
|
/aosp_15_r20/external/webrtc/video/adaptation/ |
H A D | video_stream_encoder_resource.h | 31 void RegisterEncoderTaskQueue(TaskQueueBase* encoder_queue); 43 TaskQueueBase* encoder_queue() const; 49 TaskQueueBase* encoder_queue_;
|
H A D | pixel_limit_resource.h | 37 TaskQueueBase* task_queue, 40 PixelLimitResource(TaskQueueBase* task_queue, 51 TaskQueueBase* const task_queue_;
|
/aosp_15_r20/external/webrtc/modules/pacing/ |
H A D | task_queue_paced_sender.cc | 315 TaskQueueBase::DelayPrecision precision = in MaybeProcessPackets() 318 ? TaskQueueBase::DelayPrecision::kLow in MaybeProcessPackets() 319 : TaskQueueBase::DelayPrecision::kHigh; in MaybeProcessPackets() 321 if (precision == TaskQueueBase::DelayPrecision::kLow) { in MaybeProcessPackets() 335 precision = TaskQueueBase::DelayPrecision::kHigh; in MaybeProcessPackets()
|
/aosp_15_r20/external/webrtc/video/ |
H A D | frame_cadence_adapter.cc | 99 ZeroHertzAdapterMode(TaskQueueBase* queue, 193 TaskQueueBase* const queue_; 226 TaskQueueBase* queue, 267 TaskQueueBase* const queue_; 305 TaskQueueBase* queue, in ZeroHertzAdapterMode() 590 TaskQueueBase* queue, in FrameCadenceAdapterImpl() 798 TaskQueueBase* queue, in Create()
|
/aosp_15_r20/external/webrtc/modules/video_coding/codecs/test/ |
H A D | videoprocessor.h | 95 task_queue_(TaskQueueBase::Current()) { in VideoProcessorEncodeCompleteCallback() 121 TaskQueueBase* const task_queue_; 132 task_queue_(TaskQueueBase::Current()) { in VideoProcessorDecodeCompleteCallback() 153 TaskQueueBase* const task_queue_;
|