Change TCPListenSocket::SendInternal to use a non-blocking implementation.

net/base/tcp_listen_socket.h

 // Copyright (c) 2012 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.
 
 // TCP/IP server that handles IO asynchronously in the specified MessageLoop.
 // These objects are NOT thread safe.  They use WSAEVENT handles to monitor
 // activity in a given MessageLoop.  This means that callbacks will
 // happen in that loop's thread always and that all other methods (including
 // constructors and destructors) should also be called from the same thread.
 
 #ifndef NET_BASE_TCP_LISTEN_SOCKET_H_
 #define NET_BASE_TCP_LISTEN_SOCKET_H_
 #pragma once
 
+#include <vector>
+
 #include "build/build_config.h"
 
 #if defined(OS_WIN)
 #include <winsock2.h>
 #endif
 #include <string>
 #if defined(OS_WIN)
 #include "base/win/object_watcher.h"
 #elif defined(OS_POSIX)
 #include "base/message_loop.h"
 #endif
 
 #include "base/basictypes.h"
 #include "base/compiler_specific.h"
+#include "base/memory/ref_counted.h"
+#include "base/timer.h"
+#include "net/base/backoff_entry.h"
+#include "net/base/io_buffer.h"
 #include "net/base/listen_socket.h"
 #include "net/base/net_export.h"
 
 #if defined(OS_POSIX)
 typedef int SOCKET;
 #endif
 
 namespace net {
 
 // Implements a TCP socket interface. Note that this is ref counted.
@@ skipping 55 matching lines @@
   virtual void OnFileCanReadWithoutBlocking(int fd) OVERRIDE;
   virtual void OnFileCanWriteWithoutBlocking(int fd) OVERRIDE;
   WaitState wait_state_;
   // The socket's libevent wrapper
   MessageLoopForIO::FileDescriptorWatcher watcher_;
 #endif
 
   SOCKET socket_;
 
  private:
+  void SendData();
+
   bool reads_paused_;
   bool has_pending_reads_;
+  std::vector<scoped_refptr<DrainableIOBuffer> > send_buffers_;

[mmenke, 2012/05/09 19:20:08]

Out of paranoia, might be best to make this a list.  

[Marshall, 2012/05/10 16:28:05]

Done.

+  int send_pending_size_;
+  bool send_error_;
+  net::BackoffEntry send_backoff_;
+
+  // Used to continue sending data asynchronously.
+  base::OneShotTimer<TCPListenSocket> send_timer_;
 
   DISALLOW_COPY_AND_ASSIGN(TCPListenSocket);
 };
 
 }  // namespace net
 
 #endif  // NET_BASE_TCP_LISTEN_SOCKET_H_