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 |