OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 1077 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1088 1000000; | 1088 1000000; |
1089 acked_time_series.points.emplace_back(x, y); | 1089 acked_time_series.points.emplace_back(x, y); |
1090 } | 1090 } |
1091 ++rtcp_iterator; | 1091 ++rtcp_iterator; |
1092 } | 1092 } |
1093 if (clock.TimeInMicroseconds() >= NextRtpTime()) { | 1093 if (clock.TimeInMicroseconds() >= NextRtpTime()) { |
1094 RTC_DCHECK_EQ(clock.TimeInMicroseconds(), NextRtpTime()); | 1094 RTC_DCHECK_EQ(clock.TimeInMicroseconds(), NextRtpTime()); |
1095 const LoggedRtpPacket& rtp = *rtp_iterator->second; | 1095 const LoggedRtpPacket& rtp = *rtp_iterator->second; |
1096 if (rtp.header.extension.hasTransportSequenceNumber) { | 1096 if (rtp.header.extension.hasTransportSequenceNumber) { |
1097 RTC_DCHECK(rtp.header.extension.hasTransportSequenceNumber); | 1097 RTC_DCHECK(rtp.header.extension.hasTransportSequenceNumber); |
1098 cc.AddPacket(rtp.header.extension.transportSequenceNumber, | 1098 cc.AddPacket(rtp.header.ssrc, |
| 1099 rtp.header.extension.transportSequenceNumber, |
1099 rtp.total_length, PacedPacketInfo()); | 1100 rtp.total_length, PacedPacketInfo()); |
1100 rtc::SentPacket sent_packet( | 1101 rtc::SentPacket sent_packet( |
1101 rtp.header.extension.transportSequenceNumber, rtp.timestamp / 1000); | 1102 rtp.header.extension.transportSequenceNumber, rtp.timestamp / 1000); |
1102 cc.OnSentPacket(sent_packet); | 1103 cc.OnSentPacket(sent_packet); |
1103 } | 1104 } |
1104 ++rtp_iterator; | 1105 ++rtp_iterator; |
1105 } | 1106 } |
1106 if (clock.TimeInMicroseconds() >= NextProcessTime()) { | 1107 if (clock.TimeInMicroseconds() >= NextProcessTime()) { |
1107 RTC_DCHECK_EQ(clock.TimeInMicroseconds(), NextProcessTime()); | 1108 RTC_DCHECK_EQ(clock.TimeInMicroseconds(), NextProcessTime()); |
1108 cc.Process(); | 1109 cc.Process(); |
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1189 time_series.points.emplace_back(x, y); | 1190 time_series.points.emplace_back(x, y); |
1190 } | 1191 } |
1191 } | 1192 } |
1192 ++rtcp_iterator; | 1193 ++rtcp_iterator; |
1193 } | 1194 } |
1194 if (clock.TimeInMicroseconds() >= NextRtpTime()) { | 1195 if (clock.TimeInMicroseconds() >= NextRtpTime()) { |
1195 RTC_DCHECK_EQ(clock.TimeInMicroseconds(), NextRtpTime()); | 1196 RTC_DCHECK_EQ(clock.TimeInMicroseconds(), NextRtpTime()); |
1196 const LoggedRtpPacket& rtp = *rtp_iterator->second; | 1197 const LoggedRtpPacket& rtp = *rtp_iterator->second; |
1197 if (rtp.header.extension.hasTransportSequenceNumber) { | 1198 if (rtp.header.extension.hasTransportSequenceNumber) { |
1198 RTC_DCHECK(rtp.header.extension.hasTransportSequenceNumber); | 1199 RTC_DCHECK(rtp.header.extension.hasTransportSequenceNumber); |
1199 feedback_adapter.AddPacket(rtp.header.extension.transportSequenceNumber, | 1200 feedback_adapter.AddPacket(rtp.header.ssrc, |
| 1201 rtp.header.extension.transportSequenceNumber, |
1200 rtp.total_length, PacedPacketInfo()); | 1202 rtp.total_length, PacedPacketInfo()); |
1201 feedback_adapter.OnSentPacket( | 1203 feedback_adapter.OnSentPacket( |
1202 rtp.header.extension.transportSequenceNumber, rtp.timestamp / 1000); | 1204 rtp.header.extension.transportSequenceNumber, rtp.timestamp / 1000); |
1203 } | 1205 } |
1204 ++rtp_iterator; | 1206 ++rtp_iterator; |
1205 } | 1207 } |
1206 time_us = std::min(NextRtpTime(), NextRtcpTime()); | 1208 time_us = std::min(NextRtpTime(), NextRtcpTime()); |
1207 } | 1209 } |
1208 // We assume that the base network delay (w/o queues) is the min delay | 1210 // We assume that the base network delay (w/o queues) is the min delay |
1209 // observed during the call. | 1211 // observed during the call. |
(...skipping 159 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1369 return rtc::Optional<float>(); | 1371 return rtc::Optional<float>(); |
1370 }); | 1372 }); |
1371 plot->series_list_.back().label = "Audio encoder number of channels"; | 1373 plot->series_list_.back().label = "Audio encoder number of channels"; |
1372 plot->SetXAxis(0, call_duration_s_, "Time (s)", kLeftMargin, kRightMargin); | 1374 plot->SetXAxis(0, call_duration_s_, "Time (s)", kLeftMargin, kRightMargin); |
1373 plot->SetSuggestedYAxis(0, 1, "Number of channels (1 (mono)/2 (stereo))", | 1375 plot->SetSuggestedYAxis(0, 1, "Number of channels (1 (mono)/2 (stereo))", |
1374 kBottomMargin, kTopMargin); | 1376 kBottomMargin, kTopMargin); |
1375 plot->SetTitle("Reported audio encoder number of channels"); | 1377 plot->SetTitle("Reported audio encoder number of channels"); |
1376 } | 1378 } |
1377 } // namespace plotting | 1379 } // namespace plotting |
1378 } // namespace webrtc | 1380 } // namespace webrtc |
OLD | NEW |