simpleTimeFedAmb1516e.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2018 MaK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: simpleTimeFedAmb1516.h,v $ $Revision: 1.2 $ $State: Exp $
*******************************************************************************/

#ifndef MyFederateAmbassador_H_
#define MyFederateAmbassador_H_

#ifdef WIN32
#pragma warning(disable: 4251)
#pragma warning(disable: 4786)
#pragma warning(disable: 4290)
#endif

#include <RTI/Enums.h>
#include <RTI/Typedefs.h>
#include <RTI/RTI1516.h>
#include <RTI/NullFederateAmbassador.h>
#include "simpleTimeStringUtil.h"
#include "simpleTimeTimeManagedEntity.h"
#include <string>
#include <map>

using namespace rti1516e;

typedef std::map<std::wstring, AttributeHandle> DtAttrNameHandleMap;
typedef std::map<std::wstring, ParameterHandle> DtParamNameHandleMap;

class DtTalkAmbData
{

public:
    DtTalkAmbData();
    ~DtTalkAmbData();


public:
    bool myNameReservationReturned;
    bool myNameReservationSucceeded;
    std::map<ObjectClassHandle, std::wstring> objectClassMap;
    std::map<ObjectInstanceHandle, std::wstring> objectInstanceMap;
    std::map<InteractionClassHandle,std::wstring> interactionClassMap;
    std::map<ObjectInstanceHandle, AttributeHandleSet*> updateRequestMap;

    // Map between strings and attribute handles
    DtAttrNameHandleMap theAttrNameHandleMap;

    // Map between strings and paramterHandles
    DtParamNameHandleMap theParamNameHandleMap;

    // The set of Attributes that this federate's published objects will contain.
    std::set<std::string> ourAttrs;

    // the Set of Parameters that this federate's published interactions will contain.
    std::set<std::string> ourParms;

    // This federation of simple objects has a single master object, (determined by command line arguments)
    //  The master federate will keep the other federates from entering their main loop of execution until
    //  all of numFederates have joined.
    bool isMaster;

    // numFederates is the number of federates (including the master) that the master should wait to join the
    //  federation before it allows any federate to enter its main loop.
    // This variable is only used by the master federate.
    int numFederates;

    AttributeHandleValueMap* attrValues;
    ParameterHandleValueMap* paramValues;
    bool isConstrained;
    bool isRegulating;
    bool timeAdvanced;
    LogicalTime* time;
    int otherFederatesReady;
    bool registerFailed;
    bool registerSucceeded;
    bool announceSyncReceived;
    bool federationIsSynchronized;
    timeManagedEntity timeManagedObject;
};

class MyFederateAmbassador : public NullFederateAmbassador
{
public:
    MyFederateAmbassador(DtTalkAmbData & data);

    virtual ~MyFederateAmbassador ()
        throw () ;

    // 6.3
    virtual
        void
        objectInstanceNameReservationSucceeded(std::wstring const &
        theObjectInstanceName)
        throw (FederateInternalError);

    virtual
        void
        objectInstanceNameReservationFailed(std::wstring const &
        theObjectInstanceName)
        throw (FederateInternalError);

    // 6.5
    virtual void discoverObjectInstance (
        ObjectInstanceHandle theObject,
        ObjectClassHandle theObjectClass,
        std::wstring const & theObjectInstanceName)
        throw (FederateInternalError);

    virtual void discoverObjectInstance (
        ObjectInstanceHandle theObject,
        ObjectClassHandle theObjectClass,
        std::wstring const & theObjectInstanceName,
        FederateHandle producingFederate)
        throw (
        FederateInternalError);

    // 6.11
    virtual void reflectAttributeValues (
        ObjectInstanceHandle theObject,
        AttributeHandleValueMap const & theAttributeValues,
        VariableLengthData const & theUserSuppliedTag,
        OrderType sentOrder,
        TransportationType theType,
        SupplementalReflectInfo theReflectInfo)
        throw (
        FederateInternalError);

    virtual void reflectAttributeValues (
        ObjectInstanceHandle theObject,
        AttributeHandleValueMap const & theAttributeValues,
        VariableLengthData const & theUserSuppliedTag,
        OrderType sentOrder,
        TransportationType theType,
        LogicalTime const & theTime,
        OrderType receivedOrder,
        SupplementalReflectInfo theReflectInfo)
        throw (
        FederateInternalError);

    virtual void reflectAttributeValues (
        ObjectInstanceHandle theObject,
        AttributeHandleValueMap const & theAttributeValues,
        VariableLengthData const & theUserSuppliedTag,
        OrderType sentOrder,
        TransportationType theType,
        LogicalTime const & theTime,
        OrderType receivedOrder,
        MessageRetractionHandle theHandle,
        SupplementalReflectInfo theReflectInfo)
        throw (
        FederateInternalError);

    // 6.13
    virtual void receiveInteraction (
        InteractionClassHandle theInteraction,
        ParameterHandleValueMap const & theParameterValues,
        VariableLengthData const & theUserSuppliedTag,
        OrderType sentOrder,
        TransportationType theType,
        SupplementalReceiveInfo theReceiveInfo)
        throw (
        FederateInternalError);

    virtual void receiveInteraction (
        InteractionClassHandle theInteraction,
        ParameterHandleValueMap const & theParameterValues,
        VariableLengthData const & theUserSuppliedTag,
        OrderType sentOrder,
        TransportationType theType,
        LogicalTime const & theTime,
        OrderType receivedOrder,
        SupplementalReceiveInfo theReceiveInfo)
        throw (
        FederateInternalError);

    virtual void receiveInteraction (
        InteractionClassHandle theInteraction,
        ParameterHandleValueMap const & theParameterValues,
        VariableLengthData const & theUserSuppliedTag,
        OrderType sentOrder,
        TransportationType theType,
        LogicalTime const & theTime,
        OrderType receivedOrder,
        MessageRetractionHandle theHandle,
        SupplementalReceiveInfo theReceiveInfo)
        throw (
        FederateInternalError);

    // 6.15
    virtual void removeObjectInstance (
        ObjectInstanceHandle theObject,
        VariableLengthData const & theUserSuppliedTag,
        OrderType sentOrder,
        SupplementalRemoveInfo theRemoveInfo)
        throw (
        FederateInternalError);
    virtual void removeObjectInstance (
        ObjectInstanceHandle theObject,
        VariableLengthData const & theUserSuppliedTag,
        OrderType sentOrder,
        LogicalTime const & theTime,
        OrderType receivedOrder,
        SupplementalRemoveInfo theRemoveInfo)
        throw (
        FederateInternalError);

    virtual void removeObjectInstance (
        ObjectInstanceHandle theObject,
        VariableLengthData const & theUserSuppliedTag,
        OrderType sentOrder,
        LogicalTime const & theTime,
        OrderType receivedOrder,
        MessageRetractionHandle theHandle,
        SupplementalRemoveInfo theRemoveInfo)
        throw (
        FederateInternalError);

    virtual
        void
        provideAttributeValueUpdate(ObjectInstanceHandle theObject,
        AttributeHandleSet const & theAttributes,
        VariableLengthData const & theUserSuppliedTag)
        throw (
        FederateInternalError);

    virtual
        void
        timeRegulationEnabled(LogicalTime const & theFederateTime)
        throw (
        FederateInternalError);


    virtual
        void
        timeConstrainedEnabled(LogicalTime const & theFederateTime)
        throw (
        FederateInternalError);

    virtual
        void
        timeAdvanceGrant(LogicalTime const & theTime)
        throw (
        FederateInternalError);

    virtual
        void
        requestRetraction(MessageRetractionHandle theHandle)
        throw (FederateInternalError);


    virtual
        void
        synchronizationPointRegistrationSucceeded(std::wstring const & label )
        throw (FederateInternalError);
    virtual
        void
        synchronizationPointRegistrationFailed(std::wstring const & label,
        SynchronizationPointFailureReason reason)
        throw (FederateInternalError);

    virtual
        void
        announceSynchronizationPoint(std::wstring  const & label,
        VariableLengthData const & theUserSuppliedTag)
        throw (FederateInternalError);

    virtual void federationSynchronized (
       std::wstring const & label,
       FederateHandleSet const& failedToSyncSet)
       throw (
       FederateInternalError);


public:
    DtTalkAmbData & myData;
};

#endif