Index: webrtc/modules/audio_coding/acm2/audio_coding_module_unittest_oldapi.cc |
diff --git a/webrtc/modules/audio_coding/acm2/audio_coding_module_unittest_oldapi.cc b/webrtc/modules/audio_coding/acm2/audio_coding_module_unittest_oldapi.cc |
index 6f82a96ee508414a488df94824e48e6da95bbab7..c738d0f0957af2eab61d1ef09f8d86cd4d556d93 100644 |
--- a/webrtc/modules/audio_coding/acm2/audio_coding_module_unittest_oldapi.cc |
+++ b/webrtc/modules/audio_coding/acm2/audio_coding_module_unittest_oldapi.cc |
@@ -13,17 +13,18 @@ |
#include <vector> |
#include "testing/gtest/include/gtest/gtest.h" |
+#include "webrtc/base/criticalsection.h" |
#include "webrtc/base/md5digest.h" |
#include "webrtc/base/platform_thread.h" |
#include "webrtc/base/scoped_ptr.h" |
#include "webrtc/base/thread_annotations.h" |
+#include "webrtc/modules/audio_coding/acm2/acm_receive_test_oldapi.h" |
+#include "webrtc/modules/audio_coding/acm2/acm_send_test_oldapi.h" |
#include "webrtc/modules/audio_coding/codecs/audio_encoder.h" |
#include "webrtc/modules/audio_coding/codecs/g711/audio_decoder_pcm.h" |
#include "webrtc/modules/audio_coding/codecs/g711/audio_encoder_pcm.h" |
#include "webrtc/modules/audio_coding/codecs/isac/main/include/audio_encoder_isac.h" |
#include "webrtc/modules/audio_coding/codecs/mock/mock_audio_encoder.h" |
-#include "webrtc/modules/audio_coding/acm2/acm_receive_test_oldapi.h" |
-#include "webrtc/modules/audio_coding/acm2/acm_send_test_oldapi.h" |
#include "webrtc/modules/audio_coding/include/audio_coding_module.h" |
#include "webrtc/modules/audio_coding/include/audio_coding_module_typedefs.h" |
#include "webrtc/modules/audio_coding/neteq/audio_decoder_impl.h" |
@@ -37,7 +38,6 @@ |
#include "webrtc/modules/audio_coding/neteq/tools/rtp_file_source.h" |
#include "webrtc/modules/include/module_common_types.h" |
#include "webrtc/system_wrappers/include/clock.h" |
-#include "webrtc/system_wrappers/include/critical_section_wrapper.h" |
#include "webrtc/system_wrappers/include/event_wrapper.h" |
#include "webrtc/system_wrappers/include/sleep.h" |
#include "webrtc/test/testsupport/fileutils.h" |
@@ -94,8 +94,7 @@ class PacketizationCallbackStubOldApi : public AudioPacketizationCallback { |
: num_calls_(0), |
last_frame_type_(kEmptyFrame), |
last_payload_type_(-1), |
- last_timestamp_(0), |
- crit_sect_(CriticalSectionWrapper::CreateCriticalSection()) {} |
+ last_timestamp_(0) {} |
int32_t SendData(FrameType frame_type, |
uint8_t payload_type, |
@@ -103,7 +102,7 @@ class PacketizationCallbackStubOldApi : public AudioPacketizationCallback { |
const uint8_t* payload_data, |
size_t payload_len_bytes, |
const RTPFragmentationHeader* fragmentation) override { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
++num_calls_; |
last_frame_type_ = frame_type; |
last_payload_type_ = payload_type; |
@@ -113,32 +112,32 @@ class PacketizationCallbackStubOldApi : public AudioPacketizationCallback { |
} |
int num_calls() const { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
return num_calls_; |
} |
int last_payload_len_bytes() const { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
return last_payload_vec_.size(); |
} |
FrameType last_frame_type() const { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
return last_frame_type_; |
} |
int last_payload_type() const { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
return last_payload_type_; |
} |
uint32_t last_timestamp() const { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
return last_timestamp_; |
} |
void SwapBuffers(std::vector<uint8_t>* payload) { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
last_payload_vec_.swap(*payload); |
} |
@@ -148,7 +147,7 @@ class PacketizationCallbackStubOldApi : public AudioPacketizationCallback { |
int last_payload_type_ GUARDED_BY(crit_sect_); |
uint32_t last_timestamp_ GUARDED_BY(crit_sect_); |
std::vector<uint8_t> last_payload_vec_ GUARDED_BY(crit_sect_); |
- const rtc::scoped_ptr<CriticalSectionWrapper> crit_sect_; |
+ mutable rtc::CriticalSection crit_sect_; |
}; |
class AudioCodingModuleTestOldApi : public ::testing::Test { |
@@ -469,7 +468,6 @@ class AudioCodingModuleMtTestOldApi : public AudioCodingModuleTestOldApi { |
send_count_(0), |
insert_packet_count_(0), |
pull_audio_count_(0), |
- crit_sect_(CriticalSectionWrapper::CreateCriticalSection()), |
next_insert_packet_time_ms_(0), |
fake_clock_(new SimulatedClock(0)) { |
clock_ = fake_clock_.get(); |
@@ -503,7 +501,7 @@ class AudioCodingModuleMtTestOldApi : public AudioCodingModuleTestOldApi { |
virtual bool TestDone() { |
if (packet_cb_.num_calls() > kNumPackets) { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
if (pull_audio_count_ > kNumPullCalls) { |
// Both conditions for completion are met. End the test. |
return true; |
@@ -541,7 +539,7 @@ class AudioCodingModuleMtTestOldApi : public AudioCodingModuleTestOldApi { |
bool CbInsertPacketImpl() { |
SleepMs(1); |
{ |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
if (clock_->TimeInMilliseconds() < next_insert_packet_time_ms_) { |
return true; |
} |
@@ -561,7 +559,7 @@ class AudioCodingModuleMtTestOldApi : public AudioCodingModuleTestOldApi { |
bool CbPullAudioImpl() { |
SleepMs(1); |
{ |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
// Don't let the insert thread fall behind. |
if (next_insert_packet_time_ms_ < clock_->TimeInMilliseconds()) { |
return true; |
@@ -581,7 +579,7 @@ class AudioCodingModuleMtTestOldApi : public AudioCodingModuleTestOldApi { |
int send_count_; |
int insert_packet_count_; |
int pull_audio_count_ GUARDED_BY(crit_sect_); |
- const rtc::scoped_ptr<CriticalSectionWrapper> crit_sect_; |
+ mutable rtc::CriticalSection crit_sect_; |
int64_t next_insert_packet_time_ms_ GUARDED_BY(crit_sect_); |
rtc::scoped_ptr<SimulatedClock> fake_clock_; |
}; |
@@ -681,7 +679,7 @@ class AcmIsacMtTestOldApi : public AudioCodingModuleMtTestOldApi { |
// run). |
virtual bool TestDone() { |
if (packet_cb_.num_calls() > kNumPackets) { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
if (pull_audio_count_ > kNumPullCalls) { |
// Both conditions for completion are met. End the test. |
return true; |
@@ -720,7 +718,6 @@ class AcmReRegisterIsacMtTestOldApi : public AudioCodingModuleTestOldApi { |
this, |
"codec_registration"), |
test_complete_(EventWrapper::Create()), |
- crit_sect_(CriticalSectionWrapper::CreateCriticalSection()), |
codec_registered_(false), |
receive_packet_count_(0), |
next_insert_packet_time_ms_(0), |
@@ -781,7 +778,7 @@ class AcmReRegisterIsacMtTestOldApi : public AudioCodingModuleTestOldApi { |
rtc::scoped_ptr<uint8_t[]> encoded(new uint8_t[max_encoded_bytes]); |
AudioEncoder::EncodedInfo info; |
{ |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
if (clock_->TimeInMilliseconds() < next_insert_packet_time_ms_) { |
return true; |
} |
@@ -829,7 +826,7 @@ class AcmReRegisterIsacMtTestOldApi : public AudioCodingModuleTestOldApi { |
// End the test early if a fatal failure (ASSERT_*) has occurred. |
test_complete_->Set(); |
} |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
if (!codec_registered_ && |
receive_packet_count_ > kRegisterAfterNumPackets) { |
// Register the iSAC encoder. |
@@ -845,7 +842,7 @@ class AcmReRegisterIsacMtTestOldApi : public AudioCodingModuleTestOldApi { |
rtc::PlatformThread receive_thread_; |
rtc::PlatformThread codec_registration_thread_; |
const rtc::scoped_ptr<EventWrapper> test_complete_; |
- const rtc::scoped_ptr<CriticalSectionWrapper> crit_sect_; |
+ mutable rtc::CriticalSection crit_sect_; |
bool codec_registered_ GUARDED_BY(crit_sect_); |
int receive_packet_count_ GUARDED_BY(crit_sect_); |
int64_t next_insert_packet_time_ms_ GUARDED_BY(crit_sect_); |