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

Side by Side Diff: remoting/signaling/xmpp_signal_strategy.cc

Issue 1197853003: Add P2PDatagramSocket and P2PStreamSocket interfaces. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 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
OLDNEW
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
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
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
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
OLDNEW
« remoting/protocol/p2p_datagram_socket.h ('K') | « remoting/remoting_test.gypi ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698