Index: media/cast/net/rtp/cast_message_builder.cc |
diff --git a/media/cast/net/rtp/cast_message_builder.cc b/media/cast/net/rtp/cast_message_builder.cc |
index 42d6b98e0b23feb2398f646b3356964e562c3fc0..3d1d7a774872c330d489bd7e7d949a8ade073bba 100644 |
--- a/media/cast/net/rtp/cast_message_builder.cc |
+++ b/media/cast/net/rtp/cast_message_builder.cc |
@@ -5,6 +5,7 @@ |
#include "media/cast/net/rtp/cast_message_builder.h" |
#include "media/cast/cast_defines.h" |
+#include "media/cast/net/rtp/framer.h" |
namespace media { |
namespace cast { |
@@ -12,13 +13,13 @@ namespace cast { |
CastMessageBuilder::CastMessageBuilder( |
base::TickClock* clock, |
RtpPayloadFeedback* incoming_payload_feedback, |
- FrameIdMap* frame_id_map, |
+ const Framer* framer, |
uint32 media_ssrc, |
bool decoder_faster_than_max_frame_rate, |
int max_unacked_frames) |
: clock_(clock), |
cast_feedback_(incoming_payload_feedback), |
- frame_id_map_(frame_id_map), |
+ framer_(framer), |
media_ssrc_(media_ssrc), |
decoder_faster_than_max_frame_rate_(decoder_faster_than_max_frame_rate), |
max_unacked_frames_(max_unacked_frames), |
@@ -51,7 +52,7 @@ void CastMessageBuilder::CompleteFrameReceived(uint32 frame_id) { |
bool CastMessageBuilder::UpdateAckMessage(uint32 frame_id) { |
if (!decoder_faster_than_max_frame_rate_) { |
- int complete_frame_count = frame_id_map_->NumberOfCompleteFrames(); |
+ int complete_frame_count = framer_->NumberOfCompleteFrames(); |
if (complete_frame_count > max_unacked_frames_) { |
// We have too many frames pending in our framer; slow down ACK. |
if (!slowing_down_ack_) { |
@@ -95,7 +96,7 @@ bool CastMessageBuilder::UpdateAckMessage(uint32 frame_id) { |
bool CastMessageBuilder::TimeToSendNextCastMessage( |
base::TimeTicks* time_to_send) { |
// We haven't received any packets. |
- if (last_update_time_.is_null() && frame_id_map_->Empty()) |
+ if (last_update_time_.is_null() && framer_->Empty()) |
return false; |
*time_to_send = last_update_time_ + base::TimeDelta::FromMilliseconds( |
@@ -120,7 +121,7 @@ void CastMessageBuilder::Reset() { |
bool CastMessageBuilder::UpdateCastMessageInternal(RtcpCastMessage* message) { |
if (last_update_time_.is_null()) { |
- if (!frame_id_map_->Empty()) { |
+ if (!framer_->Empty()) { |
// We have received packets. |
last_update_time_ = clock_->NowTicks(); |
} |
@@ -148,10 +149,10 @@ void CastMessageBuilder::BuildPacketList() { |
cast_msg_.missing_frames_and_packets.clear(); |
// Are we missing packets? |
- if (frame_id_map_->Empty()) |
+ if (framer_->Empty()) |
return; |
- uint32 newest_frame_id = frame_id_map_->NewestFrameId(); |
+ uint32 newest_frame_id = framer_->NewestFrameId(); |
uint32 next_expected_frame_id = cast_msg_.ack_frame_id + 1; |
// Iterate over all frames. |
@@ -169,9 +170,9 @@ void CastMessageBuilder::BuildPacketList() { |
} |
PacketIdSet missing; |
- if (frame_id_map_->FrameExists(next_expected_frame_id)) { |
+ if (framer_->FrameExists(next_expected_frame_id)) { |
bool last_frame = (newest_frame_id == next_expected_frame_id); |
- frame_id_map_->GetMissingPackets( |
+ framer_->GetMissingPackets( |
next_expected_frame_id, last_frame, &missing); |
if (!missing.empty()) { |
time_last_nacked_map_[next_expected_frame_id] = now; |