simpleTimeFedAmb1516.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/RTI1516.h>
#include <RTI/NullFederateAmbassador.h>
#include "simpleTimeStringUtil.h"
#include "simpleTimeTimeManagedEntity.h"
#include <string>
#include <map>

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

class DtTalkAmbData
{

public:
   DtTalkAmbData();
   ~DtTalkAmbData();


public:
   bool myNameReservationReturned;
   bool myNameReservationSucceeded;
   std::map<rti1516::ObjectClassHandle, std::wstring> objectClassMap;
   std::map<rti1516::ObjectInstanceHandle, std::wstring> objectInstanceMap;
   std::map<rti1516::InteractionClassHandle,std::wstring> interactionClassMap;
   std::map<rti1516::ObjectInstanceHandle, rti1516::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;

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

class MyFederateAmbassador : public rti1516::NullFederateAmbassador
{
public:

   MyFederateAmbassador(DtTalkAmbData & data);

   virtual ~MyFederateAmbassador()
     throw ();

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

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

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

    // 6.7
    virtual
    void
    reflectAttributeValues
    (rti1516::ObjectInstanceHandle theObject,
     rti1516::AttributeHandleValueMap const & theAttributeValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType)
      throw (rti1516::ObjectInstanceNotKnown,
             rti1516::AttributeNotRecognized,
             rti1516::AttributeNotSubscribed,
             rti1516::FederateInternalError);

    virtual
    void
    reflectAttributeValues
    (rti1516::ObjectInstanceHandle theObject,
     rti1516::AttributeHandleValueMap const & theAttributeValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType,
     rti1516::RegionHandleSet const & theSentRegionHandleSet)
      throw (rti1516::ObjectInstanceNotKnown,
             rti1516::AttributeNotRecognized,
             rti1516::AttributeNotSubscribed,
             rti1516::FederateInternalError);

    virtual
    void
    reflectAttributeValues
    (rti1516::ObjectInstanceHandle theObject,
     rti1516::AttributeHandleValueMap const & theAttributeValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType,
     rti1516::LogicalTime const & theTime,
     rti1516::OrderType receivedOrder)
      throw (rti1516::ObjectInstanceNotKnown,
             rti1516::AttributeNotRecognized,
             rti1516::AttributeNotSubscribed,
             rti1516::FederateInternalError);

    virtual
    void
    reflectAttributeValues
    (rti1516::ObjectInstanceHandle theObject,
     rti1516::AttributeHandleValueMap const & theAttributeValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType,
     rti1516::LogicalTime const & theTime,
     rti1516::OrderType receivedOrder,
     rti1516::RegionHandleSet const & theSentRegionHandleSet)
      throw (rti1516::ObjectInstanceNotKnown,
             rti1516::AttributeNotRecognized,
             rti1516::AttributeNotSubscribed,
             rti1516::FederateInternalError);

    virtual
    void
    reflectAttributeValues
    (rti1516::ObjectInstanceHandle theObject,
     rti1516::AttributeHandleValueMap const & theAttributeValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType,
     rti1516::LogicalTime const & theTime,
     rti1516::OrderType receivedOrder,
     rti1516::MessageRetractionHandle theHandle)
      throw (rti1516::ObjectInstanceNotKnown,
             rti1516::AttributeNotRecognized,
             rti1516::AttributeNotSubscribed,
             rti1516::InvalidLogicalTime,
             rti1516::FederateInternalError);

    virtual
    void
    reflectAttributeValues
    (rti1516::ObjectInstanceHandle theObject,
     rti1516::AttributeHandleValueMap const & theAttributeValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType,
     rti1516::LogicalTime const & theTime,
     rti1516::OrderType receivedOrder,
     rti1516::MessageRetractionHandle theHandle,
     rti1516::RegionHandleSet const & theSentRegionHandleSet)
      throw (rti1516::ObjectInstanceNotKnown,
             rti1516::AttributeNotRecognized,
             rti1516::AttributeNotSubscribed,
             rti1516::InvalidLogicalTime,
             rti1516::FederateInternalError);


    // 6.9
    virtual
    void
    receiveInteraction
    (rti1516::InteractionClassHandle theInteraction,
     rti1516::ParameterHandleValueMap const & theParameterValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType)
      throw (rti1516::InteractionClassNotRecognized,
             rti1516::InteractionParameterNotRecognized,
             rti1516::InteractionClassNotSubscribed,
             rti1516::FederateInternalError);

    virtual
    void
    receiveInteraction
    (rti1516::InteractionClassHandle theInteraction,
     rti1516::ParameterHandleValueMap const & theParameterValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType,
     rti1516::RegionHandleSet const & theSentRegionHandleSet)
      throw (rti1516::InteractionClassNotRecognized,
             rti1516::InteractionParameterNotRecognized,
             rti1516::InteractionClassNotSubscribed,
             rti1516::FederateInternalError);

    virtual
    void
    receiveInteraction
    (rti1516::InteractionClassHandle theInteraction,
     rti1516::ParameterHandleValueMap const & theParameterValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType,
     rti1516::LogicalTime const & theTime,
     rti1516::OrderType receivedOrder)
      throw (rti1516::InteractionClassNotRecognized,
             rti1516::InteractionParameterNotRecognized,
             rti1516::InteractionClassNotSubscribed,
             rti1516::FederateInternalError);

    virtual
    void
    receiveInteraction
    (rti1516::InteractionClassHandle theInteraction,
     rti1516::ParameterHandleValueMap const & theParameterValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType,
     rti1516::LogicalTime const & theTime,
     rti1516::OrderType receivedOrder,
     rti1516::RegionHandleSet const & theSentRegionHandleSet)
      throw (rti1516::InteractionClassNotRecognized,
             rti1516::InteractionParameterNotRecognized,
             rti1516::InteractionClassNotSubscribed,
             rti1516::FederateInternalError);

    virtual
    void
    receiveInteraction
    (rti1516::InteractionClassHandle theInteraction,
     rti1516::ParameterHandleValueMap const & theParameterValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType,
     rti1516::LogicalTime const & theTime,
     rti1516::OrderType receivedOrder,
     rti1516::MessageRetractionHandle theHandle)
      throw (rti1516::InteractionClassNotRecognized,
             rti1516::InteractionParameterNotRecognized,
             rti1516::InteractionClassNotSubscribed,
             rti1516::InvalidLogicalTime,
             rti1516::FederateInternalError);

    virtual
    void
    receiveInteraction
    (rti1516::InteractionClassHandle theInteraction,
     rti1516::ParameterHandleValueMap const & theParameterValues,
     rti1516::VariableLengthData const & theUserSuppliedTag,
     rti1516::OrderType sentOrder,
     rti1516::TransportationType theType,
     rti1516::LogicalTime const & theTime,
     rti1516::OrderType receivedOrder,
     rti1516::MessageRetractionHandle theHandle,
     rti1516::RegionHandleSet const & theSentRegionHandleSet)
      throw (rti1516::InteractionClassNotRecognized,
             rti1516::InteractionParameterNotRecognized,
             rti1516::InteractionClassNotSubscribed,
             rti1516::InvalidLogicalTime,
             rti1516::FederateInternalError);

    virtual
    void
    removeObjectInstance(rti1516::ObjectInstanceHandle theObject,
                         rti1516::VariableLengthData const & theUserSuppliedTag,
                         rti1516::OrderType sentOrder)
      throw (rti1516::ObjectInstanceNotKnown,
             rti1516::FederateInternalError);

    virtual
    void
    removeObjectInstance(rti1516::ObjectInstanceHandle theObject,
                         rti1516::VariableLengthData const & theUserSuppliedTag,
                         rti1516::OrderType sentOrder,
                         rti1516::LogicalTime const & theTime,
                         rti1516::OrderType receivedOrder)
      throw (rti1516::ObjectInstanceNotKnown,
             rti1516::FederateInternalError);

    virtual
    void
    removeObjectInstance(rti1516::ObjectInstanceHandle theObject,
                         rti1516::VariableLengthData const & theUserSuppliedTag,
                         rti1516::OrderType sentOrder,
                         rti1516::LogicalTime const & theTime,
                         rti1516::OrderType receivedOrder,
                         rti1516::MessageRetractionHandle theHandle)
      throw (rti1516::ObjectInstanceNotKnown,
             rti1516::InvalidLogicalTime,
             rti1516::FederateInternalError);

    virtual
    void
    provideAttributeValueUpdate(rti1516::ObjectInstanceHandle theObject,
     rti1516::AttributeHandleSet const & theAttributes,
     rti1516::VariableLengthData const & theUserSuppliedTag)
      throw (rti1516::ObjectInstanceNotKnown,
             rti1516::AttributeNotRecognized,
             rti1516::AttributeNotOwned,
             rti1516::FederateInternalError);

    virtual
    void
    timeRegulationEnabled(rti1516::LogicalTime const & theFederateTime)
      throw (rti1516::InvalidLogicalTime,
             rti1516::NoRequestToEnableTimeRegulationWasPending,
             rti1516::FederateInternalError);


    virtual
    void
    timeConstrainedEnabled(rti1516::LogicalTime const & theFederateTime)
      throw (rti1516::InvalidLogicalTime,
             rti1516::NoRequestToEnableTimeConstrainedWasPending,
             rti1516::FederateInternalError);

    virtual
    void
    timeAdvanceGrant(rti1516::LogicalTime const & theTime)
      throw (rti1516::InvalidLogicalTime,
             rti1516::JoinedFederateIsNotInTimeAdvancingState,
             rti1516::FederateInternalError);

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


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

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

    virtual
    void
    federationSynchronized(std::wstring const & label)
      throw (rti1516::FederateInternalError);


public:
   DtTalkAmbData & myData;
};

#endif