Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(136)

Side by Side Diff: media/cast/sender/congestion_control.h

Issue 542883004: Cast: Merge common functionality from audio/video sender into frame_sender. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: merge Created 6 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « media/cast/sender/audio_sender.cc ('k') | media/cast/sender/congestion_control.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 #ifndef MEDIA_CAST_CONGESTION_CONTROL_CONGESTION_CONTROL_H_ 5 #ifndef MEDIA_CAST_CONGESTION_CONTROL_CONGESTION_CONTROL_H_
6 #define MEDIA_CAST_CONGESTION_CONTROL_CONGESTION_CONTROL_H_ 6 #define MEDIA_CAST_CONGESTION_CONTROL_CONGESTION_CONTROL_H_
7 7
8 #include <deque> 8 #include <deque>
9 9
10 #include "base/basictypes.h" 10 #include "base/basictypes.h"
11 #include "base/memory/scoped_ptr.h" 11 #include "base/memory/scoped_ptr.h"
12 #include "base/time/tick_clock.h" 12 #include "base/time/tick_clock.h"
13 #include "base/time/time.h" 13 #include "base/time/time.h"
14 14
15 namespace media { 15 namespace media {
16 namespace cast { 16 namespace cast {
17 17
18 class CongestionControl { 18 class CongestionControl {
19 public: 19 public:
20 CongestionControl(base::TickClock* clock,
21 uint32 max_bitrate_configured,
22 uint32 min_bitrate_configured,
23 size_t max_unacked_frames);
24
25 virtual ~CongestionControl(); 20 virtual ~CongestionControl();
26 21
27 void UpdateRtt(base::TimeDelta rtt); 22 // Called with latest measured rtt value.
23 virtual void UpdateRtt(base::TimeDelta rtt) = 0;
28 24
29 // Called when an encoded frame is sent to the transport. 25 // Called when an encoded frame is sent to the transport.
30 void SendFrameToTransport(uint32 frame_id, 26 virtual void SendFrameToTransport(uint32 frame_id,
31 size_t frame_size, 27 size_t frame_size,
32 base::TimeTicks when); 28 base::TimeTicks when) = 0;
33
34 // Called when we receive an ACK for a frame. 29 // Called when we receive an ACK for a frame.
35 void AckFrame(uint32 frame_id, base::TimeTicks when); 30 virtual void AckFrame(uint32 frame_id, base::TimeTicks when) = 0;
36 31
37 // Returns the bitrate we should use for the next frame. 32 // Returns the bitrate we should use for the next frame.
38 uint32 GetBitrate(base::TimeTicks playout_time, 33 virtual uint32 GetBitrate(base::TimeTicks playout_time,
39 base::TimeDelta playout_delay); 34 base::TimeDelta playout_delay) = 0;
35 };
40 36
41 private: 37 CongestionControl* NewAdaptiveCongestionControl(
42 struct FrameStats { 38 base::TickClock* clock,
43 FrameStats(); 39 uint32 max_bitrate_configured,
44 // Time this frame was sent to the transport. 40 uint32 min_bitrate_configured,
45 base::TimeTicks sent_time; 41 size_t max_unacked_frames);
46 // Time this frame was acked.
47 base::TimeTicks ack_time;
48 // Size of encoded frame in bits.
49 size_t frame_size;
50 };
51 42
52 // Calculate how much "dead air" (idle time) there is between two frames. 43 CongestionControl* NewFixedCongestionControl(uint32 bitrate);
53 static base::TimeDelta DeadTime(const FrameStats& a, const FrameStats& b);
54 // Get the FrameStats for a given |frame_id|.
55 // Note: Older FrameStats will be removed automatically.
56 FrameStats* GetFrameStats(uint32 frame_id);
57 // Calculate a safe bitrate. This is based on how much we've been
58 // sending in the past.
59 double CalculateSafeBitrate();
60
61 // For a given frame, calculate when it might be acked.
62 // (Or return the time it was acked, if it was.)
63 base::TimeTicks EstimatedAckTime(uint32 frame_id, double bitrate);
64 // Calculate when we start sending the data for a given frame.
65 // This is done by calculating when we were done sending the previous
66 // frame, but obviously can't be less than |sent_time| (if known).
67 base::TimeTicks EstimatedSendingTime(uint32 frame_id, double bitrate);
68
69 base::TickClock* const clock_; // Not owned by this class.
70 const uint32 max_bitrate_configured_;
71 const uint32 min_bitrate_configured_;
72 std::deque<FrameStats> frame_stats_;
73 uint32 last_frame_stats_;
74 uint32 last_acked_frame_;
75 uint32 last_encoded_frame_;
76 base::TimeDelta rtt_;
77 size_t history_size_;
78 size_t acked_bits_in_history_;
79 base::TimeDelta dead_time_in_history_;
80
81 DISALLOW_COPY_AND_ASSIGN(CongestionControl);
82 };
83 44
84 } // namespace cast 45 } // namespace cast
85 } // namespace media 46 } // namespace media
86 47
87 #endif // MEDIA_CAST_CONGESTION_CONTROL_CONGESTION_CONTROL_H_ 48 #endif // MEDIA_CAST_CONGESTION_CONTROL_CONGESTION_CONTROL_H_
OLDNEW
« no previous file with comments | « media/cast/sender/audio_sender.cc ('k') | media/cast/sender/congestion_control.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698