assistantConnQueryMsg.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2016 VT MAK
 * All rights reserved.
 ****************************************************************************/


#pragma once

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

class DtAssistantMsgQueue;
class DtRtiAssistantServer;
class DtAssistantConnQueryMsg;
class DtNetAssistantConnQueryMsg;

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 tcpAddress() const;

   virtual int tcpPort() const;

   virtual MAKRti::DtInetAddr tcpInterfaceAddress() const;

   virtual MAKRti::DtInetAddr udpAddress() const;

   virtual int udpPort() const;

   virtual MAKRti::DtInetAddr udpInterfaceAddress() const;

   virtual MAKRti::DtInetAddr additionalForwarderConnectionAddr() const;

   virtual int forwarderPort() const;

   virtual const char* connectionName() const;

   virtual bool ridIsPreconfigured() const;

   virtual const char* ridConfiguration() const;

   virtual MAKRti::DtInetUtils::DtInetAddrFamily addressFamily() 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 void printData() const;

   virtual void setLRCParameters(
      const DtString& connectionName, bool isRidPreconfigured, const DtString& ridConfig,
      const DtInetAddr& tcpAddr,  int tcpPort, const DtInetAddr& tcpIntfAddr,
      const DtInetAddr& udpAddr, int udpPort, const DtInetAddr& udpIntfAddr,
      int forwarderPort, bool useRtiExec, bool isForceFullCompliance, bool isAccepted );

   virtual void setForwardingParameters(
      const DtString& connectionName, bool isRidPreconfigured, const DtString& ridConfig,
      const DtInetAddr& tcpAddr,  int tcpPort, const DtInetAddr& tcpIntfAddr,
      const DtInetAddr& udpAddr, int udpPort, const DtInetAddr& udpIntfAddr,
      const DtInetAddr& additionalForwarder, int forwarderPort,
      bool isFullyCompliant, bool isAccepted );

   virtual void setConnectionName( const MAKRti::DtString& name, bool adjustBufferSize = true );

   virtual void setRidIsPreconfigured( bool val );

   virtual void setRidConfiguration( const MAKRti::DtString& ridConfig, bool adjustBufferSize = true);

   virtual void setError( bool val );

protected:

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

   virtual void setTcpPort( int port );

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

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

   virtual void setUdpPort( int port );

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

   virtual void setAdditionalForwarderConnectionAddr( const MAKRti::DtInetAddr& addr, bool adjustBufferSize = true);

   virtual void setForwarderPort( int port );

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

   virtual void setUseRtiexec( bool val );

   virtual void setForceFullCompliance( bool val );

   virtual void setAccepted( bool val );

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;

   virtual int minSize(DtString const& connectionName, DtString const& ridConfig,
      DtInetAddr const* additionalForwarder=nullptr) const;

   virtual void setAdditionalForwarderSize( unsigned long size );

   virtual unsigned long additionalForwarderSize() const;

   virtual const char* additionalForwarderPtr() const;

   virtual char* additionalForwarderPtr();

   virtual void setConnectionNameSize( unsigned long size );

   virtual unsigned long connectionNameSize() const;

   virtual const char* connectionNamePtr() const;

   virtual char* connectionNamePtr();

   virtual void setRidConfigurationSize( unsigned long size );

   virtual unsigned long ridConfigurationSize() const;

   virtual const char* ridConfigurationPtr() const;

   virtual char* ridConfigurationPtr();

};