| /external/webrtc/api/task_queue/ |
| D | task_queue_base.cc | 21 ABSL_CONST_INIT thread_local TaskQueueBase* current = nullptr;
25 TaskQueueBase* TaskQueueBase::Current() { in Current()
29 TaskQueueBase::CurrentTaskQueueSetter::CurrentTaskQueueSetter( in CurrentTaskQueueSetter()
30 TaskQueueBase* task_queue) in CurrentTaskQueueSetter()
35 TaskQueueBase::CurrentTaskQueueSetter::~CurrentTaskQueueSetter() { in ~CurrentTaskQueueSetter()
61 TaskQueueBase* TaskQueueBase::Current() { in Current()
62 return static_cast<TaskQueueBase*>(pthread_getspecific(GetQueuePtrTls())); in Current()
65 TaskQueueBase::CurrentTaskQueueSetter::CurrentTaskQueueSetter( in CurrentTaskQueueSetter()
66 TaskQueueBase* task_queue) in CurrentTaskQueueSetter()
67 : previous_(TaskQueueBase::Current()) { in CurrentTaskQueueSetter()
[all …]
|
| D | task_queue_base.h | 25 class RTC_LOCKABLE RTC_EXPORT TaskQueueBase {
57 static TaskQueueBase* Current();
63 explicit CurrentTaskQueueSetter(TaskQueueBase* task_queue);
69 TaskQueueBase* const previous_;
74 virtual ~TaskQueueBase() = default;
78 void operator()(TaskQueueBase* task_queue) const { task_queue->Delete(); } in operator()
|
| /external/webrtc/video/adaptation/ |
| D | video_stream_encoder_resource.h | 32 void RegisterEncoderTaskQueue(TaskQueueBase* encoder_queue);
43 void RegisterAdaptationTaskQueue(TaskQueueBase* resource_adaptation_queue);
54 TaskQueueBase* encoder_queue() const;
60 TaskQueueBase* resource_adaptation_queue() const;
73 TaskQueueBase* encoder_queue_;
74 TaskQueueBase* resource_adaptation_queue_ RTC_GUARDED_BY(lock_);
|
| D | video_stream_encoder_resource.cc | 32 TaskQueueBase* encoder_queue) { in RegisterEncoderTaskQueue()
39 TaskQueueBase* resource_adaptation_queue) { in RegisterAdaptationTaskQueue()
74 TaskQueueBase* VideoStreamEncoderResource::encoder_queue() const { in encoder_queue()
78 TaskQueueBase* VideoStreamEncoderResource::resource_adaptation_queue() const { in resource_adaptation_queue()
|
| D | video_stream_encoder_resource_manager.h | 177 void SetAdaptationQueue(TaskQueueBase* resource_adaptation_queue);
195 TaskQueueBase* resource_adaptation_queue_;
211 void SetAdaptationQueue(TaskQueueBase* resource_adaptation_queue);
227 TaskQueueBase* resource_adaptation_queue_;
|
| /external/webrtc/test/time_controller/ |
| D | simulated_time_controller.h | 44 virtual TaskQueueBase* GetAsTaskQueue() = 0;
53 std::unique_ptr<TaskQueueBase, TaskQueueDeleter> CreateTaskQueue(
85 void StartYield(TaskQueueBase* yielding_from);
87 void StopYield(TaskQueueBase* yielding_from);
102 std::unordered_set<TaskQueueBase*> yielded_;
107 class TokenTaskQueue : public TaskQueueBase {
110 using CurrentTaskQueueSetter = TaskQueueBase::CurrentTaskQueueSetter;
|
| D | simulated_time_controller.cc | 45 std::unique_ptr<TaskQueueBase, TaskQueueDeleter>
77 TaskQueueBase* yielding_from = TaskQueueBase::Current(); in YieldExecution()
165 void SimulatedTimeControllerImpl::StartYield(TaskQueueBase* yielding_from) { in StartYield()
170 void SimulatedTimeControllerImpl::StopYield(TaskQueueBase* yielding_from) { in StopYield()
|
| D | external_time_controller.cc | 128 class ExternalTimeController::TaskQueueWrapper : public TaskQueueBase {
131 std::unique_ptr<TaskQueueBase, TaskQueueDeleter> base) in TaskQueueWrapper() argument
171 std::unique_ptr<TaskQueueBase, TaskQueueDeleter> base_;
212 std::unique_ptr<TaskQueueBase, TaskQueueDeleter>
216 return std::unique_ptr<TaskQueueBase, TaskQueueDeleter>( in CreateTaskQueue()
|
| D | simulated_task_queue.h | 23 class SimulatedTaskQueue : public TaskQueueBase,
37 TaskQueueBase* GetAsTaskQueue() override { return this; } in GetAsTaskQueue()
|
| /external/webrtc/rtc_base/synchronization/ |
| D | sequence_checker.cc | 42 valid_queue_(TaskQueueBase::Current()), in SequenceCheckerImpl()
48 const TaskQueueBase* const current_queue = TaskQueueBase::Current(); in IsCurrent()
77 const TaskQueueBase* const current_queue = TaskQueueBase::Current(); in ExpectationToString()
|
| /external/webrtc/rtc_base/task_utils/ |
| D | repeating_task.h | 31 RepeatingTaskBase(TaskQueueBase* task_queue,
43 TaskQueueBase* const task_queue_;
54 RepeatingTaskImpl(TaskQueueBase* task_queue, in RepeatingTaskImpl()
97 static RepeatingTaskHandle Start(TaskQueueBase* task_queue,
112 TaskQueueBase* task_queue,
|
| D | pending_task_safety_flag_unittest.cc | 70 Owner() : tq_main_(TaskQueueBase::Current()) { RTC_DCHECK(tq_main_); } in TEST()
88 TaskQueueBase* const tq_main_; in TEST()
119 : tq_main_(TaskQueueBase::Current()), stuff_done_(stuff_done) { in TEST()
134 TaskQueueBase* const tq_main_; in TEST()
|
| /external/webrtc/video/end_to_end_tests/ |
| D | probing_tests.cc | 72 explicit InitialProbingTest(bool* success, TaskQueueBase* task_queue)
98 TaskQueueBase* const task_queue_;
125 TriggerMidCallProbingTest(TaskQueueBase* task_queue, bool* success)
178 TaskQueueBase* const task_queue_;
203 ReconfigureTest(TaskQueueBase* task_queue, bool* success)
220 TaskQueueBase* task_queue,
306 TaskQueueBase* const task_queue_;
|
| 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()
215 TaskQueueBase* task_queue) override { in TEST_F()
311 TaskQueueBase* const task_queue_; in TEST_F()
327 explicit EncoderRateStatsTest(TaskQueueBase* task_queue) in TEST_F()
402 TaskQueueBase* const task_queue_; in TEST_F()
|
| D | multi_stream_tester.h | 56 TaskQueueBase* task_queue,
59 TaskQueueBase* task_queue,
|
| /external/webrtc/modules/rtp_rtcp/source/ |
| D | rtp_sender_video_frame_transformer_delegate.h | 34 TaskQueueBase* send_transport_queue);
71 TaskQueueBase* encoder_queue_ = nullptr;
72 TaskQueueBase* send_transport_queue_;
|
| /external/webrtc/rtc_base/ |
| D | task_queue.h | 82 explicit TaskQueue(std::unique_ptr<webrtc::TaskQueueBase,
90 webrtc::TaskQueueBase* Get() { return impl_; } in Get()
127 webrtc::TaskQueueBase* const impl_;
|
| D | task_queue_gcd.cc | 43 class TaskQueueGcd : public TaskQueueBase {
140 std::unique_ptr<TaskQueueBase, TaskQueueDeleter> CreateTaskQueue( in CreateTaskQueue()
143 return std::unique_ptr<TaskQueueBase, TaskQueueDeleter>( in CreateTaskQueue()
|
| /external/webrtc/call/adaptation/ |
| D | resource_adaptation_processor.h | 63 TaskQueueBase* resource_adaptation_queue) override;
95 void SetResourceAdaptationQueue(TaskQueueBase* resource_adaptation_queue);
103 TaskQueueBase* resource_adaptation_queue_;
147 TaskQueueBase* resource_adaptation_queue_;
|
| /external/webrtc/call/ |
| D | rampup_tests.h | 49 TaskQueueBase* task_queue);
94 TaskQueueBase* task_queue,
119 TaskQueueBase* const task_queue_;
134 TaskQueueBase* task_queue);
|
| /external/webrtc/modules/video_coding/codecs/test/ |
| D | videoprocessor.h | 87 task_queue_(TaskQueueBase::Current()) { in VideoProcessorEncodeCompleteCallback()
133 TaskQueueBase* const task_queue_;
144 task_queue_(TaskQueueBase::Current()) { in VideoProcessorDecodeCompleteCallback()
165 TaskQueueBase* const task_queue_;
|
| /external/webrtc/video/ |
| D | rtp_streams_synchronizer2.h | 31 RtpStreamsSynchronizer(TaskQueueBase* main_queue, Syncable* syncable_video);
50 TaskQueueBase* const task_queue_;
|
| /external/webrtc/audio/test/ |
| D | audio_bwe_integration_test.h | 43 TaskQueueBase* task_queue,
46 TaskQueueBase* task_queue) override;
|
| D | audio_bwe_integration_test.cc | 62 TaskQueueBase* task_queue, in CreateSendTransport()
73 TaskQueueBase* task_queue) { in CreateReceiveTransport()
96 TaskQueueBase::Current()->PostDelayedTask(std::unique_ptr<QueuedTask>(this), in Run()
|
| /external/webrtc/test/ |
| D | layer_filtering_transport.h | 33 TaskQueueBase* task_queue,
44 TaskQueueBase* task_queue,
|