OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/signaling/xmpp_signal_strategy.h" | 5 #include "remoting/signaling/xmpp_signal_strategy.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/location.h" | 10 #include "base/location.h" |
(...skipping 345 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
356 | 356 |
357 void XmppSignalStrategy::Core::OnSocketConnected(int result) { | 357 void XmppSignalStrategy::Core::OnSocketConnected(int result) { |
358 DCHECK(thread_checker_.CalledOnValidThread()); | 358 DCHECK(thread_checker_.CalledOnValidThread()); |
359 | 359 |
360 if (result != net::OK) { | 360 if (result != net::OK) { |
361 OnNetworkError(result); | 361 OnNetworkError(result); |
362 return; | 362 return; |
363 } | 363 } |
364 | 364 |
365 writer_.reset(new BufferedSocketWriter()); | 365 writer_.reset(new BufferedSocketWriter()); |
366 writer_->Init(socket_.get(), base::Bind(&Core::OnNetworkError, | 366 writer_->Init( |
367 base::Unretained(this))); | 367 base::Bind(&net::Socket::Write, base::Unretained(socket_.get())), |
| 368 base::Bind(&Core::OnNetworkError, base::Unretained(this))); |
368 | 369 |
369 XmppLoginHandler::TlsMode tls_mode; | 370 XmppLoginHandler::TlsMode tls_mode; |
370 if (xmpp_server_config_.use_tls) { | 371 if (xmpp_server_config_.use_tls) { |
371 tls_mode = (xmpp_server_config_.port == kDefaultXmppPort) | 372 tls_mode = (xmpp_server_config_.port == kDefaultXmppPort) |
372 ? XmppLoginHandler::TlsMode::WITH_HANDSHAKE | 373 ? XmppLoginHandler::TlsMode::WITH_HANDSHAKE |
373 : XmppLoginHandler::TlsMode::WITHOUT_HANDSHAKE; | 374 : XmppLoginHandler::TlsMode::WITHOUT_HANDSHAKE; |
374 } else { | 375 } else { |
375 tls_mode = XmppLoginHandler::TlsMode::NO_TLS; | 376 tls_mode = XmppLoginHandler::TlsMode::NO_TLS; |
376 } | 377 } |
377 | 378 |
(...skipping 22 matching lines...) Expand all Loading... |
400 DCHECK(thread_checker_.CalledOnValidThread()); | 401 DCHECK(thread_checker_.CalledOnValidThread()); |
401 DCHECK(tls_state_ == TlsState::CONNECTING); | 402 DCHECK(tls_state_ == TlsState::CONNECTING); |
402 tls_state_ = TlsState::CONNECTED; | 403 tls_state_ = TlsState::CONNECTED; |
403 | 404 |
404 if (result != net::OK) { | 405 if (result != net::OK) { |
405 OnNetworkError(result); | 406 OnNetworkError(result); |
406 return; | 407 return; |
407 } | 408 } |
408 | 409 |
409 writer_.reset(new BufferedSocketWriter()); | 410 writer_.reset(new BufferedSocketWriter()); |
410 writer_->Init(socket_.get(), base::Bind(&Core::OnNetworkError, | 411 writer_->Init( |
411 base::Unretained(this))); | 412 base::Bind(&net::Socket::Write, base::Unretained(socket_.get())), |
| 413 base::Bind(&Core::OnNetworkError, base::Unretained(this))); |
412 | 414 |
413 login_handler_->OnTlsStarted(); | 415 login_handler_->OnTlsStarted(); |
414 | 416 |
415 ReadSocket(); | 417 ReadSocket(); |
416 } | 418 } |
417 | 419 |
418 void XmppSignalStrategy::Core::ReadSocket() { | 420 void XmppSignalStrategy::Core::ReadSocket() { |
419 DCHECK(thread_checker_.CalledOnValidThread()); | 421 DCHECK(thread_checker_.CalledOnValidThread()); |
420 | 422 |
421 while (socket_ && !read_pending_ && (tls_state_ == TlsState::NOT_REQUESTED || | 423 while (socket_ && !read_pending_ && (tls_state_ == TlsState::NOT_REQUESTED || |
(...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
527 std::string XmppSignalStrategy::GetNextId() { | 529 std::string XmppSignalStrategy::GetNextId() { |
528 return base::Uint64ToString(base::RandUint64()); | 530 return base::Uint64ToString(base::RandUint64()); |
529 } | 531 } |
530 | 532 |
531 void XmppSignalStrategy::SetAuthInfo(const std::string& username, | 533 void XmppSignalStrategy::SetAuthInfo(const std::string& username, |
532 const std::string& auth_token) { | 534 const std::string& auth_token) { |
533 core_->SetAuthInfo(username, auth_token); | 535 core_->SetAuthInfo(username, auth_token); |
534 } | 536 } |
535 | 537 |
536 } // namespace remoting | 538 } // namespace remoting |
OLD | NEW |