Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1211)

Unified Diff: webrtc/modules/congestion_controller/transport_feedback_adapter.cc

Issue 3001653002: Revert of Add functionality which limits the number of bytes on the network. (Closed)
Patch Set: Created 3 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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
« no previous file with comments | « webrtc/modules/congestion_controller/transport_feedback_adapter.h ('k') | webrtc/modules/pacing/paced_sender.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698