| Index: remoting/protocol/jingle_stream_connector.cc
|
| diff --git a/remoting/protocol/jingle_stream_connector.cc b/remoting/protocol/jingle_stream_connector.cc
|
| index f953a541aa9c1dd25552f4b265de09b5e94fc42e..44cc3c526bb047bd4bf22601a456e452f805ab90 100644
|
| --- a/remoting/protocol/jingle_stream_connector.cc
|
| +++ b/remoting/protocol/jingle_stream_connector.cc
|
| @@ -72,8 +72,6 @@ JingleStreamConnector::JingleStreamConnector(
|
| initiator_(false),
|
| local_private_key_(NULL),
|
| raw_channel_(NULL),
|
| - ssl_client_socket_(NULL),
|
| - ssl_server_socket_(NULL),
|
| ALLOW_THIS_IN_INITIALIZER_LIST(tcp_connect_callback_(
|
| this, &JingleStreamConnector::OnTCPConnect)),
|
| ALLOW_THIS_IN_INITIALIZER_LIST(ssl_connect_callback_(
|
| @@ -122,8 +120,8 @@ bool JingleStreamConnector::EstablishTCPConnection(net::Socket* socket) {
|
| adapter->SetReceiveBufferSize(kTcpReceiveBufferSize);
|
| adapter->SetSendBufferSize(kTcpSendBufferSize);
|
|
|
| - socket_.reset(adapter);
|
| - int result = socket_->Connect(&tcp_connect_callback_);
|
| + tcp_socket_.reset(adapter);
|
| + int result = tcp_socket_->Connect(&tcp_connect_callback_);
|
| if (result == net::ERR_IO_PENDING) {
|
| return true;
|
| } else if (result == net::OK) {
|
| @@ -135,18 +133,18 @@ bool JingleStreamConnector::EstablishTCPConnection(net::Socket* socket) {
|
| }
|
|
|
| bool JingleStreamConnector::EstablishSSLConnection() {
|
| - DCHECK(socket_->IsConnected());
|
| + DCHECK(tcp_socket_->IsConnected());
|
|
|
| int result;
|
| if (initiator_) {
|
| cert_verifier_.reset(new net::CertVerifier());
|
|
|
| // Create client SSL socket.
|
| - ssl_client_socket_ = CreateSSLClientSocket(
|
| - socket_.release(), remote_cert_, cert_verifier_.get());
|
| - socket_.reset(ssl_client_socket_);
|
| + net::SSLClientSocket* socket = CreateSSLClientSocket(
|
| + tcp_socket_.release(), remote_cert_, cert_verifier_.get());
|
| + socket_.reset(socket);
|
|
|
| - result = ssl_client_socket_->Connect(&ssl_connect_callback_);
|
| + result = socket->Connect(&ssl_connect_callback_);
|
| } else {
|
| scoped_refptr<net::X509Certificate> cert =
|
| net::X509Certificate::CreateFromBytes(
|
| @@ -158,11 +156,11 @@ bool JingleStreamConnector::EstablishSSLConnection() {
|
|
|
| // Create server SSL socket.
|
| net::SSLConfig ssl_config;
|
| - ssl_server_socket_ = net::CreateSSLServerSocket(
|
| - socket_.release(), cert, local_private_key_, ssl_config);
|
| - socket_.reset(ssl_server_socket_);
|
| + net::SSLServerSocket* socket = net::CreateSSLServerSocket(
|
| + tcp_socket_.release(), cert, local_private_key_, ssl_config);
|
| + socket_.reset(socket);
|
|
|
| - result = ssl_server_socket_->Handshake(&ssl_connect_callback_);
|
| + result = socket->Handshake(&ssl_connect_callback_);
|
| }
|
|
|
| if (result == net::ERR_IO_PENDING) {
|
| @@ -205,15 +203,14 @@ void JingleStreamConnector::OnSSLConnect(int result) {
|
|
|
| void JingleStreamConnector::AuthenticateChannel() {
|
| if (initiator_) {
|
| - authenticator_.reset(new ClientChannelAuthenticator(ssl_client_socket_));
|
| + authenticator_.reset(
|
| + new ClientChannelAuthenticator(session_->shared_secret()));
|
| } else {
|
| - authenticator_.reset(new HostChannelAuthenticator(ssl_server_socket_));
|
| + authenticator_.reset(
|
| + new HostChannelAuthenticator(session_->shared_secret()));
|
| }
|
| -
|
| - authenticator_->Authenticate(
|
| - session_->shared_secret(),
|
| - base::Bind(&JingleStreamConnector::OnAuthenticationDone,
|
| - base::Unretained(this)));
|
| + authenticator_->Authenticate(socket_.get(), base::Bind(
|
| + &JingleStreamConnector::OnAuthenticationDone, base::Unretained(this)));
|
| }
|
|
|
| void JingleStreamConnector::OnAuthenticationDone(
|
|
|