OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/framer/framer.h" | 5 #include "media/cast/framer/framer.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 | 8 |
9 namespace media { | 9 namespace media { |
10 namespace cast { | 10 namespace cast { |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
62 if (complete) { | 62 if (complete) { |
63 // ACK as soon as possible. | 63 // ACK as soon as possible. |
64 VLOG(2) << "Complete frame " << static_cast<int>(rtp_header.frame_id); | 64 VLOG(2) << "Complete frame " << static_cast<int>(rtp_header.frame_id); |
65 cast_msg_builder_->CompleteFrameReceived(rtp_header.frame_id, | 65 cast_msg_builder_->CompleteFrameReceived(rtp_header.frame_id, |
66 rtp_header.is_key_frame); | 66 rtp_header.is_key_frame); |
67 } | 67 } |
68 return complete; | 68 return complete; |
69 } | 69 } |
70 | 70 |
71 // This does not release the frame. | 71 // This does not release the frame. |
72 bool Framer::GetEncodedAudioFrame(transport::EncodedAudioFrame* audio_frame, | 72 bool Framer::GetEncodedAudioFrame(transport::EncodedFrame* audio_frame, |
73 bool* next_frame) { | 73 bool* next_frame) { |
74 uint32 frame_id; | 74 uint32 frame_id; |
75 // Find frame id. | 75 // Find frame id. |
76 if (frame_id_map_.NextContinuousFrame(&frame_id)) { | 76 if (frame_id_map_.NextContinuousFrame(&frame_id)) { |
77 // We have our next frame. | 77 // We have our next frame. |
78 *next_frame = true; | 78 *next_frame = true; |
79 } else { | 79 } else { |
80 if (!frame_id_map_.NextAudioFrameAllowingMissingFrames(&frame_id)) { | 80 if (!frame_id_map_.NextAudioFrameAllowingMissingFrames(&frame_id)) { |
81 return false; | 81 return false; |
82 } | 82 } |
83 *next_frame = false; | 83 *next_frame = false; |
84 } | 84 } |
85 | 85 |
86 ConstFrameIterator it = frames_.find(frame_id); | 86 ConstFrameIterator it = frames_.find(frame_id); |
87 DCHECK(it != frames_.end()); | 87 DCHECK(it != frames_.end()); |
88 if (it == frames_.end()) | 88 if (it == frames_.end()) |
89 return false; | 89 return false; |
90 | 90 |
91 return it->second->GetEncodedAudioFrame(audio_frame); | 91 return it->second->AssembleEncodedFrame(audio_frame); |
92 } | 92 } |
93 | 93 |
94 // This does not release the frame. | 94 // This does not release the frame. |
95 bool Framer::GetEncodedVideoFrame(transport::EncodedVideoFrame* video_frame, | 95 bool Framer::GetEncodedVideoFrame(transport::EncodedFrame* video_frame, |
96 bool* next_frame) { | 96 bool* next_frame) { |
97 uint32 frame_id; | 97 uint32 frame_id; |
98 // Find frame id. | 98 // Find frame id. |
99 if (frame_id_map_.NextContinuousFrame(&frame_id)) { | 99 if (frame_id_map_.NextContinuousFrame(&frame_id)) { |
100 // We have our next frame. | 100 // We have our next frame. |
101 *next_frame = true; | 101 *next_frame = true; |
102 } else { | 102 } else { |
103 // Check if we can skip frames when our decoder is too slow. | 103 // Check if we can skip frames when our decoder is too slow. |
104 if (!decoder_faster_than_max_frame_rate_) | 104 if (!decoder_faster_than_max_frame_rate_) |
105 return false; | 105 return false; |
106 | 106 |
107 if (!frame_id_map_.NextVideoFrameAllowingSkippingFrames(&frame_id)) { | 107 if (!frame_id_map_.NextVideoFrameAllowingSkippingFrames(&frame_id)) { |
108 return false; | 108 return false; |
109 } | 109 } |
110 *next_frame = false; | 110 *next_frame = false; |
111 } | 111 } |
112 | 112 |
113 ConstFrameIterator it = frames_.find(frame_id); | 113 ConstFrameIterator it = frames_.find(frame_id); |
114 DCHECK(it != frames_.end()); | 114 DCHECK(it != frames_.end()); |
115 if (it == frames_.end()) | 115 if (it == frames_.end()) |
116 return false; | 116 return false; |
117 | 117 |
118 return it->second->GetEncodedVideoFrame(video_frame); | 118 return it->second->AssembleEncodedFrame(video_frame); |
119 } | 119 } |
120 | 120 |
121 void Framer::Reset() { | 121 void Framer::Reset() { |
122 frame_id_map_.Clear(); | 122 frame_id_map_.Clear(); |
123 frames_.clear(); | 123 frames_.clear(); |
124 cast_msg_builder_->Reset(); | 124 cast_msg_builder_->Reset(); |
125 } | 125 } |
126 | 126 |
127 void Framer::ReleaseFrame(uint32 frame_id) { | 127 void Framer::ReleaseFrame(uint32 frame_id) { |
128 frame_id_map_.RemoveOldFrames(frame_id); | 128 frame_id_map_.RemoveOldFrames(frame_id); |
(...skipping 16 matching lines...) Expand all Loading... |
145 } | 145 } |
146 | 146 |
147 bool Framer::TimeToSendNextCastMessage(base::TimeTicks* time_to_send) { | 147 bool Framer::TimeToSendNextCastMessage(base::TimeTicks* time_to_send) { |
148 return cast_msg_builder_->TimeToSendNextCastMessage(time_to_send); | 148 return cast_msg_builder_->TimeToSendNextCastMessage(time_to_send); |
149 } | 149 } |
150 | 150 |
151 void Framer::SendCastMessage() { cast_msg_builder_->UpdateCastMessage(); } | 151 void Framer::SendCastMessage() { cast_msg_builder_->UpdateCastMessage(); } |
152 | 152 |
153 } // namespace cast | 153 } // namespace cast |
154 } // namespace media | 154 } // namespace media |
OLD | NEW |