TCPIPCommSend.h

//*****************************************************************************
// project   : ANALYTICA Class Library
// part      : Communication class for simple TCP/IP
// file name : TCPIPCommSend.h
// version   : $Revision: 1.3 $
// author    : Udo Weber
// platform  : MS VC++ 6.0
//
//-----------------------------------------------------------------------------
// Description:
// =============
// implementation of the class CTCPIPComm to encapsulate simple TCP/IP
// communications
// Part : Sending of messages
//
//-----------------------------------------------------------------------------
// Revisionhistory:
// $Log: TCPIPCommSend.h,v $
// Revision 1.3  2001/07/12 14:36:00  AxelSchmidt
// virtuelle Basis-Klasse CTraceObject hinzugefügt
//
// 03.07.2001 ASc  Function InitializeClass added
// 20.07.1998 UWe  Some bug fixes
// 20.04.1998 UWe  first version
//*****************************************************************************

#ifndef _TCPIPCommSend_h
#define _TCPIPCommSend_h

//---- includes ---------------------------------------------------------------

#include <winsock.h>
#include "TraceObject.h"


//---- defines/const ----------------------------------------------------------


//---- enums ------------------------------------------------------------------


//---- structs ----------------------------------------------------------------


//---- classes ----------------------------------------------------------------

class CTCPIPCommSend : virtual public CTraceObject
{
   // public part
public:

   CTCPIPCommSend( const long MaxSendBufferLen = 8192 );

   virtual ~CTCPIPCommSend();


   //
   // public operations
   //

   void Initialize( const SOCKET       Socket );


   bool Send( const void   *pData,
              const long   DataLen );

   int GetLastSocketError( void ) const;

   bool Terminating( void ) const;

   void Terminating( bool Terminating );



   // protected part
protected:

   //
   // virtual callback functions
   //

   virtual void SendDisInd( void ) = 0;

   void InitializeClass( const long MaxSendBufferLen );


   // private part
private:

   //
   // static member functions
   //
   static void SendThread( CTCPIPCommSend *pClass );



   // member definition
   SOCKET          m_Socket;
   int             m_LastSocketError;

   DWORD           m_ThreadID;

   HANDLE          m_hReadPipe;
   HANDLE          m_hWritePipe;
   HANDLE          m_ThreadHandle;
   HANDLE          m_hEventTerminate;
   HANDLE          m_hEventTerminateFinished;
   HANDLE          m_hEventStartReceiving;

   void            *m_pSendBuffer;
   long            m_MaxSendBufferLen;

   bool            m_Terminating;

   int             m_SendCnt;
};


//
// inline operations 
//

// get last socket error
inline int CTCPIPCommSend::GetLastSocketError( void ) const
{
   return m_LastSocketError;
}


inline bool CTCPIPCommSend::Terminating( void ) const
{
   return m_Terminating;
}


inline void CTCPIPCommSend::Terminating( bool  Terminating )
{
   m_Terminating = Terminating;
}



#endif // _TCPIPCommSend_h

---