fedAmbCallbackQueue13.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2007 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: fedAmbCallbackQueue13.h,v $ $Revision: 1.4 $ $State: Exp $
*********************************************************************/

#ifndef DtFedAmbCallbackQueue13_h
#define DtDtFedAmbCallbackQueue13_h
#ifdef DtIFSPEC13


#include <queue>
#include "fedAmbWrap.h"
#include "rtiMsg.h"

typedef std::queue<DtRtiMsg*> DtFedAmbMsgQueue;

class DtFederateMgr;
class DtFedAmbCallbackMsg;

class DT_DLL_LRC DtCallbackQueue : public DtFedAmbWrapper
{
public:

   DtCallbackQueue(DtFederateMgr* fedMgr = 0);

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

private:
   DtCallbackQueue(DtCallbackQueue const& orig);
   DtCallbackQueue& operator = (DtCallbackQueue const& orig);

public:

   virtual void enableQueue();

   virtual void disableQueue();

   MAKRti::DtString const& name() const;

   virtual DtRtiMsg* popMessage();

   virtual bool isEmpty();


   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);  

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

   virtual void federationSaved () throw (RTI::FederateInternalError);

   virtual void federationNotSaved () throw (RTI::FederateInternalError);

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

   virtual void requestFederationRestoreFailed (
      const char *label,
      const char *reason) throw (RTI::FederateInternalError);  

   virtual void federationRestoreBegun () throw (RTI::FederateInternalError);

   virtual void initiateFederateRestore (
      const char *label, 
      RTI::FederateHandle handle) throw (RTI::FederateInternalError); 

   virtual void federationRestored () throw (RTI::FederateInternalError);

   virtual void federationNotRestored () throw (RTI::FederateInternalError);


   virtual void startRegistrationForObjectClass (
      RTI::ObjectClassHandle theClass) throw (RTI::FederateInternalError); 

   virtual void stopRegistrationForObjectClass (
      RTI::ObjectClassHandle theClass) throw (RTI::FederateInternalError); 

   virtual void turnInteractionsOn (
      RTI::InteractionClassHandle theHandle) throw (RTI::FederateInternalError); 

   virtual void turnInteractionsOff (
      RTI::InteractionClassHandle theHandle) throw (RTI::FederateInternalError); 


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

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

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

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

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

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

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

   virtual void attributesInScope (
      RTI::ObjectHandle theObject, 
      const RTI::AttributeHandleSet& theAttributes) throw (RTI::FederateInternalError); 

   virtual void attributesOutOfScope (
      RTI::ObjectHandle theObject, 
      const RTI::AttributeHandleSet& theAttributes) throw (RTI::FederateInternalError); 

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

   virtual void turnUpdatesOnForObjectInstance (
      RTI::ObjectHandle theObject, 
      const RTI::AttributeHandleSet& theAttributes) throw (RTI::FederateInternalError); 

   virtual void turnUpdatesOffForObjectInstance (
      RTI::ObjectHandle theObject, 
      const RTI::AttributeHandleSet& theAttributes) throw (RTI::FederateInternalError); 


   virtual void requestAttributeOwnershipAssumption (
      RTI::ObjectHandle theObject, 
      const RTI::AttributeHandleSet& offeredAttributes, 
      const char *theTag) throw (RTI::FederateInternalError); 

   virtual void attributeOwnershipDivestitureNotification (
      RTI::ObjectHandle theObject, 
      const RTI::AttributeHandleSet& releasedAttributes) throw (RTI::FederateInternalError); 

   virtual void attributeOwnershipAcquisitionNotification (
      RTI::ObjectHandle theObject, 
      const RTI::AttributeHandleSet& securedAttributes) throw (RTI::FederateInternalError); 

   virtual void attributeOwnershipUnavailable (
      RTI::ObjectHandle theObject, 
      const RTI::AttributeHandleSet& theAttributes) throw (RTI::FederateInternalError); 

   virtual void requestAttributeOwnershipRelease (
      RTI::ObjectHandle theObject, 
      const RTI::AttributeHandleSet& candidateAttributes, 
      const char *theTag) throw (RTI::FederateInternalError); 

   virtual void confirmAttributeOwnershipAcquisitionCancellation (
      RTI::ObjectHandle theObject, 
      const RTI::AttributeHandleSet& theAttributes) throw (RTI::FederateInternalError); 

   virtual void informAttributeOwnership (
      RTI::ObjectHandle theObject, 
      RTI::AttributeHandle theAttribute, 
      RTI::FederateHandle theOwner) throw (RTI::FederateInternalError); 

   virtual void attributeIsNotOwned (
      RTI::ObjectHandle theObject, 
      RTI::AttributeHandle theAttribute) throw (RTI::FederateInternalError); 

   virtual void attributeOwnedByRTI (
      RTI::ObjectHandle theObject, 
      RTI::AttributeHandle theAttribute) throw (RTI::FederateInternalError); 


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

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

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

   virtual void requestRetraction (
      RTI::EventRetractionHandle theHandle) throw (RTI::FederateInternalError); 

protected:

   virtual DtRtiApiUniquePtrTime copyTime(RTI::FedTime const& timeValue);

   virtual void queueCallback(DtFedAmbCallbackMsg* callbackMsg, bool stampWithFedex = true);

protected:

   DtFederateMgr* myFedMgr;
   DtFedAmbMsgQueue myFedAmbQueue;
   bool myQueueCallback;
   const MAKRti::DtString myName;

};

#endif 
#endif