TCPIPCommReceive.h

//*****************************************************************************
// project   : ANALYTICA Class Library
// part      : Communication class for simple TCP/IP
// file name : TCPIPCommReceive.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 : Receiving of messages
//
//-----------------------------------------------------------------------------
// Revisionhistory:
// $Log: TCPIPCommReceive.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 _TCPIPCommReceive_h
#define _TCPIPCommReceive_h

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

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

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


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


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


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

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

   CTCPIPCommReceive( const long MaxRecvBufferLen = 8192 );

   virtual ~CTCPIPCommReceive();


   //
   // public operations
   //

   void Initialize( const SOCKET       Socket );

   bool StartReceiving( void );

   int GetLastSocketError( void ) const;

   bool Terminating( void ) const;

   void Terminating( bool Terminating );


   // protected part
protected:

   //
   // virtual callback functions
   //

   virtual void Receive( void    *pData,
                         long    DataLen ) = 0;


   virtual void RecvDisInd( void ) = 0;


   void InitializeClass( const long MaxRecvBufferLen );

   // private part
private:

   //
   // static member functions
   //
   static void RecvThread( CTCPIPCommReceive *pClass );

   // member definition
   SOCKET          m_Socket;
   int             m_LastSocketError;

   DWORD           m_ThreadID;

   HANDLE          m_ThreadHandle;
   HANDLE          m_hEventTerminate;
   HANDLE          m_hEventTerminateFinished;
   HANDLE          m_hEventStartReceiving;

   void            *m_pRecvBuffer;
   long            m_MaxRecvBufferLen;

   bool            m_Terminating;
};


//
// inline operations 
//

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


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


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



#endif // _TCPIPCommReceive_h

---