Index: webrtc/test/rtp_rtcp_observer.h |
diff --git a/webrtc/test/rtp_rtcp_observer.h b/webrtc/test/rtp_rtcp_observer.h |
index f8d696c763e1ec5ca3ac93ab8fd0bd9296aada4e..5eb88d3f0d33ecb7178d165e816ce03c35d2b90c 100644 |
--- a/webrtc/test/rtp_rtcp_observer.h |
+++ b/webrtc/test/rtp_rtcp_observer.h |
@@ -16,6 +16,7 @@ |
#include "testing/gtest/include/gtest/gtest.h" |
#include "webrtc/base/criticalsection.h" |
+#include "webrtc/base/event.h" |
#include "webrtc/modules/rtp_rtcp/include/rtp_header_parser.h" |
#include "webrtc/test/constants.h" |
#include "webrtc/test/direct_transport.h" |
@@ -36,10 +37,7 @@ class RtpRtcpObserver { |
virtual ~RtpRtcpObserver() {} |
- virtual EventTypeWrapper Wait() { |
- EventTypeWrapper result = observation_complete_->Wait(timeout_ms_); |
- return result; |
- } |
+ virtual bool Wait() { return observation_complete_.Wait(timeout_ms_); } |
virtual Action OnSendRtp(const uint8_t* packet, size_t length) { |
return SEND_PACKET; |
@@ -58,8 +56,8 @@ class RtpRtcpObserver { |
} |
protected: |
- explicit RtpRtcpObserver(unsigned int event_timeout_ms) |
- : observation_complete_(EventWrapper::Create()), |
+ explicit RtpRtcpObserver(int event_timeout_ms) |
+ : observation_complete_(false, false), |
parser_(RtpHeaderParser::Create()), |
timeout_ms_(event_timeout_ms) { |
parser_->RegisterRtpHeaderExtension(kRtpExtensionTransmissionTimeOffset, |
@@ -70,11 +68,11 @@ class RtpRtcpObserver { |
kTransportSequenceNumberExtensionId); |
} |
- const rtc::scoped_ptr<EventWrapper> observation_complete_; |
+ rtc::Event observation_complete_; |
const rtc::scoped_ptr<RtpHeaderParser> parser_; |
private: |
- unsigned int timeout_ms_; |
+ const int timeout_ms_; |
}; |
class PacketTransport : public test::DirectTransport { |