LoopbackSocket.h

/*
 * 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: LoopbackSocket.h,v 1.4 2004/05/19 15:56:55 mmarsh Exp $
//
// $Log: LoopbackSocket.h,v $
// Revision 1.4  2004/05/19 15:56:55  mmarsh
// *** empty log message ***
//
// Revision 1.3  2004/01/23 14:55:50  mmarsh
// Added flush() method specific to loopback sockets.
//
// Revision 1.2  2003/11/04 22:31:50  mmarsh
// *** empty log message ***
//
//

#ifndef __CODEX_QUORUM_LOOPBACKSOCKET_H__
#define __CODEX_QUORUM_LOOPBACKSOCKET_H__

#include <list>

#include "Socket.h"
#include "SocketBuilder.h"

namespace CODEX_Quorum
{
   class LoopbackSocket : public SocketBase
   {
      public :
         LoopbackSocket();

         LoopbackSocket( const LoopbackSocket& aOther );

         virtual ~LoopbackSocket();

         void setup(int port, int backlog) {}
         void setup(struct sockaddr* my_addr,
                    socklen_t addrlen,
                    int backlog) {}
         void connect(const RemoteServer& server) {}
         SocketBase* accept() { return clone(); }

         size_t readFrom( void* output, size_t maxSize=1024 ) const;
         /*
         size_t writeTo( const void* input,
                         size_t maxSize=1024 ) const;
         */

         int set_fd( fd_set* fd_bitmap, StateType s ) const { return 0; }

         bool isset_fd( const fd_set* fd_bitmap, StateType s ) const;

         void flush() const;

      protected :
         SocketBase* clone() { return this; }

      private :
         typedef list< unsigned char > BufferType;
         mutable BufferType m_buffer;
   };

   class LoopbackSocketBuilder : public SocketBuilder
   {
      public :
         LoopbackSocketBuilder() :
            SocketBuilder(0,0,0,false)
         {}

         virtual ~LoopbackSocketBuilder() {}

         SocketBase* operator()() const {
            return new LoopbackSocket;
         }
   };
}

#endif /* __CODEX_QUORUM_LOOPBACKSOCKET_H__ */

---