Index: webrtc/modules/rtp_rtcp/source/rtcp_receiver.cc |
diff --git a/webrtc/modules/rtp_rtcp/source/rtcp_receiver.cc b/webrtc/modules/rtp_rtcp/source/rtcp_receiver.cc |
index 168557d22409802c99e0d80b3b3e2ae6f00140ec..4392f52e6a4daf53f85deba4bffdee12f04a8df3 100644 |
--- a/webrtc/modules/rtp_rtcp/source/rtcp_receiver.cc |
+++ b/webrtc/modules/rtp_rtcp/source/rtcp_receiver.cc |
@@ -17,7 +17,6 @@ |
#include "webrtc/base/checks.h" |
#include "webrtc/modules/rtp_rtcp/source/rtcp_utility.h" |
-#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/transport_feedback.h" |
#include "webrtc/modules/rtp_rtcp/source/rtp_rtcp_impl.h" |
#include "webrtc/system_wrappers/interface/critical_section_wrapper.h" |
#include "webrtc/system_wrappers/interface/logging.h" |
@@ -30,15 +29,12 @@ using namespace RTCPHelp; |
// The number of RTCP time intervals needed to trigger a timeout. |
const int kRrTimeoutIntervals = 3; |
-const int64_t kMaxWarningLogIntervalMs = 10000; |
- |
RTCPReceiver::RTCPReceiver( |
Clock* clock, |
bool receiver_only, |
RtcpPacketTypeCounterObserver* packet_type_counter_observer, |
RtcpBandwidthObserver* rtcp_bandwidth_observer, |
RtcpIntraFrameObserver* rtcp_intra_frame_observer, |
- TransportFeedbackObserver* transport_feedback_observer, |
ModuleRtpRtcpImpl* owner) |
: TMMBRHelp(), |
_clock(clock), |
@@ -50,7 +46,6 @@ RTCPReceiver::RTCPReceiver( |
CriticalSectionWrapper::CreateCriticalSection()), |
_cbRtcpBandwidthObserver(rtcp_bandwidth_observer), |
_cbRtcpIntraFrameObserver(rtcp_intra_frame_observer), |
- _cbTransportFeedbackObserver(transport_feedback_observer), |
_criticalSectionRTCPReceiver( |
CriticalSectionWrapper::CreateCriticalSection()), |
main_ssrc_(0), |
@@ -66,9 +61,7 @@ RTCPReceiver::RTCPReceiver( |
_lastReceivedRrMs(0), |
_lastIncreasedSequenceNumberMs(0), |
stats_callback_(NULL), |
- packet_type_counter_observer_(packet_type_counter_observer), |
- num_skipped_packets_(0), |
- last_skipped_packets_warning_(clock->TimeInMilliseconds()) { |
+ packet_type_counter_observer_(packet_type_counter_observer) { |
memset(&_remoteSenderInfo, 0, sizeof(_remoteSenderInfo)); |
} |
@@ -356,9 +349,6 @@ RTCPReceiver::IncomingRTCPPacket(RTCPPacketInformation& rtcpPacketInformation, |
// generic application messages |
HandleAPPItem(*rtcpParser, rtcpPacketInformation); |
break; |
- case RTCPPacketTypes::kTransportFeedback: |
- HandleTransportFeedback(rtcpParser, &rtcpPacketInformation); |
- break; |
default: |
rtcpParser->Iterate(); |
break; |
@@ -371,19 +361,6 @@ RTCPReceiver::IncomingRTCPPacket(RTCPPacketInformation& rtcpPacketInformation, |
main_ssrc_, packet_type_counter_); |
} |
- num_skipped_packets_ += rtcpParser->NumSkippedBlocks(); |
- |
- int64_t now = _clock->TimeInMilliseconds(); |
- if (now - last_skipped_packets_warning_ >= kMaxWarningLogIntervalMs && |
- num_skipped_packets_ > 0) { |
- last_skipped_packets_warning_ = now; |
- LOG(LS_WARNING) |
- << num_skipped_packets_ |
- << " RTCP blocks were skipped due to being malformed or of " |
- "unrecognized/unsupported type, during the past " |
- << (kMaxWarningLogIntervalMs / 1000) << " second period."; |
- } |
- |
return 0; |
} |
@@ -1275,17 +1252,6 @@ void RTCPReceiver::HandleAPPItem(RTCPUtility::RTCPParserV2& rtcpParser, |
rtcpParser.Iterate(); |
} |
-void RTCPReceiver::HandleTransportFeedback( |
- RTCPUtility::RTCPParserV2* rtcp_parser, |
- RTCPHelp::RTCPPacketInformation* rtcp_packet_information) { |
- rtcp::RtcpPacket* packet = rtcp_parser->ReleaseRtcpPacket(); |
- RTC_DCHECK(packet != nullptr); |
- rtcp_packet_information->rtcpPacketTypeFlags |= kRtcpTransportFeedback; |
- rtcp_packet_information->transport_feedback_.reset( |
- static_cast<rtcp::TransportFeedback*>(packet)); |
- |
- rtcp_parser->Iterate(); |
-} |
int32_t RTCPReceiver::UpdateTMMBR() { |
int32_t numBoundingSet = 0; |
uint32_t bitrate = 0; |
@@ -1355,11 +1321,11 @@ void RTCPReceiver::TriggerCallbacksFromRTCPPacket( |
local_ssrc = main_ssrc_; |
} |
if (!receiver_only_ && |
- (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpSrReq)) { |
+ rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpSrReq) { |
_rtpRtcp.OnRequestSendReport(); |
} |
if (!receiver_only_ && |
- (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpNack)) { |
+ rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpNack) { |
if (rtcpPacketInformation.nackSequenceNumbers.size() > 0) { |
LOG(LS_VERBOSE) << "Incoming NACK length: " |
<< rtcpPacketInformation.nackSequenceNumbers.size(); |
@@ -1410,17 +1376,6 @@ void RTCPReceiver::TriggerCallbacksFromRTCPPacket( |
now); |
} |
} |
- if (_cbTransportFeedbackObserver && |
- (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpTransportFeedback)) { |
- uint32_t media_source_ssrc = |
- rtcpPacketInformation.transport_feedback_->GetMediaSourceSsrc(); |
- if (media_source_ssrc == main_ssrc_ || |
- registered_ssrcs_.find(media_source_ssrc) != |
- registered_ssrcs_.end()) { |
- _cbTransportFeedbackObserver->OnTransportFeedback( |
- *rtcpPacketInformation.transport_feedback_.get()); |
- } |
- } |
} |
if (!receiver_only_) { |