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

Side by Side Diff: media/cast/transport/rtp_sender/rtp_packetizer/rtp_packetizer.cc

Issue 281453003: Cast: Simplify code path for RTCP sender report (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: merged Created 6 years, 7 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 | Annotate | Revision Log
OLDNEW
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/transport/rtp_sender/rtp_packetizer/rtp_packetizer.h" 5 #include "media/cast/transport/rtp_sender/rtp_packetizer/rtp_packetizer.h"
6 6
7 #include "base/big_endian.h" 7 #include "base/big_endian.h"
8 #include "base/logging.h" 8 #include "base/logging.h"
9 #include "media/cast/transport/pacing/paced_sender.h" 9 #include "media/cast/transport/pacing/paced_sender.h"
10 10
(...skipping 20 matching lines...) Expand all
31 31
32 RtpPacketizer::RtpPacketizer(PacedSender* const transport, 32 RtpPacketizer::RtpPacketizer(PacedSender* const transport,
33 PacketStorage* packet_storage, 33 PacketStorage* packet_storage,
34 RtpPacketizerConfig rtp_packetizer_config) 34 RtpPacketizerConfig rtp_packetizer_config)
35 : config_(rtp_packetizer_config), 35 : config_(rtp_packetizer_config),
36 transport_(transport), 36 transport_(transport),
37 packet_storage_(packet_storage), 37 packet_storage_(packet_storage),
38 sequence_number_(config_.sequence_number), 38 sequence_number_(config_.sequence_number),
39 rtp_timestamp_(0), 39 rtp_timestamp_(0),
40 packet_id_(0), 40 packet_id_(0),
41 send_packets_count_(0), 41 send_packet_count_(0),
42 send_octet_count_(0) { 42 send_octet_count_(0) {
43 DCHECK(transport) << "Invalid argument"; 43 DCHECK(transport) << "Invalid argument";
44 } 44 }
45 45
46 RtpPacketizer::~RtpPacketizer() {} 46 RtpPacketizer::~RtpPacketizer() {}
47 47
48 void RtpPacketizer::IncomingEncodedVideoFrame( 48 void RtpPacketizer::IncomingEncodedVideoFrame(
49 const EncodedVideoFrame* video_frame, 49 const EncodedVideoFrame* video_frame,
50 const base::TimeTicks& capture_time) { 50 const base::TimeTicks& capture_time) {
51 DCHECK(!config_.audio) << "Invalid state"; 51 DCHECK(!config_.audio) << "Invalid state";
(...skipping 21 matching lines...) Expand all
73 audio_frame->rtp_timestamp, 73 audio_frame->rtp_timestamp,
74 audio_frame->data, 74 audio_frame->data,
75 recorded_time); 75 recorded_time);
76 } 76 }
77 77
78 uint16 RtpPacketizer::NextSequenceNumber() { 78 uint16 RtpPacketizer::NextSequenceNumber() {
79 ++sequence_number_; 79 ++sequence_number_;
80 return sequence_number_ - 1; 80 return sequence_number_ - 1;
81 } 81 }
82 82
83 bool RtpPacketizer::LastSentTimestamp(base::TimeTicks* time_sent,
84 uint32* rtp_timestamp) const {
85 if (time_last_sent_rtp_timestamp_.is_null())
86 return false;
87
88 *time_sent = time_last_sent_rtp_timestamp_;
89 *rtp_timestamp = rtp_timestamp_;
90 return true;
91 }
92
93 // TODO(mikhal): Switch to pass data with a const_ref. 83 // TODO(mikhal): Switch to pass data with a const_ref.
94 void RtpPacketizer::Cast(bool is_key, 84 void RtpPacketizer::Cast(bool is_key,
95 uint32 frame_id, 85 uint32 frame_id,
96 uint32 reference_frame_id, 86 uint32 reference_frame_id,
97 uint32 timestamp, 87 uint32 timestamp,
98 const std::string& data, 88 const std::string& data,
99 const base::TimeTicks& capture_time) { 89 const base::TimeTicks& capture_time) {
100 time_last_sent_rtp_timestamp_ = capture_time;
101 uint16 rtp_header_length = kCommonRtpHeaderLength + kCastRtpHeaderLength; 90 uint16 rtp_header_length = kCommonRtpHeaderLength + kCastRtpHeaderLength;
102 uint16 max_length = config_.max_payload_length - rtp_header_length - 1; 91 uint16 max_length = config_.max_payload_length - rtp_header_length - 1;
103 rtp_timestamp_ = timestamp; 92 rtp_timestamp_ = timestamp;
104 93
105 // Split the payload evenly (round number up). 94 // Split the payload evenly (round number up).
106 size_t num_packets = (data.size() + max_length) / max_length; 95 size_t num_packets = (data.size() + max_length) / max_length;
107 size_t payload_length = (data.size() + num_packets) / num_packets; 96 size_t payload_length = (data.size() + num_packets) / num_packets;
108 DCHECK_LE(payload_length, max_length) << "Invalid argument"; 97 DCHECK_LE(payload_length, max_length) << "Invalid argument";
109 98
110 SendPacketVector packets; 99 SendPacketVector packets;
(...skipping 29 matching lines...) Expand all
140 PacketKey key = PacedPacketSender::MakePacketKey(capture_time, 129 PacketKey key = PacedPacketSender::MakePacketKey(capture_time,
141 config_.ssrc, 130 config_.ssrc,
142 packet_id_); 131 packet_id_);
143 132
144 // Store packet. 133 // Store packet.
145 packet_storage_->StorePacket(frame_id, packet_id_, key, packet); 134 packet_storage_->StorePacket(frame_id, packet_id_, key, packet);
146 ++packet_id_; 135 ++packet_id_;
147 data_iter += payload_length; 136 data_iter += payload_length;
148 137
149 // Update stats. 138 // Update stats.
150 ++send_packets_count_; 139 ++send_packet_count_;
151 send_octet_count_ += payload_length; 140 send_octet_count_ += payload_length;
152 packets.push_back(make_pair(key, packet)); 141 packets.push_back(make_pair(key, packet));
153 } 142 }
154 DCHECK(packet_id_ == num_packets) << "Invalid state"; 143 DCHECK(packet_id_ == num_packets) << "Invalid state";
155 144
156 // Send to network. 145 // Send to network.
157 transport_->SendPackets(packets); 146 transport_->SendPackets(packets);
158 147
159 // Prepare for next frame. 148 // Prepare for next frame.
160 packet_id_ = 0; 149 packet_id_ = 0;
(...skipping 11 matching lines...) Expand all
172 reinterpret_cast<char*>(&((*packet)[start_size])), 10); 161 reinterpret_cast<char*>(&((*packet)[start_size])), 10);
173 big_endian_writer.WriteU16(sequence_number_); 162 big_endian_writer.WriteU16(sequence_number_);
174 big_endian_writer.WriteU32(time_stamp); 163 big_endian_writer.WriteU32(time_stamp);
175 big_endian_writer.WriteU32(config_.ssrc); 164 big_endian_writer.WriteU32(config_.ssrc);
176 ++sequence_number_; 165 ++sequence_number_;
177 } 166 }
178 167
179 } // namespace transport 168 } // namespace transport
180 } // namespace cast 169 } // namespace cast
181 } // namespace media 170 } // namespace media
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698