diff options
Diffstat (limited to 'test/pc/e2e/test_activities_executor.cc')
-rw-r--r-- | test/pc/e2e/test_activities_executor.cc | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/test/pc/e2e/test_activities_executor.cc b/test/pc/e2e/test_activities_executor.cc index 4ace6ae7d8..ded39920f2 100644 --- a/test/pc/e2e/test_activities_executor.cc +++ b/test/pc/e2e/test_activities_executor.cc @@ -24,7 +24,7 @@ namespace webrtc_pc_e2e { void TestActivitiesExecutor::Start(TaskQueueForTest* task_queue) { RTC_DCHECK(task_queue); task_queue_ = task_queue; - rtc::CritScope crit(&lock_); + MutexLock lock(&lock_); start_time_ = Now(); while (!scheduled_activities_.empty()) { PostActivity(std::move(scheduled_activities_.front())); @@ -39,7 +39,7 @@ void TestActivitiesExecutor::Stop() { } task_queue_->SendTask( [this]() { - rtc::CritScope crit(&lock_); + MutexLock lock(&lock_); for (auto& handle : repeating_task_handles_) { handle.Stop(); } @@ -56,7 +56,7 @@ void TestActivitiesExecutor::ScheduleActivity( initial_delay_since_start >= TimeDelta::Zero()); RTC_CHECK(!interval || (interval->IsFinite() && *interval > TimeDelta::Zero())); - rtc::CritScope crit(&lock_); + MutexLock lock(&lock_); ScheduledActivity activity(initial_delay_since_start, interval, func); if (start_time_.IsInfinite()) { scheduled_activities_.push(std::move(activity)); |