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

remoting/base/protocol_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/base/protocol_decoder.h"
 
 #include "base/logging.h"
 #include "remoting/base/multiple_array_input_stream.h"
 #include "talk/base/byteorder.h"
 
@@ skipping 11 matching lines @@
   ParseMessages<ChromotingClientMessage>(data, messages);
 }
 
 void ProtocolDecoder::ParseHostMessages(scoped_refptr<media::DataBuffer> data,
                                         HostMessageList* messages) {
   ParseMessages<ChromotingHostMessage>(data, messages);
 }
 
 template <typename T>
 void ProtocolDecoder::ParseMessages(scoped_refptr<media::DataBuffer> data,
-                                    std::vector<T*>* messages) {
+                                    std::list<T*>* messages) {
   // If this is the first data in the processing queue, then set the
   // last read position to 0.
   if (data_list_.empty())
     last_read_position_ = 0;
 
   // First enqueue the data received.
   data_list_.push_back(data);
   available_bytes_ += data->GetDataSize();
 
   // Then try to parse one message until we can't parse anymore.
@@ skipping 97 matching lines @@
 
   if (header.length() == kHeaderSize) {
     *size = talk_base::GetBE32(header.c_str());
     return true;
   }
   NOTREACHED() << "Unable to extract payload size";
   return false;
 }
 
 }  // namespace remoting