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

Unified Diff: remoting/protocol/jingle_session.cc

Issue 1984383003: Support LCS signaling address in the Host. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Add DCHECK Created 4 years, 7 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « remoting/protocol/jingle_session.h ('k') | remoting/protocol/jingle_session_manager.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: remoting/protocol/jingle_session.cc
diff --git a/remoting/protocol/jingle_session.cc b/remoting/protocol/jingle_session.cc
index ba523000e7cf9fcf1320d295dec8f71e0dc44e3f..93ae815bb4be2bf485f5d5da066c4e23eca5b2a9 100644
--- a/remoting/protocol/jingle_session.cc
+++ b/remoting/protocol/jingle_session.cc
@@ -96,7 +96,7 @@ void JingleSession::StartConnection(
DCHECK(authenticator.get());
DCHECK_EQ(authenticator->state(), Authenticator::MESSAGE_READY);
- peer_jid_ = peer_jid;
+ peer_address_ = SignalingAddress(peer_jid);
authenticator_ = std::move(authenticator);
// Generate random session ID. There are usually not more than 1
@@ -107,7 +107,7 @@ void JingleSession::StartConnection(
base::RandGenerator(std::numeric_limits<uint64_t>::max()));
// Send session-initiate message.
- JingleMessage message(peer_jid_, JingleMessage::SESSION_INITIATE,
+ JingleMessage message(peer_address_, JingleMessage::SESSION_INITIATE,
session_id_);
message.initiator = session_manager_->signal_strategy_->GetLocalJid();
message.description.reset(new ContentDescription(
@@ -126,7 +126,7 @@ void JingleSession::InitializeIncomingConnection(
DCHECK(authenticator.get());
DCHECK_EQ(authenticator->state(), Authenticator::WAITING_MESSAGE);
- peer_jid_ = initiate_message.from;
+ peer_address_ = initiate_message.from;
authenticator_ = std::move(authenticator);
session_id_ = initiate_message.sid;
@@ -136,7 +136,7 @@ void JingleSession::InitializeIncomingConnection(
SessionConfig::SelectCommon(initiate_message.description->config(),
session_manager_->protocol_config_.get());
if (!config_) {
- LOG(WARNING) << "Rejecting connection from " << peer_jid_
+ LOG(WARNING) << "Rejecting connection from " << peer_address_.id()
<< " because no compatible configuration has been found.";
Close(INCOMPATIBLE_PROTOCOL);
return;
@@ -171,7 +171,7 @@ void JingleSession::ContinueAcceptIncomingConnection() {
}
// Send the session-accept message.
- JingleMessage message(peer_jid_, JingleMessage::SESSION_ACCEPT,
+ JingleMessage message(peer_address_, JingleMessage::SESSION_ACCEPT,
session_id_);
std::unique_ptr<buzz::XmlElement> auth_message;
@@ -197,7 +197,7 @@ void JingleSession::ContinueAcceptIncomingConnection() {
const std::string& JingleSession::jid() {
DCHECK(thread_checker_.CalledOnValidThread());
- return peer_jid_;
+ return peer_address_.id();
}
const SessionConfig& JingleSession::config() {
@@ -217,7 +217,8 @@ void JingleSession::SendTransportInfo(
DCHECK(thread_checker_.CalledOnValidThread());
DCHECK_EQ(state_, AUTHENTICATED);
- JingleMessage message(peer_jid_, JingleMessage::TRANSPORT_INFO, session_id_);
+ JingleMessage message(peer_address_, JingleMessage::TRANSPORT_INFO,
+ session_id_);
message.transport_info = std::move(transport_info);
std::unique_ptr<IqRequest> request = session_manager_->iq_sender()->SendIq(
@@ -261,7 +262,7 @@ void JingleSession::Close(protocol::ErrorCode error) {
reason = JingleMessage::GENERAL_ERROR;
}
- JingleMessage message(peer_jid_, JingleMessage::SESSION_TERMINATE,
+ JingleMessage message(peer_address_, JingleMessage::SESSION_TERMINATE,
session_id_);
message.reason = reason;
SendMessage(message);
@@ -370,7 +371,7 @@ void JingleSession::OnIncomingMessage(const JingleMessage& message,
const ReplyCallback& reply_callback) {
DCHECK(thread_checker_.CalledOnValidThread());
- if (message.from != peer_jid_) {
+ if (peer_address_ != message.from) {
// Ignore messages received from a different Jid.
reply_callback.Run(JingleMessageReply::INVALID_SID);
return;
@@ -538,7 +539,8 @@ void JingleSession::ProcessAuthenticationStep() {
}
if (authenticator_->state() == Authenticator::MESSAGE_READY) {
- JingleMessage message(peer_jid_, JingleMessage::SESSION_INFO, session_id_);
+ JingleMessage message(peer_address_, JingleMessage::SESSION_INFO,
+ session_id_);
message.info = authenticator_->GetNextMessage();
DCHECK(message.info.get());
SendMessage(message);
« no previous file with comments | « remoting/protocol/jingle_session.h ('k') | remoting/protocol/jingle_session_manager.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698