cabal_tcpsocket.h

/*
   cabal_tcpsocket.h
   Basic TCP socket object for cabal

   $Id: cabal_tcpsocket.h,v 1.3 2004/04/10 15:28:16 jonnymind Exp $
---------------------------------------------
   Begin      : Thu, 11 Mar 2004 03:05:18 +0100
   Author     : Giancarlo Niccolai

   Last modified because:

*/

#ifndef CABAL_TCPSOCKET_H
#define CABAL_TCPSOCKET_H

#include <cabal_socket.h>

namespace Cabal
{

class TCPSocket: public Socket
{
   void buildSocket( const Address *local, const Address *remote ) throw( InitError );

protected:
   OpType m_opType;
   const void *m_buffer;
   int m_buflen;
   int m_bufdone;
   
   virtual int rawRecv( void *data, const int len ) 
   {
      return Net::recv( m_skCom, data, len );
   }
   
   virtual int rawSend( const void *data, const int len ) 
   {
      return Net::send( m_skCom, data, len );
   }

public:
   
   TCPSocket( const long timeout=-1, const Address *local=0, const Address *remote=0 ) throw( InitError )
         : Socket( ST_TCP )
   {
      m_timeout = timeout;
      m_opType = OT_NONE;
      buildSocket( local, remote );   
   }
   
   TCPSocket( const Address *local, const Address *remote=0 ) throw( InitError )
         : Socket( ST_TCP )
   {
      m_timeout = -1;
      m_opType = OT_NONE;
      buildSocket( local, remote );   
   }
   
   TCPSocket( const long timeout, const char *local_ip, const int port ) throw( InitError )
         : Socket( ST_TCP )
   {
      m_timeout = -1;
      m_opType = OT_NONE;
      Address addr( local_ip, port );
      buildSocket( &addr, 0 );
   }
   
   virtual bool close() 
   {
      Net::shutdown( m_skCom );
      return Socket::close();
   }

   bool connect();
   
   bool connect( const Address &remote )
   {
       m_remote = remote;
       return connect();
   }
   
   bool connect( const char *ip_addr, const int port ) {
      m_remote.set( ip_addr, port );
      return connect();
   }
   
   int recvAll( void *buffer, const int len );
   
   int sendAll( const void *buffer, const int len );
   
   std::string recvLine( const int maxCount=0 );
   
   int sendLine( const std::string &val )
   {
      std::string sendstr = val + "\r\n";
      return sendAll( sendstr.c_str(), sendstr.length() );
   }

   int send( const std::string &val )
   {
      return sendAll( val.c_str(), val.length() );
   }
   
   int sendLine( const char *data ) {
      return sendLine( std::string( data ) );
   }
   
   int sendString( const char *data ) {
      return send( std::string( data ) );
   }
   
   bool continueOp();
};

}

#endif

/* end of cabal_tcpsocket.h */

---