Index: webrtc/modules/rtp_rtcp/source/rtp_rtcp_impl.cc |
diff --git a/webrtc/modules/rtp_rtcp/source/rtp_rtcp_impl.cc b/webrtc/modules/rtp_rtcp/source/rtp_rtcp_impl.cc |
index a79774d16029a0f992d111f2cb95e9ac0dde1f0a..142fce3336966f211b0233bcd99538a0fbf75167 100644 |
--- a/webrtc/modules/rtp_rtcp/source/rtp_rtcp_impl.cc |
+++ b/webrtc/modules/rtp_rtcp/source/rtp_rtcp_impl.cc |
@@ -611,6 +611,31 @@ void ModuleRtpRtcpImpl::GetSendStreamDataCounters( |
rtp_sender_.GetDataCounters(rtp_counters, rtx_counters); |
} |
+void ModuleRtpRtcpImpl::GetRtpPacketLossStats( |
+ bool outgoing, |
+ uint32_t ssrc, |
+ struct RtpPacketLossStats* loss_stats) const { |
+ if (!loss_stats) return; |
+ const PacketLossStats* stats_source = NULL; |
+ if (outgoing) { |
+ if (SSRC() == ssrc) { |
+ stats_source = &send_loss_stats_; |
+ } |
+ } else { |
+ if (rtcp_receiver_.RemoteSSRC() == ssrc) { |
+ stats_source = &receive_loss_stats_; |
+ } |
+ } |
+ if (stats_source) { |
+ loss_stats->single_packet_loss_count = |
+ stats_source->GetSingleLossCount(); |
+ loss_stats->multiple_packet_loss_event_count = |
+ stats_source->GetMultipleLossEventCount(); |
+ loss_stats->multiple_packet_loss_packet_count = |
+ stats_source->GetMultipleLossPacketCount(); |
+ } |
+} |
+ |
int32_t ModuleRtpRtcpImpl::RemoteRTCPStat(RTCPSenderInfo* sender_info) { |
return rtcp_receiver_.SenderInfoReceived(sender_info); |
} |
@@ -684,6 +709,9 @@ int ModuleRtpRtcpImpl::SetSelectiveRetransmissions(uint8_t settings) { |
// Send a Negative acknowledgment packet. |
int32_t ModuleRtpRtcpImpl::SendNACK(const uint16_t* nack_list, |
const uint16_t size) { |
+ for (int i = 0; i < size; ++i) { |
+ receive_loss_stats_.AddLostPacket(nack_list[i]); |
+ } |
uint16_t nack_length = size; |
uint16_t start_id = 0; |
int64_t now = clock_->TimeInMilliseconds(); |
@@ -899,6 +927,9 @@ bool ModuleRtpRtcpImpl::SendTimeOfXrRrReport( |
void ModuleRtpRtcpImpl::OnReceivedNACK( |
const std::list<uint16_t>& nack_sequence_numbers) { |
+ for (uint16_t nack_sequence_number : nack_sequence_numbers) { |
+ send_loss_stats_.AddLostPacket(nack_sequence_number); |
+ } |
if (!rtp_sender_.StorePackets() || |
nack_sequence_numbers.size() == 0) { |
return; |