simpleTimeFedAmb13dlc.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2009 MaK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: simpleTimeFedAmb13dlc.h,v $ $Revision: 1.1 $ $State: Exp $
*******************************************************************************/

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

#include "NullFederateAmbassador13.h"
#include <map>
#include <set>
#include <string>
#include "simpleTimeTimeManagedEntity.h"



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

class DtTalkAmbData{
   
public :
   DtTalkAmbData();
   ~DtTalkAmbData();
 

public:
 std::map<rti13::ObjectClassHandle, std::string> objectClassMap;
 std::map<rti13::ObjectHandle, std::string> objectInstanceMap;
 std::map<rti13::InteractionClassHandle, std::string> interactionClassMap; 
 std::map<rti13::ObjectHandle, rti13::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;

 
 rti13::AttributeHandleValuePairSet* attrValues;
 rti13::ParameterHandleValuePairSet* paramValues;

 bool isConstrained;
 bool isRegulating;
 bool timeAdvanced;
 int otherFederatesReady;
 bool registerFailed;
 bool registerSucceeded;
 bool announceSyncReceived;
 bool federationIsSynchronized;
 timeManagedEntity timeManagedObject; 
};


class MyFederateAmbassador : public rti13::NullFederateAmbassador
{
public:

   MyFederateAmbassador(DtTalkAmbData & data);

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


   // Object Management Services //

   virtual void discoverObjectInstance (
           rti13::ObjectHandle          theObject,      // supplied C1
           rti13::ObjectClassHandle     theObjectClass, // supplied C1
     const char*                      theObjectName)  // supplied C4  
   throw (
     rti13::CouldNotDiscover,
     rti13::ObjectClassNotKnown,
     rti13::FederateInternalError);

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

   virtual void reflectAttributeValues (
           rti13::ObjectHandle                 theObject,     // supplied C1
     const rti13::AttributeHandleValuePairSet& theAttributes, // supplied C4
     const char                             *theTag)        // supplied C4
   throw (
     rti13::ObjectNotKnown,
     rti13::AttributeNotKnown,
     rti13::FederateOwnsAttributes,
     rti13::FederateInternalError);

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

   virtual void receiveInteraction (
           rti13::InteractionClassHandle       theInteraction, // supplied C1
     const rti13::ParameterHandleValuePairSet& theParameters,  // supplied C4
     const char                             *theTag)         // supplied C4
   throw (
     rti13::InteractionClassNotKnown,
     rti13::InteractionParameterNotKnown,
     rti13::FederateInternalError);

   virtual void removeObjectInstance (
           rti13::ObjectHandle          theObject, // supplied C1
     const rti13::FedTime&              theTime,   // supplied C4
     const char                      *theTag,    // supplied C4
           rti13::EventRetractionHandle theHandle) // supplied C1
   throw (
     rti13::ObjectNotKnown,
     rti13::InvalidFederationTime,
     rti13::FederateInternalError);

   virtual void removeObjectInstance (
           rti13::ObjectHandle          theObject, // supplied C1
     const char                      *theTag)    // supplied C4
   throw (
     rti13::ObjectNotKnown,
     rti13::FederateInternalError);

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

virtual void timeRegulationEnabled (
 const  rti13::FedTime& theFederateTime) // supplied C4
throw (
  rti13::InvalidFederationTime,
  rti13::EnableTimeRegulationWasNotPending,
  rti13::FederateInternalError);

virtual void timeConstrainedEnabled (
  const rti13::FedTime& theFederateTime) // supplied C4
throw (
  rti13::InvalidFederationTime,
  rti13::EnableTimeConstrainedWasNotPending,
  rti13::FederateInternalError);

virtual void timeAdvanceGrant (
  const rti13::FedTime& theTime) // supplied C4
throw (
  rti13::InvalidFederationTime,
  rti13::TimeAdvanceWasNotInProgress,
  rti13::FederateInternalError);

virtual void synchronizationPointRegistrationSucceeded (
  const char *label) // supplied C4)
throw (
  rti13::FederateInternalError);


virtual void synchronizationPointRegistrationFailed (
  const char *label) // supplied C4)
throw (
  rti13::FederateInternalError);

virtual void announceSynchronizationPoint (
  const char *label, // supplied C4
  const char *tag)   // supplied C4
throw (
  rti13::FederateInternalError);

virtual void federationSynchronized (
  const char *label) // supplied C4)
throw (
  rti13::FederateInternalError);
 

public:
   DtTalkAmbData & myData;
};