| Index: webrtc/modules/congestion_controller/transport_feedback_adapter.cc
|
| diff --git a/webrtc/modules/congestion_controller/transport_feedback_adapter.cc b/webrtc/modules/congestion_controller/transport_feedback_adapter.cc
|
| index 918b9c5b0e11aa914a345f0af94270d1ef38b8ab..7f3f744ecf70a811610fc7fd05a6d87811b07ffb 100644
|
| --- a/webrtc/modules/congestion_controller/transport_feedback_adapter.cc
|
| +++ b/webrtc/modules/congestion_controller/transport_feedback_adapter.cc
|
| @@ -9,8 +9,6 @@
|
| */
|
|
|
| #include "webrtc/modules/congestion_controller/transport_feedback_adapter.h"
|
| -
|
| -#include <algorithm>
|
|
|
| #include "webrtc/modules/congestion_controller/delay_based_bwe.h"
|
| #include "webrtc/modules/rtp_rtcp/source/rtcp_packet/transport_feedback.h"
|
| @@ -105,12 +103,11 @@
|
| std::vector<PacketFeedback> TransportFeedbackAdapter::GetPacketFeedbackVector(
|
| const rtcp::TransportFeedback& feedback) {
|
| int64_t timestamp_us = feedback.GetBaseTimeUs();
|
| - int64_t now_ms = clock_->TimeInMilliseconds();
|
| // Add timestamp deltas to a local time base selected on first packet arrival.
|
| // This won't be the true time base, but makes it easier to manually inspect
|
| // time stamps.
|
| if (last_timestamp_us_ == kNoTimestamp) {
|
| - current_offset_ms_ = now_ms;
|
| + current_offset_ms_ = clock_->TimeInMilliseconds();
|
| } else {
|
| int64_t delta = timestamp_us - last_timestamp_us_;
|
|
|
| @@ -131,7 +128,7 @@
|
| return packet_feedback_vector;
|
| }
|
| packet_feedback_vector.reserve(feedback.GetPacketStatusCount());
|
| - int64_t feedback_rtt = -1;
|
| +
|
| {
|
| rtc::CritScope cs(&lock_);
|
| size_t failed_lookups = 0;
|
| @@ -161,12 +158,6 @@
|
| ++failed_lookups;
|
| if (packet_feedback.local_net_id == local_net_id_ &&
|
| packet_feedback.remote_net_id == remote_net_id_) {
|
| - if (packet_feedback.send_time_ms >= 0) {
|
| - int64_t rtt = now_ms - packet_feedback.send_time_ms;
|
| - // max() is used to account for feedback being delayed by the
|
| - // receiver.
|
| - feedback_rtt = std::max(rtt, feedback_rtt);
|
| - }
|
| packet_feedback_vector.push_back(packet_feedback);
|
| }
|
|
|
| @@ -177,14 +168,6 @@
|
| LOG(LS_WARNING) << "Failed to lookup send time for " << failed_lookups
|
| << " packet" << (failed_lookups > 1 ? "s" : "")
|
| << ". Send time history too small?";
|
| - }
|
| - if (feedback_rtt > -1) {
|
| - feedback_rtts_.push_back(feedback_rtt);
|
| - const size_t kFeedbackRttWindow = 32;
|
| - if (feedback_rtts_.size() > kFeedbackRttWindow)
|
| - feedback_rtts_.pop_front();
|
| - min_feedback_rtt_.emplace(
|
| - *std::min_element(feedback_rtts_.begin(), feedback_rtts_.end()));
|
| }
|
| }
|
| return packet_feedback_vector;
|
| @@ -205,14 +188,4 @@
|
| TransportFeedbackAdapter::GetTransportFeedbackVector() const {
|
| return last_packet_feedback_vector_;
|
| }
|
| -
|
| -rtc::Optional<int64_t> TransportFeedbackAdapter::GetMinFeedbackLoopRtt() const {
|
| - rtc::CritScope cs(&lock_);
|
| - return min_feedback_rtt_;
|
| -}
|
| -
|
| -size_t TransportFeedbackAdapter::GetOutstandingBytes() const {
|
| - rtc::CritScope cs(&lock_);
|
| - return send_time_history_.GetOutstandingBytes(local_net_id_, remote_net_id_);
|
| -}
|
| } // namespace webrtc
|
|
|