tcp_server.cpp

/*
   CABAL Protocol
   Test for server TCP socket

   $Id: tcp_server.cpp,v 1.3 2004/03/26 22:45:11 jonnymind Exp $
---------------------------------------------
   Begin      :
   Author     : Giancarlo Niccolai

   Last modified because:

*/

#include <cabal.h>

#define DEFAULT_PORT       2051

using namespace std;
using namespace Cabal;

int main ( int argc, char *argv[] )
{
   int n_port;
   if ( argc > 1 ) {
      n_port = atoi( argv[1] );
   }
   else {
      n_port = DEFAULT_PORT;
   }


   try {
      Net::init();

      Address local( "0.0.0.0", n_port );
      ServerSocket ss( local );
      TCPSocket *s;

      cout << "Server waiting on port "<< n_port << " (closing in 60 secs)\n";
      // setting timeout to 30 seconds
      ss.timeout( 60000 );

      while ( ( s = ss.accept() ) ) {
         cout << "Connection from: " << s->remote_ip() << ":" <<
            s->remote_port() << "\n";

         s->timeout( 10000 );

         s->sendLine("Welcome on board!");
         s->sendLine("Say something in 10 seconds or be banned!");

         string line;

         while ( s->osError() == 0 && ! s->closed() && ! s->hasTimedOut() ) {
            line = s->recvLine( 1024 );
            if ( line != "" ) {
               cout << "Client sayed: \"" << line << "\"\n";
               if ( ! s->osError() && ! s->closed() )
                  s->sendLine( "Received" );
            }
         }

         if ( s->hasTimedOut() )  {
            if ( ! s->closed() )
               s->sendLine("You have timed out. Goodbye.");
            cout << "Client has timed out\n";
         }
         else if ( s->closed() )
            cout << "Client closed connection\n";
         else
            cout << "Socket has got error: " << s->osError()<<"\n";

         delete s;
      }

      if ( ss.hasTimedOut() )
         cout << "Done on timeout\n";
      else
         cout << "Done\n";

      Net::exit();
   }
   catch (Error &e ) {
      cout << e << endl;
   }

   return 0;
}

---