Index: webrtc/modules/rtp_rtcp/source/ulpfec_receiver_impl.cc |
diff --git a/webrtc/modules/rtp_rtcp/source/ulpfec_receiver_impl.cc b/webrtc/modules/rtp_rtcp/source/ulpfec_receiver_impl.cc |
index 2752a378c9fa8fed18486905a38e367083b31335..dad445dab0e45cd78af7086b7a0f44727e7cc979 100644 |
--- a/webrtc/modules/rtp_rtcp/source/ulpfec_receiver_impl.cc |
+++ b/webrtc/modules/rtp_rtcp/source/ulpfec_receiver_impl.cc |
@@ -21,11 +21,11 @@ |
namespace webrtc { |
-UlpfecReceiver* UlpfecReceiver::Create(RtpData* callback) { |
+UlpfecReceiver* UlpfecReceiver::Create(RecoveredPacketReceiver* callback) { |
return new UlpfecReceiverImpl(callback); |
} |
-UlpfecReceiverImpl::UlpfecReceiverImpl(RtpData* callback) |
+UlpfecReceiverImpl::UlpfecReceiverImpl(RecoveredPacketReceiver* callback) |
: recovered_packet_callback_(callback), |
fec_(ForwardErrorCorrection::CreateUlpfec()) {} |
@@ -212,10 +212,8 @@ int32_t UlpfecReceiverImpl::ProcessReceivedFec() { |
if (!received_packets_.front()->is_fec) { |
ForwardErrorCorrection::Packet* packet = received_packets_.front()->pkt; |
crit_sect_.Leave(); |
- if (!recovered_packet_callback_->OnRecoveredPacket(packet->data, |
- packet->length)) { |
- return -1; |
- } |
+ recovered_packet_callback_->OnRecoveredPacket(packet->data, |
+ packet->length); |
crit_sect_.Enter(); |
} |
if (fec_->DecodeFec(&received_packets_, &recovered_packets_) != 0) { |
@@ -233,10 +231,8 @@ int32_t UlpfecReceiverImpl::ProcessReceivedFec() { |
ForwardErrorCorrection::Packet* packet = recovered_packet->pkt; |
++packet_counter_.num_recovered_packets; |
crit_sect_.Leave(); |
- if (!recovered_packet_callback_->OnRecoveredPacket(packet->data, |
- packet->length)) { |
- return -1; |
- } |
+ recovered_packet_callback_->OnRecoveredPacket(packet->data, |
+ packet->length); |
crit_sect_.Enter(); |
recovered_packet->returned = true; |
} |