| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 // A standalone tool for testing MCS connections and the MCS client on their | 5 // A standalone tool for testing MCS connections and the MCS client on their |
| 6 // own. | 6 // own. |
| 7 | 7 |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | |
| 10 #include <cstddef> | 9 #include <cstddef> |
| 11 #include <cstdio> | 10 #include <cstdio> |
| 12 #include <string> | 11 #include <string> |
| 12 #include <utility> |
| 13 #include <vector> | 13 #include <vector> |
| 14 | 14 |
| 15 #include "base/at_exit.h" | 15 #include "base/at_exit.h" |
| 16 #include "base/command_line.h" | 16 #include "base/command_line.h" |
| 17 #include "base/compiler_specific.h" | 17 #include "base/compiler_specific.h" |
| 18 #include "base/files/scoped_file.h" | 18 #include "base/files/scoped_file.h" |
| 19 #include "base/logging.h" | 19 #include "base/logging.h" |
| 20 #include "base/memory/ref_counted.h" | 20 #include "base/memory/ref_counted.h" |
| 21 #include "base/memory/scoped_ptr.h" | 21 #include "base/memory/scoped_ptr.h" |
| 22 #include "base/message_loop/message_loop.h" | 22 #include "base/message_loop/message_loop.h" |
| (...skipping 326 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 349 secret_, | 349 secret_, |
| 350 base::Bind(&MCSProbe::UpdateCallback, | 350 base::Bind(&MCSProbe::UpdateCallback, |
| 351 base::Unretained(this))); | 351 base::Unretained(this))); |
| 352 } else { | 352 } else { |
| 353 android_id_ = load_result->device_android_id; | 353 android_id_ = load_result->device_android_id; |
| 354 secret_ = load_result->device_security_token; | 354 secret_ = load_result->device_security_token; |
| 355 DVLOG(1) << "Loaded MCS id " << android_id_; | 355 DVLOG(1) << "Loaded MCS id " << android_id_; |
| 356 } | 356 } |
| 357 mcs_client_->Initialize( | 357 mcs_client_->Initialize( |
| 358 base::Bind(&MCSProbe::ErrorCallback, base::Unretained(this)), | 358 base::Bind(&MCSProbe::ErrorCallback, base::Unretained(this)), |
| 359 base::Bind(&MessageReceivedCallback), | 359 base::Bind(&MessageReceivedCallback), base::Bind(&MessageSentCallback), |
| 360 base::Bind(&MessageSentCallback), | 360 std::move(load_result)); |
| 361 load_result.Pass()); | |
| 362 | 361 |
| 363 if (!android_id_ || !secret_) { | 362 if (!android_id_ || !secret_) { |
| 364 DVLOG(1) << "Checkin to generate new MCS credentials."; | 363 DVLOG(1) << "Checkin to generate new MCS credentials."; |
| 365 CheckIn(); | 364 CheckIn(); |
| 366 return; | 365 return; |
| 367 } | 366 } |
| 368 | 367 |
| 369 StartMCSLogin(); | 368 StartMCSLogin(); |
| 370 } | 369 } |
| 371 | 370 |
| 372 void MCSProbe::UpdateCallback(bool success) { | 371 void MCSProbe::UpdateCallback(bool success) { |
| 373 } | 372 } |
| 374 | 373 |
| 375 void MCSProbe::InitializeNetworkState() { | 374 void MCSProbe::InitializeNetworkState() { |
| 376 base::ScopedFILE log_file; | 375 base::ScopedFILE log_file; |
| 377 if (command_line_.HasSwitch(kLogFileSwitch)) { | 376 if (command_line_.HasSwitch(kLogFileSwitch)) { |
| 378 base::FilePath log_path = command_line_.GetSwitchValuePath(kLogFileSwitch); | 377 base::FilePath log_path = command_line_.GetSwitchValuePath(kLogFileSwitch); |
| 379 #if defined(OS_WIN) | 378 #if defined(OS_WIN) |
| 380 log_file.reset(_wfopen(log_path.value().c_str(), L"w")); | 379 log_file.reset(_wfopen(log_path.value().c_str(), L"w")); |
| 381 #elif defined(OS_POSIX) | 380 #elif defined(OS_POSIX) |
| 382 log_file.reset(fopen(log_path.value().c_str(), "w")); | 381 log_file.reset(fopen(log_path.value().c_str(), "w")); |
| 383 #endif | 382 #endif |
| 384 } | 383 } |
| 385 if (log_file.get()) { | 384 if (log_file.get()) { |
| 386 logger_.reset(new net::WriteToFileNetLogObserver()); | 385 logger_.reset(new net::WriteToFileNetLogObserver()); |
| 387 logger_->set_capture_mode( | 386 logger_->set_capture_mode( |
| 388 net::NetLogCaptureMode::IncludeCookiesAndCredentials()); | 387 net::NetLogCaptureMode::IncludeCookiesAndCredentials()); |
| 389 logger_->StartObserving(&net_log_, log_file.Pass(), nullptr, nullptr); | 388 logger_->StartObserving(&net_log_, std::move(log_file), nullptr, nullptr); |
| 390 } | 389 } |
| 391 | 390 |
| 392 host_resolver_ = net::HostResolver::CreateDefaultResolver(&net_log_); | 391 host_resolver_ = net::HostResolver::CreateDefaultResolver(&net_log_); |
| 393 | 392 |
| 394 if (command_line_.HasSwitch(kIgnoreCertSwitch)) { | 393 if (command_line_.HasSwitch(kIgnoreCertSwitch)) { |
| 395 cert_verifier_.reset(new MyTestCertVerifier()); | 394 cert_verifier_.reset(new MyTestCertVerifier()); |
| 396 } else { | 395 } else { |
| 397 cert_verifier_ = net::CertVerifier::CreateDefault(); | 396 cert_verifier_ = net::CertVerifier::CreateDefault(); |
| 398 } | 397 } |
| 399 system_channel_id_service_.reset( | 398 system_channel_id_service_.reset( |
| 400 new net::ChannelIDService( | 399 new net::ChannelIDService( |
| 401 new net::DefaultChannelIDStore(NULL), | 400 new net::DefaultChannelIDStore(NULL), |
| 402 base::WorkerPool::GetTaskRunner(true))); | 401 base::WorkerPool::GetTaskRunner(true))); |
| 403 | 402 |
| 404 transport_security_state_.reset(new net::TransportSecurityState()); | 403 transport_security_state_.reset(new net::TransportSecurityState()); |
| 405 http_auth_handler_factory_ = | 404 http_auth_handler_factory_ = net::HttpAuthHandlerRegistryFactory::Create( |
| 406 net::HttpAuthHandlerRegistryFactory::Create(&http_auth_preferences_, | 405 &http_auth_preferences_, host_resolver_.get()); |
| 407 host_resolver_.get()) | |
| 408 .Pass(); | |
| 409 http_server_properties_.reset(new net::HttpServerPropertiesImpl()); | 406 http_server_properties_.reset(new net::HttpServerPropertiesImpl()); |
| 410 host_mapping_rules_.reset(new net::HostMappingRules()); | 407 host_mapping_rules_.reset(new net::HostMappingRules()); |
| 411 proxy_service_ = net::ProxyService::CreateDirectWithNetLog(&net_log_); | 408 proxy_service_ = net::ProxyService::CreateDirectWithNetLog(&net_log_); |
| 412 } | 409 } |
| 413 | 410 |
| 414 void MCSProbe::BuildNetworkSession() { | 411 void MCSProbe::BuildNetworkSession() { |
| 415 net::HttpNetworkSession::Params session_params; | 412 net::HttpNetworkSession::Params session_params; |
| 416 session_params.host_resolver = host_resolver_.get(); | 413 session_params.host_resolver = host_resolver_.get(); |
| 417 session_params.cert_verifier = cert_verifier_.get(); | 414 session_params.cert_verifier = cert_verifier_.get(); |
| 418 session_params.channel_id_service = system_channel_id_service_.get(); | 415 session_params.channel_id_service = system_channel_id_service_.get(); |
| (...skipping 97 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 516 | 513 |
| 517 return 0; | 514 return 0; |
| 518 } | 515 } |
| 519 | 516 |
| 520 } // namespace | 517 } // namespace |
| 521 } // namespace gcm | 518 } // namespace gcm |
| 522 | 519 |
| 523 int main(int argc, char* argv[]) { | 520 int main(int argc, char* argv[]) { |
| 524 return gcm::MCSProbeMain(argc, argv); | 521 return gcm::MCSProbeMain(argc, argv); |
| 525 } | 522 } |
| OLD | NEW |