| Index: webrtc/video/video_capture_input.cc
|
| diff --git a/webrtc/video/video_capture_input.cc b/webrtc/video/video_capture_input.cc
|
| index ac05e36c4098b238df0a667bbad1c053b8444dc2..a70ce364192bdd07232a37ccb5a98e6fed4dc9bc 100644
|
| --- a/webrtc/video/video_capture_input.cc
|
| +++ b/webrtc/video/video_capture_input.cc
|
| @@ -43,7 +43,7 @@ VideoCaptureInput::VideoCaptureInput(
|
| stats_proxy_(stats_proxy),
|
| incoming_frame_cs_(CriticalSectionWrapper::CreateCriticalSection()),
|
| encoder_thread_(EncoderThreadFunction, this, "EncoderThread"),
|
| - capture_event_(EventWrapper::Create()),
|
| + capture_event_(false, false),
|
| stop_(0),
|
| last_captured_timestamp_(0),
|
| delta_ntp_internal_ms_(
|
| @@ -64,7 +64,7 @@ VideoCaptureInput::~VideoCaptureInput() {
|
|
|
| // Stop the thread.
|
| rtc::AtomicOps::ReleaseStore(&stop_, 1);
|
| - capture_event_->Set();
|
| + capture_event_.Set();
|
| encoder_thread_.Stop();
|
| }
|
|
|
| @@ -116,7 +116,7 @@ void VideoCaptureInput::IncomingCapturedFrame(const VideoFrame& video_frame) {
|
| TRACE_EVENT_ASYNC_BEGIN1("webrtc", "Video", video_frame.render_time_ms(),
|
| "render_time", video_frame.render_time_ms());
|
|
|
| - capture_event_->Set();
|
| + capture_event_.Set();
|
| }
|
|
|
| bool VideoCaptureInput::EncoderThreadFunction(void* obj) {
|
| @@ -126,7 +126,7 @@ bool VideoCaptureInput::EncoderThreadFunction(void* obj) {
|
| bool VideoCaptureInput::EncoderProcess() {
|
| static const int kThreadWaitTimeMs = 100;
|
| int64_t capture_time = -1;
|
| - if (capture_event_->Wait(kThreadWaitTimeMs) == kEventSignaled) {
|
| + if (capture_event_.Wait(kThreadWaitTimeMs)) {
|
| if (rtc::AtomicOps::AcquireLoad(&stop_))
|
| return false;
|
|
|
|
|