Searched refs:RunOrPost (Results 1 – 9 of 9) sorted by relevance
| /external/webrtc/modules/pacing/ |
| D | task_queue_paced_sender.cc | 103 task_queue_.RunOrPost([&]() { in ~TaskQueuePacedSender()
110 task_queue_.RunOrPost([this]() { in EnsureStarted()
119 task_queue_.RunOrPost( in CreateProbeClusters()
128 task_queue_.RunOrPost([this]() { in Pause()
135 task_queue_.RunOrPost([this]() { in Resume()
143 task_queue_.RunOrPost([this, congested]() { in SetCongested()
152 task_queue_.RunOrPost([this, pacing_rate, padding_rate]() { in SetPacingRates()
185 task_queue_.RunOrPost([this, account_for_audio]() { in SetAccountForAudioPackets()
193 task_queue_.RunOrPost([this]() { in SetIncludeOverhead()
202 task_queue_.RunOrPost([this, overhead_per_packet]() { in SetTransportOverhead()
[all …]
|
| /external/webrtc/call/ |
| D | rtp_transport_controller_send.cc | 246 task_queue_.RunOrPost([this, observer] { in RegisterTargetTransferRateObserver()
306 task_queue_.RunOrPost([this, network_route] { in OnNetworkRouteChanged()
335 task_queue_.RunOrPost([this, msg, network_route] { in OnNetworkRouteChanged()
358 task_queue_.RunOrPost([this, msg]() { in OnNetworkAvailability()
395 task_queue_.RunOrPost([this, enable]() { in EnablePeriodicAlrProbing()
429 task_queue_.RunOrPost([this, packet_msg]() { in OnReceivedPacket()
439 task_queue_.RunOrPost([this, msg]() { in UpdateBitrateConstraints()
520 task_queue_.RunOrPost([this, msg]() { in OnReceivedEstimatedBitrate()
531 task_queue_.RunOrPost([this, report_blocks, now_ms, rtt_ms]() { in OnReceivedRtcpReceiverReport()
547 task_queue_.RunOrPost([this, packet_info, creation_time]() { in OnAddPacket()
[all …]
|
| D | rtp_video_sender_unittest.cc | 212 transport_controller_.GetWorkerQueue()->RunOrPost(std::move(task)); in RunOnTransportQueue()
|
| /external/webrtc/modules/utility/ |
| D | maybe_worker_thread_unittests.cc | 36 m.RunOrPost([&] { in TEST()
50 m.RunOrPost([&] { in TEST()
146 m.RunOrPost([&] { EXPECT_TRUE(m.IsCurrent()); }); in TEST()
156 m.RunOrPost([&] { EXPECT_TRUE(m.IsCurrent()); }); in TEST()
|
| D | maybe_worker_thread.h | 50 void RunOrPost(absl::AnyInvocable<void() &&> task);
|
| D | maybe_worker_thread.cc | 64 void MaybeWorkerThread::RunOrPost(absl::AnyInvocable<void() &&> task) { in RunOrPost() function in webrtc::MaybeWorkerThread
|
| /external/webrtc/video/ |
| D | video_send_stream.cc | 241 rtp_transport_queue_->RunOrPost( in StartPerRtpStream()
255 rtp_transport_queue_->RunOrPost(SafeTask(transport_queue_safety_, [this] { in Stop()
|
| D | video_send_stream_impl.cc | 291 rtp_transport_queue_->RunOrPost(SafeTask(transport_queue_safety_, [this] { in VideoSendStreamImpl()
|
| /external/webrtc/audio/ |
| D | audio_send_stream.cc | 852 rtp_transport_queue_->RunOrPost([this, constraints, priority_bitrate, in ConfigureBitrateObserver()
933 rtp_transport_queue_->RunOrPost([this, new_constraints]() { in UpdateCachedTargetAudioBitrateConstraints()
|