| Index: webrtc/test/rtp_rtcp_observer.h
|
| diff --git a/webrtc/test/rtp_rtcp_observer.h b/webrtc/test/rtp_rtcp_observer.h
|
| index 63e97be4dd6b3afd092a51c59bf4dc7e1a47c84d..4856de790587af3a2b7dced69e933ce40109d521 100644
|
| --- a/webrtc/test/rtp_rtcp_observer.h
|
| +++ b/webrtc/test/rtp_rtcp_observer.h
|
| @@ -17,12 +17,17 @@
|
| #include "webrtc/base/criticalsection.h"
|
| #include "webrtc/base/event.h"
|
| #include "webrtc/modules/rtp_rtcp/include/rtp_header_parser.h"
|
| +#include "webrtc/system_wrappers/include/field_trial.h"
|
| #include "webrtc/test/constants.h"
|
| #include "webrtc/test/direct_transport.h"
|
| #include "webrtc/test/gtest.h"
|
| #include "webrtc/typedefs.h"
|
| #include "webrtc/video_send_stream.h"
|
|
|
| +namespace {
|
| +const int kShortTimeoutMs = 500;
|
| +}
|
| +
|
| namespace webrtc {
|
| namespace test {
|
|
|
| @@ -37,7 +42,13 @@ class RtpRtcpObserver {
|
|
|
| virtual ~RtpRtcpObserver() {}
|
|
|
| - virtual bool Wait() { return observation_complete_.Wait(timeout_ms_); }
|
| + virtual bool Wait() {
|
| + if (field_trial::FindFullName("WebRTC-QuickPerfTest") == "Enabled") {
|
| + observation_complete_.Wait(kShortTimeoutMs);
|
| + return true;
|
| + }
|
| + return observation_complete_.Wait(timeout_ms_);
|
| + }
|
|
|
| virtual Action OnSendRtp(const uint8_t* packet, size_t length) {
|
| return SEND_PACKET;
|
|
|