Index: webrtc/modules/pacing/bitrate_prober.cc |
diff --git a/webrtc/modules/pacing/bitrate_prober.cc b/webrtc/modules/pacing/bitrate_prober.cc |
index e4de4a8dadc120c869b91dd4110ac887e34692e9..1f515bfb1a1a917c831f06e51e0e72aaca465f78 100644 |
--- a/webrtc/modules/pacing/bitrate_prober.cc |
+++ b/webrtc/modules/pacing/bitrate_prober.cc |
@@ -86,6 +86,7 @@ void BitrateProber::OnIncomingPacket(size_t packet_size) { |
void BitrateProber::CreateProbeCluster(int bitrate_bps, int64_t now_ms) { |
RTC_DCHECK(probing_state_ != ProbingState::kDisabled); |
+ RTC_DCHECK_GT(bitrate_bps, 0); |
while (!clusters_.empty() && |
now_ms - clusters_.front().time_created_ms > kProbeClusterTimeoutMs) { |
clusters_.pop(); |
@@ -151,7 +152,7 @@ int BitrateProber::TimeUntilNextProbe(int64_t now_ms) { |
PacedPacketInfo BitrateProber::CurrentCluster() const { |
RTC_DCHECK(!clusters_.empty()); |
- RTC_DCHECK(ProbingState::kActive == probing_state_); |
+ RTC_DCHECK(probing_state_ == ProbingState::kActive); |
return clusters_.front().pace_info; |
} |
@@ -176,7 +177,7 @@ void BitrateProber::ProbeSent(int64_t now_ms, size_t bytes) { |
} |
cluster->sent_bytes += static_cast<int>(bytes); |
cluster->sent_probes += 1; |
- next_probe_time_ms_ = GetNextProbeTime(clusters_.front()); |
+ next_probe_time_ms_ = GetNextProbeTime(*cluster); |
if (cluster->sent_bytes >= cluster->pace_info.probe_cluster_min_bytes && |
cluster->sent_probes >= cluster->pace_info.probe_cluster_min_probes) { |
clusters_.pop(); |