Upstream changes making ListenSocket an abstract class.

net/base/listen_socket.h

Index: net/base/listen_socket.h
diff --git a/net/base/listen_socket.h b/net/base/listen_socket.h
index 8223767d548738559056aa42eb241009eaebba17..346f73c01d190f77c25da84320ad7557e3040c89 100644
--- a/net/base/listen_socket.h
+++ b/net/base/listen_socket.h
@@ -2,46 +2,25 @@
 // 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.
+// Abstract socket server that handles IO asynchronously in the specified
+// MessageLoop.
 
 #ifndef NET_BASE_LISTEN_SOCKET_H_
 #define NET_BASE_LISTEN_SOCKET_H_
 #pragma once
 
-#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 "build/build_config.h"
 #include "net/base/net_export.h"
 
-#if defined(OS_POSIX)
-typedef int SOCKET;
-#endif
-
 namespace net {
 
-// Implements a raw socket interface
-class NET_EXPORT ListenSocket : public base::RefCountedThreadSafe<ListenSocket>,
-#if defined(OS_WIN)
-                                public base::win::ObjectWatcher::Delegate {
-#elif defined(OS_POSIX)
-                                public MessageLoopForIO::Watcher {
-#endif
+// Defines a socket interface for a server.
+class NET_EXPORT ListenSocket
+    : public base::RefCountedThreadSafe<ListenSocket> {
  public:
   // TODO(erikkay): this delegate should really be split into two parts
   // to split up the listener from the connected socket.  Perhaps this class
@@ -53,80 +32,36 @@ class NET_EXPORT ListenSocket : public base::RefCountedThreadSafe<ListenSocket>,
     // server is the original listening Socket, connection is the new
     // Socket that was created.  Ownership of connection is transferred
     // to the delegate with this call.
-    virtual void DidAccept(ListenSocket *server, ListenSocket *connection) = 0;
+    virtual void DidAccept(ListenSocket *server,
+                           ListenSocket *connection) = 0;
     virtual void DidRead(ListenSocket *connection,
                          const char* data,
                          int len) = 0;
     virtual void DidClose(ListenSocket *sock) = 0;
   };
 
-  // Listen on port for the specified IP address.  Use 127.0.0.1 to only
-  // accept local connections.
-  static ListenSocket* Listen(std::string ip, int port,
-                              ListenSocketDelegate* del);
-
   // Send data to the socket.
-  void Send(const char* bytes, int len, bool append_linefeed = false);
-  void Send(const std::string& str, bool append_linefeed = false);
+  void Send(const char* bytes, int len, bool append_linefeed = false) {
+    SendInternal(bytes, len);
+    if (append_linefeed)
+      SendInternal("\r\n", 2);
+  }

[mmenke, 2012/04/23 14:57:39]

You should de-inline these, per the Chromium style guide
(http://dev.chromium.org/developers/coding-style), which strongly discourages
inlining anything other than getters and setters.  Same goes for the
constructor/destructors.

There are a huge number of violations of this, but I prefer to stick to the
guide.

[Philippe, 2012/04/23 15:17:25]

I agree. This is especially true with non-trivial constructors/destructors
(which can have an empty body but can still result in a lot of duplicated code
due to members construction, vptr initialization...).

 
-  // NOTE: This is for unit test use only!
-  // Pause/Resume calling Read().  Note that ResumeReads() will also call
-  // Read() if there is anything to read.
-  void PauseReads();
-  void ResumeReads();
+  void Send(const std::string& str, bool append_linefeed = false) {
+    Send(str.data(), static_cast<int>(str.length()), append_linefeed);
+  }
 
  protected:
   friend class base::RefCountedThreadSafe<ListenSocket>;

[mmenke, 2012/04/23 14:57:39]

Know it was like this before, but while you're here, could you move this into
the private section, per the Google style guide?  Thanks.

[Philippe, 2012/04/23 15:17:25]

Done.

 
-  enum WaitState {
-    NOT_WAITING      = 0,
-    WAITING_ACCEPT   = 1,
-    WAITING_READ     = 2
-  };
+  ListenSocket(ListenSocketDelegate *del) : socket_delegate_(del) {}
+  virtual ~ListenSocket() {}
 
-  static const SOCKET kInvalidSocket;
-  static const int kSocketError;
-
-  ListenSocket(SOCKET s, ListenSocketDelegate* del);
-  virtual ~ListenSocket();
-  static SOCKET Listen(std::string ip, int port);
-  // if valid, returned SOCKET is non-blocking
-  static SOCKET Accept(SOCKET s);
-
-  virtual void SendInternal(const char* bytes, int len);
-
-  virtual void Listen();
-  virtual void Accept();
-  virtual void Read();
-  virtual void Close();
-  virtual void CloseSocket(SOCKET s);
-
-  // Pass any value in case of Windows, because in Windows
-  // we are not using state.
-  void WatchSocket(WaitState state);
-  void UnwatchSocket();
-
-#if defined(OS_WIN)
-  // ObjectWatcher delegate
-  virtual void OnObjectSignaled(HANDLE object);
-  base::win::ObjectWatcher watcher_;
-  HANDLE socket_event_;
-#elif defined(OS_POSIX)
-  // Called by MessagePumpLibevent when the socket is ready to do I/O
-  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_;
-  ListenSocketDelegate *socket_delegate_;
+  virtual void SendInternal(const char* bytes, int len) = 0;
 
- private:
-  bool reads_paused_;
-  bool has_pending_reads_;
+  ListenSocketDelegate* const socket_delegate_;
 
+ private:
   DISALLOW_COPY_AND_ASSIGN(ListenSocket);
 };