Implement InputStub in the host side for chromoting

remoting/host/chromoting_host.cc

 // Copyright (c) 2010 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/host/chromoting_host.h"
 
 #include "base/stl_util-inl.h"
 #include "base/task.h"
 #include "build/build_config.h"
 #include "remoting/base/constants.h"
 #include "remoting/base/encoder.h"
 #include "remoting/base/encoder_verbatim.h"
 #include "remoting/base/encoder_vp8.h"
 #include "remoting/base/encoder_zlib.h"
 #include "remoting/host/chromoting_host_context.h"
 #include "remoting/host/capturer.h"
-#include "remoting/host/event_executor.h"
 #include "remoting/host/host_config.h"
 #include "remoting/host/session_manager.h"
 #include "remoting/protocol/session_config.h"
 #include "remoting/protocol/jingle_session_manager.h"
 #include "remoting/protocol/connection_to_client.h"
 
 using remoting::protocol::ConnectionToClient;
 
 namespace remoting {
 
 ChromotingHost::ChromotingHost(ChromotingHostContext* context,
                                MutableHostConfig* config,
                                Capturer* capturer,
-                               EventExecutor* executor)
+                               protocol::InputStub* input_stub)
     : context_(context),
       config_(config),
       capturer_(capturer),
-      executor_(executor),
+      input_stub_(input_stub),
       state_(kInitial) {
 }
 
 ChromotingHost::~ChromotingHost() {
 }
 
 void ChromotingHost::Start(Task* shutdown_task) {
   if (MessageLoop::current() != context_->main_message_loop()) {
     context_->main_message_loop()->PostTask(
         FROM_HERE,
@@ skipping 127 matching lines @@
 
   // Close the connection to connection just to be safe.
   connection->Disconnect();
 
   // Also remove reference to ConnectionToClient from this object.
   connection_ = NULL;
 }
 
 ////////////////////////////////////////////////////////////////////////////
 // protocol::ConnectionToClient::EventHandler implementations
-void ChromotingHost::HandleMessage(ConnectionToClient* connection,
-                                   ChromotingClientMessage* message) {
-  DCHECK_EQ(context_->main_message_loop(), MessageLoop::current());
-
-  // Delegate the messages to EventExecutor and delete the unhandled
-  // messages.
-  DCHECK(executor_.get());
-  executor_->HandleInputEvent(message);
-}
-
 void ChromotingHost::OnConnectionOpened(ConnectionToClient* connection) {
   DCHECK_EQ(context_->main_message_loop(), MessageLoop::current());
 
   // Completes the connection to the client.
   VLOG(1) << "Connection to client established.";
   OnClientConnected(connection_.get());
 }
 
 void ChromotingHost::OnConnectionClosed(ConnectionToClient* connection) {
   DCHECK_EQ(context_->main_message_loop(), MessageLoop::current());
@@ skipping 73 matching lines @@
   }
 
   session->set_config(config);
 
   *response = protocol::SessionManager::ACCEPT;
 
   VLOG(1) << "Client connected: " << session->jid();
 
   // If we accept the connected then create a client object and set the
   // callback.
-  connection_ = new ConnectionToClient(context_->main_message_loop(), this);
+  connection_ = new ConnectionToClient(context_->main_message_loop(),
+                                       this, NULL, input_stub_.get());
   connection_->Init(session);
 }
 
 void ChromotingHost::OnServerClosed() {
   // Don't need to do anything here.
 }
 
 // TODO(sergeyu): Move this to SessionManager?
 Encoder* ChromotingHost::CreateEncoder(const protocol::SessionConfig* config) {
   const protocol::ChannelConfig& video_config = config->video_config();
 
   if (video_config.codec == protocol::ChannelConfig::CODEC_VERBATIM) {
     return new remoting::EncoderVerbatim();
   } else if (video_config.codec == protocol::ChannelConfig::CODEC_ZIP) {
     return new remoting::EncoderZlib();
   }
   // TODO(sergeyu): Enable VP8 on ARM builds.
 #if !defined(ARCH_CPU_ARM_FAMILY)
   else if (video_config.codec == protocol::ChannelConfig::CODEC_VP8) {
     return new remoting::EncoderVp8();
   }
 #endif
 
   return NULL;
 }
 
 }  // namespace remoting