queryTransportMsg.h

Go to the documentation of this file.

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


#ifndef DtQueryTransportMsg_H_
#define DtQueryTransportMsg_H_

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

class DtConnectionMgr;
class DtQueryTransportMsg;
typedef void (*DtQueryTransportCb)(const DtQueryTransportMsg& msg, void* usr);

enum DtQueryTransMsgKind
{
    DtAttributeQuery,
    DtInteractionQuery,
};

class DT_DLL_LRC DtQueryTransportMsg : public DtRtiMsg
{
public:

    DtQueryTransportMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

    DtQueryTransportMsg(
        DtFederateHandle targetFed,
        DtQueryTransMsgKind kind,
        DtObjectInstanceHandle objHand, 
        DtAttributeHandle handle,
        DtTransportType transType,
        DtFederateHandle sendingFed = 0,
        DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

    DtQueryTransportMsg(const DtNetQueryTransportMsg* netRepMsg,
        DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

    virtual ~DtQueryTransportMsg();

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

    virtual void set(
        DtFederateHandle targetFed,
        DtQueryTransMsgKind kind,
        DtObjectInstanceHandle objHand, 
        DtAttributeHandle handle,
        DtTransportType transType,
        DtFederateHandle sendingFed = 0);

    virtual void setQueryTransportMsgKind(DtQueryTransMsgKind kind);
    virtual DtQueryTransMsgKind queryTransportMsgKind() const;

    virtual void setObjHandle(DtObjectInstanceHandle id);
    virtual DtObjectInstanceHandle objHandle() const;

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

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

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

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

    virtual void setTransportType( DtTransportType type );
    virtual DtTransportType transportationType() 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, 
        DtQueryTransportCb cb, void *usr);
    static void removeCallback(DtConnectionMgr *conn, 
        DtQueryTransportCb cb, void *usr);

protected:

    virtual int tagFieldSize() const;

    virtual DtNetQueryTransportMsg* netQueryTransportMsg();
    virtual const DtNetQueryTransportMsg* netQueryTransportMsg() const;

    virtual DtRtiMsgKind internalDtRtiMsgKind();

    virtual int minSize() const;

    virtual DtQueryTransportMsg* self() const;

protected:

    int myDirty;   
    DtAttributeHandle* myHandle;
    DtTransportType myTransportType;
};


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

#endif