Index: webrtc/call/flexfec_receive_stream_impl.cc |
diff --git a/webrtc/call/flexfec_receive_stream_impl.cc b/webrtc/call/flexfec_receive_stream_impl.cc |
index 13390a12c06ce891c9f85248fb474c00aea39fea..e0e49c1a2ec24b9ae2651fa833360ca476f608c9 100644 |
--- a/webrtc/call/flexfec_receive_stream_impl.cc |
+++ b/webrtc/call/flexfec_receive_stream_impl.cc |
@@ -9,8 +9,6 @@ |
*/ |
#include "webrtc/call/flexfec_receive_stream_impl.h" |
- |
-#include <utility> |
#include "webrtc/base/checks.h" |
#include "webrtc/base/logging.h" |
@@ -36,12 +34,12 @@ |
if (!protected_media_ssrcs.empty()) |
ss << protected_media_ssrcs[i]; |
ss << "], transport_cc: " << (transport_cc ? "on" : "off"); |
- ss << ", rtp_header_extensions: ["; |
+ ss << ", extensions: ["; |
i = 0; |
- for (; i + 1 < rtp_header_extensions.size(); ++i) |
- ss << rtp_header_extensions[i].ToString() << ", "; |
- if (!rtp_header_extensions.empty()) |
- ss << rtp_header_extensions[i].ToString(); |
+ for (; i + 1 < extensions.size(); ++i) |
+ ss << extensions[i].ToString() << ", "; |
+ if (!extensions.empty()) |
+ ss << extensions[i].ToString(); |
ss << "]}"; |
return ss.str(); |
} |
@@ -51,7 +49,7 @@ |
// TODO(brandtr): Update this function when we support multistream protection. |
std::unique_ptr<FlexfecReceiver> MaybeCreateFlexfecReceiver( |
const FlexfecReceiveStream::Config& config, |
- RecoveredPacketReceiver* recovered_packet_receiver) { |
+ RecoveredPacketReceiver* recovered_packet_callback) { |
if (config.payload_type < 0) { |
LOG(LS_WARNING) << "Invalid FlexFEC payload type given. " |
<< "This FlexfecReceiveStream will therefore be useless."; |
@@ -81,18 +79,18 @@ |
RTC_DCHECK_EQ(1U, config.protected_media_ssrcs.size()); |
return std::unique_ptr<FlexfecReceiver>( |
new FlexfecReceiver(config.remote_ssrc, config.protected_media_ssrcs[0], |
- recovered_packet_receiver)); |
+ recovered_packet_callback)); |
} |
} // namespace |
FlexfecReceiveStreamImpl::FlexfecReceiveStreamImpl( |
const Config& config, |
- RecoveredPacketReceiver* recovered_packet_receiver) |
+ RecoveredPacketReceiver* recovered_packet_callback) |
: started_(false), |
config_(config), |
receiver_( |
- MaybeCreateFlexfecReceiver(config_, recovered_packet_receiver)) { |
+ MaybeCreateFlexfecReceiver(config_, recovered_packet_callback)) { |
LOG(LS_INFO) << "FlexfecReceiveStreamImpl: " << config_.ToString(); |
} |
@@ -102,7 +100,8 @@ |
} |
bool FlexfecReceiveStreamImpl::AddAndProcessReceivedPacket( |
- RtpPacketReceived packet) { |
+ const uint8_t* packet, |
+ size_t packet_length) { |
{ |
rtc::CritScope cs(&crit_); |
if (!started_) |
@@ -110,7 +109,7 @@ |
} |
if (!receiver_) |
return false; |
- return receiver_->AddAndProcessReceivedPacket(std::move(packet)); |
+ return receiver_->AddAndProcessReceivedPacket(packet, packet_length); |
} |
void FlexfecReceiveStreamImpl::Start() { |