| OLD | NEW | 
|    1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |    1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 
|    2 // Use of this source code is governed by a BSD-style license that can be |    2 // Use of this source code is governed by a BSD-style license that can be | 
|    3 // found in the LICENSE file. |    3 // found in the LICENSE file. | 
|    4  |    4  | 
|    5 #include "remoting/host/chromoting_host.h" |    5 #include "remoting/host/chromoting_host.h" | 
|    6  |    6  | 
|    7 #include "base/bind.h" |    7 #include "base/bind.h" | 
|    8 #include "base/callback.h" |    8 #include "base/callback.h" | 
|    9 #include "base/logging.h" |    9 #include "base/logging.h" | 
|   10 #include "base/message_loop_proxy.h" |   10 #include "base/message_loop_proxy.h" | 
| (...skipping 207 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  218   } |  218   } | 
|  219 } |  219 } | 
|  220  |  220  | 
|  221 void ChromotingHost::OnSessionSequenceNumber(ClientSession* session, |  221 void ChromotingHost::OnSessionSequenceNumber(ClientSession* session, | 
|  222                                              int64 sequence_number) { |  222                                              int64 sequence_number) { | 
|  223   DCHECK(context_->network_message_loop()->BelongsToCurrentThread()); |  223   DCHECK(context_->network_message_loop()->BelongsToCurrentThread()); | 
|  224   if (recorder_.get()) |  224   if (recorder_.get()) | 
|  225     recorder_->UpdateSequenceNumber(sequence_number); |  225     recorder_->UpdateSequenceNumber(sequence_number); | 
|  226 } |  226 } | 
|  227  |  227  | 
 |  228 void ChromotingHost::OnSessionIpEndPoint(ClientSession* session, | 
 |  229                                          const std::string& channel_name, | 
 |  230                                          const net::IPEndPoint& end_point) { | 
 |  231   // TODO(lambroslambrou): Notify the HostStatusObservers via a new interface | 
 |  232   // method. | 
 |  233 } | 
 |  234  | 
|  228 void ChromotingHost::OnSessionManagerReady() { |  235 void ChromotingHost::OnSessionManagerReady() { | 
|  229   DCHECK(context_->network_message_loop()->BelongsToCurrentThread()); |  236   DCHECK(context_->network_message_loop()->BelongsToCurrentThread()); | 
|  230   // Don't need to do anything here, just wait for incoming |  237   // Don't need to do anything here, just wait for incoming | 
|  231   // connections. |  238   // connections. | 
|  232 } |  239 } | 
|  233  |  240  | 
|  234 void ChromotingHost::OnIncomingSession( |  241 void ChromotingHost::OnIncomingSession( | 
|  235       protocol::Session* session, |  242       protocol::Session* session, | 
|  236       protocol::SessionManager::IncomingSessionResponse* response) { |  243       protocol::SessionManager::IncomingSessionResponse* response) { | 
|  237   DCHECK(context_->network_message_loop()->BelongsToCurrentThread()); |  244   DCHECK(context_->network_message_loop()->BelongsToCurrentThread()); | 
| (...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  360                     OnShutdown()); |  367                     OnShutdown()); | 
|  361  |  368  | 
|  362   for (std::vector<base::Closure>::iterator it = shutdown_tasks_.begin(); |  369   for (std::vector<base::Closure>::iterator it = shutdown_tasks_.begin(); | 
|  363        it != shutdown_tasks_.end(); ++it) { |  370        it != shutdown_tasks_.end(); ++it) { | 
|  364     it->Run(); |  371     it->Run(); | 
|  365   } |  372   } | 
|  366   shutdown_tasks_.clear(); |  373   shutdown_tasks_.clear(); | 
|  367 } |  374 } | 
|  368  |  375  | 
|  369 }  // namespace remoting |  376 }  // namespace remoting | 
| OLD | NEW |