queryInterTransportMsg.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2010 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: queryInterTransportMsg.h,v $ $Revision: 1.0 $ $State: Exp $
*********************************************************************/


#ifndef DtQueryInterTransportMsg_H_
#define DtQueryInterTransportMsg_H_

#include "rtiMsConfig.h"
#include "rtiMsg.h"
#include "netQueryInterMsg.h"
#include "vlutil/vlFedTarget.h"

class DtConnectionMgr;
class DtQueryInterTransportMsg;
typedef void (*DtQueryInterTransportCb)(const DtQueryInterTransportMsg& msg, void* usr);

class DT_DLL_LRC DtQueryInterTransportMsg : public DtRtiMsg
{
public:

    DtQueryInterTransportMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

    DtQueryInterTransportMsg(
        DtFederateHandle targetFed,
        DtInteractionClassHandle handle,
        DtFederateHandle sendingFed,
        DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

    DtQueryInterTransportMsg(const DtNetQueryInterTransportMsg* netRepMsg,
        DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

    virtual ~DtQueryInterTransportMsg();

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

    virtual void set(
        DtFederateHandle targetFed,
        DtInteractionClassHandle handle,
        DtFederateHandle sendingFed);

    virtual void setClassHandle(DtObjectClassHandle handle);
    virtual DtObjectClassHandle classHandle() const;

    virtual void setRecipientFederate(DtFederateHandle hand);
    virtual DtFederateHandle recipientFederate() const;

    virtual void setSendingFederate(DtFederateHandle hand);
    virtual DtFederateHandle sendingFederate() const;

    virtual void setHandle(const DtInteractionClassHandle& handle);
    virtual const DtInteractionClassHandle& handle() const;

    virtual void printData(DtLogicalTimeFactory* logicalTimeFactory) const;

public:

    static DtRtiMsg* create(const DtNetMsgHeader* initial, 
        DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);    

    static DtRtiMsg* create(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

    static void addCallback(DtConnectionMgr *conn, 
        DtQueryInterTransportCb cb, void *usr);
    static void removeCallback(DtConnectionMgr *conn, 
        DtQueryInterTransportCb cb, void *usr);

protected:

    virtual int tagFieldSize() const;

    virtual DtNetQueryInterTransportMsg* netQueryInterTransportMsg();
    virtual const DtNetQueryInterTransportMsg* netQueryInterTransportMsg() const;

    virtual DtRtiMsgKind internalDtRtiMsgKind();

    virtual int minSize() const;

    virtual DtQueryInterTransportMsg* self() const;

protected:

    int myDirty;   
    DtInteractionClassHandle* myHandle;
};


inline DtQueryInterTransportMsg* DtQueryInterTransportMsg::self() const
{
    return const_cast<DtQueryInterTransportMsg*>( this );
}

#endif