Index: media/cast/net/rtcp/rtcp_sender.cc |
diff --git a/media/cast/net/rtcp/rtcp_sender.cc b/media/cast/net/rtcp/rtcp_sender.cc |
index d0986a2f0264e8bd0545cd1387e3ea4f19431c68..f4ae23979fd3567613288a4ea59f045d49a0699e 100644 |
--- a/media/cast/net/rtcp/rtcp_sender.cc |
+++ b/media/cast/net/rtcp/rtcp_sender.cc |
@@ -11,7 +11,6 @@ |
#include "base/big_endian.h" |
#include "base/logging.h" |
-#include "media/cast/cast_environment.h" |
#include "media/cast/net/cast_transport_defines.h" |
#include "media/cast/net/pacing/paced_sender.h" |
#include "media/cast/net/rtcp/rtcp_defines.h" |
@@ -146,15 +145,12 @@ class NackStringBuilder { |
}; |
} // namespace |
-// TODO(mikhal): This is only used by the receiver. Consider renaming. |
-RtcpSender::RtcpSender(scoped_refptr<CastEnvironment> cast_environment, |
- PacedPacketSender* outgoing_transport, |
+RtcpSender::RtcpSender(PacedPacketSender* outgoing_transport, |
uint32 sending_ssrc, |
const std::string& c_name) |
: ssrc_(sending_ssrc), |
c_name_(c_name), |
- transport_(outgoing_transport), |
- cast_environment_(cast_environment) { |
+ transport_(outgoing_transport) { |
DCHECK_LT(c_name_.length(), kRtcpCnameSize) << "Invalid config"; |
} |
@@ -181,7 +177,6 @@ void RtcpSender::SendRtcpFromRtpReceiver( |
} |
PacketRef packet(new base::RefCountedData<Packet>); |
packet->data.reserve(kMaxIpPacketSize); |
- |
if (packet_type_flags & kRtcpRr) { |
BuildRR(report_block, &packet->data); |
if (!c_name_.empty()) { |
@@ -210,6 +205,38 @@ void RtcpSender::SendRtcpFromRtpReceiver( |
transport_->SendRtcpPacket(ssrc_, packet); |
} |
+void RtcpSender::SendRtcpFromRtpSender( |
+ uint32 packet_type_flags, |
+ const RtcpSenderInfo& sender_info, |
+ const RtcpDlrrReportBlock& dlrr) { |
+ if (packet_type_flags & kRtcpRr || |
+ packet_type_flags & kRtcpPli || |
+ packet_type_flags & kRtcpRrtr || |
+ packet_type_flags & kRtcpCast || |
+ packet_type_flags & kRtcpReceiverLog || |
+ packet_type_flags & kRtcpRpsi || |
+ packet_type_flags & kRtcpRemb || |
+ packet_type_flags & kRtcpNack) { |
+ NOTREACHED() << "Invalid argument"; |
+ } |
+ PacketRef packet(new base::RefCountedData<Packet>); |
+ packet->data.reserve(kMaxIpPacketSize); |
+ if (packet_type_flags & kRtcpSr) { |
+ BuildSR(sender_info, &packet->data); |
+ BuildSdec(&packet->data); |
+ } |
+ if (packet_type_flags & kRtcpBye) { |
+ BuildBye(&packet->data); |
+ } |
+ if (packet_type_flags & kRtcpDlrr) { |
+ BuildDlrrRb(dlrr, &packet->data); |
+ } |
+ if (packet->data.empty()) |
+ return; // Sanity - don't send empty packets. |
miu
2014/07/16 19:58:02
I wonder if there should be a NOTREACHED() here?
Alpha Left Google
2014/07/17 01:01:46
Done.
|
+ |
+ transport_->SendRtcpPacket(ssrc_, packet); |
+} |
+ |
void RtcpSender::BuildRR(const RtcpReportBlock* report_block, |
Packet* packet) const { |
size_t start_size = packet->size(); |
@@ -334,7 +361,8 @@ void RtcpSender::BuildPli(uint32 remote_ssrc, Packet* packet) const { |
| defined per codec ... | Padding (0) | |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
*/ |
-void RtcpSender::BuildRpsi(const RtcpRpsiMessage* rpsi, Packet* packet) const { |
+void RtcpSender::BuildRpsi(const RtcpRpsiMessage* rpsi, |
+ Packet* packet) const { |
size_t start_size = packet->size(); |
DCHECK_LT(start_size + 24, kMaxIpPacketSize) << "Not enough buffer space"; |
if (start_size + 24 > kMaxIpPacketSize) |
@@ -388,7 +416,8 @@ void RtcpSender::BuildRpsi(const RtcpRpsiMessage* rpsi, Packet* packet) const { |
} |
} |
-void RtcpSender::BuildRemb(const RtcpRembMessage* remb, Packet* packet) const { |
+void RtcpSender::BuildRemb(const RtcpRembMessage* remb, |
+ Packet* packet) const { |
size_t start_size = packet->size(); |
size_t remb_size = 20 + 4 * remb->remb_ssrcs.size(); |
DCHECK_LT(start_size + remb_size, kMaxIpPacketSize) |
@@ -429,7 +458,8 @@ void RtcpSender::BuildRemb(const RtcpRembMessage* remb, Packet* packet) const { |
} |
} |
-void RtcpSender::BuildNack(const RtcpNackMessage* nack, Packet* packet) const { |
+void RtcpSender::BuildNack(const RtcpNackMessage* nack, |
+ Packet* packet) const { |
size_t start_size = packet->size(); |
DCHECK_LT(start_size + 16, kMaxIpPacketSize) << "Not enough buffer space"; |
if (start_size + 16 > kMaxIpPacketSize) |
@@ -621,6 +651,74 @@ void RtcpSender::BuildCast(const RtcpCastMessage* cast, |
(*packet)[cast_loss_field_pos] = static_cast<uint8>(number_of_loss_fields); |
} |
+void RtcpSender::BuildSR(const RtcpSenderInfo& sender_info, |
+ Packet* packet) const { |
+ // Sender report. |
+ size_t start_size = packet->size(); |
+ if (start_size + 52 > kMaxIpPacketSize) { |
+ DLOG(FATAL) << "Not enough buffer space"; |
+ return; |
+ } |
+ |
+ uint16 number_of_rows = 6; |
+ packet->resize(start_size + 28); |
+ |
+ base::BigEndianWriter big_endian_writer( |
+ reinterpret_cast<char*>(&((*packet)[start_size])), 28); |
+ big_endian_writer.WriteU8(0x80); |
+ big_endian_writer.WriteU8(kPacketTypeSenderReport); |
+ big_endian_writer.WriteU16(number_of_rows); |
+ big_endian_writer.WriteU32(ssrc_); |
+ big_endian_writer.WriteU32(sender_info.ntp_seconds); |
+ big_endian_writer.WriteU32(sender_info.ntp_fraction); |
+ big_endian_writer.WriteU32(sender_info.rtp_timestamp); |
+ big_endian_writer.WriteU32(sender_info.send_packet_count); |
+ big_endian_writer.WriteU32(static_cast<uint32>(sender_info.send_octet_count)); |
+ return; |
+} |
+ |
+/* |
+ 0 1 2 3 |
+ 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 |
+ +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
+ |V=2|P|reserved | PT=XR=207 | length | |
+ +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
+ | SSRC | |
+ +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
+ | BT=5 | reserved | block length | |
+ +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ |
+ | SSRC1 (SSRC of first receiver) | sub- |
+ +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ block |
+ | last RR (LRR) | 1 |
+ +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
+ | delay since last RR (DLRR) | |
+ +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ |
+*/ |
+void RtcpSender::BuildDlrrRb(const RtcpDlrrReportBlock& dlrr, |
+ Packet* packet) const { |
+ size_t start_size = packet->size(); |
+ if (start_size + 24 > kMaxIpPacketSize) { |
+ DLOG(FATAL) << "Not enough buffer space"; |
+ return; |
+ } |
+ |
+ packet->resize(start_size + 24); |
+ |
+ base::BigEndianWriter big_endian_writer( |
+ reinterpret_cast<char*>(&((*packet)[start_size])), 24); |
+ big_endian_writer.WriteU8(0x80); |
+ big_endian_writer.WriteU8(kPacketTypeXr); |
+ big_endian_writer.WriteU16(5); // Length. |
+ big_endian_writer.WriteU32(ssrc_); // Add our own SSRC. |
+ big_endian_writer.WriteU8(5); // Add block type. |
+ big_endian_writer.WriteU8(0); // Add reserved. |
+ big_endian_writer.WriteU16(3); // Block length. |
+ big_endian_writer.WriteU32(ssrc_); // Add the media (received RTP) SSRC. |
+ big_endian_writer.WriteU32(dlrr.last_rr); |
+ big_endian_writer.WriteU32(dlrr.delay_since_last_rr); |
+ return; |
+} |
+ |
void RtcpSender::BuildReceiverLog( |
const ReceiverRtcpEventSubscriber::RtcpEventMultiMap& rtcp_events, |
Packet* packet) { |