Add test for dropping repeated NTP timestamps.

webrtc/video/video_capture_input_unittest.cc

 /*
  *  Copyright (c) 2014 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 "webrtc/video/video_capture_input.h"
@@ skipping 121 matching lines @@
   WaitOutputFrame();
 
   EXPECT_EQ(output_frames_[0]->video_frame_buffer().get(),
             frame.video_frame_buffer().get());
   output_frames_.clear();
   frame.Reset();
   EXPECT_EQ(kEventSignaled, frame_destroyed_event->Wait(FRAME_TIMEOUT_MS));
 }
 
 TEST_F(VideoCaptureInputTest, TestNtpTimeStampSetIfRenderTimeSet) {
-  input_frames_.push_back(CreateVideoFrame(static_cast<uint8_t>(0)));
+  input_frames_.push_back(CreateVideoFrame(0));
   input_frames_[0]->set_render_time_ms(5);
   input_frames_[0]->set_ntp_time_ms(0);
 
   AddInputFrame(input_frames_[0]);
   WaitOutputFrame();
   EXPECT_GT(output_frames_[0]->ntp_time_ms(),
             input_frames_[0]->render_time_ms());
 }
 
 TEST_F(VideoCaptureInputTest, TestRtpTimeStampSet) {
-  input_frames_.push_back(CreateVideoFrame(static_cast<uint8_t>(0)));
+  input_frames_.push_back(CreateVideoFrame(0));
   input_frames_[0]->set_render_time_ms(0);
   input_frames_[0]->set_ntp_time_ms(1);
   input_frames_[0]->set_timestamp(0);
 
   AddInputFrame(input_frames_[0]);
   WaitOutputFrame();
   EXPECT_EQ(output_frames_[0]->timestamp(),
             input_frames_[0]->ntp_time_ms() * 90);
 }
 
+TEST_F(VideoCaptureInputTest, DropsFramesWithSameOrOldNtpTimestamp) {
+  input_frames_.push_back(CreateVideoFrame(0));
+
+  input_frames_[0]->set_ntp_time_ms(17);
+  AddInputFrame(input_frames_[0]);
+  WaitOutputFrame();
+  EXPECT_EQ(output_frames_[0]->timestamp(),
+            input_frames_[0]->ntp_time_ms() * 90);
+
+  // Repeat frame with the same NTP timestamp should drop.
+  AddInputFrame(input_frames_[0]);
+  EXPECT_EQ(kEventTimeout, output_frame_event_->Wait(FRAME_TIMEOUT_MS));
+
+  // As should frames with a decreased NTP timestamp.
+  input_frames_[0]->set_ntp_time_ms(input_frames_[0]->ntp_time_ms() - 1);
+  AddInputFrame(input_frames_[0]);
+  EXPECT_EQ(kEventTimeout, output_frame_event_->Wait(FRAME_TIMEOUT_MS));
+
+  // But delivering with an increased NTP timestamp should succeed.
+  input_frames_[0]->set_ntp_time_ms(4711);
+  AddInputFrame(input_frames_[0]);
+  WaitOutputFrame();
+  EXPECT_EQ(output_frames_[1]->timestamp(),
+            input_frames_[0]->ntp_time_ms() * 90);
+}
+
 TEST_F(VideoCaptureInputTest, TestTextureFrames) {
   const int kNumFrame = 3;
   for (int i = 0 ; i < kNumFrame; ++i) {
     test::FakeNativeHandle* dummy_handle = new test::FakeNativeHandle();
     // Add one to |i| so that width/height > 0.
     input_frames_.push_back(new VideoFrame(test::CreateFakeNativeHandleFrame(
         dummy_handle, i + 1, i + 1, i + 1, i + 1, webrtc::kVideoRotation_0)));
     AddInputFrame(input_frames_[i]);
     WaitOutputFrame();
     EXPECT_EQ(dummy_handle, output_frames_[i]->native_handle());
@@ skipping 97 matching lines @@
   const int kSizeY = width * height * 2;
   uint8_t buffer[kSizeY];
   memset(buffer, data, kSizeY);
   frame->CreateFrame(buffer, buffer, buffer, width, height, width, width / 2,
                      width / 2);
   frame->set_render_time_ms(data);
   return frame;
 }
 
 }  // namespace webrtc