Index: webrtc/modules/rtp_rtcp/source/fec_receiver_impl.cc |
diff --git a/webrtc/modules/rtp_rtcp/source/fec_receiver_impl.cc b/webrtc/modules/rtp_rtcp/source/fec_receiver_impl.cc |
index 2109574e396437aa016eb3908de2597d8fd315e9..28e98ba8b29420f528a58d47f82480f7934dad54 100644 |
--- a/webrtc/modules/rtp_rtcp/source/fec_receiver_impl.cc |
+++ b/webrtc/modules/rtp_rtcp/source/fec_receiver_impl.cc |
@@ -16,7 +16,6 @@ |
#include "webrtc/base/scoped_ptr.h" |
#include "webrtc/modules/rtp_rtcp/source/byte_io.h" |
#include "webrtc/modules/rtp_rtcp/source/rtp_receiver_video.h" |
-#include "webrtc/system_wrappers/include/critical_section_wrapper.h" |
// RFC 5109 |
namespace webrtc { |
@@ -26,8 +25,7 @@ FecReceiver* FecReceiver::Create(RtpData* callback) { |
} |
FecReceiverImpl::FecReceiverImpl(RtpData* callback) |
- : crit_sect_(CriticalSectionWrapper::CreateCriticalSection()), |
- recovered_packet_callback_(callback), |
+ : recovered_packet_callback_(callback), |
fec_(new ForwardErrorCorrection()) {} |
FecReceiverImpl::~FecReceiverImpl() { |
@@ -42,7 +40,7 @@ FecReceiverImpl::~FecReceiverImpl() { |
} |
FecPacketCounter FecReceiverImpl::GetPacketCounter() const { |
- CriticalSectionScoped cs(crit_sect_.get()); |
+ rtc::CritScope cs(&crit_sect_); |
return packet_counter_; |
} |
@@ -77,7 +75,7 @@ FecPacketCounter FecReceiverImpl::GetPacketCounter() const { |
int32_t FecReceiverImpl::AddReceivedRedPacket( |
const RTPHeader& header, const uint8_t* incoming_rtp_packet, |
size_t packet_length, uint8_t ulpfec_payload_type) { |
- CriticalSectionScoped cs(crit_sect_.get()); |
+ rtc::CritScope cs(&crit_sect_); |
uint8_t REDHeaderLength = 1; |
size_t payload_data_length = packet_length - header.headerLength; |
@@ -219,21 +217,21 @@ int32_t FecReceiverImpl::AddReceivedRedPacket( |
} |
int32_t FecReceiverImpl::ProcessReceivedFec() { |
- crit_sect_->Enter(); |
+ crit_sect_.Enter(); |
if (!received_packet_list_.empty()) { |
// Send received media packet to VCM. |
if (!received_packet_list_.front()->is_fec) { |
ForwardErrorCorrection::Packet* packet = |
received_packet_list_.front()->pkt; |
- crit_sect_->Leave(); |
+ crit_sect_.Leave(); |
if (!recovered_packet_callback_->OnRecoveredPacket(packet->data, |
packet->length)) { |
return -1; |
} |
- crit_sect_->Enter(); |
+ crit_sect_.Enter(); |
} |
if (fec_->DecodeFEC(&received_packet_list_, &recovered_packet_list_) != 0) { |
- crit_sect_->Leave(); |
+ crit_sect_.Leave(); |
return -1; |
} |
assert(received_packet_list_.empty()); |
@@ -246,15 +244,15 @@ int32_t FecReceiverImpl::ProcessReceivedFec() { |
continue; |
ForwardErrorCorrection::Packet* packet = (*it)->pkt; |
++packet_counter_.num_recovered_packets; |
- crit_sect_->Leave(); |
+ crit_sect_.Leave(); |
if (!recovered_packet_callback_->OnRecoveredPacket(packet->data, |
packet->length)) { |
return -1; |
} |
- crit_sect_->Enter(); |
+ crit_sect_.Enter(); |
(*it)->returned = true; |
} |
- crit_sect_->Leave(); |
+ crit_sect_.Leave(); |
return 0; |
} |