---

LoopbackSocket.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: LoopbackSocket.cc,v 1.4 2004/05/19 15:56:55 mmarsh Exp $
//
// $Log: LoopbackSocket.cc,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 ***
//
//

#include "LoopbackSocket.h"
#include "Message.h"

using namespace CODEX_Quorum;

LoopbackSocket::LoopbackSocket()
{
}

LoopbackSocket::LoopbackSocket( const LoopbackSocket& aOther )
{
}

LoopbackSocket::~LoopbackSocket()
{
}

size_t
LoopbackSocket::readFrom( void* output, size_t maxSize ) const
{
   unsigned char* ucoutput = (unsigned char*)output;
   size_t buffSize = m_buffer.size();
   size_t readSize = ( buffSize < maxSize )? buffSize : maxSize;
   for ( size_t i = 0 ; i < readSize ; ++i )
   {
      ucoutput[i] = m_buffer.front();
      m_buffer.pop_front();
   }
   return readSize;
}

/*
size_t
LoopbackSocket::writeTo( const void* input, size_t maxSize ) const
{
   unsigned char* ucinput = (unsigned char*)input;
   for ( size_t i = 0 ; i < maxSize ; ++i )
   {
      m_buffer.push_back( ucinput[i] );
   }
   return maxSize;
}
*/

bool
LoopbackSocket::isset_fd( const fd_set* fd_bitmap, StateType s ) const
{
   switch(s)
   {
      case kRead :
         return ( ! m_buffer.empty() );
         break;
      case kWrite :
         while ( ! m_msgQueue.empty() )
         {
            Message* first = m_msgQueue.front();
            for ( unsigned int i = 0 ; i < first->length() ; ++i )
            {
               m_buffer.push_back( first->buffer()[i] );
            }
            delete first;
            m_msgQueue.pop();
         }
         return true;
         break;
      case kError :
         return false;
         break;
   }
   return false;
}

void
LoopbackSocket::flush() const
{
   while ( ! m_msgQueue.empty() )
   {
      Message* first = m_msgQueue.front();
      for ( unsigned int i = 0 ; i < first->length() ; ++i )
      {
         m_buffer.push_back( first->buffer()[i] );
      }
      delete first;
      m_msgQueue.pop();
   }
}

---