vlTcpSocket.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1992, 1997 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: vlTcpSocket.h,v $ $Revision: 1.2.6.5 $ $State: Exp $
*********************************************************************/
#ifndef vlTcpSocket_H_ 
#define vlTcpSocket_H_

#include "vlSocket.h"

#ifdef DtUSE_UTILITIES_NAMESPACE
namespace DtUSE_UTILITIES_NAMESPACE
{
#endif

class DT_DLL_NETCOMPAT DtTcpMessage
{
public:

   DtTcpMessage( const char* buff, int size );
   DtTcpMessage( const char* buff, int offset, int size );
   ~DtTcpMessage();

   char* myBuff;
   int mySize;

private:
   DtTcpMessage(const DtTcpMessage &);

   DtTcpMessage &operator=(const DtTcpMessage &);

};

class DT_DLL_NETCOMPAT DtTcpSocket : public DtSocket
{
public:

   DtTcpSocket(int socketfd, DtIpv4Addr addr, int clientPort = 0);

   DtTcpSocket(DtIpv4Addr addr, int port=DtDEFAULT_PORT, 
               int nonBlockingConnect=0);

   virtual ~DtTcpSocket();

   virtual int sendTo(caddr_t packet, size_t packetSize, 
                      DtIpv4Addr addr=DtUSE_DEFAULT_IP_ADDR);

   virtual int DtRecv(caddr_t *buffptr, int *status=NULL);

   virtual int DtRecv(caddr_t buff, size_t bufsize);

   virtual DtFlushStatus flush();

   virtual DtFlushStatus flush(long& byteCount);

   virtual void DtBecomeNonBlocking();

   virtual void DtBecomeBlocking();

   virtual bool isOk() const;

   virtual bool isConnectionEstablished();

   virtual bool testConnectionStatus();

   
   inline DtIpv4Addr getConnectionAddr() const;
   
   int sizeOffset() const { return mySizeOffset; }
   void setSizeOffset(int offset);
   
   int sizeLength() const { return mySizeLength; }
   void setSizeLength(int length);

   virtual void setNoDelay(bool onOff);

   virtual int peerPort() const;

   virtual int localPort() const;

   int maxForwarderQueue() const;
   void setMaxForwarderQueue( int maxForwarderQueue ); 

public:

   static void setNoDelay(int sockfd, bool onOff);

   static void setPacketBufferSize(int size);

   std::pair<int, int> getQueueStatus() const;

protected:

   int sendTo(caddr_t packet, size_t packetSize, bool reportMinSizePktFaults );

   int recvWithStatus(caddr_t *buffptr, int *status);
   int checkSize(int size, caddr_t *buffptr, int *status);
   bool expandPktBuffer( unsigned int sizeNeeded );
   int sendMinimumSizePkt( bool reportMinSizePktFaults );

private:

   DtTcpSocket(const DtTcpSocket &);

   DtTcpSocket& operator=(const DtTcpSocket &);
   
protected:
   
   char* myPktBuff;
   unsigned int myPktBuffSize;
   DtIpv4Addr myConnectAddr;
   int myPeerPort;
   int myLocalPort;
   bool myOk;
   int myNeedSize;
   int mySizeOffset;
   int mySizeLength;
   int myNumBytesToWaitFor;
   int myNumBytesReceived;

   DtList* myPktWaitList;

   int myMaxForwarderQueue;

protected:

   static int thePktBuffSize;
};

inline DtIpv4Addr DtTcpSocket::getConnectionAddr() const
{
   return myConnectAddr;
}

inline bool DtTcpSocket::isOk() const 
{ 
   return myOk; 
}

#ifdef DtUSE_UTILITIES_NAMESPACE
} 
#endif


#endif