Adding the base ChromotingInstance implementation and unittests. This class will be used by the ap…

remoting/protocol/connection_to_host_impl.cc

-// Copyright (c) 2012 The Chromium Authors. All rights reserved.
+// Copyright 2015 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/connection_to_host.h"
+#include "remoting/protocol/connection_to_host_impl.h"
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/location.h"
 #include "remoting/base/constants.h"
 #include "remoting/protocol/audio_reader.h"
 #include "remoting/protocol/audio_stub.h"
 #include "remoting/protocol/auth_util.h"
 #include "remoting/protocol/authenticator.h"
 #include "remoting/protocol/client_control_dispatcher.h"
 #include "remoting/protocol/client_event_dispatcher.h"
 #include "remoting/protocol/client_stub.h"
 #include "remoting/protocol/client_video_dispatcher.h"
 #include "remoting/protocol/clipboard_stub.h"
 #include "remoting/protocol/errors.h"
 #include "remoting/protocol/jingle_session_manager.h"
 #include "remoting/protocol/transport.h"
 #include "remoting/protocol/video_stub.h"
 
 namespace remoting {
 namespace protocol {
 
-ConnectionToHost::ConnectionToHost()
+ConnectionToHostImpl::ConnectionToHostImpl()
     : event_callback_(nullptr),
       client_stub_(nullptr),
       clipboard_stub_(nullptr),
       audio_stub_(nullptr),
       signal_strategy_(nullptr),
       state_(INITIALIZING),
       error_(OK) {
 }
 
-ConnectionToHost::~ConnectionToHost() {
+ConnectionToHostImpl::~ConnectionToHostImpl() {
   CloseChannels();
 
   if (session_.get())
     session_.reset();
 
   if (session_manager_.get())
     session_manager_.reset();
 
   if (signal_strategy_)
     signal_strategy_->RemoveListener(this);
 }
 
-void ConnectionToHost::Connect(SignalStrategy* signal_strategy,
-                               scoped_ptr<TransportFactory> transport_factory,
-                               scoped_ptr<Authenticator> authenticator,
-                               const std::string& host_jid,
-                               HostEventCallback* event_callback) {
+void ConnectionToHostImpl::Connect(
+    SignalStrategy* signal_strategy,
+    scoped_ptr<TransportFactory> transport_factory,
+    scoped_ptr<Authenticator> authenticator,
+    const std::string& host_jid,
+    HostEventCallback* event_callback) {
   DCHECK(client_stub_);
   DCHECK(clipboard_stub_);
   DCHECK(monitored_video_stub_);
 
   // Initialize default |candidate_config_| if set_candidate_config() wasn't
   // called.
   if (!candidate_config_) {
     candidate_config_ = CandidateSessionConfig::CreateDefault();
     if (!audio_stub_) {
       candidate_config_->DisableAudioChannel();
@@ skipping 11 matching lines @@
 
   signal_strategy_->AddListener(this);
   signal_strategy_->Connect();
 
   session_manager_.reset(new JingleSessionManager(transport_factory.Pass()));
   session_manager_->Init(signal_strategy_, this);
 
   SetState(CONNECTING, OK);
 }
 
-void ConnectionToHost::set_candidate_config(
+void ConnectionToHostImpl::set_candidate_config(
     scoped_ptr<CandidateSessionConfig> config) {
   DCHECK_EQ(state_, INITIALIZING);
 
   candidate_config_ = config.Pass();
 }
 
-
-const SessionConfig& ConnectionToHost::config() {
+const SessionConfig& ConnectionToHostImpl::config() {
   return session_->config();
 }
 
-ClipboardStub* ConnectionToHost::clipboard_forwarder() {
+ClipboardStub* ConnectionToHostImpl::clipboard_forwarder() {
   return &clipboard_forwarder_;
 }
 
-HostStub* ConnectionToHost::host_stub() {
+HostStub* ConnectionToHostImpl::host_stub() {
   // TODO(wez): Add a HostFilter class, equivalent to input filter.
   return control_dispatcher_.get();
 }
 
-InputStub* ConnectionToHost::input_stub() {
+InputStub* ConnectionToHostImpl::input_stub() {
   return &event_forwarder_;
 }
 
-void ConnectionToHost::set_client_stub(ClientStub* client_stub) {
+void ConnectionToHostImpl::set_client_stub(ClientStub* client_stub) {
   client_stub_ = client_stub;
 }
 
-void ConnectionToHost::set_clipboard_stub(ClipboardStub* clipboard_stub) {
+void ConnectionToHostImpl::set_clipboard_stub(ClipboardStub* clipboard_stub) {
   clipboard_stub_ = clipboard_stub;
 }
 
-void ConnectionToHost::set_video_stub(VideoStub* video_stub) {
+void ConnectionToHostImpl::set_video_stub(VideoStub* video_stub) {
   DCHECK(video_stub);
   monitored_video_stub_.reset(new MonitoredVideoStub(
-      video_stub,
-      base::TimeDelta::FromSeconds(
-          MonitoredVideoStub::kConnectivityCheckDelaySeconds),
-      base::Bind(&ConnectionToHost::OnVideoChannelStatus,
+      video_stub, base::TimeDelta::FromSeconds(
+                      MonitoredVideoStub::kConnectivityCheckDelaySeconds),
+      base::Bind(&ConnectionToHostImpl::OnVideoChannelStatus,
                  base::Unretained(this))));
 }
 
-void ConnectionToHost::set_audio_stub(AudioStub* audio_stub) {
+void ConnectionToHostImpl::set_audio_stub(AudioStub* audio_stub) {
   audio_stub_ = audio_stub;
 }
 
-void ConnectionToHost::OnSignalStrategyStateChange(
+void ConnectionToHostImpl::OnSignalStrategyStateChange(
     SignalStrategy::State state) {
   DCHECK(CalledOnValidThread());
   DCHECK(event_callback_);
 
   if (state == SignalStrategy::CONNECTED) {
     VLOG(1) << "Connected as: " << signal_strategy_->GetLocalJid();
   } else if (state == SignalStrategy::DISCONNECTED) {
     VLOG(1) << "Connection closed.";
     CloseOnError(SIGNALING_ERROR);
   }
 }
 
-bool ConnectionToHost::OnSignalStrategyIncomingStanza(
-   const buzz::XmlElement* stanza) {
+bool ConnectionToHostImpl::OnSignalStrategyIncomingStanza(
+    const buzz::XmlElement* stanza) {
   return false;
 }
 
-void ConnectionToHost::OnSessionManagerReady() {
+void ConnectionToHostImpl::OnSessionManagerReady() {
   DCHECK(CalledOnValidThread());
 
   // After SessionManager is initialized we can try to connect to the host.
-  session_ = session_manager_->Connect(
-      host_jid_, authenticator_.Pass(), candidate_config_.Pass());
+  session_ = session_manager_->Connect(host_jid_, authenticator_.Pass(),
+                                       candidate_config_.Pass());
   session_->SetEventHandler(this);
 }
 
-void ConnectionToHost::OnIncomingSession(
+void ConnectionToHostImpl::OnIncomingSession(
     Session* session,
     SessionManager::IncomingSessionResponse* response) {
   DCHECK(CalledOnValidThread());
   // Client always rejects incoming sessions.
   *response = SessionManager::DECLINE;
 }
 
-void ConnectionToHost::OnSessionStateChange(
-    Session::State state) {
+void ConnectionToHostImpl::OnSessionStateChange(Session::State state) {
   DCHECK(CalledOnValidThread());
   DCHECK(event_callback_);
 
   switch (state) {
     case Session::INITIALIZING:
     case Session::CONNECTING:
     case Session::ACCEPTING:
     case Session::CONNECTED:
     case Session::AUTHENTICATING:
       // Don't care about these events.
@@ skipping 41 matching lines @@
       if (state_ == CONNECTED && session_->error() == SIGNALING_TIMEOUT) {
         CloseChannels();
         SetState(CLOSED, OK);
       } else {
         CloseOnError(session_->error());
       }
       break;
   }
 }
 
-void ConnectionToHost::OnSessionRouteChange(const std::string& channel_name,
-                                            const TransportRoute& route) {
+void ConnectionToHostImpl::OnSessionRouteChange(const std::string& channel_name,
+                                                const TransportRoute& route) {
   event_callback_->OnRouteChanged(channel_name, route);
 }
 
-void ConnectionToHost::OnChannelInitialized(
+void ConnectionToHostImpl::OnChannelInitialized(
     ChannelDispatcherBase* channel_dispatcher) {
   NotifyIfChannelsReady();
 }
 
-void ConnectionToHost::OnChannelError(
+void ConnectionToHostImpl::OnChannelError(
     ChannelDispatcherBase* channel_dispatcher,
     ErrorCode error) {
   LOG(ERROR) << "Failed to connect channel " << channel_dispatcher;
   CloseOnError(CHANNEL_CONNECTION_ERROR);
   return;
 }
 
-void ConnectionToHost::OnVideoChannelStatus(bool active) {
+void ConnectionToHostImpl::OnVideoChannelStatus(bool active) {
   event_callback_->OnConnectionReady(active);
 }
 
-ConnectionToHost::State ConnectionToHost::state() const {
+ConnectionToHost::State ConnectionToHostImpl::state() const {
   return state_;
 }
 
-void ConnectionToHost::NotifyIfChannelsReady() {
+void ConnectionToHostImpl::NotifyIfChannelsReady() {
   if (!control_dispatcher_.get() || !control_dispatcher_->is_connected())
     return;
   if (!event_dispatcher_.get() || !event_dispatcher_->is_connected())
     return;
   if (!video_dispatcher_.get() || !video_dispatcher_->is_connected())
     return;
   if ((!audio_reader_.get() || !audio_reader_->is_connected()) &&
       session_->config().is_audio_enabled()) {
     return;
   }
   if (state_ != AUTHENTICATED)
     return;
 
   // Start forwarding clipboard and input events.
   clipboard_forwarder_.set_clipboard_stub(control_dispatcher_.get());
   event_forwarder_.set_input_stub(event_dispatcher_.get());
   SetState(CONNECTED, OK);
 }
 
-void ConnectionToHost::CloseOnError(ErrorCode error) {
+void ConnectionToHostImpl::CloseOnError(ErrorCode error) {
   CloseChannels();
   SetState(FAILED, error);
 }
 
-void ConnectionToHost::CloseChannels() {
+void ConnectionToHostImpl::CloseChannels() {
   control_dispatcher_.reset();
   event_dispatcher_.reset();
   clipboard_forwarder_.set_clipboard_stub(nullptr);
   event_forwarder_.set_input_stub(nullptr);
   video_dispatcher_.reset();
   audio_reader_.reset();
 }
 
-void ConnectionToHost::SetState(State state, ErrorCode error) {
+void ConnectionToHostImpl::SetState(State state, ErrorCode error) {
   DCHECK(CalledOnValidThread());
   // |error| should be specified only when |state| is set to FAILED.
   DCHECK(state == FAILED || error == OK);
 
   if (state != state_) {
     state_ = state;
     error_ = error;
     event_callback_->OnConnectionState(state_, error_);
   }
 }
 
 }  // namespace protocol
 }  // namespace remoting