Reland of Split IncomingVideoStream into two implementations, with smoothing and without.

webrtc/common_video/incoming_video_stream_unittest.cc

+/*
+ *  Copyright (c) 2016 The WebRTC project authors. All Rights Reserved.
+ *
+ *  Use of this source code is governed by a BSD-style license
+ *  that can be found in the LICENSE file in the root of the source
+ *  tree. An additional intellectual property rights grant can be found
+ *  in the file PATENTS.  All contributing project authors may
+ *  be found in the AUTHORS file in the root of the source tree.
+ */
+
+#include "testing/gtest/include/gtest/gtest.h"
+#include "webrtc/base/event.h"
+#include "webrtc/common_video/include/incoming_video_stream.h"
+#include "webrtc/media/base/videosinkinterface.h"
+#include "webrtc/video_frame.h"
+
+namespace webrtc {
+
+// Basic test that checks if the no-smoothing implementation delivers a frame.
+TEST(IncomingVideoStreamTest, NoSmoothingOneFrame) {
+  class TestCallback : public rtc::VideoSinkInterface<VideoFrame> {
+   public:
+    TestCallback() : event_(false, false) {}
+    ~TestCallback() override {}
+
+    bool WaitForFrame(int milliseconds) { return event_.Wait(milliseconds); }
+
+   private:
+    void OnFrame(const VideoFrame& frame) override { event_.Set(); }
+
+    rtc::Event event_;
+  } callback;
+  IncomingVideoStreamNoSmoothing stream(&callback);
+
+  rtc::VideoSinkInterface<VideoFrame>* stream_sink = &stream;
+  stream_sink->OnFrame(VideoFrame());
+
+  EXPECT_TRUE(callback.WaitForFrame(500));
+}
+
+// Tests that if the renderer is too slow, that frames will not be dropped and
+// still the "producer thread" (main test thread), will not be blocked from
+// delivering frames.
+TEST(IncomingVideoStreamTest, NoSmoothingManyFrames) {
+  rtc::Event done(false, false);
+
+  class TestCallback : public rtc::VideoSinkInterface<VideoFrame> {
+   public:
+    explicit TestCallback(rtc::Event* done)
+        : event_(false, false), done_(done) {}
+    ~TestCallback() override {}
+
+    void Continue() { event_.Set(); }
+    int frame_count() const { return frame_count_; }
+
+   private:
+    void OnFrame(const VideoFrame& frame) override {
+      ++frame_count_;
+      if (frame_count_ == 1) {
+        // Block delivery of frames until we're allowed to continue.
+        event_.Wait(rtc::Event::kForever);
+      } else if (frame_count_ == 100) {
+        done_->Set();
+      }
+    }
+
+    rtc::Event event_;
+    rtc::Event* done_;
+    int frame_count_ = 0;
+  } callback(&done);
+
+  {
+    IncomingVideoStreamNoSmoothing stream(&callback);
+
+    rtc::VideoSinkInterface<VideoFrame>* stream_sink = &stream;
+    for (int i = 0; i < 100; ++i)
+      stream_sink->OnFrame(VideoFrame());
+    // Unblock the 'processing' of the first frame and wait for all the frames
+    // to be processed.
+    EXPECT_LE(callback.frame_count(), 1);
+    callback.Continue();
+    done.Wait(rtc::Event::kForever);
+  }
+
+  EXPECT_EQ(callback.frame_count(), 100);
+}
+
+}  // namespace webrtc