Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(149)

Side by Side Diff: media/cast/net/rtcp/rtcp_builder.cc

Issue 427733002: Cast: Remove unused RTCP messages (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: merged Created 6 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « media/cast/net/rtcp/rtcp_builder.h ('k') | media/cast/net/rtcp/rtcp_builder_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 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 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "media/cast/net/rtcp/rtcp_builder.h" 5 #include "media/cast/net/rtcp/rtcp_builder.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 #include <string> 8 #include <string>
9 #include <vector> 9 #include <vector>
10 10
11 #include "base/big_endian.h" 11 #include "base/big_endian.h"
12 #include "base/logging.h" 12 #include "base/logging.h"
13 #include "media/cast/net/cast_transport_defines.h" 13 #include "media/cast/net/cast_transport_defines.h"
14 #include "media/cast/net/pacing/paced_sender.h" 14 #include "media/cast/net/pacing/paced_sender.h"
15 15
16 namespace media { 16 namespace media {
17 namespace cast { 17 namespace cast {
18 18
19 RtcpBuilder::RtcpBuilder(PacedSender* const outgoing_transport) 19 RtcpBuilder::RtcpBuilder(PacedSender* const outgoing_transport)
20 : transport_(outgoing_transport), 20 : transport_(outgoing_transport),
21 ssrc_(0) { 21 ssrc_(0) {
22 } 22 }
23 23
24 RtcpBuilder::~RtcpBuilder() {} 24 RtcpBuilder::~RtcpBuilder() {}
25 25
26 void RtcpBuilder::SendRtcpFromRtpSender( 26 void RtcpBuilder::SendRtcpFromRtpSender(
27 uint32 packet_type_flags, 27 uint32 packet_type_flags,
28 const RtcpSenderInfo& sender_info, 28 const RtcpSenderInfo& sender_info,
29 const RtcpDlrrReportBlock& dlrr, 29 const RtcpDlrrReportBlock& dlrr,
30 uint32 sending_ssrc, 30 uint32 sending_ssrc) {
31 const std::string& c_name) {
32 if (packet_type_flags & kRtcpRr || 31 if (packet_type_flags & kRtcpRr ||
33 packet_type_flags & kRtcpPli ||
34 packet_type_flags & kRtcpRrtr || 32 packet_type_flags & kRtcpRrtr ||
35 packet_type_flags & kRtcpCast || 33 packet_type_flags & kRtcpCast ||
36 packet_type_flags & kRtcpReceiverLog || 34 packet_type_flags & kRtcpReceiverLog ||
37 packet_type_flags & kRtcpRpsi ||
38 packet_type_flags & kRtcpRemb ||
39 packet_type_flags & kRtcpNack) { 35 packet_type_flags & kRtcpNack) {
40 NOTREACHED() << "Invalid argument"; 36 NOTREACHED() << "Invalid argument";
41 } 37 }
42 ssrc_ = sending_ssrc; 38 ssrc_ = sending_ssrc;
43 c_name_ = c_name;
44 PacketRef packet(new base::RefCountedData<Packet>); 39 PacketRef packet(new base::RefCountedData<Packet>);
45 packet->data.reserve(kMaxIpPacketSize); 40 packet->data.reserve(kMaxIpPacketSize);
46 if (packet_type_flags & kRtcpSr) { 41 if (packet_type_flags & kRtcpSr) {
47 if (!BuildSR(sender_info, &packet->data)) return; 42 if (!BuildSR(sender_info, &packet->data)) return;
48 if (!BuildSdec(&packet->data)) return; 43 if (!BuildSdec(&packet->data)) return;
49 } 44 }
50 if (packet_type_flags & kRtcpBye) {
51 if (!BuildBye(&packet->data)) return;
52 }
53 if (packet_type_flags & kRtcpDlrr) { 45 if (packet_type_flags & kRtcpDlrr) {
54 if (!BuildDlrrRb(dlrr, &packet->data)) return; 46 if (!BuildDlrrRb(dlrr, &packet->data)) return;
55 } 47 }
56 if (packet->data.empty()) 48 if (packet->data.empty())
57 return; // Sanity - don't send empty packets. 49 return; // Sanity - don't send empty packets.
58 50
59 transport_->SendRtcpPacket(ssrc_, packet); 51 transport_->SendRtcpPacket(ssrc_, packet);
60 } 52 }
61 53
62 bool RtcpBuilder::BuildSR(const RtcpSenderInfo& sender_info, 54 bool RtcpBuilder::BuildSR(const RtcpSenderInfo& sender_info,
(...skipping 15 matching lines...) Expand all
78 big_endian_writer.WriteU16(number_of_rows); 70 big_endian_writer.WriteU16(number_of_rows);
79 big_endian_writer.WriteU32(ssrc_); 71 big_endian_writer.WriteU32(ssrc_);
80 big_endian_writer.WriteU32(sender_info.ntp_seconds); 72 big_endian_writer.WriteU32(sender_info.ntp_seconds);
81 big_endian_writer.WriteU32(sender_info.ntp_fraction); 73 big_endian_writer.WriteU32(sender_info.ntp_fraction);
82 big_endian_writer.WriteU32(sender_info.rtp_timestamp); 74 big_endian_writer.WriteU32(sender_info.rtp_timestamp);
83 big_endian_writer.WriteU32(sender_info.send_packet_count); 75 big_endian_writer.WriteU32(sender_info.send_packet_count);
84 big_endian_writer.WriteU32(static_cast<uint32>(sender_info.send_octet_count)); 76 big_endian_writer.WriteU32(static_cast<uint32>(sender_info.send_octet_count));
85 return true; 77 return true;
86 } 78 }
87 79
88 bool RtcpBuilder::BuildSdec(Packet* packet) const {
89 size_t start_size = packet->size();
90 if (start_size + 12 + c_name_.length() > kMaxIpPacketSize) {
91 DLOG(FATAL) << "Not enough buffer space";
92 return false;
93 }
94
95 // SDES Source Description.
96 packet->resize(start_size + 10);
97
98 base::BigEndianWriter big_endian_writer(
99 reinterpret_cast<char*>(&((*packet)[start_size])), 10);
100 // We always need to add one SDES CNAME.
101 big_endian_writer.WriteU8(0x80 + 1);
102 big_endian_writer.WriteU8(kPacketTypeSdes);
103
104 // Handle SDES length later on.
105 uint32 sdes_length_position = static_cast<uint32>(start_size) + 3;
106 big_endian_writer.WriteU16(0);
107 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC.
108 big_endian_writer.WriteU8(1); // CNAME = 1
109 big_endian_writer.WriteU8(static_cast<uint8>(c_name_.length()));
110
111 size_t sdes_length = 10 + c_name_.length();
112 packet->insert(packet->end(), c_name_.c_str(),
113 c_name_.c_str() + c_name_.length());
114
115 size_t padding = 0;
116
117 // We must have a zero field even if we have an even multiple of 4 bytes.
118 if ((packet->size() % 4) == 0) {
119 padding++;
120 packet->push_back(0);
121 }
122 while ((packet->size() % 4) != 0) {
123 padding++;
124 packet->push_back(0);
125 }
126 sdes_length += padding;
127
128 // In 32-bit words minus one and we don't count the header.
129 uint8 buffer_length = static_cast<uint8>((sdes_length / 4) - 1);
130 (*packet)[sdes_length_position] = buffer_length;
131 return true;
132 }
133
134 bool RtcpBuilder::BuildBye(Packet* packet) const {
135 size_t start_size = packet->size();
136 if (start_size + 8 > kMaxIpPacketSize) {
137 DLOG(FATAL) << "Not enough buffer space";
138 return false;
139 }
140
141 packet->resize(start_size + 8);
142
143 base::BigEndianWriter big_endian_writer(
144 reinterpret_cast<char*>(&((*packet)[start_size])), 8);
145 big_endian_writer.WriteU8(0x80 + 1);
146 big_endian_writer.WriteU8(kPacketTypeBye);
147 big_endian_writer.WriteU16(1); // Length.
148 big_endian_writer.WriteU32(ssrc_); // Add our own SSRC.
149 return true;
150 }
151
152 /* 80 /*
153 0 1 2 3 81 0 1 2 3
154 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 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
155 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 83 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
156 |V=2|P|reserved | PT=XR=207 | length | 84 |V=2|P|reserved | PT=XR=207 | length |
157 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 85 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
158 | SSRC | 86 | SSRC |
159 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 87 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
160 | BT=5 | reserved | block length | 88 | BT=5 | reserved | block length |
161 +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ 89 +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
(...skipping 24 matching lines...) Expand all
186 big_endian_writer.WriteU8(0); // Add reserved. 114 big_endian_writer.WriteU8(0); // Add reserved.
187 big_endian_writer.WriteU16(3); // Block length. 115 big_endian_writer.WriteU16(3); // Block length.
188 big_endian_writer.WriteU32(ssrc_); // Add the media (received RTP) SSRC. 116 big_endian_writer.WriteU32(ssrc_); // Add the media (received RTP) SSRC.
189 big_endian_writer.WriteU32(dlrr.last_rr); 117 big_endian_writer.WriteU32(dlrr.last_rr);
190 big_endian_writer.WriteU32(dlrr.delay_since_last_rr); 118 big_endian_writer.WriteU32(dlrr.delay_since_last_rr);
191 return true; 119 return true;
192 } 120 }
193 121
194 } // namespace cast 122 } // namespace cast
195 } // namespace media 123 } // namespace media
OLDNEW
« no previous file with comments | « media/cast/net/rtcp/rtcp_builder.h ('k') | media/cast/net/rtcp/rtcp_builder_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698