Porting of listen_socket, telnet_server to linux

net/base/telnet_server.cc

 // Copyright (c) 2006-2008 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 "build/build_config.h"
+
+#if defined(OS_WIN)
 // winsock2.h must be included first in order to ensure it is included before
 // windows.h.
 #include <winsock2.h>
+#elif defined(OS_POSIX)
+#include <errno.h>
+#include <sys/socket.h>
+#include "base/message_loop.h"
+#include "net/base/net_errors.h"
+#include "third_party/libevent/event.h"
+#include "base/message_pump_libevent.h"
+#endif
 
 #include "net/base/telnet_server.h"
 
-#define READ_BUF_SIZE 200
+#if defined(OS_POSIX)
+// Used same name as in Windows to avoid #ifdef where refrenced
+#define SOCKET int
+const int INVALID_SOCKET = -1; 
+const int SOCKET_ERROR = -1;
+struct event;  // From libevent
+#endif
+
+const int kReadBufSize = 200;
 
 // Telnet protocol constants.
 class TelnetProtocol {
  public:
   // Telnet command definitions (from arpa/telnet.h).
   enum Commands {
     IAC   = 255,  // Interpret as command.
     DONT  = 254,  // You are not to use option.
     DO    = 253,  // Please, you use option.
     WONT  = 252,  // I won't use option.
@@ skipping 80 matching lines @@
   ListenSocket::SendInternal(data + begin_index, len - begin_index);
 }
 
 void TelnetServer::Accept() {
   SOCKET conn = ListenSocket::Accept(socket_);
   if (conn == INVALID_SOCKET) {
     // TODO
   } else {
     scoped_refptr<TelnetServer> sock =
         new TelnetServer(conn, socket_delegate_);
-
+#if defined(OS_POSIX)
+    sock->WatchSocket(WAITING_READ);
+#endif
     // Setup the way we want to communicate
     sock->SendIAC(TelnetProtocol::DO, TelnetProtocol::ECHO);
     sock->SendIAC(TelnetProtocol::DO, TelnetProtocol::NAWS);
     sock->SendIAC(TelnetProtocol::DO, TelnetProtocol::LFLOW);
     sock->SendIAC(TelnetProtocol::WILL, TelnetProtocol::ECHO);
     sock->SendIAC(TelnetProtocol::WILL, TelnetProtocol::SGA);
 
     // it's up to the delegate to AddRef if it wants to keep it around
     socket_delegate_->DidAccept(this, sock);
   }
 }
 
 TelnetServer* TelnetServer::Listen(std::string ip, int port,
                                    ListenSocketDelegate *del) {
   SOCKET s = ListenSocket::Listen(ip, port);
   if (s == INVALID_SOCKET) {
-    // TODO
+    // TODO (ibrar): error handling
   } else {
     TelnetServer *serv = new TelnetServer(s, del);
     serv->Listen();
     return serv;
   }
   return NULL;
 }
 
 void TelnetServer::StateMachineStep(unsigned char c) {
   switch (input_state_) {
@@ skipping 79 matching lines @@
         // Ignore ESC sequence content for now.
       } else {
         // Final character in ESC sequence.
         input_state_ = NOT_IN_IAC_OR_ESC_SEQUENCE;
       }
       break;
   }
 }
 
 void TelnetServer::Read() {
-  char buf[READ_BUF_SIZE];
+  char buf[kReadBufSize + 1];
   int len;
   do {
-    len = recv(socket_, buf, READ_BUF_SIZE, 0);
+    len = recv(socket_, buf, kReadBufSize, 0);
+
+#if defined(OS_WIN)
     if (len == SOCKET_ERROR) {
       int err = WSAGetLastError();
-      if (err == WSAEWOULDBLOCK) {
+      if (err == WSAEWOULDBLOCK)
         break;
-      } else {
-        // TODO - error
+#else
+    if (len == SOCKET_ERROR) {
+      if (errno == EWOULDBLOCK || errno == EAGAIN) 
         break;
-      }
+#endif
+    } else if (len == 0) {
+      socket_delegate_->DidClose(this);
     } else {
       const char *data = buf;
       for (int i = 0; i < len; ++i) {
         unsigned char c = static_cast<unsigned char>(*data);
         StateMachineStep(c);
         data++;
       }
     }
-  } while (len == READ_BUF_SIZE);
+  } while (len == kReadBufSize);
 }
-