| Index: media/cast/transport/rtp_sender/rtp_packetizer/rtp_packetizer.cc
|
| diff --git a/media/cast/transport/rtp_sender/rtp_packetizer/rtp_packetizer.cc b/media/cast/transport/rtp_sender/rtp_packetizer/rtp_packetizer.cc
|
| deleted file mode 100644
|
| index a459abacfc8e6ef37f8e9932c9fee66552f3b989..0000000000000000000000000000000000000000
|
| --- a/media/cast/transport/rtp_sender/rtp_packetizer/rtp_packetizer.cc
|
| +++ /dev/null
|
| @@ -1,134 +0,0 @@
|
| -// Copyright 2013 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "media/cast/transport/rtp_sender/rtp_packetizer/rtp_packetizer.h"
|
| -
|
| -#include "base/big_endian.h"
|
| -#include "base/logging.h"
|
| -#include "media/cast/transport/pacing/paced_sender.h"
|
| -
|
| -namespace media {
|
| -namespace cast {
|
| -namespace transport {
|
| -
|
| -static const uint16 kCommonRtpHeaderLength = 12;
|
| -static const uint16 kCastRtpHeaderLength = 7;
|
| -static const uint8 kCastKeyFrameBitMask = 0x80;
|
| -static const uint8 kCastReferenceFrameIdBitMask = 0x40;
|
| -static const uint8 kRtpMarkerBitMask = 0x80;
|
| -
|
| -RtpPacketizerConfig::RtpPacketizerConfig()
|
| - : payload_type(-1),
|
| - max_payload_length(kMaxIpPacketSize - 28), // Default is IP-v4/UDP.
|
| - sequence_number(0),
|
| - ssrc(0) {}
|
| -
|
| -RtpPacketizerConfig::~RtpPacketizerConfig() {}
|
| -
|
| -RtpPacketizer::RtpPacketizer(PacedSender* const transport,
|
| - PacketStorage* packet_storage,
|
| - RtpPacketizerConfig rtp_packetizer_config)
|
| - : config_(rtp_packetizer_config),
|
| - transport_(transport),
|
| - packet_storage_(packet_storage),
|
| - sequence_number_(config_.sequence_number),
|
| - rtp_timestamp_(0),
|
| - packet_id_(0),
|
| - send_packet_count_(0),
|
| - send_octet_count_(0) {
|
| - DCHECK(transport) << "Invalid argument";
|
| -}
|
| -
|
| -RtpPacketizer::~RtpPacketizer() {}
|
| -
|
| -uint16 RtpPacketizer::NextSequenceNumber() {
|
| - ++sequence_number_;
|
| - return sequence_number_ - 1;
|
| -}
|
| -
|
| -void RtpPacketizer::SendFrameAsPackets(const EncodedFrame& frame) {
|
| - uint16 rtp_header_length = kCommonRtpHeaderLength + kCastRtpHeaderLength;
|
| - uint16 max_length = config_.max_payload_length - rtp_header_length - 1;
|
| - rtp_timestamp_ = frame.rtp_timestamp;
|
| -
|
| - // Split the payload evenly (round number up).
|
| - size_t num_packets = (frame.data.size() + max_length) / max_length;
|
| - size_t payload_length = (frame.data.size() + num_packets) / num_packets;
|
| - DCHECK_LE(payload_length, max_length) << "Invalid argument";
|
| -
|
| - SendPacketVector packets;
|
| -
|
| - size_t remaining_size = frame.data.size();
|
| - std::string::const_iterator data_iter = frame.data.begin();
|
| - while (remaining_size > 0) {
|
| - PacketRef packet(new base::RefCountedData<Packet>);
|
| -
|
| - if (remaining_size < payload_length) {
|
| - payload_length = remaining_size;
|
| - }
|
| - remaining_size -= payload_length;
|
| - BuildCommonRTPheader(
|
| - &packet->data, remaining_size == 0, frame.rtp_timestamp);
|
| -
|
| - // Build Cast header.
|
| - // TODO(miu): Should we always set the ref frame bit and the ref_frame_id?
|
| - DCHECK_NE(frame.dependency, EncodedFrame::UNKNOWN_DEPENDENCY);
|
| - packet->data.push_back(
|
| - ((frame.dependency == EncodedFrame::KEY) ? kCastKeyFrameBitMask : 0) |
|
| - kCastReferenceFrameIdBitMask);
|
| - packet->data.push_back(static_cast<uint8>(frame.frame_id));
|
| - size_t start_size = packet->data.size();
|
| - packet->data.resize(start_size + 4);
|
| - base::BigEndianWriter big_endian_writer(
|
| - reinterpret_cast<char*>(&(packet->data[start_size])), 4);
|
| - big_endian_writer.WriteU16(packet_id_);
|
| - big_endian_writer.WriteU16(static_cast<uint16>(num_packets - 1));
|
| - packet->data.push_back(static_cast<uint8>(frame.referenced_frame_id));
|
| -
|
| - // Copy payload data.
|
| - packet->data.insert(packet->data.end(),
|
| - data_iter,
|
| - data_iter + payload_length);
|
| - data_iter += payload_length;
|
| -
|
| - const PacketKey key =
|
| - PacedPacketSender::MakePacketKey(frame.reference_time,
|
| - config_.ssrc,
|
| - packet_id_++);
|
| - packets.push_back(make_pair(key, packet));
|
| -
|
| - // Update stats.
|
| - ++send_packet_count_;
|
| - send_octet_count_ += payload_length;
|
| - }
|
| - DCHECK(packet_id_ == num_packets) << "Invalid state";
|
| -
|
| - packet_storage_->StoreFrame(frame.frame_id, packets);
|
| -
|
| - // Send to network.
|
| - transport_->SendPackets(packets);
|
| -
|
| - // Prepare for next frame.
|
| - packet_id_ = 0;
|
| -}
|
| -
|
| -void RtpPacketizer::BuildCommonRTPheader(Packet* packet,
|
| - bool marker_bit,
|
| - uint32 time_stamp) {
|
| - packet->push_back(0x80);
|
| - packet->push_back(static_cast<uint8>(config_.payload_type) |
|
| - (marker_bit ? kRtpMarkerBitMask : 0));
|
| - size_t start_size = packet->size();
|
| - packet->resize(start_size + 10);
|
| - base::BigEndianWriter big_endian_writer(
|
| - reinterpret_cast<char*>(&((*packet)[start_size])), 10);
|
| - big_endian_writer.WriteU16(sequence_number_);
|
| - big_endian_writer.WriteU32(time_stamp);
|
| - big_endian_writer.WriteU32(config_.ssrc);
|
| - ++sequence_number_;
|
| -}
|
| -
|
| -} // namespace transport
|
| -} // namespace cast
|
| -} // namespace media
|
|
|