| OLD | NEW |
|---|
| (Empty) |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "media/cast/net/rtcp/rtcp_builder.h" | |
| 6 | |
| 7 #include <algorithm> | |
| 8 #include <string> | |
| 9 #include <vector> | |
| 10 | |
| 11 #include "base/big_endian.h" | |
| 12 #include "base/logging.h" | |
| 13 #include "media/cast/net/cast_transport_defines.h" | |
| 14 #include "media/cast/net/pacing/paced_sender.h" | |
| 15 | |
| 16 namespace media { | |
| 17 namespace cast { | |
| 18 | |
| 19 RtcpBuilder::RtcpBuilder(PacedSender* const outgoing_transport) | |
| 20 : transport_(outgoing_transport), | |
| 21 ssrc_(0) { | |
| 22 } | |
| 23 | |
| 24 RtcpBuilder::~RtcpBuilder() {} | |
| 25 | |
| 26 void RtcpBuilder::SendRtcpFromRtpSender( | |
| 27 uint32 packet_type_flags, | |
| 28 const RtcpSenderInfo& sender_info, | |
| 29 const RtcpDlrrReportBlock& dlrr, | |
| 30 uint32 sending_ssrc) { | |
| 31 if (packet_type_flags & kRtcpRr || | |
| 32 packet_type_flags & kRtcpRrtr || | |
| 33 packet_type_flags & kRtcpCast || | |
| 34 packet_type_flags & kRtcpReceiverLog || | |
| 35 packet_type_flags & kRtcpNack) { | |
| 36 NOTREACHED() << "Invalid argument"; | |
| 37 } | |
| 38 ssrc_ = sending_ssrc; | |
| 39 PacketRef packet(new base::RefCountedData<Packet>); | |
| 40 packet->data.reserve(kMaxIpPacketSize); | |
| 41 if (packet_type_flags & kRtcpSr) { | |
| 42 if (!BuildSR(sender_info, &packet->data)) return; | |
| 43 if (!BuildSdec(&packet->data)) return; | |
| 44 } | |
| 45 if (packet_type_flags & kRtcpDlrr) { | |
| 46 if (!BuildDlrrRb(dlrr, &packet->data)) return; | |
| 47 } | |
| 48 if (packet->data.empty()) | |
| 49 return; // Sanity - don't send empty packets. | |
| 50 | |
| 51 transport_->SendRtcpPacket(ssrc_, packet); | |
| 52 } | |
| 53 | |
| 54 bool RtcpBuilder::BuildSR(const RtcpSenderInfo& sender_info, | |
| 55 Packet* packet) const { | |
| 56 // Sender report. | |
| 57 size_t start_size = packet->size(); | |
| 58 if (start_size + 52 > kMaxIpPacketSize) { | |
| 59 DLOG(FATAL) << "Not enough buffer space"; | |
| 60 return false; | |
| 61 } | |
| 62 | |
| 63 uint16 number_of_rows = 6; | |
| 64 packet->resize(start_size + 28); | |
| 65 | |
| 66 base::BigEndianWriter big_endian_writer( | |
| 67 reinterpret_cast<char*>(&((*packet)[start_size])), 28); | |
| 68 big_endian_writer.WriteU8(0x80); | |
| 69 big_endian_writer.WriteU8(kPacketTypeSenderReport); | |
| 70 big_endian_writer.WriteU16(number_of_rows); | |
| 71 big_endian_writer.WriteU32(ssrc_); | |
| 72 big_endian_writer.WriteU32(sender_info.ntp_seconds); | |
| 73 big_endian_writer.WriteU32(sender_info.ntp_fraction); | |
| 74 big_endian_writer.WriteU32(sender_info.rtp_timestamp); | |
| 75 big_endian_writer.WriteU32(sender_info.send_packet_count); | |
| 76 big_endian_writer.WriteU32(static_cast<uint32>(sender_info.send_octet_count)); | |
| 77 return true; | |
| 78 } | |
| 79 | |
| 80 /* | |
| 81 0 1 2 3 | |
| 82 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 | |
| 83 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | |
| 84 |V=2|P|reserved | PT=XR=207 | length | | |
| 85 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | |
| 86 | SSRC | | |
| 87 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | |
| 88 | BT=5 | reserved | block length | | |
| 89 +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ | |
| 90 | SSRC_1 (SSRC of first receiver) | sub- | |
| 91 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ block | |
| 92 | last RR (LRR) | 1 | |
| 93 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | |
| 94 | delay since last RR (DLRR) | | |
| 95 +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ | |
| 96 */ | |
| 97 bool RtcpBuilder::BuildDlrrRb(const RtcpDlrrReportBlock& dlrr, | |
| 98 Packet* packet) const { | |
| 99 size_t start_size = packet->size(); | |
| 100 if (start_size + 24 > kMaxIpPacketSize) { | |
| 101 DLOG(FATAL) << "Not enough buffer space"; | |
| 102 return false; | |
| 103 } | |
| 104 | |
| 105 packet->resize(start_size + 24); | |
| 106 | |
| 107 base::BigEndianWriter big_endian_writer( | |
| 108 reinterpret_cast<char*>(&((*packet)[start_size])), 24); | |
| 109 big_endian_writer.WriteU8(0x80); | |
| 110 big_endian_writer.WriteU8(kPacketTypeXr); | |
| 111 big_endian_writer.WriteU16(5); // Length. | |
| 112 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC. | |
| 113 big_endian_writer.WriteU8(5); // Add block type. | |
| 114 big_endian_writer.WriteU8(0); // Add reserved. | |
| 115 big_endian_writer.WriteU16(3); // Block length. | |
| 116 big_endian_writer.WriteU32(ssrc_); // Add the media (received RTP) SSRC. | |
| 117 big_endian_writer.WriteU32(dlrr.last_rr); | |
| 118 big_endian_writer.WriteU32(dlrr.delay_since_last_rr); | |
| 119 return true; | |
| 120 } | |
| 121 | |
| 122 } // namespace cast | |
| 123 } // namespace media | |
| OLD | NEW |
|---|
Chromium Code Reviews
Issue 495203002:
Delete some dead files (Closed)
Base URL: https://chromium.googlesource.com/chromium/src.git@master