Add TCP configuration parameters for Transport API.

webkit/plugins/ppapi/ppb_transport_impl.cc

 // Copyright (c) 2011 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 "webkit/plugins/ppapi/ppb_transport_impl.h"
 
 #include "base/message_loop.h"
 #include "base/string_util.h"
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
@@ skipping 15 matching lines @@
 namespace webkit {
 namespace ppapi {
 
 namespace {
 
 const char kUdpProtocolName[] = "udp";
 const char kTcpProtocolName[] = "tcp";
 
 const int kMinBufferSize = 1024;
 const int kMaxBufferSize = 1024 * 1024;
+const int kMinAckDelay = 10;
+const int kMaxAckDelay = 1000;
 
 int MapNetError(int result) {
   if (result > 0)
     return result;
 
   switch (result) {
     case net::OK:
       return PP_OK;
     case net::ERR_IO_PENDING:
       return PP_OK_COMPLETIONPENDING;
@@ skipping 117 matching lines @@
 
       int32_t int_value = value.value.as_int;
       if (value.type != PP_VARTYPE_INT32 || int_value < kMinBufferSize ||
           int_value > kMaxBufferSize) {
         return PP_ERROR_BADARGUMENT;
       }
       config_.tcp_send_window = int_value;
       break;
     }
 
+    case PP_TRANSPORTPROPERTY_TCP_NO_DELAY: {
+      if (!use_tcp_)
+        return PP_ERROR_BADARGUMENT;
+
+      if (value.type != PP_VARTYPE_BOOL)
+        return PP_ERROR_BADARGUMENT;
+      config_.tcp_no_delay = PP_ToBool(value.value.as_bool);
+      break;
+    }
+
+    case PP_TRANSPORTPROPERTY_TCP_ACK_DELAY: {
+      if (!use_tcp_)
+        return PP_ERROR_BADARGUMENT;
+
+      int32_t int_value = value.value.as_int;
+      if (value.type != PP_VARTYPE_INT32 || int_value < kMinAckDelay ||
+          int_value > kMaxAckDelay) {
+        return PP_ERROR_BADARGUMENT;
+      }
+      config_.tcp_ack_delay_ms = int_value;
+      break;
+    }
+
     default:
       return PP_ERROR_BADARGUMENT;
   }
 
   return PP_OK;
 }
 
 int32_t PPB_Transport_Impl::Connect(PP_CompletionCallback callback) {
   if (!p2p_transport_.get())
     return PP_ERROR_FAILED;
@@ skipping 109 matching lines @@
 
   return result;
 }
 
 int32_t PPB_Transport_Impl::Close() {
   if (!p2p_transport_.get())
     return PP_ERROR_FAILED;
 
   p2p_transport_.reset();
 
-
   PluginModule* plugin_module = ResourceHelper::GetPluginModule(this);
   if (plugin_module)
     plugin_module->GetCallbackTracker()->AbortAll();
   return PP_OK;
 }
 
 void PPB_Transport_Impl::OnCandidateReady(const std::string& address) {
   // Store the candidate first before calling the callback.
   local_candidates_.push_back(address);
 
@@ skipping 33 matching lines @@
 void PPB_Transport_Impl::OnWritten(int result) {
   DCHECK(send_callback_.get() && !send_callback_->completed());
 
   scoped_refptr<TrackedCompletionCallback> callback;
   callback.swap(send_callback_);
   callback->Run(MapNetError(result));
 }
 
 }  // namespace ppapi
 }  // namespace webkit