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

remoting/host/client_connection.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/client_connection.h"
 
 #include "google/protobuf/message.h"
 #include "media/base/data_buffer.h"
 #include "remoting/base/protocol_decoder.h"
 #include "remoting/base/protocol_util.h"
@@ skipping 97 matching lines @@
   size_in_queue_ += update_stream_size_;
   size_queue_.push_back(update_stream_size_);
   if (size_queue_.size() > kAverageUpdateStream) {
     size_in_queue_ -= size_queue_.front();
     size_queue_.pop_front();
     DCHECK_GE(size_in_queue_, 0);
   }
   update_stream_size_ = 0;
 }
 
+void ClientConnection::MarkEndOfUpdate() {
+  // This is some logic to help calculate the average update stream size.
+  size_in_queue_ += update_stream_size_;
+  size_queue_.push_back(update_stream_size_);
+  if (size_queue_.size() > kAverageUpdateStream) {
+    size_in_queue_ -= size_queue_.front();
+    size_queue_.pop_front();
+    DCHECK_GE(size_in_queue_, 0);
+  }
+  update_stream_size_ = 0;
+}
+
 int ClientConnection::GetPendingUpdateStreamMessages() {
   DCHECK_EQ(loop_, MessageLoop::current());
 
   if (!size_queue_.size())
     return 0;
   int average_size = size_in_queue_ / size_queue_.size();
   if (!average_size)
     return 0;
   return channel_->write_buffer_size() / average_size;
 }
@@ skipping 52 matching lines @@
   DCHECK(decoder_.get());
   ClientMessageList list;
   decoder_->ParseClientMessages(data, &list);
 
   // Then submit the messages to the handler.
   DCHECK(handler_);
   handler_->HandleMessages(this, &list);
 }
 
 }  // namespace remoting