diff --git a/call/rtp_transport_controller_send.cc b/call/rtp_transport_controller_send.cc index 54aef21fd9..a0a5547287 100644 --- a/call/rtp_transport_controller_send.cc +++ b/call/rtp_transport_controller_send.cc @@ -26,11 +26,6 @@ static const size_t kMaxOverheadBytes = 500; const char kTaskQueueExperiment[] = "WebRTC-TaskQueueCongestionControl"; using TaskQueueController = webrtc::webrtc_cc::SendSideCongestionController; -bool TaskQueueExperimentEnabled() { - std::string trial = webrtc::field_trial::FindFullName(kTaskQueueExperiment); - return trial.find("Enable") == 0; -} - std::unique_ptr CreateController( Clock* clock, rtc::TaskQueue* task_queue, @@ -70,9 +65,9 @@ RtpTransportControllerSend::RtpTransportControllerSend( retransmission_rate_limiter_(clock, kRetransmitWindowSizeMs), task_queue_("rtp_send_controller") { // Created after task_queue to be able to post to the task queue internally. - send_side_cc_ = - CreateController(clock, &task_queue_, event_log, &pacer_, bitrate_config, - TaskQueueExperimentEnabled(), controller_factory); + send_side_cc_ = CreateController( + clock, &task_queue_, event_log, &pacer_, bitrate_config, + !field_trial::IsDisabled(kTaskQueueExperiment), controller_factory); process_thread_->RegisterModule(&pacer_, RTC_FROM_HERE); process_thread_->RegisterModule(send_side_cc_.get(), RTC_FROM_HERE);