| Index: webrtc/voice_engine/test/auto_test/fixtures/after_initialization_fixture.h
|
| diff --git a/webrtc/voice_engine/test/auto_test/fixtures/after_initialization_fixture.h b/webrtc/voice_engine/test/auto_test/fixtures/after_initialization_fixture.h
|
| index 116ff0aec32776e68f4bf346c1bbf685e8535160..843be848e6a3db08cbf6b045b015db9b8f1ec788 100644
|
| --- a/webrtc/voice_engine/test/auto_test/fixtures/after_initialization_fixture.h
|
| +++ b/webrtc/voice_engine/test/auto_test/fixtures/after_initialization_fixture.h
|
| @@ -13,12 +13,12 @@
|
|
|
| #include <deque>
|
|
|
| +#include "webrtc/base/criticalsection.h"
|
| #include "webrtc/base/platform_thread.h"
|
| #include "webrtc/base/scoped_ptr.h"
|
| #include "webrtc/common_types.h"
|
| #include "webrtc/modules/rtp_rtcp/source/byte_io.h"
|
| #include "webrtc/system_wrappers/include/atomic32.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/voice_engine/test/auto_test/fixtures/before_initialization_fixture.h"
|
| @@ -28,8 +28,7 @@ class TestErrorObserver;
|
| class LoopBackTransport : public webrtc::Transport {
|
| public:
|
| LoopBackTransport(webrtc::VoENetwork* voe_network, int channel)
|
| - : crit_(webrtc::CriticalSectionWrapper::CreateCriticalSection()),
|
| - packet_event_(webrtc::EventWrapper::Create()),
|
| + : packet_event_(webrtc::EventWrapper::Create()),
|
| thread_(NetworkProcess, this, "LoopBackTransport"),
|
| channel_(channel),
|
| voe_network_(voe_network),
|
| @@ -62,7 +61,7 @@ class LoopBackTransport : public webrtc::Transport {
|
| }
|
|
|
| void AddChannel(uint32_t ssrc, int channel) {
|
| - webrtc::CriticalSectionScoped lock(crit_.get());
|
| + rtc::CritScope lock(&crit_);
|
| channels_[ssrc] = channel;
|
| }
|
|
|
| @@ -85,7 +84,7 @@ class LoopBackTransport : public webrtc::Transport {
|
| const void* data,
|
| size_t len) {
|
| {
|
| - webrtc::CriticalSectionScoped lock(crit_.get());
|
| + rtc::CritScope lock(&crit_);
|
| packet_queue_.push_back(Packet(type, data, len));
|
| }
|
| packet_event_->Set();
|
| @@ -110,7 +109,7 @@ class LoopBackTransport : public webrtc::Transport {
|
| Packet p;
|
| int channel = channel_;
|
| {
|
| - webrtc::CriticalSectionScoped lock(crit_.get());
|
| + rtc::CritScope lock(&crit_);
|
| if (packet_queue_.empty())
|
| break;
|
| p = packet_queue_.front();
|
| @@ -143,12 +142,12 @@ class LoopBackTransport : public webrtc::Transport {
|
| return true;
|
| }
|
|
|
| - const rtc::scoped_ptr<webrtc::CriticalSectionWrapper> crit_;
|
| + mutable rtc::CriticalSection crit_;
|
| const rtc::scoped_ptr<webrtc::EventWrapper> packet_event_;
|
| rtc::PlatformThread thread_;
|
| - std::deque<Packet> packet_queue_ GUARDED_BY(crit_.get());
|
| + std::deque<Packet> packet_queue_ GUARDED_BY(crit_);
|
| const int channel_;
|
| - std::map<uint32_t, int> channels_ GUARDED_BY(crit_.get());
|
| + std::map<uint32_t, int> channels_ GUARDED_BY(crit_);
|
| webrtc::VoENetwork* const voe_network_;
|
| webrtc::Atomic32 transmitted_packets_;
|
| };
|
|
|