federationPub.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2001 MAK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: federationPub.h,v $ $Revision: 1.14 $ $State: Exp $
*********************************************************************/
#ifdef DtMOM

#ifndef DtMomFederationPublisher_H_
#define DtMomFederationPublisher_H_

#include "momPublisher.h"

class DtMomFederationSR;
class DtMomInspector;
namespace MAKRti
{
   class DtOMTTree;
};

class DT_DLL_LRC DtMomFederationPublisher : public DtMomPublisher
{
public:

   DtMomFederationPublisher(DtConnectionMgr* connMgrPtr, DtFomClassMgr* fomPtr,
      DtObjectMgr* objMgrPtr, DtMomInspector* servicePtr);

   virtual ~DtMomFederationPublisher();

   virtual void designate();

   virtual void updateAutoProvide();

   virtual void updateLastSave();

   virtual void updateNextSave();

   virtual void updateFederatesInFederation();

   virtual void setFomsInFederation(const std::vector<MAKRti::DtString> & foms);

   virtual void tick();

   virtual void setSubscribedToCurrentFdd(bool subscribeStatus);
   virtual bool subscribedToCurrentFdd() const;

   virtual void forceUpdate(const DtAttributeHandleSet& set);

   virtual bool hasCurrentFdd(const DtAttributeHandleSet& attrs) const;
   virtual bool isAttributeHandleCurrentFdd(DtAttributeHandle handle) const;
   
   virtual void setNeedFomUpdateFromRtiexec(bool needUpdate=true);

   MAKRti::DtOMTTree* readFiles(const std::vector<MAKRti::DtString>& fedFileName);

protected:

   DtMomFederationPublisher(const DtMomFederationPublisher& orig);
 
   DtMomFederationPublisher& operator=(const DtMomFederationPublisher& orig);

protected:

   DtMomFederationSR* myFederationSR;
   bool myAutoProvide;
   MAKRti::DtString myLastSaveName;
   MAKRti::DtString myNextSaveName;
#ifdef DtIFSPEC1516
   std::auto_ptr<rti1516::LogicalTime> myTime;
   std::auto_ptr<rti1516::LogicalTime> myLastSaveTime;
   std::auto_ptr<rti1516::LogicalTime> myNextSaveTime;
#elif defined(DtIFSPEC1516E)
   std::auto_ptr<rti1516e::LogicalTime> myTime;
   std::auto_ptr<rti1516e::LogicalTime> myLastSaveTime;
   std::auto_ptr<rti1516e::LogicalTime> myNextSaveTime;
#else
   std::auto_ptr<RTI::FedTime> myTime;
   std::auto_ptr<RTI::FedTime> myLastSaveTime;
   std::auto_ptr<RTI::FedTime> myNextSaveTime;

#endif

   bool mySubscribedToCurrentFdd;
   bool myNeedFomUpdateFromRti;
   bool myWaitingForFomUpdate;
   bool myUpdateConditionForCurrentFDD;

   std::vector<DtAttributeHandleSet> myPendingCurrentFddRequests;

};

#endif
#endif