connection.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1998 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: connection.h,v $ $Revision: 1.25 $ $State: Exp $
*********************************************************************/


#ifndef DtRtiConnection_H_
#define DtRtiConnection_H_ 

#include <vlutil/vlInetAddr.h>
#include "rtiMsgFact.h"

class DtRtiMsg;
class DtMsgSocket;

enum DtNetReadStatus
{
   DtNET_READ_SUCCESS = 0,
   DtNET_READ_NO_PACKETS,
   DtNET_READ_BAD_PACKET,
   DtNET_READ_SERVER_MSG,
   DtNET_READ_SIZE_MISMATCH,
   DtNET_READ_VERSION_MISMATCH,
   DtNET_READ_VERSION_UNKNOWN,
   DtNET_READ_FILTERED_PACKET,
   DtNET_QUEUED_PACKET,
   DtNET_INVALID_VERSION,
   DtNET_BUFFER_TOO_SMALL,
   DtNET_UNKNOWN_ERROR
};

class DT_DLL_LRC DtRtiConnection
{
public:

   DtRtiConnection(DtMsgSocket *skt);

   virtual ~DtRtiConnection();

   virtual void setMsgFactory(DtRtiMsgFactory* fact);
   virtual DtRtiMsgFactory *rtiMsgFactory();


   virtual DtRtiMsg* netRead(DtNetReadStatus *retCode = NULL);

   virtual int send(const DtRtiMsg& msg,
                    const MAKRti::DtInetAddr& addr = MAKRti::DtInetAddr());

   virtual bool flush();

   virtual int isOk();

   virtual void setCheckVersion(bool enableCheckVersion);
   virtual bool checkVersion() const;

   virtual void disableCheckSize();

   virtual void enableCheckSize();

   virtual void setFedExName(const MAKRti::DtString& newFedExName);
   virtual const MAKRti::DtString& fedExName() const;

   virtual void setFedExHandle(int handle);
   virtual int fedExHandle() const;

   virtual void setFederateHandle(DtFederationHandle handle);
   virtual DtFederationHandle federateHandle() const;

   virtual void setConnId(unsigned long connId);
   virtual unsigned long connId() const;

   virtual DtMsgSocket* socket();

protected:

   void init(DtMsgSocket *s);

private:
   DtRtiConnection(const DtRtiConnection& orig);

   DtRtiConnection& operator=(DtRtiConnection const& orig);

protected:

   MAKRti::DtString myFedExName;
   int myFedExHandle;
   DtFederationHandle myFedHandle;
   DtMsgSocket* mySocket;
   DtRtiMsgFactory* myMsgFact;
   unsigned long myReceivedMsgCount;
   bool myCheckSize;
   bool myCheckVersion;
   unsigned int myWaitEventIndex;  
   unsigned long myConnId;
};

inline DtRtiMsgFactory *DtRtiConnection::rtiMsgFactory()
{
   return myMsgFact;
}

inline DtMsgSocket* DtRtiConnection::socket()
{
   return mySocket;
}

inline void DtRtiConnection::setFedExName(const MAKRti::DtString& newFedExName)
{
   myFedExName = newFedExName;
}

inline const MAKRti::DtString& DtRtiConnection::fedExName() const
{
   return myFedExName;
}

inline void DtRtiConnection::setFedExHandle(int handle)
{
   myFedExHandle = handle;
}

inline int DtRtiConnection::fedExHandle() const
{
   return myFedExHandle;
}

inline void DtRtiConnection::setFederateHandle(DtFederationHandle handle)
{
   myFedHandle = handle;
}

inline DtFederationHandle DtRtiConnection::federateHandle() const
{
   return myFedHandle;
}

inline void DtRtiConnection::setConnId(unsigned long connId)
{
   myConnId = connId;
}

inline unsigned long DtRtiConnection::connId() const
{
   return myConnId;
}

#endif