| OLD | NEW |
| 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/cast_transport_sender_impl.h" | 5 #include "media/cast/net/cast_transport_sender_impl.h" |
| 6 | 6 |
| 7 #include "base/single_thread_task_runner.h" | 7 #include "base/single_thread_task_runner.h" |
| 8 #include "base/values.h" | 8 #include "base/values.h" |
| 9 #include "media/cast/net/cast_transport_defines.h" | 9 #include "media/cast/net/cast_transport_defines.h" |
| 10 #include "media/cast/net/udp_transport.h" | 10 #include "media/cast/net/udp_transport.h" |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 45 LookupOptionWithDefault(options, kOptionPacerMaxBurstSize, | 45 LookupOptionWithDefault(options, kOptionPacerMaxBurstSize, |
| 46 kMaxBurstSize) * kMaxIpPacketSize; | 46 kMaxBurstSize) * kMaxIpPacketSize; |
| 47 int32 min_send_buffer_size = | 47 int32 min_send_buffer_size = |
| 48 LookupOptionWithDefault(options, kOptionSendBufferMinSize, 0); | 48 LookupOptionWithDefault(options, kOptionSendBufferMinSize, 0); |
| 49 return std::max(max_burst_size, min_send_buffer_size); | 49 return std::max(max_burst_size, min_send_buffer_size); |
| 50 } | 50 } |
| 51 | 51 |
| 52 } // namespace | 52 } // namespace |
| 53 | 53 |
| 54 scoped_ptr<CastTransportSender> CastTransportSender::Create( | 54 scoped_ptr<CastTransportSender> CastTransportSender::Create( |
| 55 net::NetLog* net_log, | 55 base::WeakPtr<CastTransportSenderInfo> cast_transport_sender_info, |
| 56 base::TickClock* clock, | 56 base::TickClock* clock, |
| 57 const net::IPEndPoint& local_end_point, | |
| 58 const net::IPEndPoint& remote_end_point, | |
| 59 scoped_ptr<base::DictionaryValue> options, | |
| 60 const CastTransportStatusCallback& status_callback, | |
| 61 const BulkRawEventsCallback& raw_events_callback, | |
| 62 base::TimeDelta raw_events_callback_interval, | |
| 63 const PacketReceiverCallback& packet_callback, | |
| 64 const scoped_refptr<base::SingleThreadTaskRunner>& transport_task_runner) { | 57 const scoped_refptr<base::SingleThreadTaskRunner>& transport_task_runner) { |
| 65 return scoped_ptr<CastTransportSender>( | 58 return scoped_ptr<CastTransportSender>(new CastTransportSenderImpl( |
| 66 new CastTransportSenderImpl(net_log, | 59 cast_transport_sender_info, clock, transport_task_runner.get(), NULL)); |
| 67 clock, | |
| 68 local_end_point, | |
| 69 remote_end_point, | |
| 70 options.Pass(), | |
| 71 status_callback, | |
| 72 raw_events_callback, | |
| 73 raw_events_callback_interval, | |
| 74 transport_task_runner.get(), | |
| 75 packet_callback, | |
| 76 NULL)); | |
| 77 } | 60 } |
| 78 | 61 |
| 79 PacketReceiverCallback CastTransportSender::PacketReceiverForTesting() { | 62 PacketReceiverCallback CastTransportSender::PacketReceiverForTesting() { |
| 80 return PacketReceiverCallback(); | 63 return PacketReceiverCallback(); |
| 81 } | 64 } |
| 82 | 65 |
| 83 CastTransportSenderImpl::CastTransportSenderImpl( | 66 CastTransportSenderImpl::CastTransportSenderImpl( |
| 84 net::NetLog* net_log, | 67 net::NetLog* net_log, |
| 85 base::TickClock* clock, | 68 base::TickClock* clock, |
| 86 const net::IPEndPoint& local_end_point, | 69 const net::IPEndPoint& local_end_point, |
| (...skipping 399 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 486 sender_ssrc); | 469 sender_ssrc); |
| 487 rtcp.SendRtcpFromRtpReceiver(time_data, | 470 rtcp.SendRtcpFromRtpReceiver(time_data, |
| 488 cast_message, | 471 cast_message, |
| 489 target_delay, | 472 target_delay, |
| 490 rtcp_events, | 473 rtcp_events, |
| 491 rtp_receiver_statistics); | 474 rtp_receiver_statistics); |
| 492 } | 475 } |
| 493 | 476 |
| 494 } // namespace cast | 477 } // namespace cast |
| 495 } // namespace media | 478 } // namespace media |
| OLD | NEW |