Revert "Connect UDP sockets. (#4270)"

This reverts commit d955af2.

net/socket/udp_socket_starboard.cc

@@ -162,7 +162,7 @@ int UDPSocketStarboard::GetLocalAddress(IPEndPoint* address) const {
 int UDPSocketStarboard::Read(IOBuffer* buf,
                              int buf_len,
                              CompletionOnceCallback callback) {
-  return RecvFrom(buf, buf_len, nullptr, std::move(callback));
+  return RecvFrom(buf, buf_len, NULL, std::move(callback));
 }
 
 int UDPSocketStarboard::RecvFrom(IOBuffer* buf,
@@ -206,7 +206,9 @@ int UDPSocketStarboard::Write(IOBuffer* buf,
                               int buf_len,
                               CompletionOnceCallback callback,
                               const NetworkTrafficAnnotationTag&) {
-  return SendToOrWrite(buf, buf_len, nullptr, std::move(callback));
+  DCHECK(remote_address_);
+  return SendToOrWrite(buf, buf_len, remote_address_.get(),
+                       std::move(callback));
 }
 
 int UDPSocketStarboard::SendTo(IOBuffer* buf,
@@ -269,29 +271,17 @@ int UDPSocketStarboard::InternalConnect(const IPEndPoint& address) {
   DCHECK(!remote_address_.get());
 
   int rv = 0;
-  if (bind_type_ == DatagramSocket::RANDOM_BIND) {
-    // Construct IPAddress of appropriate size (IPv4 or IPv6) of 0s,
-    // representing INADDR_ANY or in6addr_any.
-    rv = RandomBind(address.GetFamily() == ADDRESS_FAMILY_IPV4
-                        ? IPAddress::IPv4AllZeros()
-                        : IPAddress::IPv6AllZeros());
-  }
+  // Cobalt does random bind despite bind_type_ because we do not connect
+  // UDP sockets but Chromium does. And if a socket does recvfrom() without
+  // any sendto() before, it needs to be bound to have a local port.
+  rv = RandomBind(address.GetFamily() == ADDRESS_FAMILY_IPV4 ?
+                      IPAddress::IPv4AllZeros() : IPAddress::IPv6AllZeros());
 
   if (rv != OK)
     return rv;
 
-  SbSocketAddress storage;
-  if (!address.ToSbSocketAddress(&storage)) {
-    return ERR_ADDRESS_INVALID;
-  }
-
   remote_address_.reset(new IPEndPoint(address));
 
-  SbSocketError result = SbSocketConnect(socket_, &storage);
-  if (result != kSbSocketOk) {
-    return MapLastSocketError(socket_);
-  }
-
   return OK;
 }
 
@@ -469,16 +459,16 @@ int UDPSocketStarboard::InternalRecvFrom(IOBuffer* buf,
                                          int buf_len,
                                          IPEndPoint* address) {
   SbSocketAddress sb_address;
-  int bytes_transferred = SbSocketReceiveFrom(socket_, buf->data(), buf_len,
-                                              address ? &sb_address : nullptr);
+  int bytes_transferred =
+      SbSocketReceiveFrom(socket_, buf->data(), buf_len, &sb_address);
   int result;
   if (bytes_transferred >= 0) {
     result = bytes_transferred;
     // Passing in NULL address is allowed. This is only to align with other
     // platform's implementation.
     if (address && !address->FromSbSocketAddress(&sb_address)) {
       result = ERR_ADDRESS_INVALID;
-    } else if (bytes_transferred >= buf_len) {
+    } else if (bytes_transferred == buf_len) {
       result = ERR_MSG_TOO_BIG;
     }
   } else {
@@ -487,9 +477,8 @@ int UDPSocketStarboard::InternalRecvFrom(IOBuffer* buf,
 
   if (result != ERR_IO_PENDING) {
     IPEndPoint log_address;
-    if (result < 0 || !address ||
-        !log_address.FromSbSocketAddress(&sb_address)) {
-      LogRead(result, buf->data(), nullptr);
+    if (result < 0 || !log_address.FromSbSocketAddress(&sb_address)) {
+      LogRead(result, buf->data(), NULL);
     } else {
       LogRead(result, buf->data(), &log_address);
     }
@@ -502,25 +491,19 @@ int UDPSocketStarboard::InternalSendTo(IOBuffer* buf,
                                        int buf_len,
                                        const IPEndPoint* address) {
   SbSocketAddress sb_address;
-  if (address && !address->ToSbSocketAddress(&sb_address)) {
+  if (!address || !address->ToSbSocketAddress(&sb_address)) {
     int result = ERR_FAILED;
     LogWrite(result, NULL, NULL);
     return result;
   }
 
-  int result = SbSocketSendTo(socket_, buf->data(), buf_len,
-                              address ? &sb_address : nullptr);
+  int result = SbSocketSendTo(socket_, buf->data(), buf_len, &sb_address);
 
   if (result < 0)
     result = MapLastSocketError(socket_);
 
-  if (result != ERR_IO_PENDING) {
-    if (!address) {
-      LogWrite(result, buf->data(), nullptr);
-    } else {
-      LogWrite(result, buf->data(), address);
-    }
-  }
+  if (result != ERR_IO_PENDING)
+    LogWrite(result, buf->data(), address);
 
   return result;
 }

starboard/shared/posix/socket_send_to.cc

@@ -57,6 +57,12 @@ int SbSocketSendTo(SbSocket socket,
     socket->error = sbposix::TranslateSocketErrno(errno);
     return -1;
   } else if (socket->protocol == kSbSocketProtocolUdp) {
+    if (!destination) {
+      SB_LOG(FATAL) << "No destination passed to UDP send.";
+      socket->error = kSbSocketErrorFailed;
+      return -1;
+    }
+
     sbposix::SockAddr sock_addr;
     const sockaddr* sockaddr = NULL;
     socklen_t sockaddr_length = 0;