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

remoting/client/rectangle_update_decoder.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/rectangle_update_decoder.h"
 
 #include "base/logging.h"
 #include "base/message_loop.h"
 #include "media/base/callback.h"
 #include "remoting/base/decoder.h"
-#include "remoting/base/decoder_verbatim.h"
-#include "remoting/base/decoder_zlib.h"
+#include "remoting/base/decoder_row_based.h"
 #include "remoting/base/protocol/chromotocol.pb.h"
+#include "remoting/base/protocol_util.h"
 #include "remoting/base/tracer.h"
 #include "remoting/client/frame_consumer.h"
 
 using media::AutoTaskRunner;
 
 namespace remoting {
 
 namespace {
 
 class PartialFrameCleanup : public Task {
@@ skipping 164 matching lines @@
     //
     // For now though, assume that only one encoding is used throughout.
     //
     // Note, this may be as simple as just deleting the current decoder.
     // However, we need to verify the flushing semantics of the decoder first.
     CHECK(decoder_->Encoding() == format.encoding());
   } else {
     // Initialize a new decoder based on this message encoding.
     if (format.encoding() == EncodingNone) {
       TraceContext::tracer()->PrintString("Creating Verbatim decoder.");
-      decoder_.reset(new DecoderVerbatim());
+      decoder_.reset(DecoderRowBased::CreateVerbatimDecoder());
     } else if (format.encoding() == EncodingZlib) {
       TraceContext::tracer()->PrintString("Creating Zlib decoder");
-      decoder_.reset(new DecoderZlib());
+      decoder_.reset(DecoderRowBased::CreateZlibDecoder());
     } else {
       NOTREACHED() << "Invalid Encoding found: " << format.encoding();
     }
   }
 
   // TODO(ajwong): This can happen in the face of corrupt input data.  Figure
   // out the right behavior and make this more resilient.
   CHECK(updated_rects_.empty());
 
   gfx::Rect rectangle_size(format.x(), format.y(),
                            format.width(), format.height());
   updated_rects_.push_back(rectangle_size);
-  decoder_->Initialize(frame_, rectangle_size);
+  decoder_->Initialize(frame_, rectangle_size,
+                       GetBytesPerPixel(format.pixel_format()));
   TraceContext::tracer()->PrintString("Decoder is Initialized");
 }
 
 }  // namespace remoting