[Chromoting] Hook up host talkgadget policy checks.

remoting/host/chromoting_host.cc

 // Copyright (c) 2012 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/chromoting_host.h"
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/logging.h"
 #include "base/message_loop_proxy.h"
 #include "build/build_config.h"
+#include "googleurl/src/gurl.h"
 #include "remoting/base/constants.h"
 #include "remoting/base/encoder.h"
 #include "remoting/base/encoder_row_based.h"
 #include "remoting/base/encoder_vp8.h"
 #include "remoting/codec/audio_encoder.h"
 #include "remoting/codec/audio_encoder_verbatim.h"
 #include "remoting/host/audio_scheduler.h"
 #include "remoting/host/chromoting_host_context.h"
 #include "remoting/host/desktop_environment.h"
 #include "remoting/host/event_executor.h"
@@ skipping 281 matching lines @@
 void ChromotingHost::OnSessionRouteChange(
     ClientSession* session,
     const std::string& channel_name,
     const protocol::TransportRoute& route) {
   DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
   FOR_EACH_OBSERVER(HostStatusObserver, status_observers_,
                     OnClientRouteChange(session->client_jid(), channel_name,
                                         route));
 }
 
+// SessionManager::Listener implementation.
 void ChromotingHost::OnSessionManagerReady() {
   DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
   // Don't need to do anything here, just wait for incoming
   // connections.
 }
 
 void ChromotingHost::OnIncomingSession(
       protocol::Session* session,
       protocol::SessionManager::IncomingSessionResponse* response) {
   DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
@@ skipping 34 matching lines @@
   ClientSession* client = new ClientSession(
       this,
       connection.Pass(),
       desktop_environment_->event_executor(),
       desktop_environment_->event_executor(),
       desktop_environment_->capturer(),
       max_session_duration_);
   clients_.push_back(client);
 }
 
-void ChromotingHost::set_protocol_config(
-    protocol::CandidateSessionConfig* config) {
-  DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
-  DCHECK(config);
-  DCHECK_EQ(state_, kInitial);
-  protocol_config_.reset(config);
-}
-
+// MouseMoveObserver interface.
 void ChromotingHost::OnLocalMouseMoved(const SkIPoint& new_pos) {
   if (!context_->network_task_runner()->BelongsToCurrentThread()) {
     context_->network_task_runner()->PostTask(
         FROM_HERE, base::Bind(&ChromotingHost::OnLocalMouseMoved,
                               this, new_pos));
     return;
   }
 
   ClientList::iterator client;
   for (client = clients_.begin(); client != clients_.end(); ++client) {
     (*client)->LocalMouseMoved(new_pos);
   }
 }
 
+void ChromotingHost::set_protocol_config(
+    protocol::CandidateSessionConfig* config) {
+  DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
+  DCHECK(config);
+  DCHECK_EQ(state_, kInitial);
+  protocol_config_.reset(config);
+}
+
 void ChromotingHost::PauseSession(bool pause) {
   if (!context_->network_task_runner()->BelongsToCurrentThread()) {
     context_->network_task_runner()->PostTask(
         FROM_HERE, base::Bind(&ChromotingHost::PauseSession, this, pause));
     return;
   }
 
   ClientList::iterator client;
   for (client = clients_.begin(); client != clients_.end(); ++client) {
     (*client)->SetDisableInputs(pause);
@@ skipping 99 matching lines @@
                     OnShutdown());
 
   for (std::vector<base::Closure>::iterator it = shutdown_tasks_.begin();
        it != shutdown_tasks_.end(); ++it) {
     it->Run();
   }
   shutdown_tasks_.clear();
 }
 
 }  // namespace remoting