Home
last modified time | relevance | path

Searched refs:TaskQueueBase (Results 1 – 25 of 215) sorted by relevance

123456789

/aosp_15_r20/external/webrtc/api/task_queue/
H A Dtask_queue_base.cc23 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 Dtask_queue_base.h27 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 Dpending_task_safety_flag_unittest.cc62 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 Drepeating_task.cc22 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 Drepeating_task_unittest.cc44 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 Drepeating_task.h55 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 Ddegraded_call.h98 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 Dcall_perf_tests.cc114 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 Drampup_tests.h51 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 Dsimulated_time_controller.h42 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 Dexternal_time_controller.cc30 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 Dsimulated_time_controller.cc44 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 Dtask_queue_timeout.h40 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 Dtimer.h60 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 Dtimer_test.cc29 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 Dsequence_checker_internal.cc39 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 Dmaybe_worker_thread.h58 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 Dbandwidth_tests.cc87 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 Dstats_tests.cc232 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 Dstun_request.h43 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 Dvideo_stream_encoder_resource.h31 void RegisterEncoderTaskQueue(TaskQueueBase* encoder_queue);
43 TaskQueueBase* encoder_queue() const;
49 TaskQueueBase* encoder_queue_;
H A Dpixel_limit_resource.h37 TaskQueueBase* task_queue,
40 PixelLimitResource(TaskQueueBase* task_queue,
51 TaskQueueBase* const task_queue_;
/aosp_15_r20/external/webrtc/modules/pacing/
H A Dtask_queue_paced_sender.cc315 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 Dframe_cadence_adapter.cc99 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 Dvideoprocessor.h95 task_queue_(TaskQueueBase::Current()) { in VideoProcessorEncodeCompleteCallback()
121 TaskQueueBase* const task_queue_;
132 task_queue_(TaskQueueBase::Current()) { in VideoProcessorDecodeCompleteCallback()
153 TaskQueueBase* const task_queue_;

123456789