Add InputEventTimestampSource interface.

remoting/protocol/connection_unittest.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #define _USE_MATH_DEFINES // For VC++ to get M_PI. This has to be first.
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/macros.h"
@@ skipping 452 matching lines @@
 
 TEST_P(ConnectionTest, Events) {
   Connect();
 
   KeyEvent event;
   event.set_usb_keycode(3);
   event.set_pressed(true);
 
   base::RunLoop run_loop;
 
-  EXPECT_CALL(host_event_handler_, OnInputEventReceived(_));
   EXPECT_CALL(host_input_stub_, InjectKeyEvent(EqualsKeyEvent(event)))
       .WillOnce(QuitRunLoop(&run_loop));
 
   // Send key event from the client.
   client_connection_->input_stub()->InjectKeyEvent(event);
 
   run_loop.Run();
 }
 
 TEST_P(ConnectionTest, Video) {
@@ skipping 24 matching lines @@
 
 TEST_P(ConnectionTest, DestroyOnIncomingMessage) {
   Connect();
 
   KeyEvent event;
   event.set_usb_keycode(3);
   event.set_pressed(true);
 
   base::RunLoop run_loop;
 
-  EXPECT_CALL(host_event_handler_, OnInputEventReceived(_));
   EXPECT_CALL(host_input_stub_, InjectKeyEvent(EqualsKeyEvent(event)))
       .WillOnce(DoAll(InvokeWithoutArgs(this, &ConnectionTest::DestroyHost),
                       QuitRunLoop(&run_loop)));
 
   // Send key event from the client.
   client_connection_->input_stub()->InjectKeyEvent(event);
 
   run_loop.Run();
 }
 
 TEST_P(ConnectionTest, VideoStats) {
   // Currently this test only works for WebRTC because for ICE connections stats
   // are reported by SoftwareVideoRenderer which is not used in this test.
   // TODO(sergeyu): Fix this.
   if (!is_using_webrtc())
     return;
 
   Connect();
 
   base::TimeTicks start_time = base::TimeTicks::Now();
 
+  scoped_refptr<InputEventTimestampsSourceImpl> input_event_timestamps_source =
+      new InputEventTimestampsSourceImpl();
+  input_event_timestamps_source->OnEventReceived(
+      InputEventTimestamps{start_time, start_time});
+
   std::unique_ptr<VideoStream> video_stream =
       host_connection_->StartVideoStream(
           base::MakeUnique<TestScreenCapturer>());
-
-  // Simulate an input invent injected at the start.
-  video_stream->OnInputEventReceived(start_time.ToInternalValue());
+  video_stream->SetEventTimestampsSource(input_event_timestamps_source);
 
   WaitFirstVideoFrame();
 
   base::TimeTicks finish_time = base::TimeTicks::Now();
 
   WaitFirstFrameStats();
 
   const FrameStats& stats =
       client_video_renderer_.GetFrameStatsConsumer()->received_stats().front();
 
@@ skipping 29 matching lines @@
   std::unique_ptr<AudioStream> audio_stream =
       host_connection_->StartAudioStream(base::MakeUnique<TestAudioSource>());
 
   // Wait for 1 second worth of audio samples.
   client_audio_player_.WaitForSamples(kAudioSampleRate * 2);
   client_audio_player_.Verify();
 }
 
 }  // namespace protocol
 }  // namespace remoting