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
3 // found in the LICENSE file.
5 #include "media/cast/net/rtp/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),
21 new CastMessageBuilder(clock,
22 incoming_payload_feedback,
25 decoder_faster_than_max_frame_rate,
26 max_unacked_frames)) {
27 DCHECK(incoming_payload_feedback) << "Invalid argument";
32 bool Framer::InsertPacket(const uint8* payload_data,
34 const RtpCastHeader& rtp_header,
37 PacketType packet_type = frame_id_map_.InsertPacket(rtp_header);
38 if (packet_type == kTooOldPacket) {
41 if (packet_type == kDuplicatePacket) {
42 VLOG(3) << "Packet already received, ignored: frame "
43 << static_cast<int>(rtp_header.frame_id) << ", packet "
44 << rtp_header.packet_id;
49 // Does this packet belong to a new frame?
50 FrameList::iterator it = frames_.find(rtp_header.frame_id);
51 if (it == frames_.end()) {
53 linked_ptr<FrameBuffer> frame_buffer(new FrameBuffer());
54 frame_buffer->InsertPacket(payload_data, payload_size, rtp_header);
55 frames_.insert(std::make_pair(rtp_header.frame_id, frame_buffer));
57 // Insert packet to existing frame buffer.
58 it->second->InsertPacket(payload_data, payload_size, rtp_header);
61 return packet_type == kNewPacketCompletingFrame;
64 // This does not release the frame.
65 bool Framer::GetEncodedFrame(EncodedFrame* frame,
67 bool* have_multiple_decodable_frames) {
68 *have_multiple_decodable_frames = frame_id_map_.HaveMultipleDecodableFrames();
72 if (frame_id_map_.NextContinuousFrame(&frame_id)) {
73 // We have our next frame.
76 // Check if we can skip frames when our decoder is too slow.
77 if (!decoder_faster_than_max_frame_rate_)
80 if (!frame_id_map_.NextFrameAllowingSkippingFrames(&frame_id)) {
87 VLOG(2) << "ACK frame " << frame_id;
88 cast_msg_builder_->CompleteFrameReceived(frame_id);
91 ConstFrameIterator it = frames_.find(frame_id);
92 DCHECK(it != frames_.end());
93 if (it == frames_.end())
96 return it->second->AssembleEncodedFrame(frame);
99 void Framer::Reset() {
100 frame_id_map_.Clear();
102 cast_msg_builder_->Reset();
105 void Framer::ReleaseFrame(uint32 frame_id) {
106 frame_id_map_.RemoveOldFrames(frame_id);
107 frames_.erase(frame_id);
109 // We have a frame - remove all frames with lower frame id.
110 bool skipped_old_frame = false;
111 FrameList::iterator it;
112 for (it = frames_.begin(); it != frames_.end();) {
113 if (IsOlderFrameId(it->first, frame_id)) {
115 skipped_old_frame = true;
120 if (skipped_old_frame) {
121 cast_msg_builder_->UpdateCastMessage();
125 bool Framer::TimeToSendNextCastMessage(base::TimeTicks* time_to_send) {
126 return cast_msg_builder_->TimeToSendNextCastMessage(time_to_send);
129 void Framer::SendCastMessage() { cast_msg_builder_->UpdateCastMessage(); }