Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(863)

Side by Side Diff: remoting/host/remoting_me2me_host.cc

Issue 320403002: Pull out common code from client and host versions of LogToServer (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix try failures Created 6 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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 // This file implements a standalone host process for Me2Me. 5 // This file implements a standalone host process for Me2Me.
6 6
7 #include <string> 7 #include <string>
8 8
9 #include "base/at_exit.h" 9 #include "base/at_exit.h"
10 #include "base/bind.h" 10 #include "base/bind.h"
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after
46 #include "remoting/host/config_watcher.h" 46 #include "remoting/host/config_watcher.h"
47 #include "remoting/host/desktop_environment.h" 47 #include "remoting/host/desktop_environment.h"
48 #include "remoting/host/desktop_session_connector.h" 48 #include "remoting/host/desktop_session_connector.h"
49 #include "remoting/host/dns_blackhole_checker.h" 49 #include "remoting/host/dns_blackhole_checker.h"
50 #include "remoting/host/heartbeat_sender.h" 50 #include "remoting/host/heartbeat_sender.h"
51 #include "remoting/host/host_change_notification_listener.h" 51 #include "remoting/host/host_change_notification_listener.h"
52 #include "remoting/host/host_config.h" 52 #include "remoting/host/host_config.h"
53 #include "remoting/host/host_event_logger.h" 53 #include "remoting/host/host_event_logger.h"
54 #include "remoting/host/host_exit_codes.h" 54 #include "remoting/host/host_exit_codes.h"
55 #include "remoting/host/host_main.h" 55 #include "remoting/host/host_main.h"
56 #include "remoting/host/host_status_logger.h"
56 #include "remoting/host/host_status_sender.h" 57 #include "remoting/host/host_status_sender.h"
57 #include "remoting/host/ipc_constants.h" 58 #include "remoting/host/ipc_constants.h"
58 #include "remoting/host/ipc_desktop_environment.h" 59 #include "remoting/host/ipc_desktop_environment.h"
59 #include "remoting/host/ipc_host_event_logger.h" 60 #include "remoting/host/ipc_host_event_logger.h"
60 #include "remoting/host/json_host_config.h" 61 #include "remoting/host/json_host_config.h"
61 #include "remoting/host/log_to_server.h"
62 #include "remoting/host/logging.h" 62 #include "remoting/host/logging.h"
63 #include "remoting/host/me2me_desktop_environment.h" 63 #include "remoting/host/me2me_desktop_environment.h"
64 #include "remoting/host/pairing_registry_delegate.h" 64 #include "remoting/host/pairing_registry_delegate.h"
65 #include "remoting/host/policy_hack/policy_watcher.h" 65 #include "remoting/host/policy_hack/policy_watcher.h"
66 #include "remoting/host/session_manager_factory.h" 66 #include "remoting/host/session_manager_factory.h"
67 #include "remoting/host/signaling_connector.h" 67 #include "remoting/host/signaling_connector.h"
68 #include "remoting/host/token_validator_factory_impl.h" 68 #include "remoting/host/token_validator_factory_impl.h"
69 #include "remoting/host/usage_stats_consent.h" 69 #include "remoting/host/usage_stats_consent.h"
70 #include "remoting/host/username.h" 70 #include "remoting/host/username.h"
71 #include "remoting/jingle_glue/network_settings.h" 71 #include "remoting/jingle_glue/network_settings.h"
(...skipping 229 matching lines...) Expand 10 before | Expand all | Expand 10 after
301 bool curtain_required_; 301 bool curtain_required_;
302 ThirdPartyAuthConfig third_party_auth_config_; 302 ThirdPartyAuthConfig third_party_auth_config_;
303 bool enable_gnubby_auth_; 303 bool enable_gnubby_auth_;
304 304
305 scoped_ptr<OAuthTokenGetter> oauth_token_getter_; 305 scoped_ptr<OAuthTokenGetter> oauth_token_getter_;
306 scoped_ptr<XmppSignalStrategy> signal_strategy_; 306 scoped_ptr<XmppSignalStrategy> signal_strategy_;
307 scoped_ptr<SignalingConnector> signaling_connector_; 307 scoped_ptr<SignalingConnector> signaling_connector_;
308 scoped_ptr<HeartbeatSender> heartbeat_sender_; 308 scoped_ptr<HeartbeatSender> heartbeat_sender_;
309 scoped_ptr<HostStatusSender> host_status_sender_; 309 scoped_ptr<HostStatusSender> host_status_sender_;
310 scoped_ptr<HostChangeNotificationListener> host_change_notification_listener_; 310 scoped_ptr<HostChangeNotificationListener> host_change_notification_listener_;
311 scoped_ptr<LogToServer> log_to_server_; 311 scoped_ptr<HostStatusLogger> host_status_logger_;
312 scoped_ptr<HostEventLogger> host_event_logger_; 312 scoped_ptr<HostEventLogger> host_event_logger_;
313 313
314 scoped_ptr<ChromotingHost> host_; 314 scoped_ptr<ChromotingHost> host_;
315 315
316 // Used to keep this HostProcess alive until it is shutdown. 316 // Used to keep this HostProcess alive until it is shutdown.
317 scoped_refptr<HostProcess> self_; 317 scoped_refptr<HostProcess> self_;
318 318
319 #if defined(REMOTING_MULTI_PROCESS) 319 #if defined(REMOTING_MULTI_PROCESS)
320 DesktopSessionConnector* desktop_session_connector_; 320 DesktopSessionConnector* desktop_session_connector_;
321 #endif // defined(REMOTING_MULTI_PROCESS) 321 #endif // defined(REMOTING_MULTI_PROCESS)
(...skipping 891 matching lines...) Expand 10 before | Expand all | Expand 10 after
1213 heartbeat_sender_.reset(new HeartbeatSender( 1213 heartbeat_sender_.reset(new HeartbeatSender(
1214 this, host_id_, signal_strategy_.get(), key_pair_, 1214 this, host_id_, signal_strategy_.get(), key_pair_,
1215 directory_bot_jid_)); 1215 directory_bot_jid_));
1216 1216
1217 host_status_sender_.reset(new HostStatusSender( 1217 host_status_sender_.reset(new HostStatusSender(
1218 host_id_, signal_strategy_.get(), key_pair_, directory_bot_jid_)); 1218 host_id_, signal_strategy_.get(), key_pair_, directory_bot_jid_));
1219 1219
1220 host_change_notification_listener_.reset(new HostChangeNotificationListener( 1220 host_change_notification_listener_.reset(new HostChangeNotificationListener(
1221 this, host_id_, signal_strategy_.get(), directory_bot_jid_)); 1221 this, host_id_, signal_strategy_.get(), directory_bot_jid_));
1222 1222
1223 log_to_server_.reset( 1223 host_status_logger_.reset(
1224 new LogToServer(host_->AsWeakPtr(), ServerLogEntry::ME2ME, 1224 new HostStatusLogger(host_->AsWeakPtr(), ServerLogEntry::ME2ME,
1225 signal_strategy_.get(), directory_bot_jid_)); 1225 signal_strategy_.get(), directory_bot_jid_));
1226 1226
1227 // Set up repoting the host status notifications. 1227 // Set up repoting the host status notifications.
1228 #if defined(REMOTING_MULTI_PROCESS) 1228 #if defined(REMOTING_MULTI_PROCESS)
1229 host_event_logger_.reset( 1229 host_event_logger_.reset(
1230 new IpcHostEventLogger(host_->AsWeakPtr(), daemon_channel_.get())); 1230 new IpcHostEventLogger(host_->AsWeakPtr(), daemon_channel_.get()));
1231 #else // !defined(REMOTING_MULTI_PROCESS) 1231 #else // !defined(REMOTING_MULTI_PROCESS)
1232 host_event_logger_ = 1232 host_event_logger_ =
1233 HostEventLogger::Create(host_->AsWeakPtr(), kApplicationName); 1233 HostEventLogger::Create(host_->AsWeakPtr(), kApplicationName);
1234 #endif // !defined(REMOTING_MULTI_PROCESS) 1234 #endif // !defined(REMOTING_MULTI_PROCESS)
1235 1235
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after
1287 FROM_HERE, 1287 FROM_HERE,
1288 base::Bind(&HostProcess::ShutdownOnNetworkThread, base::Unretained(this)), 1288 base::Bind(&HostProcess::ShutdownOnNetworkThread, base::Unretained(this)),
1289 base::TimeDelta::FromSeconds(2)); 1289 base::TimeDelta::FromSeconds(2));
1290 } 1290 }
1291 1291
1292 void HostProcess::ShutdownOnNetworkThread() { 1292 void HostProcess::ShutdownOnNetworkThread() {
1293 DCHECK(context_->network_task_runner()->BelongsToCurrentThread()); 1293 DCHECK(context_->network_task_runner()->BelongsToCurrentThread());
1294 1294
1295 host_.reset(); 1295 host_.reset();
1296 host_event_logger_.reset(); 1296 host_event_logger_.reset();
1297 log_to_server_.reset(); 1297 host_status_logger_.reset();
1298 heartbeat_sender_.reset(); 1298 heartbeat_sender_.reset();
1299 host_status_sender_.reset(); 1299 host_status_sender_.reset();
1300 host_change_notification_listener_.reset(); 1300 host_change_notification_listener_.reset();
1301 signaling_connector_.reset(); 1301 signaling_connector_.reset();
1302 oauth_token_getter_.reset(); 1302 oauth_token_getter_.reset();
1303 signal_strategy_.reset(); 1303 signal_strategy_.reset();
1304 network_change_notifier_.reset(); 1304 network_change_notifier_.reset();
1305 1305
1306 if (state_ == HOST_STOPPING_TO_RESTART) { 1306 if (state_ == HOST_STOPPING_TO_RESTART) {
1307 StartHost(); 1307 StartHost();
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after
1375 return exit_code; 1375 return exit_code;
1376 } 1376 }
1377 1377
1378 } // namespace remoting 1378 } // namespace remoting
1379 1379
1380 #if !defined(OS_WIN) 1380 #if !defined(OS_WIN)
1381 int main(int argc, char** argv) { 1381 int main(int argc, char** argv) {
1382 return remoting::HostMain(argc, argv); 1382 return remoting::HostMain(argc, argv);
1383 } 1383 }
1384 #endif // !defined(OS_WIN) 1384 #endif // !defined(OS_WIN)
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698