niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 1 | /* |
pwestin@webrtc.org | f6bb77a | 2012-01-24 17:16:59 +0000 | [diff] [blame] | 2 | * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 3 | * |
| 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 |
| 6 | * tree. An additional intellectual property rights grant can be found |
| 7 | * in the file PATENTS. All contributing project authors may |
| 8 | * be found in the AUTHORS file in the root of the source tree. |
| 9 | */ |
| 10 | |
| 11 | #ifndef WEBRTC_MODULES_RTP_RTCP_SOURCE_RTCP_RECEIVER_H_ |
| 12 | #define WEBRTC_MODULES_RTP_RTCP_SOURCE_RTCP_RECEIVER_H_ |
| 13 | |
pwestin@webrtc.org | 26f8d9c | 2012-01-19 15:53:09 +0000 | [diff] [blame] | 14 | #include <map> |
perkj@webrtc.org | ce5990c | 2012-01-11 13:00:08 +0000 | [diff] [blame] | 15 | #include <vector> |
| 16 | |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 17 | #include "typedefs.h" |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 18 | #include "rtp_utility.h" |
| 19 | #include "rtcp_utility.h" |
| 20 | #include "rtp_rtcp_defines.h" |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 21 | #include "rtcp_receiver_help.h" |
pwestin@webrtc.org | cac7878 | 2012-04-05 08:30:10 +0000 | [diff] [blame] | 22 | #include "tmmbr_help.h" |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 23 | |
| 24 | namespace webrtc { |
pwestin@webrtc.org | 741da94 | 2011-09-20 13:52:04 +0000 | [diff] [blame] | 25 | class ModuleRtpRtcpImpl; |
| 26 | |
pwestin@webrtc.org | cac7878 | 2012-04-05 08:30:10 +0000 | [diff] [blame] | 27 | class RTCPReceiver : public TMMBRHelp |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 28 | { |
| 29 | public: |
stefan@webrtc.org | 20ed36d | 2013-01-17 14:01:20 +0000 | [diff] [blame] | 30 | RTCPReceiver(const WebRtc_Word32 id, Clock* clock, |
pwestin@webrtc.org | 0644b1d | 2011-12-01 15:42:31 +0000 | [diff] [blame] | 31 | ModuleRtpRtcpImpl* owner); |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 32 | virtual ~RTCPReceiver(); |
| 33 | |
| 34 | void ChangeUniqueId(const WebRtc_Word32 id); |
| 35 | |
| 36 | RTCPMethod Status() const; |
| 37 | WebRtc_Word32 SetRTCPStatus(const RTCPMethod method); |
| 38 | |
pwestin@webrtc.org | 1853005 | 2012-07-03 10:41:54 +0000 | [diff] [blame] | 39 | WebRtc_Word64 LastReceived(); |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 40 | |
| 41 | void SetSSRC( const WebRtc_UWord32 ssrc); |
| 42 | void SetRelaySSRC( const WebRtc_UWord32 ssrc); |
| 43 | WebRtc_Word32 SetRemoteSSRC( const WebRtc_UWord32 ssrc); |
| 44 | |
| 45 | WebRtc_UWord32 RelaySSRC() const; |
| 46 | |
pwestin@webrtc.org | 49888ce | 2012-04-27 05:25:53 +0000 | [diff] [blame] | 47 | void RegisterRtcpObservers(RtcpIntraFrameObserver* intra_frame_callback, |
| 48 | RtcpBandwidthObserver* bandwidth_callback, |
| 49 | RtcpFeedback* feedback_callback); |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 50 | |
| 51 | WebRtc_Word32 IncomingRTCPPacket(RTCPHelp::RTCPPacketInformation& rtcpPacketInformation, |
| 52 | RTCPUtility::RTCPParserV2 *rtcpParser); |
| 53 | |
| 54 | void TriggerCallbacksFromRTCPPacket(RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 55 | |
| 56 | // get received cname |
| 57 | WebRtc_Word32 CNAME(const WebRtc_UWord32 remoteSSRC, |
pwestin@webrtc.org | f6bb77a | 2012-01-24 17:16:59 +0000 | [diff] [blame] | 58 | char cName[RTCP_CNAME_SIZE]) const; |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 59 | |
| 60 | // get received NTP |
| 61 | WebRtc_Word32 NTP(WebRtc_UWord32 *ReceivedNTPsecs, |
pwestin@webrtc.org | 741da94 | 2011-09-20 13:52:04 +0000 | [diff] [blame] | 62 | WebRtc_UWord32 *ReceivedNTPfrac, |
| 63 | WebRtc_UWord32 *RTCPArrivalTimeSecs, |
stefan@webrtc.org | 7c3523c | 2012-09-11 07:00:42 +0000 | [diff] [blame] | 64 | WebRtc_UWord32 *RTCPArrivalTimeFrac, |
| 65 | WebRtc_UWord32 *rtcp_timestamp) const; |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 66 | |
| 67 | // get rtt |
| 68 | WebRtc_Word32 RTT(const WebRtc_UWord32 remoteSSRC, |
pwestin@webrtc.org | 741da94 | 2011-09-20 13:52:04 +0000 | [diff] [blame] | 69 | WebRtc_UWord16* RTT, |
| 70 | WebRtc_UWord16* avgRTT, |
| 71 | WebRtc_UWord16* minRTT, |
| 72 | WebRtc_UWord16* maxRTT) const; |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 73 | |
mflodman@webrtc.org | d7d4688 | 2012-02-14 12:49:59 +0000 | [diff] [blame] | 74 | WebRtc_UWord16 RTT() const; |
| 75 | |
| 76 | int SetRTT(WebRtc_UWord16 rtt); |
| 77 | |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 78 | WebRtc_Word32 ResetRTT(const WebRtc_UWord32 remoteSSRC); |
| 79 | |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 80 | WebRtc_Word32 SenderInfoReceived(RTCPSenderInfo* senderInfo) const; |
| 81 | |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 82 | // get statistics |
perkj@webrtc.org | ce5990c | 2012-01-11 13:00:08 +0000 | [diff] [blame] | 83 | WebRtc_Word32 StatisticsReceived( |
| 84 | std::vector<RTCPReportBlock>* receiveBlocks) const; |
| 85 | |
mflodman@webrtc.org | 2f225ca | 2013-01-09 13:54:43 +0000 | [diff] [blame] | 86 | // Returns true if we haven't received an RTCP RR for several RTCP |
| 87 | // intervals, but only triggers true once. |
| 88 | bool RtcpRrTimeout(int64_t rtcp_interval_ms); |
| 89 | |
| 90 | // Returns true if we haven't received an RTCP RR telling the receive side |
| 91 | // has not received RTP packets for too long, i.e. extended highest sequence |
| 92 | // number hasn't increased for several RTCP intervals. The function only |
| 93 | // returns true once until a new RR is received. |
| 94 | bool RtcpRrSequenceNumberTimeout(int64_t rtcp_interval_ms); |
| 95 | |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 96 | // Get TMMBR |
| 97 | WebRtc_Word32 TMMBRReceived(const WebRtc_UWord32 size, |
pwestin@webrtc.org | 1da1ce0 | 2011-10-13 15:19:55 +0000 | [diff] [blame] | 98 | const WebRtc_UWord32 accNumCandidates, |
| 99 | TMMBRSet* candidateSet) const; |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 100 | |
| 101 | bool UpdateRTCPReceiveInformationTimers(); |
| 102 | |
hta@webrtc.org | 65a4e4e | 2012-04-30 11:23:41 +0000 | [diff] [blame] | 103 | WebRtc_Word32 BoundingSet(bool &tmmbrOwner, TMMBRSet* boundingSetRec); |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 104 | |
pwestin@webrtc.org | cac7878 | 2012-04-05 08:30:10 +0000 | [diff] [blame] | 105 | WebRtc_Word32 UpdateTMMBR(); |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 106 | |
| 107 | WebRtc_Word32 SetPacketTimeout(const WebRtc_UWord32 timeoutMS); |
| 108 | void PacketTimeout(); |
| 109 | |
| 110 | protected: |
| 111 | RTCPHelp::RTCPReportBlockInformation* CreateReportBlockInformation(const WebRtc_UWord32 remoteSSRC); |
| 112 | RTCPHelp::RTCPReportBlockInformation* GetReportBlockInformation(const WebRtc_UWord32 remoteSSRC) const; |
| 113 | |
| 114 | RTCPUtility::RTCPCnameInformation* CreateCnameInformation(const WebRtc_UWord32 remoteSSRC); |
| 115 | RTCPUtility::RTCPCnameInformation* GetCnameInformation(const WebRtc_UWord32 remoteSSRC) const; |
| 116 | |
| 117 | RTCPHelp::RTCPReceiveInformation* CreateReceiveInformation(const WebRtc_UWord32 remoteSSRC); |
| 118 | RTCPHelp::RTCPReceiveInformation* GetReceiveInformation(const WebRtc_UWord32 remoteSSRC); |
| 119 | |
| 120 | void UpdateReceiveInformation( RTCPHelp::RTCPReceiveInformation& receiveInformation); |
| 121 | |
| 122 | void HandleSenderReceiverReport(RTCPUtility::RTCPParserV2& rtcpParser, |
| 123 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 124 | |
| 125 | void HandleReportBlock(const RTCPUtility::RTCPPacket& rtcpPacket, |
| 126 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation, |
| 127 | const WebRtc_UWord32 remoteSSRC, |
| 128 | const WebRtc_UWord8 numberOfReportBlocks); |
| 129 | |
| 130 | void HandleSDES(RTCPUtility::RTCPParserV2& rtcpParser); |
| 131 | |
| 132 | void HandleSDESChunk(RTCPUtility::RTCPParserV2& rtcpParser); |
| 133 | |
| 134 | void HandleXRVOIPMetric(RTCPUtility::RTCPParserV2& rtcpParser, |
| 135 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 136 | |
| 137 | void HandleNACK(RTCPUtility::RTCPParserV2& rtcpParser, |
| 138 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 139 | |
| 140 | void HandleNACKItem(const RTCPUtility::RTCPPacket& rtcpPacket, |
| 141 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 142 | |
| 143 | void HandleBYE(RTCPUtility::RTCPParserV2& rtcpParser); |
| 144 | |
| 145 | void HandlePLI(RTCPUtility::RTCPParserV2& rtcpParser, |
| 146 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 147 | |
| 148 | void HandleSLI(RTCPUtility::RTCPParserV2& rtcpParser, |
| 149 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 150 | |
| 151 | void HandleSLIItem(const RTCPUtility::RTCPPacket& rtcpPacket, |
| 152 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 153 | |
| 154 | void HandleRPSI(RTCPUtility::RTCPParserV2& rtcpParser, |
| 155 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 156 | |
pwestin@webrtc.org | 741da94 | 2011-09-20 13:52:04 +0000 | [diff] [blame] | 157 | void HandlePsfbApp(RTCPUtility::RTCPParserV2& rtcpParser, |
| 158 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 159 | |
| 160 | void HandleREMBItem(RTCPUtility::RTCPParserV2& rtcpParser, |
| 161 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 162 | |
asapersson@webrtc.org | 5249cc8 | 2011-12-16 14:31:37 +0000 | [diff] [blame] | 163 | void HandleIJ(RTCPUtility::RTCPParserV2& rtcpParser, |
| 164 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 165 | |
| 166 | void HandleIJItem(const RTCPUtility::RTCPPacket& rtcpPacket, |
| 167 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 168 | |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 169 | void HandleTMMBR(RTCPUtility::RTCPParserV2& rtcpParser, |
| 170 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 171 | |
| 172 | void HandleTMMBRItem(RTCPHelp::RTCPReceiveInformation& receiveInfo, |
| 173 | const RTCPUtility::RTCPPacket& rtcpPacket, |
| 174 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation, |
| 175 | const WebRtc_UWord32 senderSSRC); |
| 176 | |
hta@webrtc.org | 9d54cd1 | 2012-04-30 08:24:55 +0000 | [diff] [blame] | 177 | void HandleTMMBN(RTCPUtility::RTCPParserV2& rtcpParser, |
| 178 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 179 | |
| 180 | void HandleSR_REQ(RTCPUtility::RTCPParserV2& rtcpParser, |
| 181 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 182 | |
| 183 | void HandleTMMBNItem(RTCPHelp::RTCPReceiveInformation& receiveInfo, |
| 184 | const RTCPUtility::RTCPPacket& rtcpPacket); |
| 185 | |
| 186 | void HandleFIR(RTCPUtility::RTCPParserV2& rtcpParser, |
| 187 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 188 | |
pwestin@webrtc.org | b2179c2 | 2012-05-21 12:00:49 +0000 | [diff] [blame] | 189 | void HandleFIRItem(RTCPHelp::RTCPReceiveInformation* receiveInfo, |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 190 | const RTCPUtility::RTCPPacket& rtcpPacket, |
| 191 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 192 | |
| 193 | void HandleAPP(RTCPUtility::RTCPParserV2& rtcpParser, |
| 194 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 195 | |
| 196 | void HandleAPPItem(RTCPUtility::RTCPParserV2& rtcpParser, |
| 197 | RTCPHelp::RTCPPacketInformation& rtcpPacketInformation); |
| 198 | |
pwestin@webrtc.org | 26f8d9c | 2012-01-19 15:53:09 +0000 | [diff] [blame] | 199 | private: |
| 200 | WebRtc_Word32 _id; |
stefan@webrtc.org | a678a3b | 2013-01-21 07:42:11 +0000 | [diff] [blame] | 201 | Clock* _clock; |
pwestin@webrtc.org | 26f8d9c | 2012-01-19 15:53:09 +0000 | [diff] [blame] | 202 | RTCPMethod _method; |
pwestin@webrtc.org | 1853005 | 2012-07-03 10:41:54 +0000 | [diff] [blame] | 203 | WebRtc_Word64 _lastReceived; |
pwestin@webrtc.org | 26f8d9c | 2012-01-19 15:53:09 +0000 | [diff] [blame] | 204 | ModuleRtpRtcpImpl& _rtpRtcp; |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 205 | |
pwestin@webrtc.org | 26f8d9c | 2012-01-19 15:53:09 +0000 | [diff] [blame] | 206 | CriticalSectionWrapper* _criticalSectionFeedbacks; |
| 207 | RtcpFeedback* _cbRtcpFeedback; |
pwestin@webrtc.org | 49888ce | 2012-04-27 05:25:53 +0000 | [diff] [blame] | 208 | RtcpBandwidthObserver* _cbRtcpBandwidthObserver; |
| 209 | RtcpIntraFrameObserver* _cbRtcpIntraFrameObserver; |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 210 | |
pwestin@webrtc.org | 26f8d9c | 2012-01-19 15:53:09 +0000 | [diff] [blame] | 211 | CriticalSectionWrapper* _criticalSectionRTCPReceiver; |
| 212 | WebRtc_UWord32 _SSRC; |
| 213 | WebRtc_UWord32 _remoteSSRC; |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 214 | |
pwestin@webrtc.org | 26f8d9c | 2012-01-19 15:53:09 +0000 | [diff] [blame] | 215 | // Received send report |
| 216 | RTCPSenderInfo _remoteSenderInfo; |
| 217 | // when did we receive the last send report |
| 218 | WebRtc_UWord32 _lastReceivedSRNTPsecs; |
| 219 | WebRtc_UWord32 _lastReceivedSRNTPfrac; |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 220 | |
pwestin@webrtc.org | 26f8d9c | 2012-01-19 15:53:09 +0000 | [diff] [blame] | 221 | // Received report blocks. |
| 222 | std::map<WebRtc_UWord32, RTCPHelp::RTCPReportBlockInformation*> |
| 223 | _receivedReportBlockMap; |
| 224 | std::map<WebRtc_UWord32, RTCPHelp::RTCPReceiveInformation*> |
| 225 | _receivedInfoMap; |
| 226 | std::map<WebRtc_UWord32, RTCPUtility::RTCPCnameInformation*> |
| 227 | _receivedCnameMap; |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 228 | |
pwestin@webrtc.org | 26f8d9c | 2012-01-19 15:53:09 +0000 | [diff] [blame] | 229 | WebRtc_UWord32 _packetTimeOutMS; |
mflodman@webrtc.org | d7d4688 | 2012-02-14 12:49:59 +0000 | [diff] [blame] | 230 | |
mflodman@webrtc.org | 2f225ca | 2013-01-09 13:54:43 +0000 | [diff] [blame] | 231 | // The last time we received an RTCP RR. |
| 232 | int64_t _lastReceivedRrMs; |
| 233 | |
| 234 | // The time we last received an RTCP RR telling we have ssuccessfully |
| 235 | // delivered RTP packet to the remote side. |
| 236 | int64_t _lastIncreasedSequenceNumberMs; |
| 237 | |
mflodman@webrtc.org | d7d4688 | 2012-02-14 12:49:59 +0000 | [diff] [blame] | 238 | // Externally set RTT. This value can only be used if there are no valid |
| 239 | // RTT estimates. |
| 240 | WebRtc_UWord16 _rtt; |
| 241 | |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 242 | }; |
| 243 | } // namespace webrtc |
| 244 | #endif // WEBRTC_MODULES_RTP_RTCP_SOURCE_RTCP_RECEIVER_H_ |