Move decoder into separate thread, clean up API layering, and redo update protocl

remoting/client/plugin/chromoting_instance.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/client/plugin/chromoting_instance.h"
 
 #include <string>
 #include <vector>
 
 #include "base/message_loop.h"
 #include "base/string_util.h"
 #include "base/thread.h"
 #include "remoting/client/client_config.h"
 #include "remoting/client/client_util.h"
 #include "remoting/client/chromoting_client.h"
 #include "remoting/client/host_connection.h"
 #include "remoting/client/jingle_host_connection.h"
+#include "remoting/client/rectangle_update_decoder.h"
 #include "remoting/client/plugin/chromoting_scriptable_object.h"
 #include "remoting/client/plugin/pepper_input_handler.h"
 #include "remoting/client/plugin/pepper_view.h"
 #include "remoting/jingle_glue/jingle_thread.h"
 #include "third_party/ppapi/c/pp_input_event.h"
 #include "third_party/ppapi/cpp/completion_callback.h"
 #include "third_party/ppapi/cpp/rect.h"
 
 namespace remoting {
 
@@ skipping 32 matching lines @@
   // TODO(ajwong): See if there is a method for querying what thread we're on
   // from inside the pepper API.
   pepper_main_loop_dont_post_to_me_ = MessageLoop::current();
   LOG(INFO) << "Started ChromotingInstance::Init";
 
   // Start all the threads.
   context_.Start();
 
   // Create the chromoting objects.
   host_connection_.reset(new JingleHostConnection(&context_));
-  view_.reset(new PepperView(this));
+  view_.reset(new PepperView(this, &context_));
+  rectangle_decoder_.reset(
+      new RectangleUpdateDecoder(context_.decode_message_loop(), view_.get()));
   input_handler_.reset(new PepperInputHandler(&context_, host_connection_.get(),
                                               view_.get()));
 
   // Default to a medium grey.
   view_->SetSolidFill(0xFFCDCDCD);
 
   return true;
 }
 
 void ChromotingInstance::Connect(const ClientConfig& config) {
   DCHECK(CurrentlyOnPluginThread());
 
   client_.reset(new ChromotingClient(config,
                                      &context_,
                                      host_connection_.get(),
                                      view_.get(),
+                                     rectangle_decoder_.get(),
                                      input_handler_.get(),
                                      NULL));
 
   // Kick off the connection.
   client_->Start();
 }
 
 void ChromotingInstance::ViewChanged(const pp::Rect& position,
                                    const pp::Rect& clip) {
   DCHECK(CurrentlyOnPluginThread());
@@ skipping 61 matching lines @@
 
     LOG(ERROR) << "Object initted.";
     // The pp::Var takes ownership of object here.
     instance_object_ = pp::Var(object);
   }
 
   return instance_object_;
 }
 
 }  // namespace remoting