EchoServer.cc

/*
 * Copyright 2003 Michael A. Marsh, Cornell University. All rights reserved.
 * This software is released under the modified BSD license.
 * See the file LICENSE in the top-level directory for details.
 */
//
// $Id: EchoServer.cc,v 1.3 2004/05/19 15:56:55 mmarsh Exp $
//
// $Log: EchoServer.cc,v $
// Revision 1.3  2004/05/19 15:56:55  mmarsh
// *** empty log message ***
//
// Revision 1.2  2003/11/04 22:17:23  mmarsh
// General code cleanup.
//
//

#include <iostream>
#include "EchoServer.h"
#include "SocketBuilder.h"
#include "Message.h"

using namespace CODEX_Quorum;

EchoServer::~EchoServer()
{
}


void
EchoServer::processRequest( SocketBase::StateType s )
{
   SocketBase* skt;
   switch(s)
   {
      case SocketBase::kRead :
         skt = socket()->accept();
         while(1)
         {
            fd_set read_set;
            FD_ZERO(&read_set);
            int snum = skt->set_fd(&read_set, s);
            select(snum+1,&read_set,0,0,0);
            if ( skt->isset_fd( &read_set, s ) )
            {
               unsigned char buffer[1025];
               int n = skt->readFrom( buffer, 1024 );
               if ( 0 == n )
               {
                  cout << "closing connection" << endl;
                  delete skt; // closes connection
                  return;
               }
               // echo back to sender
               Message m(buffer,n);
               skt->writeTo( m );
               buffer[n] = '\0';
               // echo to terminal
               cout << buffer << flush;
            }
         }
         break;
      case SocketBase::kWrite :
         break;
      case SocketBase::kError :
         break;
   }
}

---