Add InputEventTimestampSource interface.

remoting/protocol/webrtc_connection_to_client.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.
 
 #include "remoting/protocol/webrtc_connection_to_client.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/location.h"
@@ skipping 65 matching lines @@
 }
 
 std::unique_ptr<VideoStream> WebrtcConnectionToClient::StartVideoStream(
     std::unique_ptr<webrtc::DesktopCapturer> desktop_capturer) {
   DCHECK(thread_checker_.CalledOnValidThread());
   DCHECK(transport_);
 
   std::unique_ptr<WebrtcVideoStream> stream(new WebrtcVideoStream());
   stream->Start(std::move(desktop_capturer), transport_.get(),
                 video_encode_task_runner_);
+  stream->SetEventTimestampsSource(
+      event_dispatcher_->event_timestamps_source());
   return std::move(stream);
 }
 
 std::unique_ptr<AudioStream> WebrtcConnectionToClient::StartAudioStream(
     std::unique_ptr<AudioSource> audio_source) {
   DCHECK(thread_checker_.CalledOnValidThread());
   DCHECK(transport_);
 
   std::unique_ptr<WebrtcAudioStream> stream(new WebrtcAudioStream());
   stream->Start(audio_task_runner_, std::move(audio_source), transport_.get());
@@ skipping 78 matching lines @@
   DCHECK(thread_checker_.CalledOnValidThread());
   Disconnect(error);
 }
 
 void WebrtcConnectionToClient::OnWebrtcTransportIncomingDataChannel(
     const std::string& name,
     std::unique_ptr<MessagePipe> pipe) {
   DCHECK(thread_checker_.CalledOnValidThread());
   if (name == event_dispatcher_->channel_name() &&
       !event_dispatcher_->is_connected()) {
-    event_dispatcher_->set_on_input_event_callback(
-        base::Bind(&WebrtcConnectionToClient::OnInputEventReceived,
-                   base::Unretained(this)));
     event_dispatcher_->Init(std::move(pipe), this);
   }
 }
 
 void WebrtcConnectionToClient::OnWebrtcTransportMediaStreamAdded(
     scoped_refptr<webrtc::MediaStreamInterface> stream) {
   DCHECK(thread_checker_.CalledOnValidThread());
   LOG(WARNING) << "The client created an unexpected media stream.";
 }
 
@@ skipping 14 matching lines @@
 
 void WebrtcConnectionToClient::OnChannelClosed(
     ChannelDispatcherBase* channel_dispatcher) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   LOG(ERROR) << "Channel " << channel_dispatcher->channel_name()
              << " was closed unexpectedly.";
   Disconnect(INCOMPATIBLE_PROTOCOL);
 }
 
-void WebrtcConnectionToClient::OnInputEventReceived(int64_t timestamp) {
-  DCHECK(thread_checker_.CalledOnValidThread());
-  event_handler_->OnInputEventReceived(timestamp);
-}
-
 }  // namespace protocol
 }  // namespace remoting