Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(105)

Unified Diff: webrtc/video/vie_remb.cc

Issue 1613053003: Swap use of CriticalSectionWrapper for rtc::CriticalSection in webrtc/video. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Rebase? Created 4 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « webrtc/video/vie_remb.h ('k') | webrtc/video/vie_sync_module.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: webrtc/video/vie_remb.cc
diff --git a/webrtc/video/vie_remb.cc b/webrtc/video/vie_remb.cc
index 95c2f1e130c8dad5aa5804da432ac6c6dbc39ebc..dd6a034565e85678950c15027c0efa6b3e733fc6 100644
--- a/webrtc/video/vie_remb.cc
+++ b/webrtc/video/vie_remb.cc
@@ -16,7 +16,6 @@
#include "webrtc/modules/rtp_rtcp/include/rtp_rtcp.h"
#include "webrtc/modules/utility/include/process_thread.h"
-#include "webrtc/system_wrappers/include/critical_section_wrapper.h"
#include "webrtc/system_wrappers/include/tick_util.h"
#include "webrtc/system_wrappers/include/trace.h"
@@ -29,7 +28,6 @@ const unsigned int kSendThresholdPercent = 97;
VieRemb::VieRemb(Clock* clock)
: clock_(clock),
- list_crit_(CriticalSectionWrapper::CreateCriticalSection()),
last_remb_time_(clock_->TimeInMilliseconds()),
last_send_bitrate_(0),
bitrate_(0) {}
@@ -39,7 +37,7 @@ VieRemb::~VieRemb() {}
void VieRemb::AddReceiveChannel(RtpRtcp* rtp_rtcp) {
assert(rtp_rtcp);
- CriticalSectionScoped cs(list_crit_.get());
+ rtc::CritScope lock(&list_crit_);
if (std::find(receive_modules_.begin(), receive_modules_.end(), rtp_rtcp) !=
receive_modules_.end())
return;
@@ -52,7 +50,7 @@ void VieRemb::AddReceiveChannel(RtpRtcp* rtp_rtcp) {
void VieRemb::RemoveReceiveChannel(RtpRtcp* rtp_rtcp) {
assert(rtp_rtcp);
- CriticalSectionScoped cs(list_crit_.get());
+ rtc::CritScope lock(&list_crit_);
for (RtpModules::iterator it = receive_modules_.begin();
it != receive_modules_.end(); ++it) {
if ((*it) == rtp_rtcp) {
@@ -65,7 +63,7 @@ void VieRemb::RemoveReceiveChannel(RtpRtcp* rtp_rtcp) {
void VieRemb::AddRembSender(RtpRtcp* rtp_rtcp) {
assert(rtp_rtcp);
- CriticalSectionScoped cs(list_crit_.get());
+ rtc::CritScope lock(&list_crit_);
// Verify this module hasn't been added earlier.
if (std::find(rtcp_sender_.begin(), rtcp_sender_.end(), rtp_rtcp) !=
@@ -77,7 +75,7 @@ void VieRemb::AddRembSender(RtpRtcp* rtp_rtcp) {
void VieRemb::RemoveRembSender(RtpRtcp* rtp_rtcp) {
assert(rtp_rtcp);
- CriticalSectionScoped cs(list_crit_.get());
+ rtc::CritScope lock(&list_crit_);
for (RtpModules::iterator it = rtcp_sender_.begin();
it != rtcp_sender_.end(); ++it) {
if ((*it) == rtp_rtcp) {
@@ -88,53 +86,48 @@ void VieRemb::RemoveRembSender(RtpRtcp* rtp_rtcp) {
}
bool VieRemb::InUse() const {
- CriticalSectionScoped cs(list_crit_.get());
- if (receive_modules_.empty() && rtcp_sender_.empty())
- return false;
- else
- return true;
+ rtc::CritScope lock(&list_crit_);
+ return !receive_modules_.empty() || !rtcp_sender_.empty();
}
void VieRemb::OnReceiveBitrateChanged(const std::vector<unsigned int>& ssrcs,
unsigned int bitrate) {
- list_crit_->Enter();
- // If we already have an estimate, check if the new total estimate is below
- // kSendThresholdPercent of the previous estimate.
- if (last_send_bitrate_ > 0) {
- unsigned int new_remb_bitrate = last_send_bitrate_ - bitrate_ + bitrate;
-
- if (new_remb_bitrate < kSendThresholdPercent * last_send_bitrate_ / 100) {
- // The new bitrate estimate is less than kSendThresholdPercent % of the
- // last report. Send a REMB asap.
- last_remb_time_ = clock_->TimeInMilliseconds() - kRembSendIntervalMs;
+ RtpRtcp* sender = NULL;
+ {
+ rtc::CritScope lock(&list_crit_);
+ // If we already have an estimate, check if the new total estimate is below
+ // kSendThresholdPercent of the previous estimate.
+ if (last_send_bitrate_ > 0) {
+ unsigned int new_remb_bitrate = last_send_bitrate_ - bitrate_ + bitrate;
+
+ if (new_remb_bitrate < kSendThresholdPercent * last_send_bitrate_ / 100) {
+ // The new bitrate estimate is less than kSendThresholdPercent % of the
+ // last report. Send a REMB asap.
+ last_remb_time_ = clock_->TimeInMilliseconds() - kRembSendIntervalMs;
+ }
}
- }
- bitrate_ = bitrate;
+ bitrate_ = bitrate;
- // Calculate total receive bitrate estimate.
- int64_t now = clock_->TimeInMilliseconds();
+ // Calculate total receive bitrate estimate.
+ int64_t now = clock_->TimeInMilliseconds();
- if (now - last_remb_time_ < kRembSendIntervalMs) {
- list_crit_->Leave();
- return;
- }
- last_remb_time_ = now;
+ if (now - last_remb_time_ < kRembSendIntervalMs) {
+ return;
+ }
+ last_remb_time_ = now;
- if (ssrcs.empty() || receive_modules_.empty()) {
- list_crit_->Leave();
- return;
- }
+ if (ssrcs.empty() || receive_modules_.empty()) {
+ return;
+ }
- // Send a REMB packet.
- RtpRtcp* sender = NULL;
- if (!rtcp_sender_.empty()) {
- sender = rtcp_sender_.front();
- } else {
- sender = receive_modules_.front();
+ // Send a REMB packet.
+ if (!rtcp_sender_.empty()) {
+ sender = rtcp_sender_.front();
+ } else {
+ sender = receive_modules_.front();
+ }
+ last_send_bitrate_ = bitrate_;
}
- last_send_bitrate_ = bitrate_;
-
- list_crit_->Leave();
if (sender) {
sender->SetREMBData(bitrate_, ssrcs);
« no previous file with comments | « webrtc/video/vie_remb.h ('k') | webrtc/video/vie_sync_module.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698