| Index: media/cast/transport/pacing/paced_sender.cc
|
| diff --git a/media/cast/transport/pacing/paced_sender.cc b/media/cast/transport/pacing/paced_sender.cc
|
| index b24a79682bd1906682916fa093682a87a45cda62..b592b0acf5d85db587373278a2000e676d7132f2 100644
|
| --- a/media/cast/transport/pacing/paced_sender.cc
|
| +++ b/media/cast/transport/pacing/paced_sender.cc
|
| @@ -21,37 +21,19 @@ static const size_t kPacingMaxBurstsPerFrame = 3;
|
|
|
| PacedSender::PacedSender(
|
| base::TickClock* clock,
|
| - const CastTransportConfig* const config,
|
| - PacketSender* external_transport,
|
| - const scoped_refptr<base::TaskRunner>& transport_task_runner,
|
| - const CastTransportStatusCallback& status_callback)
|
| + PacketSender* transport,
|
| + const scoped_refptr<base::TaskRunner>& transport_task_runner)
|
| : clock_(clock),
|
| - external_transport_(external_transport),
|
| - config_(config),
|
| + transport_(transport),
|
| transport_task_runner_(transport_task_runner),
|
| burst_size_(1),
|
| packets_sent_in_burst_(0),
|
| weak_factory_(this) {
|
| - if (!external_transport) {
|
| - net::IPEndPoint local_end_point;
|
| - net::IPEndPoint receiver_end_point;
|
| - // Set up transport in the absence of an external transport.
|
| - transport_.reset(new UdpTransport(transport_task_runner,
|
| - config_->local_endpoint,
|
| - config_->receiver_endpoint,
|
| - status_callback));
|
| - }
|
| ScheduleNextSend();
|
| }
|
|
|
| PacedSender::~PacedSender() {}
|
|
|
| -void PacedSender::SetPacketReceiver(
|
| - const PacketReceiverCallback& packet_receiver) {
|
| - DCHECK(!external_transport_);
|
| - transport_->StartReceiving(packet_receiver);
|
| -}
|
| -
|
| bool PacedSender::SendPackets(const PacketList& packets) {
|
| return SendPacketsToTransport(packets, &packet_list_);
|
| }
|
| @@ -92,9 +74,6 @@ bool PacedSender::SendPacketsToTransport(const PacketList& packets,
|
| }
|
|
|
| bool PacedSender::SendRtcpPacket(const Packet& packet) {
|
| - if (external_transport_) {
|
| - return external_transport_->SendPacket(packet);
|
| - }
|
| // We pass the RTCP packets straight through.
|
| return transport_->SendPacket(packet);
|
| }
|
| @@ -154,11 +133,7 @@ void PacedSender::SendStoredPackets() {
|
| bool PacedSender::TransmitPackets(const PacketList& packets) {
|
| bool ret = true;
|
| for (size_t i = 0; i < packets.size(); i++) {
|
| - if (external_transport_) {
|
| - ret &= external_transport_->SendPacket(packets[i]);
|
| - } else {
|
| - ret &= transport_->SendPacket(packets[i]);
|
| - }
|
| + ret &= transport_->SendPacket(packets[i]);
|
| }
|
| return ret;
|
| }
|
| @@ -172,10 +147,6 @@ void PacedSender::UpdateBurstSize(size_t packets_to_send) {
|
| burst_size_);
|
| }
|
|
|
| -void PacedSender::InsertFakeTransportForTesting(PacketSender* fake_transport) {
|
| - external_transport_ = fake_transport;
|
| -}
|
| -
|
| } // namespace transport
|
| } // namespace cast
|
| } // namespace media
|
|
|