Add support for modifying TCP and UDP socket buffer size in nacl_io

native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc

 // Copyright 2013 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 "nacl_io/socket/udp_node.h"
 
 #include <errno.h>
 #include <string.h>
 
 #include <algorithm>
@@ skipping 176 matching lines @@
   if (!TestStreamFlags(SSF_CAN_SEND))
     return;
 
   if (TestStreamFlags(SSF_SENDING))
     return;
 
   UdpSendWork* work = new UdpSendWork(emitter_, ScopedSocketNode(this));
   stream()->EnqueueWork(work);
 }
 
+Error UdpNode::SetSockOpt(int lvl,
+                          int optname,
+                          const void* optval,
+                          socklen_t len) {
+  if (lvl == SOL_SOCKET && optname == SO_RCVBUF) {
+    if (static_cast<size_t>(len) < sizeof(int))
+      return EINVAL;
+    AUTO_LOCK(node_lock_);
+    int bufsize = *static_cast<const int*>(optval);
+    int32_t error =
+          UDPInterface()->SetOption(socket_resource_,
+                       PP_UDPSOCKET_OPTION_RECV_BUFFER_SIZE,
+                       PP_MakeInt32(bufsize),
+                       PP_BlockUntilComplete());
+    return PPErrorToErrno(error);
+  } else if (lvl == SOL_SOCKET && optname == SO_SNDBUF) {
+    if (static_cast<size_t>(len) < sizeof(int))
+      return EINVAL;
+    AUTO_LOCK(node_lock_);
+    int bufsize = *static_cast<const int*>(optval);
+    int32_t error =
+        UDPInterface()->SetOption(socket_resource_,
+                PP_UDPSOCKET_OPTION_SEND_BUFFER_SIZE,
+                PP_MakeInt32(bufsize),
+                PP_BlockUntilComplete());
+    return PPErrorToErrno(error);
+  }
+
+  return SocketNode::SetSockOpt(lvl, optname, optval, len);
+}
+
 Error UdpNode::Bind(const struct sockaddr* addr, socklen_t len) {
   if (0 == socket_resource_)
     return EBADF;
 
   /* Only bind once. */
   if (IsBound())
     return EINVAL;
 
   PP_Resource out_addr = SockAddrToResource(addr, len);
   if (0 == out_addr)
@@ skipping 84 matching lines @@
   int capped_len = static_cast<int32_t>(std::min<int>(len, kMaxPacketSize));
   Packet* packet = new Packet(filesystem_->ppapi());
   packet->Copy(buf, capped_len, addr);
 
   emitter_->WriteTXPacket_Locked(packet);
   *out_len = capped_len;
   return 0;
 }
 
 }  // namespace nacl_io