Index: webrtc/modules/rtp_rtcp/source/rtp_receiver_impl.cc |
diff --git a/webrtc/modules/rtp_rtcp/source/rtp_receiver_impl.cc b/webrtc/modules/rtp_rtcp/source/rtp_receiver_impl.cc |
index 6f2efe783a169e9d6c575fdef18f3288afd2eb69..04725ae7fed2a05c2b53c583b9c5c0b118b6230e 100644 |
--- a/webrtc/modules/rtp_rtcp/source/rtp_receiver_impl.cc |
+++ b/webrtc/modules/rtp_rtcp/source/rtp_receiver_impl.cc |
@@ -61,8 +61,6 @@ RtpReceiverImpl::RtpReceiverImpl( |
rtp_payload_registry_(rtp_payload_registry), |
rtp_media_receiver_(rtp_media_receiver), |
cb_rtp_feedback_(incoming_messages_callback), |
- critical_section_rtp_receiver_( |
- CriticalSectionWrapper::CreateCriticalSection()), |
last_receive_time_(0), |
last_received_payload_length_(0), |
ssrc_(0), |
@@ -89,7 +87,7 @@ int32_t RtpReceiverImpl::RegisterReceivePayload( |
const uint32_t frequency, |
const size_t channels, |
const uint32_t rate) { |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
// TODO(phoglund): Try to streamline handling of the RED codec and some other |
// cases which makes it necessary to keep track of whether we created a |
@@ -111,29 +109,29 @@ int32_t RtpReceiverImpl::RegisterReceivePayload( |
int32_t RtpReceiverImpl::DeRegisterReceivePayload( |
const int8_t payload_type) { |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
return rtp_payload_registry_->DeRegisterReceivePayload(payload_type); |
} |
NACKMethod RtpReceiverImpl::NACK() const { |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
return nack_method_; |
} |
// Turn negative acknowledgment requests on/off. |
void RtpReceiverImpl::SetNACKStatus(const NACKMethod method) { |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
nack_method_ = method; |
} |
uint32_t RtpReceiverImpl::SSRC() const { |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
return ssrc_; |
} |
// Get remote CSRC. |
int32_t RtpReceiverImpl::CSRCs(uint32_t array_of_csrcs[kRtpCsrcSize]) const { |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
assert(num_csrcs_ <= kRtpCsrcSize); |
@@ -179,7 +177,7 @@ bool RtpReceiverImpl::IncomingRtpPacket( |
bool is_first_packet_in_frame = false; |
{ |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
if (HaveReceivedFrame()) { |
is_first_packet_in_frame = |
last_received_sequence_number_ + 1 == rtp_header.sequenceNumber && |
@@ -198,7 +196,7 @@ bool RtpReceiverImpl::IncomingRtpPacket( |
} |
{ |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
last_receive_time_ = clock_->TimeInMilliseconds(); |
last_received_payload_length_ = payload_data_length; |
@@ -219,7 +217,7 @@ TelephoneEventHandler* RtpReceiverImpl::GetTelephoneEventHandler() { |
} |
bool RtpReceiverImpl::Timestamp(uint32_t* timestamp) const { |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
if (!HaveReceivedFrame()) |
return false; |
*timestamp = last_received_timestamp_; |
@@ -227,7 +225,7 @@ bool RtpReceiverImpl::Timestamp(uint32_t* timestamp) const { |
} |
bool RtpReceiverImpl::LastReceivedTimeMs(int64_t* receive_time_ms) const { |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
if (!HaveReceivedFrame()) |
return false; |
*receive_time_ms = last_received_frame_time_ms_; |
@@ -247,7 +245,7 @@ void RtpReceiverImpl::CheckSSRCChanged(const RTPHeader& rtp_header) { |
uint32_t rate = 0; |
{ |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
int8_t last_received_payload_type = |
rtp_payload_registry_->last_received_payload_type(); |
@@ -318,7 +316,7 @@ int32_t RtpReceiverImpl::CheckPayloadChanged(const RTPHeader& rtp_header, |
int8_t payload_type = rtp_header.payloadType; |
{ |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
int8_t last_received_payload_type = |
rtp_payload_registry_->last_received_payload_type(); |
@@ -401,7 +399,7 @@ void RtpReceiverImpl::CheckCSRC(const WebRtcRTPHeader& rtp_header) { |
uint8_t old_num_csrcs = 0; |
{ |
- CriticalSectionScoped lock(critical_section_rtp_receiver_.get()); |
+ rtc::CritScope lock(&critical_section_rtp_receiver_); |
if (!rtp_media_receiver_->ShouldReportCsrcChanges( |
rtp_header.header.payloadType)) { |