Really connect to the same server in FTP network transaction.

chrome/browser/sync/notifier/communicator/ssl_socket_adapter.cc

 // Copyright (c) 2009 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/sync/notifier/communicator/ssl_socket_adapter.h"
 
 #include "base/compiler_specific.h"
 #include "base/message_loop.h"
 #include "chrome/browser/net/url_request_context_getter.h"
 #include "chrome/browser/profile.h"
+#include "net/base/address_list.h"
 #include "net/base/net_errors.h"
 #include "net/base/ssl_config_service.h"
+#include "net/base/sys_addrinfo.h"
 #include "net/socket/client_socket_factory.h"
 #include "net/url_request/url_request_context.h"
 
 namespace notifier {
 
 namespace {
 
 // Convert values from <errno.h> to values from "net/base/net_errors.h"
 int MapPosixError(int err) {
   // There are numerous posix error codes, but these are the ones we thus far
@@ skipping 224 matching lines @@
 bool TransportSocket::IsConnected() const {
   return (socket_->GetState() == talk_base::Socket::CS_CONNECTED);
 }
 
 bool TransportSocket::IsConnectedAndIdle() const {
   // Not implemented.
   NOTREACHED();
   return false;
 }
 
-int TransportSocket::GetPeerName(struct sockaddr* name, socklen_t* namelen) {
-  talk_base::SocketAddress address = socket_->GetRemoteAddress();
-  address.ToSockAddr(reinterpret_cast<sockaddr_in *>(name));
-  return 0;
+int TransportSocket::GetPeerAddress(net::AddressList* address) const {
+  talk_base::SocketAddress socket_address = socket_->GetRemoteAddress();
+
+  // libjingle supports only IPv4 addresses.
+  sockaddr_in ipv4addr;
+  socket_address.ToSockAddr(&ipv4addr);
+
+  struct addrinfo ai;
+  memset(&ai, sizeof(ai), 0);
+  ai.ai_family = ipv4addr.sin_family;
+  ai.ai_socktype = SOCK_STREAM;
+  ai.ai_protocol = IPPROTO_TCP;
+  ai.ai_addr = reinterpret_cast<struct sockaddr*>(&ipv4addr);
+  ai.ai_addrlen = sizeof(ipv4addr);
+
+  address->Copy(&ai, false);
+  return net::OK;
 }
 
 int TransportSocket::Read(net::IOBuffer* buf, int buf_len,
                           net::CompletionCallback* callback) {
   DCHECK(buf);
   DCHECK(!read_callback_);
   DCHECK(!read_buffer_.get());
   int result = socket_->Recv(buf->data(), buf_len);
   if (result < 0) {
     result = MapPosixError(socket_->GetError());
@@ skipping 91 matching lines @@
       }
     }
     callback->RunWithParams(Tuple1<int>(result));
     return true;
   } else {
     return false;
   }
 }
 
 }  // namespace notifier