simpleTimeFedAmb1516_2025.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>

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

class DtTalkAmbData
{

   public:

   DtTalkAmbData();
   ~DtTalkAmbData();


   public:

   bool myNameReservationReturned;
   bool myNameReservationSucceeded;
   std::map<rti1516_2025::ObjectClassHandle, std::wstring> objectClassMap;
   std::map<rti1516_2025::ObjectInstanceHandle, std::wstring> objectInstanceMap;
   std::map<rti1516_2025::InteractionClassHandle,std::wstring> interactionClassMap;
   std::map<rti1516_2025::ObjectInstanceHandle, rti1516_2025::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_2025::AttributeHandleValueMap* attrValues;
   rti1516_2025::ParameterHandleValueMap* paramValues;
   rti1516_2025::TransportationTypeHandle bestEffortHandle;
   bool isConstrained;
   bool isRegulating;
   bool timeAdvanced;
   rti1516_2025::LogicalTime* time;
   int otherFederatesReady;
   bool registerFailed;
   bool registerSucceeded;
   bool announceSyncReceived;
   bool federationIsSynchronized;
   timeManagedEntity timeManagedObject;
};

class MyFederateAmbassador : public rti1516_2025::NullFederateAmbassador
{
   public:

   MyFederateAmbassador(DtTalkAmbData & data);

   virtual ~MyFederateAmbassador ();

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

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

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

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

   // 6.11
   virtual void reflectAttributeValues(
      rti1516_2025::ObjectInstanceHandle const& theObject,
      rti1516_2025::AttributeHandleValueMap const& theAttributeValues,
      rti1516_2025::VariableLengthData const& theUserSuppliedTag,
      rti1516_2025::TransportationTypeHandle const& theType,
      rti1516_2025::FederateHandle const& theProducingFederate,
      rti1516_2025::RegionHandleSet const* theOptionalSentRegions);

   virtual void reflectAttributeValues(
      rti1516_2025::ObjectInstanceHandle const& theObject,
      rti1516_2025::AttributeHandleValueMap const& theAttributeValues,
      rti1516_2025::VariableLengthData const& theUserSuppliedTag,
      rti1516_2025::TransportationTypeHandle const& theType,
      rti1516_2025::FederateHandle const& theProducingFederate,
      rti1516_2025::RegionHandleSet const* theOptionalSentRegions,
      rti1516_2025::LogicalTime const& theTime,
      rti1516_2025::OrderType theSentOrder,
      rti1516_2025::OrderType theReceivedOrder,
      rti1516_2025::MessageRetractionHandle const* theOptionalRetraction);

   // 6.13
   virtual void receiveInteraction(
      rti1516_2025::InteractionClassHandle const& theInteraction,
      rti1516_2025::ParameterHandleValueMap const& theParameterValues,
      rti1516_2025::VariableLengthData const& theUserSuppliedTag,
      rti1516_2025::TransportationTypeHandle const& theType,
      rti1516_2025::FederateHandle const& theProducingFederate,
      const rti1516_2025::RegionHandleSet* theOptionalSentRegions);

   virtual void receiveInteraction(
      rti1516_2025::InteractionClassHandle const& theInteraction,
      rti1516_2025::ParameterHandleValueMap const& theParameterValues,
      rti1516_2025::VariableLengthData const& theUserSuppliedTag,
      rti1516_2025::TransportationTypeHandle const& theType,
      rti1516_2025::FederateHandle const& theProducingFederate,
      rti1516_2025::RegionHandleSet const* theOptionalSentRegions,
      rti1516_2025::LogicalTime const& theTime,
      rti1516_2025::OrderType theSentOrder,
      rti1516_2025::OrderType theReceivedOrder,
      rti1516_2025::MessageRetractionHandle const* theOptionalRetraction);

#if 0
   // HLA4_TODO
   // 6.13
   virtual void receiveDirectedInteraction(
      rti1516_2025::InteractionClassHandle const& theInteraction,
      rti1516_2025::ObjectInstanceHandle const& theObject,
      rti1516_2025::ParameterHandleValueMap const& theParameterValues,
      rti1516_2025::VariableLengthData const& theUserSuppliedTag,
      rti1516_2025::TransportationTypeHandle const& theType,
      rti1516_2025::FederateHandle const& producingFederate);

   virtual void receiveDirectedInteraction(
      rti1516_2025::InteractionClassHandle const& theInteraction,
      rti1516_2025::ObjectInstanceHandle const& theObject,
      rti1516_2025::ParameterHandleValueMap const& theParameterValues,
      rti1516_2025::VariableLengthData const& theUserSuppliedTag,
      rti1516_2025::TransportationTypeHandle const& theType,
      rti1516_2025::FederateHandle const& theProducingFederate,
      rti1516_2025::LogicalTime const& theTime,
      rti1516_2025::OrderType theSentOrder,
      rti1516_2025::OrderType theReceivedOrder,
      rti1516_2025::MessageRetractionHandle const* theOptionalRetraction);
#endif

   // 6.15
   virtual void removeObjectInstance(
      rti1516_2025::ObjectInstanceHandle const& theObject,
      rti1516_2025::VariableLengthData const& theUserSuppliedTag,
      rti1516_2025::FederateHandle const& theProducingFederate);

   virtual void removeObjectInstance(
      rti1516_2025::ObjectInstanceHandle const& theObject,
      rti1516_2025::VariableLengthData const& theUserSuppliedTag,
      rti1516_2025::FederateHandle const& theProducingFederate,
      rti1516_2025::LogicalTime const& theTime,
      rti1516_2025::OrderType theSentOrder,
      rti1516_2025::OrderType theReceivedOrder,
      rti1516_2025::MessageRetractionHandle const* theOptionalRetraction);

   virtual void provideAttributeValueUpdate(rti1516_2025::ObjectInstanceHandle const & theObject,
      rti1516_2025::AttributeHandleSet const & theAttributes,
      rti1516_2025::VariableLengthData const & theUserSuppliedTag);

   virtual void timeRegulationEnabled(rti1516_2025::LogicalTime const & theFederateTime);

   virtual void timeConstrainedEnabled(rti1516_2025::LogicalTime const & theFederateTime);

   virtual void timeAdvanceGrant(rti1516_2025::LogicalTime const & theTime);

   virtual void requestRetraction(rti1516_2025::MessageRetractionHandle const & theHandle);

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

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

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

   protected:

   virtual interactionEvent::interaction_type interactionTypeFromParameterValues(rti1516_2025::ParameterHandleValueMap const& theParameterValues) const;

   public:
   DtTalkAmbData & myData;
};

#endif