aboutsummaryrefslogtreecommitdiff
path: root/modules/congestion_controller/rtp/transport_feedback_demuxer.cc
diff options
context:
space:
mode:
Diffstat (limited to 'modules/congestion_controller/rtp/transport_feedback_demuxer.cc')
-rw-r--r--modules/congestion_controller/rtp/transport_feedback_demuxer.cc10
1 files changed, 5 insertions, 5 deletions
diff --git a/modules/congestion_controller/rtp/transport_feedback_demuxer.cc b/modules/congestion_controller/rtp/transport_feedback_demuxer.cc
index 045ba38cd3..c958a1c3cb 100644
--- a/modules/congestion_controller/rtp/transport_feedback_demuxer.cc
+++ b/modules/congestion_controller/rtp/transport_feedback_demuxer.cc
@@ -18,7 +18,7 @@ static const size_t kMaxPacketsInHistory = 5000;
void TransportFeedbackDemuxer::RegisterStreamFeedbackObserver(
std::vector<uint32_t> ssrcs,
StreamFeedbackObserver* observer) {
- rtc::CritScope cs(&observers_lock_);
+ MutexLock lock(&observers_lock_);
RTC_DCHECK(observer);
RTC_DCHECK(absl::c_find_if(observers_, [=](const auto& pair) {
return pair.second == observer;
@@ -28,7 +28,7 @@ void TransportFeedbackDemuxer::RegisterStreamFeedbackObserver(
void TransportFeedbackDemuxer::DeRegisterStreamFeedbackObserver(
StreamFeedbackObserver* observer) {
- rtc::CritScope cs(&observers_lock_);
+ MutexLock lock(&observers_lock_);
RTC_DCHECK(observer);
const auto it = absl::c_find_if(
observers_, [=](const auto& pair) { return pair.second == observer; });
@@ -37,7 +37,7 @@ void TransportFeedbackDemuxer::DeRegisterStreamFeedbackObserver(
}
void TransportFeedbackDemuxer::AddPacket(const RtpPacketSendInfo& packet_info) {
- rtc::CritScope cs(&lock_);
+ MutexLock lock(&lock_);
if (packet_info.ssrc != 0) {
StreamFeedbackObserver::StreamPacketInfo info;
info.ssrc = packet_info.ssrc;
@@ -56,7 +56,7 @@ void TransportFeedbackDemuxer::OnTransportFeedback(
const rtcp::TransportFeedback& feedback) {
std::vector<StreamFeedbackObserver::StreamPacketInfo> stream_feedbacks;
{
- rtc::CritScope cs(&lock_);
+ MutexLock lock(&lock_);
for (const auto& packet : feedback.GetAllPackets()) {
int64_t seq_num =
seq_num_unwrapper_.UnwrapWithoutUpdate(packet.sequence_number());
@@ -71,7 +71,7 @@ void TransportFeedbackDemuxer::OnTransportFeedback(
}
}
- rtc::CritScope cs(&observers_lock_);
+ MutexLock lock(&observers_lock_);
for (auto& observer : observers_) {
std::vector<StreamFeedbackObserver::StreamPacketInfo> selected_feedback;
for (const auto& packet_info : stream_feedbacks) {