simpleTimeFedAmb13.h

Go to the documentation of this file.

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

#pragma once
#pragma warning(disable: 4786)
#pragma warning(disable: 4290)

#include "NullFederateAmbassador.hh"
#include <map>
#include <set>
#include <string>
#include "simpleTimeTimeManagedEntity.h"


// Map between strings and attribute handles
typedef std::map<std::string, RTI::AttributeHandle>  DtAttrNameHandleMap;
typedef std::map<std::string, RTI::ParameterHandle> DtParamNameHandleMap;

class DtTalkAmbData
{

   public :
      DtTalkAmbData();
      ~DtTalkAmbData();


   public:
    std::map<RTI::ObjectClassHandle, std::string> objectClassMap;
    std::map<RTI::ObjectHandle, std::string> objectInstanceMap;
    std::map<RTI::InteractionClassHandle, std::string> interactionClassMap;
    std::map<RTI::ObjectHandle, RTI::AttributeHandleSet*> updateRequestMap;

    // Map between strings and attribute handles
    DtAttrNameHandleMap theAttrNameHandleMap;

    // Map between strings and attribute handles
    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;

    RTI::AttributeHandleValuePairSet* attrValues;
    RTI::ParameterHandleValuePairSet* paramValues;

    bool isConstrained;
    bool isRegulating;
    bool timeAdvanced;
    RTI::FedTime* time;
    int otherFederatesReady;
    bool registerFailed;
    bool registerSucceeded;
    bool announceSyncReceived;
    bool federationIsSynchronized;
    timeManagedEntity timeManagedObject;
};


class MyFederateAmbassador : public NullFederateAmbassador
{
public:

   MyFederateAmbassador(DtTalkAmbData & data);

   virtual ~MyFederateAmbassador()
     throw (RTI::FederateInternalError);

   virtual void discoverObjectInstance (
           RTI::ObjectHandle          theObject,
           RTI::ObjectClassHandle     theObjectClass,
     const char*                      theObjectName)
   throw (
     RTI::CouldNotDiscover,
     RTI::ObjectClassNotKnown,
     RTI::FederateInternalError);

   virtual void reflectAttributeValues (
           RTI::ObjectHandle                 theObject,
     const RTI::AttributeHandleValuePairSet& theAttributes,
     const RTI::FedTime&                     theTime,
     const char                             *theTag,
           RTI::EventRetractionHandle        theHandle)
   throw (
     RTI::ObjectNotKnown,
     RTI::AttributeNotKnown,
     RTI::FederateOwnsAttributes,
     RTI::InvalidFederationTime,
     RTI::FederateInternalError);

   virtual void reflectAttributeValues (
           RTI::ObjectHandle                 theObject,
     const RTI::AttributeHandleValuePairSet& theAttributes,
     const char                             *theTag)
   throw (
     RTI::ObjectNotKnown,
     RTI::AttributeNotKnown,
     RTI::FederateOwnsAttributes,
     RTI::FederateInternalError);

   // 4.6
   virtual void receiveInteraction (
           RTI::InteractionClassHandle       theInteraction,
     const RTI::ParameterHandleValuePairSet& theParameters,
     const RTI::FedTime&                     theTime,
     const char                             *theTag,
           RTI::EventRetractionHandle        theHandle)
   throw (
     RTI::InteractionClassNotKnown,
     RTI::InteractionParameterNotKnown,
     RTI::InvalidFederationTime,
     RTI::FederateInternalError);

   virtual void receiveInteraction (
           RTI::InteractionClassHandle       theInteraction,
     const RTI::ParameterHandleValuePairSet& theParameters,
     const char                             *theTag)
   throw (
     RTI::InteractionClassNotKnown,
     RTI::InteractionParameterNotKnown,
     RTI::FederateInternalError);

   virtual void removeObjectInstance (
           RTI::ObjectHandle          theObject,
     const RTI::FedTime&              theTime,
     const char                      *theTag,
           RTI::EventRetractionHandle theHandle)
   throw (
     RTI::ObjectNotKnown,
     RTI::InvalidFederationTime,
     RTI::FederateInternalError);

   virtual void removeObjectInstance (
           RTI::ObjectHandle          theObject,
     const char                      *theTag)
   throw (
     RTI::ObjectNotKnown,
     RTI::FederateInternalError);

   virtual void provideAttributeValueUpdate (
           RTI::ObjectHandle        theObject,
     const RTI::AttributeHandleSet& theAttributes)
   throw (
     RTI::ObjectNotKnown,
     RTI::AttributeNotKnown,
     RTI::AttributeNotOwned,
     RTI::FederateInternalError);

   virtual void timeRegulationEnabled (
    const  RTI::FedTime& theFederateTime)
   throw (
     RTI::InvalidFederationTime,
     RTI::EnableTimeRegulationWasNotPending,
     RTI::FederateInternalError);

   virtual void timeConstrainedEnabled (
     const RTI::FedTime& theFederateTime)
   throw (
     RTI::InvalidFederationTime,
     RTI::EnableTimeConstrainedWasNotPending,
     RTI::FederateInternalError);

   virtual void timeAdvanceGrant (
     const RTI::FedTime& theTime)
   throw (
     RTI::InvalidFederationTime,
     RTI::TimeAdvanceWasNotInProgress,
     RTI::FederateInternalError);

   virtual void synchronizationPointRegistrationSucceeded (
     const char *label)
   throw (
     RTI::FederateInternalError);


   virtual void synchronizationPointRegistrationFailed (
     const char *label)
   throw (
     RTI::FederateInternalError);

   virtual void announceSynchronizationPoint (
     const char *label,
     const char *tag)
   throw (
     RTI::FederateInternalError);

   virtual void federationSynchronized (
     const char *label)
   throw (
     RTI::FederateInternalError);

public:
   DtTalkAmbData & myData;
};