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>

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

class DtTalkAmbData
{

public:
   DtTalkAmbData();
   ~DtTalkAmbData();

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

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

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

   virtual ~MyFederateAmbassador()
      throw();

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

   virtual void       synchronizationPointRegistrationSucceeded(std::wstring const & label )
      throw(rti1516e::FederateInternalError);

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

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

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

public:
   DtTalkAmbData & myData;
};

#endif