Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 /* | 1 /* |
| 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 87 | 87 |
| 88 uint8_t* RedPacket::data() const { | 88 uint8_t* RedPacket::data() const { |
| 89 return data_.get(); | 89 return data_.get(); |
| 90 } | 90 } |
| 91 | 91 |
| 92 size_t RedPacket::length() const { | 92 size_t RedPacket::length() const { |
| 93 return length_; | 93 return length_; |
| 94 } | 94 } |
| 95 | 95 |
| 96 UlpfecGenerator::UlpfecGenerator() | 96 UlpfecGenerator::UlpfecGenerator() |
| 97 : fec_(ForwardErrorCorrection::CreateUlpfec()), | 97 : UlpfecGenerator(ForwardErrorCorrection::CreateUlpfec()) {} |
| 98 | |
| 99 UlpfecGenerator::UlpfecGenerator(std::unique_ptr<ForwardErrorCorrection> fec) | |
|
stefan-webrtc
2016/11/02 13:02:42
This is a bit weird. Why not have a single constru
brandtr
2016/11/02 14:04:37
Yes, it's a bit weird. With your suggestion howeve
stefan-webrtc
2016/11/03 13:42:40
I see, you do need both constructors? I thought th
| |
| 100 : fec_(std::move(fec)), | |
| 98 num_protected_frames_(0), | 101 num_protected_frames_(0), |
| 99 min_num_media_packets_(1) { | 102 min_num_media_packets_(1) { |
| 100 memset(¶ms_, 0, sizeof(params_)); | 103 memset(¶ms_, 0, sizeof(params_)); |
| 101 memset(&new_params_, 0, sizeof(new_params_)); | 104 memset(&new_params_, 0, sizeof(new_params_)); |
| 102 } | 105 } |
| 103 | 106 |
| 104 UlpfecGenerator::~UlpfecGenerator() = default; | 107 UlpfecGenerator::~UlpfecGenerator() = default; |
| 105 | 108 |
| 106 std::unique_ptr<RedPacket> UlpfecGenerator::BuildRedPacket( | 109 std::unique_ptr<RedPacket> UlpfecGenerator::BuildRedPacket( |
| 107 const uint8_t* data_buffer, | 110 const uint8_t* data_buffer, |
| (...skipping 25 matching lines...) Expand all Loading... | |
| 133 int UlpfecGenerator::AddRtpPacketAndGenerateFec(const uint8_t* data_buffer, | 136 int UlpfecGenerator::AddRtpPacketAndGenerateFec(const uint8_t* data_buffer, |
| 134 size_t payload_length, | 137 size_t payload_length, |
| 135 size_t rtp_header_length) { | 138 size_t rtp_header_length) { |
| 136 RTC_DCHECK(generated_fec_packets_.empty()); | 139 RTC_DCHECK(generated_fec_packets_.empty()); |
| 137 if (media_packets_.empty()) { | 140 if (media_packets_.empty()) { |
| 138 params_ = new_params_; | 141 params_ = new_params_; |
| 139 } | 142 } |
| 140 bool complete_frame = false; | 143 bool complete_frame = false; |
| 141 const bool marker_bit = (data_buffer[1] & kRtpMarkerBitMask) ? true : false; | 144 const bool marker_bit = (data_buffer[1] & kRtpMarkerBitMask) ? true : false; |
| 142 if (media_packets_.size() < kUlpfecMaxMediaPackets) { | 145 if (media_packets_.size() < kUlpfecMaxMediaPackets) { |
| 143 // Generic FEC can only protect up to |kUlpfecMaxMediaPackets| packets. | 146 // Our packet masks can only protect up to |kUlpfecMaxMediaPackets| packets. |
| 144 std::unique_ptr<ForwardErrorCorrection::Packet> packet( | 147 std::unique_ptr<ForwardErrorCorrection::Packet> packet( |
| 145 new ForwardErrorCorrection::Packet()); | 148 new ForwardErrorCorrection::Packet()); |
| 146 packet->length = payload_length + rtp_header_length; | 149 packet->length = payload_length + rtp_header_length; |
| 147 memcpy(packet->data, data_buffer, packet->length); | 150 memcpy(packet->data, data_buffer, packet->length); |
| 148 media_packets_.push_back(std::move(packet)); | 151 media_packets_.push_back(std::move(packet)); |
| 149 } | 152 } |
| 150 if (marker_bit) { | 153 if (marker_bit) { |
| 151 ++num_protected_frames_; | 154 ++num_protected_frames_; |
| 152 complete_frame = true; | 155 complete_frame = true; |
| 153 } | 156 } |
| (...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 239 return (num_fec_packets << 8) / media_packets_.size(); | 242 return (num_fec_packets << 8) / media_packets_.size(); |
| 240 } | 243 } |
| 241 | 244 |
| 242 void UlpfecGenerator::ResetState() { | 245 void UlpfecGenerator::ResetState() { |
| 243 media_packets_.clear(); | 246 media_packets_.clear(); |
| 244 generated_fec_packets_.clear(); | 247 generated_fec_packets_.clear(); |
| 245 num_protected_frames_ = 0; | 248 num_protected_frames_ = 0; |
| 246 } | 249 } |
| 247 | 250 |
| 248 } // namespace webrtc | 251 } // namespace webrtc |
| OLD | NEW |