Attn: Mike Belshe

net/base/listen_socket.h

 // 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.
 
 // 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_LISTEN_SOCKET_H_
 #define NET_BASE_LISTEN_SOCKET_H_
 #pragma once
 
+#include <netinet/in.h>
+
 #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"
@@ skipping 24 matching lines @@
     virtual ~ListenSocketDelegate() {}
 
     // 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 DidRead(ListenSocket *connection,
                          const char* data,
                          int len) = 0;
     virtual void DidClose(ListenSocket *sock) = 0;
+    virtual int protocol() { return IPPROTO_TCP; }

[Mike Belshe, 2011/04/06 18:32:53]

nit: const function

   };
 
   // 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);
@@ skipping 12 matching lines @@
     WAITING_ACCEPT   = 1,
     WAITING_READ     = 3,
     WAITING_CLOSE    = 4
   };
 
   static const SOCKET kInvalidSocket;
   static const int kSocketError;
 
   ListenSocket(SOCKET s, ListenSocketDelegate* del);
   virtual ~ListenSocket();
-  static SOCKET Listen(std::string ip, int port);
+  static SOCKET Listen(std::string ip, int port, int protocol);
   // 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);
@@ skipping 21 matching lines @@
   ListenSocketDelegate *socket_delegate_;
 
  private:
   bool reads_paused_;
   bool has_pending_reads_;
 
   DISALLOW_COPY_AND_ASSIGN(ListenSocket);
 };
 
 #endif  // NET_BASE_LISTEN_SOCKET_H_