Revert 158940 - Adapt python scripts to use the new Forwarder2

tools/android/forwarder2/socket.cc

Index: tools/android/forwarder2/socket.cc
===================================================================
--- tools/android/forwarder2/socket.cc	(revision 158959)
+++ tools/android/forwarder2/socket.cc	(working copy)
@@ -36,10 +36,6 @@
 namespace {
 const int kNoTimeout = -1;
 const int kConnectTimeOut = 10;  // Seconds.
-
-bool FamilyIsTCP(int family) {
-  return family == AF_INET || family == AF_INET6;
-}
 }  // namespace
 
 namespace forwarder2 {
@@ -133,6 +129,7 @@
   abstract_ = abstract;
   family_ = PF_UNIX;
   addr_.addr_un.sun_family = family_;
+
   if (abstract) {
     // Copied from net/base/unix_domain_socket_posix.cc
     // Convert the path given into abstract socket name. It must start with
@@ -146,12 +143,14 @@
     memcpy(addr_.addr_un.sun_path, path.c_str(), path.size());
     addr_len_ = sizeof(sockaddr_un);
   }
+
   addr_ptr_ = reinterpret_cast<sockaddr*>(&addr_.addr_un);
   return InitSocketInternal();
 }
 
 bool Socket::InitTcpSocket(const std::string& host, int port) {
   port_ = port;
+
   if (host.empty()) {
     // Use localhost: INADDR_LOOPBACK
     family_ = AF_INET;
@@ -160,7 +159,8 @@
   } else if (!Resolve(host)) {
     return false;
   }
-  CHECK(FamilyIsTCP(family_)) << "Invalid socket family.";
+  CHECK(family_ == AF_INET || family_ == AF_INET6)
+      << "Invalid socket family.";
   if (family_ == AF_INET) {
     addr_.addr4.sin_port = htons(port_);
     addr_ptr_ = reinterpret_cast<sockaddr*>(&addr_.addr4);
@@ -180,7 +180,7 @@
     SetSocketError();
     return false;
   }
-  if (port_ == 0 && FamilyIsTCP(family_)) {
+  if (port_ == 0) {
     SockAddr addr;
     memset(&addr, 0, sizeof(addr));
     socklen_t addrlen = 0;
@@ -225,25 +225,19 @@
 }
 
 bool Socket::Connect() {
-  // Set non-block because we use select for connect.
-  const int flags = fcntl(socket_, F_GETFL);
-  DCHECK(!(flags & O_NONBLOCK));
-  fcntl(socket_, F_SETFL, flags | O_NONBLOCK);
+  // Set non-block because we use select.
+  fcntl(socket_, F_SETFL, fcntl(socket_, F_GETFL) | O_NONBLOCK);
   errno = 0;
   if (HANDLE_EINTR(connect(socket_, addr_ptr_, addr_len_)) < 0 &&
       errno != EINPROGRESS) {
     SetSocketError();
-    PRESERVE_ERRNO_HANDLE_EINTR(fcntl(socket_, F_SETFL, flags));
     return false;
   }
   // Wait for connection to complete, or receive a notification.
   if (!WaitForEvent(WRITE, kConnectTimeOut)) {
     SetSocketError();
-    PRESERVE_ERRNO_HANDLE_EINTR(fcntl(socket_, F_SETFL, flags));
     return false;
   }
-  // Disable non-block since our code assumes blocking semantics.
-  fcntl(socket_, F_SETFL, flags);
   return true;
 }
 
@@ -277,7 +271,7 @@
 }
 
 int Socket::GetPort() {
-  if (!FamilyIsTCP(family_)) {
+  if (family_ != AF_INET && family_ != AF_INET6) {
     LOG(ERROR) << "Can't call GetPort() on an unix domain socket.";
     return 0;
   }