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 // This is the base class for an object that send frames to a receiver. | 5 // This is the base class for an object that send frames to a receiver. |
6 // TODO(hclam): Refactor such that there is no separate AudioSender vs. | 6 // TODO(hclam): Refactor such that there is no separate AudioSender vs. |
7 // VideoSender, and the functionality of both is rolled into this class. | 7 // VideoSender, and the functionality of both is rolled into this class. |
8 | 8 |
9 #ifndef MEDIA_CAST_SENDER_FRAME_SENDER_H_ | 9 #ifndef MEDIA_CAST_SENDER_FRAME_SENDER_H_ |
10 #define MEDIA_CAST_SENDER_FRAME_SENDER_H_ | 10 #define MEDIA_CAST_SENDER_FRAME_SENDER_H_ |
(...skipping 11 matching lines...) Expand all Loading... |
22 | 22 |
23 class FrameSender { | 23 class FrameSender { |
24 public: | 24 public: |
25 FrameSender(scoped_refptr<CastEnvironment> cast_environment, | 25 FrameSender(scoped_refptr<CastEnvironment> cast_environment, |
26 bool is_audio, | 26 bool is_audio, |
27 CastTransportSender* const transport_sender, | 27 CastTransportSender* const transport_sender, |
28 base::TimeDelta rtcp_interval, | 28 base::TimeDelta rtcp_interval, |
29 int rtp_timebase, | 29 int rtp_timebase, |
30 uint32 ssrc, | 30 uint32 ssrc, |
31 double max_frame_rate, | 31 double max_frame_rate, |
32 base::TimeDelta playout_delay, | 32 base::TimeDelta min_playout_delay, |
| 33 base::TimeDelta max_playout_delay, |
33 CongestionControl* congestion_control); | 34 CongestionControl* congestion_control); |
34 virtual ~FrameSender(); | 35 virtual ~FrameSender(); |
35 | 36 |
36 // Calling this function is only valid if the receiver supports the | 37 // Calling this function is only valid if the receiver supports the |
37 // "extra_playout_delay", rtp extension. | 38 // "extra_playout_delay", rtp extension. |
38 void SetTargetPlayoutDelay(base::TimeDelta new_target_playout_delay); | 39 void SetTargetPlayoutDelay(base::TimeDelta new_target_playout_delay); |
39 | 40 |
40 base::TimeDelta GetTargetPlayoutDelay() const { | 41 base::TimeDelta GetTargetPlayoutDelay() const { |
41 return target_playout_delay_; | 42 return target_playout_delay_; |
42 } | 43 } |
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
101 | 102 |
102 const base::TimeDelta rtcp_interval_; | 103 const base::TimeDelta rtcp_interval_; |
103 | 104 |
104 // The total amount of time between a frame's capture/recording on the sender | 105 // The total amount of time between a frame's capture/recording on the sender |
105 // and its playback on the receiver (i.e., shown to a user). This is fixed as | 106 // and its playback on the receiver (i.e., shown to a user). This is fixed as |
106 // a value large enough to give the system sufficient time to encode, | 107 // a value large enough to give the system sufficient time to encode, |
107 // transmit/retransmit, receive, decode, and render; given its run-time | 108 // transmit/retransmit, receive, decode, and render; given its run-time |
108 // environment (sender/receiver hardware performance, network conditions, | 109 // environment (sender/receiver hardware performance, network conditions, |
109 // etc.). | 110 // etc.). |
110 base::TimeDelta target_playout_delay_; | 111 base::TimeDelta target_playout_delay_; |
| 112 base::TimeDelta min_playout_delay_; |
| 113 base::TimeDelta max_playout_delay_; |
111 | 114 |
112 // If true, we transmit the target playout delay to the receiver. | 115 // If true, we transmit the target playout delay to the receiver. |
113 bool send_target_playout_delay_; | 116 bool send_target_playout_delay_; |
114 | 117 |
115 // Max encoded frames generated per second. | 118 // Max encoded frames generated per second. |
116 double max_frame_rate_; | 119 double max_frame_rate_; |
117 | 120 |
118 // Maximum number of outstanding frames before the encoding and sending of | 121 // Maximum number of outstanding frames before the encoding and sending of |
119 // new frames shall halt. | 122 // new frames shall halt. |
120 int max_unacked_frames_; | 123 int max_unacked_frames_; |
(...skipping 27 matching lines...) Expand all Loading... |
148 // STATUS_VIDEO_INITIALIZED. | 151 // STATUS_VIDEO_INITIALIZED. |
149 CastInitializationStatus cast_initialization_status_; | 152 CastInitializationStatus cast_initialization_status_; |
150 | 153 |
151 // RTP timestamp increment representing one second. | 154 // RTP timestamp increment representing one second. |
152 const int rtp_timebase_; | 155 const int rtp_timebase_; |
153 | 156 |
154 // This object controls how we change the bitrate to make sure the | 157 // This object controls how we change the bitrate to make sure the |
155 // buffer doesn't overflow. | 158 // buffer doesn't overflow. |
156 scoped_ptr<CongestionControl> congestion_control_; | 159 scoped_ptr<CongestionControl> congestion_control_; |
157 | 160 |
| 161 // The most recently measured round trip time. |
| 162 base::TimeDelta current_round_trip_time_; |
| 163 |
158 private: | 164 private: |
159 const bool is_audio_; | 165 const bool is_audio_; |
160 | 166 |
161 // Ring buffers to keep track of recent frame timestamps (both in terms of | 167 // Ring buffers to keep track of recent frame timestamps (both in terms of |
162 // local reference time and RTP media time). These should only be accessed | 168 // local reference time and RTP media time). These should only be accessed |
163 // through the Record/GetXXX() methods. | 169 // through the Record/GetXXX() methods. |
164 base::TimeTicks frame_reference_times_[256]; | 170 base::TimeTicks frame_reference_times_[256]; |
165 RtpTimestamp frame_rtp_timestamps_[256]; | 171 RtpTimestamp frame_rtp_timestamps_[256]; |
166 | 172 |
167 // The most recently measured round trip time. | |
168 base::TimeDelta current_round_trip_time_; | |
169 | |
170 // NOTE: Weak pointers must be invalidated before all other member variables. | 173 // NOTE: Weak pointers must be invalidated before all other member variables. |
171 base::WeakPtrFactory<FrameSender> weak_factory_; | 174 base::WeakPtrFactory<FrameSender> weak_factory_; |
172 | 175 |
173 DISALLOW_COPY_AND_ASSIGN(FrameSender); | 176 DISALLOW_COPY_AND_ASSIGN(FrameSender); |
174 }; | 177 }; |
175 | 178 |
176 } // namespace cast | 179 } // namespace cast |
177 } // namespace media | 180 } // namespace media |
178 | 181 |
179 #endif // MEDIA_CAST_SENDER_FRAME_SENDER_H_ | 182 #endif // MEDIA_CAST_SENDER_FRAME_SENDER_H_ |
OLD | NEW |