Add VideoReader and VideoWriter interfaces.

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/jingle_chromotocol_server.h"
+#include "remoting/protocol/chromotocol_config.h"
 
 namespace remoting {
 
 ChromotingHost::ChromotingHost(ChromotingHostContext* context,
                                MutableHostConfig* config,
                                Capturer* capturer,
-                               Encoder* encoder,
                                EventExecutor* executor)
     : context_(context),
       config_(config),
       capturer_(capturer),
-      encoder_(encoder),
       executor_(executor),
       state_(kInitial) {
 }
 
 ChromotingHost::~ChromotingHost() {
 }
 
 void ChromotingHost::Start(Task* shutdown_task) {
   if (MessageLoop::current() != context_->main_message_loop()) {
     context_->main_message_loop()->PostTask(
@@ skipping 93 matching lines @@
 
 // This method is called if a client is connected to this object.
 void ChromotingHost::OnClientConnected(ClientConnection* client) {
   DCHECK_EQ(context_->main_message_loop(), MessageLoop::current());
 
   // Create a new RecordSession if there was none.
   if (!session_.get()) {
     // Then we create a SessionManager passing the message loops that
     // it should run on.
     DCHECK(capturer_.get());
-    DCHECK(encoder_.get());
+
+    Encoder* encoder = CreateEncoder(client->connection()->config());
+
     session_ = new SessionManager(context_->capture_message_loop(),
                                   context_->encode_message_loop(),
                                   context_->main_message_loop(),
-                                  capturer_.get(),
-                                  encoder_.get());
+                                  capturer_.release(),
+                                  encoder);
   }
 
   // Immediately add the client and start the session.
   session_->AddClient(client);
   session_->Start();
   VLOG(1) << "Session manager started";
 }
 
 void ChromotingHost::OnClientDisconnected(ClientConnection* client) {
   DCHECK_EQ(context_->main_message_loop(), MessageLoop::current());
@@ skipping 119 matching lines @@
   // If we accept the connected then create a client object and set the
   // callback.
   client_ = new ClientConnection(context_->main_message_loop(), this);
   client_->Init(connection);
 }
 
 void ChromotingHost::OnServerClosed() {
   // Don't need to do anything here.
 }
 
+// TODO(sergeyu): Move this to SessionManager?
+Encoder* ChromotingHost::CreateEncoder(const ChromotocolConfig* config) {
+  const ChannelConfig& video_config = config->video_config();
+
+  if (video_config.codec == ChannelConfig::CODEC_VERBATIM) {
+    return new remoting::EncoderVerbatim();
+  } else if (video_config.codec == 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 == ChannelConfig::CODEC_VP8) {
+    return new remoting::EncoderVp8();
+  }
+#endif
+
+  return NULL;
+}
+
+
 }  // namespace remoting