Index: webrtc/modules/rtp_rtcp/source/rtp_sender.cc |
diff --git a/webrtc/modules/rtp_rtcp/source/rtp_sender.cc b/webrtc/modules/rtp_rtcp/source/rtp_sender.cc |
index 3fbca7b67d8714038067338f325b898e9239e3dc..f7b72b875c785358d42179f333ff2173075c0e99 100644 |
--- a/webrtc/modules/rtp_rtcp/source/rtp_sender.cc |
+++ b/webrtc/modules/rtp_rtcp/source/rtp_sender.cc |
@@ -24,7 +24,6 @@ |
#include "webrtc/modules/rtp_rtcp/source/rtp_sender_audio.h" |
#include "webrtc/modules/rtp_rtcp/source/rtp_sender_video.h" |
#include "webrtc/modules/rtp_rtcp/source/time_util.h" |
-#include "webrtc/system_wrappers/include/critical_section_wrapper.h" |
#include "webrtc/system_wrappers/include/tick_util.h" |
namespace webrtc { |
@@ -147,7 +146,6 @@ RTPSender::RTPSender( |
nack_bitrate_(clock, bitrates_.retransmit_bitrate_observer()), |
packet_history_(clock), |
// Statistics |
- statistics_crit_(CriticalSectionWrapper::CreateCriticalSection()), |
rtp_stats_callback_(NULL), |
frame_count_observer_(frame_count_observer), |
send_side_delay_observer_(send_side_delay_observer), |
@@ -166,7 +164,6 @@ RTPSender::RTPSender( |
last_packet_marker_bit_(false), |
csrcs_(), |
rtx_(kRtxOff), |
- target_bitrate_critsect_(CriticalSectionWrapper::CreateCriticalSection()), |
target_bitrate_(0) { |
memset(nack_byte_count_times_, 0, sizeof(nack_byte_count_times_)); |
memset(nack_byte_count_, 0, sizeof(nack_byte_count_)); |
@@ -210,12 +207,12 @@ RTPSender::~RTPSender() { |
} |
void RTPSender::SetTargetBitrate(uint32_t bitrate) { |
- CriticalSectionScoped cs(target_bitrate_critsect_.get()); |
+ rtc::CritScope cs(&target_bitrate_critsect_); |
target_bitrate_ = bitrate; |
} |
uint32_t RTPSender::GetTargetBitrate() { |
- CriticalSectionScoped cs(target_bitrate_critsect_.get()); |
+ rtc::CritScope cs(&target_bitrate_critsect_); |
return target_bitrate_; |
} |
@@ -532,7 +529,7 @@ int32_t RTPSender::SendOutgoingData(FrameType frame_type, |
payload_size, fragmentation, rtp_hdr); |
} |
- CriticalSectionScoped cs(statistics_crit_.get()); |
+ rtc::CritScope cs(&statistics_crit_); |
// Note: This is currently only counting for video. |
if (frame_type == kVideoFrameKey) { |
++frame_counts_.key_frames; |
@@ -966,7 +963,7 @@ void RTPSender::UpdateRtpStats(const uint8_t* buffer, |
// Get ssrc before taking statistics_crit_ to avoid possible deadlock. |
uint32_t ssrc = is_rtx ? RtxSsrc() : SSRC(); |
- CriticalSectionScoped lock(statistics_crit_.get()); |
+ rtc::CritScope lock(&statistics_crit_); |
if (is_rtx) { |
counters = &rtx_rtp_stats_; |
} else { |
@@ -1109,7 +1106,7 @@ void RTPSender::UpdateDelayStatistics(int64_t capture_time_ms, int64_t now_ms) { |
ssrc = ssrc_; |
} |
{ |
- CriticalSectionScoped cs(statistics_crit_.get()); |
+ rtc::CritScope cs(&statistics_crit_); |
// TODO(holmer): Compute this iteratively instead. |
send_delays_[now_ms] = now_ms - capture_time_ms; |
send_delays_.erase(send_delays_.begin(), |
@@ -1157,7 +1154,7 @@ uint16_t RTPSender::AllocateSequenceNumber(uint16_t packets_to_send) { |
void RTPSender::GetDataCounters(StreamDataCounters* rtp_stats, |
StreamDataCounters* rtx_stats) const { |
- CriticalSectionScoped lock(statistics_crit_.get()); |
+ rtc::CritScope lock(&statistics_crit_); |
*rtp_stats = rtp_stats_; |
*rtx_stats = rtx_rtp_stats_; |
} |
@@ -1858,12 +1855,12 @@ void RTPSender::BuildRtxPacket(uint8_t* buffer, size_t* length, |
void RTPSender::RegisterRtpStatisticsCallback( |
StreamDataCountersCallback* callback) { |
- CriticalSectionScoped cs(statistics_crit_.get()); |
+ rtc::CritScope cs(&statistics_crit_); |
rtp_stats_callback_ = callback; |
} |
StreamDataCountersCallback* RTPSender::GetRtpStatisticsCallback() const { |
- CriticalSectionScoped cs(statistics_crit_.get()); |
+ rtc::CritScope cs(&statistics_crit_); |
return rtp_stats_callback_; |
} |