OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2012 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 1321 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1332 << rtcpPacketInformation.nackSequenceNumbers.size(); | 1332 << rtcpPacketInformation.nackSequenceNumbers.size(); |
1333 _rtpRtcp.OnReceivedNACK(rtcpPacketInformation.nackSequenceNumbers); | 1333 _rtpRtcp.OnReceivedNACK(rtcpPacketInformation.nackSequenceNumbers); |
1334 } | 1334 } |
1335 } | 1335 } |
1336 { | 1336 { |
1337 // We need feedback that we have received a report block(s) so that we | 1337 // We need feedback that we have received a report block(s) so that we |
1338 // can generate a new packet in a conference relay scenario, one received | 1338 // can generate a new packet in a conference relay scenario, one received |
1339 // report can generate several RTCP packets, based on number relayed/mixed | 1339 // report can generate several RTCP packets, based on number relayed/mixed |
1340 // a send report block should go out to all receivers. | 1340 // a send report block should go out to all receivers. |
1341 if (_cbRtcpIntraFrameObserver) { | 1341 if (_cbRtcpIntraFrameObserver) { |
1342 DCHECK(!receiver_only_); | 1342 RTC_DCHECK(!receiver_only_); |
1343 if ((rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpPli) || | 1343 if ((rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpPli) || |
1344 (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpFir)) { | 1344 (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpFir)) { |
1345 if (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpPli) { | 1345 if (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpPli) { |
1346 LOG(LS_VERBOSE) << "Incoming PLI from SSRC " | 1346 LOG(LS_VERBOSE) << "Incoming PLI from SSRC " |
1347 << rtcpPacketInformation.remoteSSRC; | 1347 << rtcpPacketInformation.remoteSSRC; |
1348 } else { | 1348 } else { |
1349 LOG(LS_VERBOSE) << "Incoming FIR from SSRC " | 1349 LOG(LS_VERBOSE) << "Incoming FIR from SSRC " |
1350 << rtcpPacketInformation.remoteSSRC; | 1350 << rtcpPacketInformation.remoteSSRC; |
1351 } | 1351 } |
1352 _cbRtcpIntraFrameObserver->OnReceivedIntraFrameRequest(local_ssrc); | 1352 _cbRtcpIntraFrameObserver->OnReceivedIntraFrameRequest(local_ssrc); |
1353 } | 1353 } |
1354 if (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpSli) { | 1354 if (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpSli) { |
1355 _cbRtcpIntraFrameObserver->OnReceivedSLI( | 1355 _cbRtcpIntraFrameObserver->OnReceivedSLI( |
1356 local_ssrc, rtcpPacketInformation.sliPictureId); | 1356 local_ssrc, rtcpPacketInformation.sliPictureId); |
1357 } | 1357 } |
1358 if (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpRpsi) { | 1358 if (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpRpsi) { |
1359 _cbRtcpIntraFrameObserver->OnReceivedRPSI( | 1359 _cbRtcpIntraFrameObserver->OnReceivedRPSI( |
1360 local_ssrc, rtcpPacketInformation.rpsiPictureId); | 1360 local_ssrc, rtcpPacketInformation.rpsiPictureId); |
1361 } | 1361 } |
1362 } | 1362 } |
1363 if (_cbRtcpBandwidthObserver) { | 1363 if (_cbRtcpBandwidthObserver) { |
1364 DCHECK(!receiver_only_); | 1364 RTC_DCHECK(!receiver_only_); |
1365 if (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpRemb) { | 1365 if (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpRemb) { |
1366 LOG(LS_VERBOSE) << "Incoming REMB: " | 1366 LOG(LS_VERBOSE) << "Incoming REMB: " |
1367 << rtcpPacketInformation.receiverEstimatedMaxBitrate; | 1367 << rtcpPacketInformation.receiverEstimatedMaxBitrate; |
1368 _cbRtcpBandwidthObserver->OnReceivedEstimatedBitrate( | 1368 _cbRtcpBandwidthObserver->OnReceivedEstimatedBitrate( |
1369 rtcpPacketInformation.receiverEstimatedMaxBitrate); | 1369 rtcpPacketInformation.receiverEstimatedMaxBitrate); |
1370 } | 1370 } |
1371 if ((rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpSr) || | 1371 if ((rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpSr) || |
1372 (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpRr)) { | 1372 (rtcpPacketInformation.rtcpPacketTypeFlags & kRtcpRr)) { |
1373 int64_t now = _clock->TimeInMilliseconds(); | 1373 int64_t now = _clock->TimeInMilliseconds(); |
1374 _cbRtcpBandwidthObserver->OnReceivedRtcpReceiverReport( | 1374 _cbRtcpBandwidthObserver->OnReceivedRtcpReceiverReport( |
(...skipping 71 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1446 return -1; | 1446 return -1; |
1447 } | 1447 } |
1448 num += receiveInfo->TmmbrSet.lengthOfSet(); | 1448 num += receiveInfo->TmmbrSet.lengthOfSet(); |
1449 receiveInfoIt++; | 1449 receiveInfoIt++; |
1450 } | 1450 } |
1451 } | 1451 } |
1452 return num; | 1452 return num; |
1453 } | 1453 } |
1454 | 1454 |
1455 } // namespace webrtc | 1455 } // namespace webrtc |
OLD | NEW |