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

native_client_sdk/src/libraries/nacl_io/socket/tcp_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/ossocket.h"
 #ifdef PROVIDES_SOCKET_API
 
 #include <assert.h>
 #include <errno.h>
 #include <string.h>
@@ skipping 332 matching lines @@
 Error TcpNode::SetSockOpt(int lvl,
                           int optname,
                           const void* optval,
                           socklen_t len) {
   if (lvl == IPPROTO_TCP && optname == TCP_NODELAY) {
     if (static_cast<size_t>(len) < sizeof(int))
       return EINVAL;
     AUTO_LOCK(node_lock_);
     tcp_nodelay_ = *static_cast<const int*>(optval) != 0;
     return SetNoDelay_Locked();
+  } else 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 =
+        TCPInterface()->SetOption(socket_resource_,
+                                  PP_TCPSOCKET_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 =
+        TCPInterface()->SetOption(socket_resource_,
+                PP_TCPSOCKET_OPTION_SEND_BUFFER_SIZE,
+                PP_MakeInt32(bufsize),
+                PP_BlockUntilComplete());
+    return PPErrorToErrno(error);
   }
 
   return SocketNode::SetSockOpt(lvl, optname, optval, len);
 }
 
 void TcpNode::QueueAccept() {
   StreamFs::Work* work = new TCPAcceptWork(stream(), emitter_);
   stream()->EnqueueWork(work);
 }
 
@@ skipping 185 matching lines @@
   assert(emitter_.get());
   if (emitter_->GetError_Locked())
     return EPIPE;
   *out_len = emitter_->WriteOut_Locked((char*)buf, len);
   return 0;
 }
 
 }  // namespace nacl_io
 
 #endif  // PROVIDES_SOCKET_API