Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(384)

Unified Diff: remoting/protocol/ice_connection_to_client.cc

Issue 2413553003: Add InputEventTimestampSource interface. (Closed)
Patch Set: Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: remoting/protocol/ice_connection_to_client.cc
diff --git a/remoting/protocol/ice_connection_to_client.cc b/remoting/protocol/ice_connection_to_client.cc
index b0ec636fe21f3b6fdd589d34ffe408ad05674606..dee680c8f3a88348674d2bf0bbcf5ed5ec824e3a 100644
--- a/remoting/protocol/ice_connection_to_client.cc
+++ b/remoting/protocol/ice_connection_to_client.cc
@@ -92,6 +92,7 @@ std::unique_ptr<VideoStream> IceConnectionToClient::StartVideoStream(
std::unique_ptr<VideoFramePump> pump(
new VideoFramePump(video_encode_task_runner_, std::move(desktop_capturer),
std::move(video_encoder), video_dispatcher_.get()));
+ pump->SetEventTimestampSource(event_dispatcher_->GetEventTimestampSource());
video_dispatcher_->set_video_feedback_stub(pump->video_feedback_stub());
return std::move(pump);
}
@@ -152,12 +153,7 @@ void IceConnectionToClient::OnSessionStateChange(Session::State state) {
// Initialize channels.
control_dispatcher_->Init(transport_.GetMultiplexedChannelFactory(),
this);
-
event_dispatcher_->Init(transport_.GetMultiplexedChannelFactory(), this);
- event_dispatcher_->set_on_input_event_callback(
- base::Bind(&IceConnectionToClient::OnInputEventReceived,
- base::Unretained(this)));
-
video_dispatcher_->Init(transport_.GetChannelFactory(), this);
audio_writer_ = AudioWriter::Create(session_->config());
@@ -204,11 +200,6 @@ void IceConnectionToClient::OnChannelClosed(
NOTREACHED();
}
-void IceConnectionToClient::OnInputEventReceived(int64_t timestamp) {
- DCHECK(thread_checker_.CalledOnValidThread());
- event_handler_->OnInputEventReceived(timestamp);
-}
-
void IceConnectionToClient::NotifyIfChannelsReady() {
DCHECK(thread_checker_.CalledOnValidThread());

Powered by Google App Engine
This is Rietveld 408576698