assistantConnQueryMsg.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2008 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: assistantConnQueryMsg.h,v $ $Revision: 1.18 $ $State: Exp $
*********************************************************************/


#ifndef assistantConnQueryMsg_H_
#define assistantConnQueryMsg_H_


#include "assistantMsg.h"
#include "netAssistantConnQueryMsg.h"
#include "assistantConnectionInfo.h"

class DtAssistantConnQueryMsg;
class DtRtiAssistantServer;
class DtAssistantMsgQueue;

typedef void (*DtAssistantConnQueryCb)(const DtAssistantConnQueryMsg& inter, void* usr);


class DT_DLL_ASSISTANT DtAssistantConnQueryMsg : public DtAssistantMsg
{

public:
   
   DtAssistantConnQueryMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtAssistantConnQueryMsg(const DtNetAssistantConnQueryMsg* netRep,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtAssistantConnQueryMsg();

   virtual DtAssistantMsg* clone(bool copy = true) const;

   virtual MAKRti::DtInetAddr reliableIpAddress() const;

   virtual MAKRti::DtInetAddr bestEffortIpAddress() const;

   virtual MAKRti::DtInetAddr networkInterfaceAddress() const;

   virtual MAKRti::DtInetUtils::DtInetAddrFamily addressFamily() const;

   virtual int udpPort() const;

   virtual int tcpPort() const;

   virtual bool useRtiexec() const;

   virtual void setIsAssistantToAssistant(bool yesNo);

   virtual bool isAssistantToAssistant() const;

   virtual bool forceFullCompliance() const;

   virtual bool isAccepted() const;

   virtual bool isError() const;

   virtual MAKRti::DtInetAddr additionalForwarderConnectionAddr() const;

   virtual int forwarderPort() const;

   virtual void printData() const;

   virtual void setLRCParameters( const MAKRti::DtInetAddr& address,
      const MAKRti::DtInetAddr& bestEffortIpAddr, 
      const MAKRti::DtInetAddr& networkInterfaceToUse, int udpPort,
      int tcpPort, bool useRtiExec, bool isForceFullCompliance,
      int forwarderPort, bool isAccepted );

   virtual void setForwardingParameters( const MAKRti::DtInetAddr& addr,
      const MAKRti::DtInetAddr& bestEffortAddr,
      const MAKRti::DtInetAddr& networkInterface, int udpPort, int tcpPort,
      bool isFullyCompliant, int forwarderPort,
      const MAKRti::DtInetAddr& additionalForwarder, bool isAccepted );

   virtual void setError( bool val );

protected:

   virtual void setReliableIpAddress(const MAKRti::DtInetAddr& ipAddress);

   virtual void setBestEffortIpAddress(const MAKRti::DtInetAddr& ipAddress);

   virtual void setNetworkInterfaceAddress(const MAKRti::DtInetAddr& address);

   virtual void setAddressFamily(MAKRti::DtInetUtils::DtInetAddrFamily addrFamily);

   virtual void setUdpPort(int port);

   virtual void setTcpPort(int port);

   virtual void setUseRtiexec( bool val );

   virtual void setForceFullCompliance( bool val );

   virtual void setAccepted( bool val );

   virtual void setAdditionalForwarderConnectionAddr(const MAKRti::DtInetAddr& addr);

   virtual void setForwarderPort( int port );

   virtual void setAdditionalForwarderSize(unsigned long size);
   virtual unsigned long additionalForwarderSize() const;

   virtual const char* additionalForwarderPtr() const;
   virtual char* additionalForwarderPtr();



public:

   static DtAssistantMsg* create(const DtNetAssistantMsgHeader* initial,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   static DtAssistantMsg* create(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   static void addCallback(DtRtiAssistantServer* conn,
      DtAssistantConnQueryCb cb, void* usr);
   static void removeCallback(DtRtiAssistantServer* conn, 
      DtAssistantConnQueryCb cb, void* usr);
   static void addCallback(DtAssistantMsgQueue* queue, 
      DtAssistantConnQueryCb cb, void* usr);
   static void removeCallback(DtAssistantMsgQueue* queue, 
      DtAssistantConnQueryCb cb, void* usr);

protected:

   virtual DtNetAssistantConnQueryMsg* netAssistantConnQueryMsg();
   virtual const DtNetAssistantConnQueryMsg* netAssistantConnQueryMsg() const;

   virtual DtAssistantMsgKind internalMsgKind();

   virtual int minSize() const;

};

#endif