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
3 // found in the LICENSE file.
5 #include "media/cast/framer/framer.h"
7 #include "base/logging.h"
12 typedef FrameList::const_iterator ConstFrameIterator;
14 Framer::Framer(base::TickClock* clock,
15 RtpPayloadFeedback* incoming_payload_feedback,
17 bool decoder_faster_than_max_frame_rate,
18 int max_unacked_frames)
19 : decoder_faster_than_max_frame_rate_(decoder_faster_than_max_frame_rate),
20 cast_msg_builder_(new CastMessageBuilder(clock, incoming_payload_feedback,
21 &frame_id_map_, ssrc, decoder_faster_than_max_frame_rate,
22 max_unacked_frames)) {
23 DCHECK(incoming_payload_feedback) << "Invalid argument";
28 bool Framer::InsertPacket(const uint8* payload_data,
30 const RtpCastHeader& rtp_header) {
31 bool complete = false;
32 if (!frame_id_map_.InsertPacket(rtp_header, &complete)) return false;
34 // Does this packet belong to a new frame?
35 FrameList::iterator it = frames_.find(rtp_header.frame_id);
36 if (it == frames_.end()) {
38 linked_ptr<FrameBuffer> frame_buffer(new FrameBuffer());
39 frame_buffer->InsertPacket(payload_data, payload_size, rtp_header);
40 frames_.insert(std::make_pair(rtp_header.frame_id, frame_buffer));
42 // Insert packet to existing frame buffer.
43 it->second->InsertPacket(payload_data, payload_size, rtp_header);
47 // ACK as soon as possible.
48 VLOG(1) << "Complete frame " << static_cast<int>(rtp_header.frame_id);
49 cast_msg_builder_->CompleteFrameReceived(rtp_header.frame_id,
50 rtp_header.is_key_frame);
55 // This does not release the frame.
56 bool Framer::GetEncodedAudioFrame(EncodedAudioFrame* audio_frame,
57 uint32* rtp_timestamp,
61 if (frame_id_map_.NextContinuousFrame(&frame_id)) {
62 // We have our next frame.
65 if (!frame_id_map_.NextAudioFrameAllowingMissingFrames(&frame_id)) {
71 ConstFrameIterator it = frames_.find(frame_id);
72 DCHECK(it != frames_.end());
73 if (it == frames_.end()) return false;
75 return it->second->GetEncodedAudioFrame(audio_frame, rtp_timestamp);
78 // This does not release the frame.
79 bool Framer::GetEncodedVideoFrame(EncodedVideoFrame* video_frame,
80 uint32* rtp_timestamp,
84 if (frame_id_map_.NextContinuousFrame(&frame_id)) {
85 // We have our next frame.
88 // Check if we can skip frames when our decoder is too slow.
89 if (!decoder_faster_than_max_frame_rate_) return false;
91 if (!frame_id_map_.NextVideoFrameAllowingSkippingFrames(&frame_id)) {
97 ConstFrameIterator it = frames_.find(frame_id);
98 DCHECK(it != frames_.end());
99 if (it == frames_.end()) return false;
101 return it->second->GetEncodedVideoFrame(video_frame, rtp_timestamp);
104 void Framer::Reset() {
105 frame_id_map_.Clear();
107 cast_msg_builder_->Reset();
110 void Framer::ReleaseFrame(uint8 frame_id) {
111 frame_id_map_.RemoveOldFrames(frame_id);
112 frames_.erase(frame_id);
114 // We have a frame - remove all frames with lower frame id.
115 bool skipped_old_frame = false;
116 FrameList::iterator it;
117 for (it = frames_.begin(); it != frames_.end(); ) {
118 if (IsOlderFrameId(it->first, frame_id)) {
120 skipped_old_frame = true;
125 if (skipped_old_frame) {
126 cast_msg_builder_->UpdateCastMessage();
130 bool Framer::TimeToSendNextCastMessage(base::TimeTicks* time_to_send) {
131 return cast_msg_builder_->TimeToSendNextCastMessage(time_to_send);
134 void Framer::SendCastMessage() {
135 cast_msg_builder_->UpdateCastMessage();