Add VideoPacket struct for video packets. Refactor Decode interface to use it.

remoting/protocol/jingle_connection_to_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/protocol/jingle_connection_to_host.h"
 
 #include "base/callback.h"
 #include "base/message_loop.h"
 #include "remoting/base/constants.h"
 // TODO(hclam): Remove this header once MessageDispatcher is used.
@@ skipping 46 matching lines @@
   video_reader_->Close();
 
   if (session_) {
     session_->Close(
         NewRunnableMethod(this, &JingleConnectionToHost::OnDisconnected));
   } else {
     OnDisconnected();
   }
 }
 
-void JingleConnectionToHost::OnControlMessage(ChromotingHostMessage* msg) {
-  event_callback_->HandleMessage(this, msg);
+void JingleConnectionToHost::OnControlMessage(ControlMessage* msg) {
+  // TODO(sergeyu): Remove this method and pass ClientStub to the control
+  // stream dispatcher.
+  delete msg;
 }
 
 void JingleConnectionToHost::InitSession() {
   DCHECK_EQ(message_loop(), MessageLoop::current());
 
   // Initialize chromotocol |session_manager_|.
   protocol::JingleSessionManager* session_manager =
       new protocol::JingleSessionManager(thread_);
   // TODO(ajwong): Make this a command switch when we're more stable.
   session_manager->set_allow_local_ips(true);
@@ skipping 26 matching lines @@
 }
 
 void JingleConnectionToHost::OnServerClosed() {
   session_manager_ = NULL;
   if (jingle_client_) {
     jingle_client_->Close();
     jingle_client_ = NULL;
   }
 }
 
+const SessionConfig* JingleConnectionToHost::config() {
+  return session_->config();
+}
+
 void JingleConnectionToHost::SendEvent(const ChromotingClientMessage& msg) {
   // This drops the message if we are not connected yet.
   event_writer_.SendMessage(msg);
 }
 
 // JingleClient::Callback interface.
 void JingleConnectionToHost::OnStateChange(JingleClient* client,
                                          JingleClient::State state) {
   DCHECK_EQ(message_loop(), MessageLoop::current());
   DCHECK(client);
@@ skipping 24 matching lines @@
     case protocol::Session::FAILED:
       event_callback_->OnConnectionFailed(this);
       break;
 
     case protocol::Session::CLOSED:
       event_callback_->OnConnectionClosed(this);
       break;
 
     case protocol::Session::CONNECTED:
       // Initialize reader and writer.
-      control_reader_.Init<ChromotingHostMessage>(
+      control_reader_.Init<ControlMessage>(
           session_->control_channel(),
           NewCallback(this, &JingleConnectionToHost::OnControlMessage));
       event_writer_.Init(session_->event_channel());
       video_reader_.reset(VideoReader::Create(session_->config()));
       video_reader_->Init(session_, video_stub_);
       event_callback_->OnConnectionOpened(this);
       break;
 
     default:
       // Ignore the other states by default.
       break;
   }
 }
 
 MessageLoop* JingleConnectionToHost::message_loop() {
   return thread_->message_loop();
 }
 
 }  // namespace protocol
 }  // namespace remoting