| Index: webrtc/modules/remote_bitrate_estimator/test/estimators/send_side.cc
|
| diff --git a/webrtc/modules/remote_bitrate_estimator/test/estimators/send_side.cc b/webrtc/modules/remote_bitrate_estimator/test/estimators/send_side.cc
|
| index 0b9312890fdc2e821c0f9760fe6620613b714172..0203a910d8e1d9da3626deee9ce64bb7fe40496e 100644
|
| --- a/webrtc/modules/remote_bitrate_estimator/test/estimators/send_side.cc
|
| +++ b/webrtc/modules/remote_bitrate_estimator/test/estimators/send_side.cc
|
| @@ -13,7 +13,7 @@
|
| #include <algorithm>
|
|
|
| #include "webrtc/base/logging.h"
|
| -#include "webrtc/modules/remote_bitrate_estimator/remote_bitrate_estimator_abs_send_time.h"
|
| +#include "webrtc/modules/congestion_controller/delay_based_bwe.h"
|
| #include "webrtc/modules/remote_bitrate_estimator/test/bwe_test_logging.h"
|
|
|
| namespace webrtc {
|
| @@ -22,12 +22,14 @@ namespace bwe {
|
|
|
| const int kFeedbackIntervalMs = 50;
|
|
|
| -FullBweSender::FullBweSender(int kbps, BitrateObserver* observer, Clock* clock)
|
| +SendSideBweSender::SendSideBweSender(int kbps,
|
| + BitrateObserver* observer,
|
| + Clock* clock)
|
| : bitrate_controller_(
|
| BitrateController::CreateBitrateController(clock,
|
| observer,
|
| &event_log_)),
|
| - rbe_(new RemoteBitrateEstimatorAbsSendTime(this, clock)),
|
| + bwe_(new DelayBasedBwe(clock)),
|
| feedback_observer_(bitrate_controller_->CreateRtcpBandwidthObserver()),
|
| clock_(clock),
|
| send_time_history_(clock_, 10000),
|
| @@ -39,17 +41,16 @@ FullBweSender::FullBweSender(int kbps, BitrateObserver* observer, Clock* clock)
|
| bitrate_controller_->SetStartBitrate(1000 * kbps);
|
| bitrate_controller_->SetMinMaxBitrate(1000 * kMinBitrateKbps,
|
| 1000 * kMaxBitrateKbps);
|
| - rbe_->SetMinBitrate(1000 * kMinBitrateKbps);
|
| + bwe_->SetMinBitrate(1000 * kMinBitrateKbps);
|
| }
|
|
|
| -FullBweSender::~FullBweSender() {
|
| -}
|
| +SendSideBweSender::~SendSideBweSender() {}
|
|
|
| -int FullBweSender::GetFeedbackIntervalMs() const {
|
| +int SendSideBweSender::GetFeedbackIntervalMs() const {
|
| return kFeedbackIntervalMs;
|
| }
|
|
|
| -void FullBweSender::GiveFeedback(const FeedbackPacket& feedback) {
|
| +void SendSideBweSender::GiveFeedback(const FeedbackPacket& feedback) {
|
| const SendSideBweFeedback& fb =
|
| static_cast<const SendSideBweFeedback&>(feedback);
|
| if (fb.packet_feedback_vector().empty())
|
| @@ -67,10 +68,14 @@ void FullBweSender::GiveFeedback(const FeedbackPacket& feedback) {
|
|
|
| int64_t rtt_ms =
|
| clock_->TimeInMilliseconds() - feedback.latest_send_time_ms();
|
| - rbe_->OnRttUpdate(rtt_ms, rtt_ms);
|
| + bwe_->OnRttUpdate(rtt_ms, rtt_ms);
|
| BWE_TEST_LOGGING_PLOT(1, "RTT", clock_->TimeInMilliseconds(), rtt_ms);
|
|
|
| - rbe_->IncomingPacketFeedbackVector(packet_feedback_vector);
|
| + DelayBasedBwe::Result result =
|
| + bwe_->IncomingPacketFeedbackVector(packet_feedback_vector);
|
| + if (result.updated)
|
| + bitrate_controller_->OnDelayBasedBweResult(result);
|
| +
|
| if (has_received_ack_) {
|
| int expected_packets = fb.packet_feedback_vector().back().sequence_number -
|
| last_acked_seq_num_;
|
| @@ -99,7 +104,7 @@ void FullBweSender::GiveFeedback(const FeedbackPacket& feedback) {
|
| }
|
| }
|
|
|
| -void FullBweSender::OnPacketsSent(const Packets& packets) {
|
| +void SendSideBweSender::OnPacketsSent(const Packets& packets) {
|
| for (Packet* packet : packets) {
|
| if (packet->GetPacketType() == Packet::kMedia) {
|
| MediaPacket* media_packet = static_cast<MediaPacket*>(packet);
|
| @@ -114,17 +119,17 @@ void FullBweSender::OnPacketsSent(const Packets& packets) {
|
| }
|
| }
|
|
|
| -void FullBweSender::OnReceiveBitrateChanged(const std::vector<uint32_t>& ssrcs,
|
| - uint32_t bitrate) {
|
| +void SendSideBweSender::OnReceiveBitrateChanged(
|
| + const std::vector<uint32_t>& ssrcs,
|
| + uint32_t bitrate) {
|
| feedback_observer_->OnReceivedEstimatedBitrate(bitrate);
|
| }
|
|
|
| -int64_t FullBweSender::TimeUntilNextProcess() {
|
| +int64_t SendSideBweSender::TimeUntilNextProcess() {
|
| return bitrate_controller_->TimeUntilNextProcess();
|
| }
|
|
|
| -void FullBweSender::Process() {
|
| - rbe_->Process();
|
| +void SendSideBweSender::Process() {
|
| bitrate_controller_->Process();
|
| }
|
|
|
|
|