cabal_ssocket.cpp

/*
   CABAL PROTOCOL
   CAched BAlanced LAN

   Server (TCP) socket class

   $Id: cabal_ssocket.cpp,v 1.5 2004/04/08 15:31:51 jonnymind Exp $
---------------------------------------------
   Begin      : Thu, 11 Mar 2004 04:49:19 +0100
   Author     : Giancarlo Niccolai

   Last modified because:
      Parent became TCPSocket; was formerly Socket

*/

#ifdef __MSC_VER
#pragma warning ( disable : 4786 )
#endif

#include <cabal_ssocket.h>

namespace Cabal {


ServerSocket::ServerSocket( const Address &local, int timeout, int incomingMax )
         throw( InitError )
         : TCPSocket( timeout, &local, 0 )
{
   if ( ! Net::listen( m_skCom, incomingMax ) ) {
      Net::closeSocket( m_skCom );
      Net::invalidate( m_skCom );
      m_osError = Net::errorCode();
      throw InitError( "Can't listen on socket", Net::errorCode() );
   }
}

ServerSocket::ServerSocket( const char *ip, const int port, int timeout, int incomingMax )
         throw( InitError )
         : TCPSocket( timeout,ip, port )
{
   if ( ! Net::listen( m_skCom, incomingMax ) ) {
      Net::closeSocket( m_skCom );
      Net::invalidate( m_skCom );
      m_osError = Net::errorCode();
      throw InitError( "Can't listen on socket", Net::errorCode() );
   }
}

ServerSocket::ServerSocket( std::string const &ip, const int port, int timeout, int incomingMax )
         throw( InitError )
         : TCPSocket( timeout, ip.c_str(), port )
{
   if ( ! Net::listen( m_skCom, incomingMax ) ) {
      Net::closeSocket( m_skCom );
      Net::invalidate( m_skCom );
      m_osError = Net::errorCode();
      throw InitError( "Can't listen on socket", Net::errorCode() );
   }
}

TCPSocket *ServerSocket::accept()
{
   int err = 0;
   SockAddrInet addr;
   RawSocket incoming;

   while( ! selectFor( false ) ) //read
   {
      err = Net::errorCode();
      if ( Net::errorAgain( err ) ) 
         continue;
   
      if ( err != 0 ) 
         break;
         
      // timed out
      m_bTout = true;
      m_osError = 0;
      return 0;
   }

   Net::invalidate( incoming );
   while ( err == 0 && ! Net::validSocket( incoming ) )
   {         
      /* On error (e.g. async connection closed) , com will be -1 and
         errno == 22 (invalid argument ) */
      incoming = Net::accept( m_skCom, &addr );
      if ( ! Net::validSocket( incoming ) ) {
         err = Net::errorCode();
         if ( ! Net::errorAgain( err ) ) 
            err = 0;
      }
   }

   m_bTout = false;

   if ( err == 0 )
   {
      TCPSocket *con = new TCPSocket();
      con->m_skCom = incoming;
      con->m_local.copy( m_local );
      con->m_remote.set( addr );
      m_osError = 0;

      return con;
   }
   else {
      m_osError = err;
      return 0;
   }

}

} // End of namespace

---