Searched refs:PacingController (Results 1 – 11 of 11) sorted by relevance
| /external/webrtc/modules/pacing/ |
| D | pacing_controller.cc | 86 const TimeDelta PacingController::kMaxExpectedQueueLength =
88 const float PacingController::kDefaultPaceMultiplier = 2.5f;
89 const TimeDelta PacingController::kPausedProcessInterval =
91 const TimeDelta PacingController::kMinSleepTime = TimeDelta::Millis(1);
93 PacingController::PacingController(Clock* clock, in PacingController() function in webrtc::PacingController
147 PacingController::~PacingController() = default;
149 void PacingController::CreateProbeCluster(DataRate bitrate, int cluster_id) { in CreateProbeCluster()
153 void PacingController::Pause() { in Pause()
160 void PacingController::Resume() { in Resume()
167 bool PacingController::IsPaused() const { in IsPaused()
[all …]
|
| D | pacing_controller_unittest.cc | 71 class MockPacingControllerCallback : public PacingController::PacketSender {
109 class MockPacketSender : public PacingController::PacketSender {
127 class PacingControllerPadding : public PacingController::PacketSender {
164 class PacingControllerProbing : public PacingController::PacketSender {
210 : public ::testing::TestWithParam<PacingController::ProcessMode> {
217 pacer_ = std::make_unique<PacingController>(&clock_, &callback_, nullptr, in SetUp()
223 return GetParam() == PacingController::ProcessMode::kPeriodic; in PeriodicProcess()
324 std::unique_ptr<PacingController> pacer_;
328 : public ::testing::TestWithParam<PacingController::ProcessMode> {
340 void InsertPacket(PacingController* pacer, MediaStream* stream) { in InsertPacket()
[all …]
|
| D | paced_sender.cc | 41 ? PacingController::ProcessMode::kDynamic in PacedSender()
42 : PacingController::ProcessMode::kPeriodic), in PacedSender()
174 if (process_mode_ == PacingController::ProcessMode::kDynamic) { in TimeUntilNextProcess()
175 return std::max(sleep_time, PacingController::kMinSleepTime).ms(); in TimeUntilNextProcess()
194 process_mode_ == PacingController::ProcessMode::kDynamic) { in MaybeWakupProcessThread()
|
| D | paced_sender_unittest.cc | 72 : public ::testing::TestWithParam<PacingController::ProcessMode> {
77 trials_(GetParam() == PacingController::ProcessMode::kDynamic) {} in PacedSenderTest()
158 ::testing::Values(PacingController::ProcessMode::kPeriodic,
159 PacingController::ProcessMode::kDynamic));
|
| D | pacing_controller.h | 45 class PacingController {
83 PacingController(Clock* clock,
89 ~PacingController();
|
| D | task_queue_paced_sender.h | 54 TimeDelta hold_back_window = PacingController::kMinSleepTime);
134 PacingController pacing_controller_ RTC_GUARDED_BY(task_queue_);
|
| D | paced_sender.h | 161 const PacingController::ProcessMode process_mode_;
162 PacingController pacing_controller_ RTC_GUARDED_BY(critsect_);
|
| D | task_queue_paced_sender.cc | 46 PacingController::ProcessMode::kDynamic), in TaskQueuePacedSender()
222 ? PacingController::kMinSleepTime in MaybeProcessPackets()
229 next_process_time_ - PacingController::kMinSleepTime) { in MaybeProcessPackets()
|
| D | task_queue_paced_sender_unittest.cc | 72 TimeDelta hold_back_window = PacingController::kMinSleepTime) in TaskQueuePacedSenderForTest()
131 PacingController::kMinSleepTime); in TEST()
170 PacingController::kMinSleepTime); in TEST()
221 PacingController::kMinSleepTime); in TEST()
|
| D | packet_router.h | 44 public PacingController::PacketSender {
|
| /external/webrtc/call/ |
| D | rtp_transport_controller_send.cc | 102 /*hold_back_window = */ PacingController::kMinSleepTime) in RtpTransportControllerSend()
|