requestDb.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1998 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: requestDb.h,v $ $Revision: 1.22 $ $State: Exp $
*********************************************************************/


#ifndef DtRequestDb
#define DtRequestDb

#include <vlutil/vlHashlist.h>
#include "attrHandSet.h"
#include "fedHandleSet.h"
#include "internalTypes.h"

#include <map>
#include <list>



class DT_DLL_LRC DtRequestDatabase
{
public:
 
   DtRequestDatabase();
   virtual ~DtRequestDatabase();

   virtual void clearAll();

   virtual void addRemoteRequest(
      const DtAttributeHandleSet& requestSet,
      DtFederateHandle fed);

   virtual void removeRemoteRequest(
      const DtAttributeHandleSet& requestSet,
      DtFederateHandle fed);

   virtual void removeRemoteRequest(
      const DtAttributeHandleSet& requestSet);

   virtual void addPendingConfirm(
      const DtAttributeHandleSet& requestSet,
      DtFederateHandle fed);

   virtual void removePendingConfirm(
      const DtAttributeHandleSet& requestSet,
      DtFederateHandle fed);


   virtual void removePendingConfirm(
      const DtAttributeHandleSet& requestSet);

   void moveRemoteRequestToPendingList(
      const DtAttributeHandleSet& requestSet );


   virtual void cancelRemoteRequest(
      const DtAttributeHandleSet& canceledSet, DtFederateHandle fed);

   virtual void cancelAllRemoteRequest(
      const DtAttributeHandleSet& canceledSet);


   virtual void removeCanceledRequests(
      const DtAttributeHandleSet& releaseSet);

   virtual bool isRequestCanceled(DtAttributeHandle hand) const;

   virtual DtAttributeHandleSet canceledRequestSet() const;

   virtual DtFederateHandle releaseRequested(
      const DtAttributeHandleSet& inSet, 
      DtAttributeHandleSet* releasedSet,
      bool keepForConfirm);

   virtual DtFederateHandle releaseConfirm(
      const DtAttributeHandleSet& inSet, 
      DtAttributeHandleSet* releasedSet);

   virtual DtFederateHandle pendingRemoteRequest(DtAttributeHandle hand) const;

   virtual DtFederateHandle pendingConfirm(DtAttributeHandle hand) const;

   virtual DtAttributeHandleSet requestedByFed(DtFederateHandle fed,
      bool includePendingConfirm=false) const;

   virtual DtAttributeHandleSet remoteRequestByFed( DtFederateHandle fed ) const;

   virtual DtAttributeHandleSet pendingConfirmByFed( DtFederateHandle fed  ) const;


   virtual int requestCount() const;

   virtual DtAttributeHandleSet const& requestedAttributes() const;

   virtual int confirmCount() const;

   virtual DtAttributeHandleSet const& pendingConfirmAttributes() const;

   virtual void markPendingRequestsUnavailable(const DtAttributeHandleSet& requestSet,
      DtFederateHandle confirmedFed );

   virtual DtFederateHandle unavailablePendingRequests( DtAttributeHandleSet* invalidatedSet );

protected:

   typedef std::map< DtAttributeHandle, DtFederateHandleSet >  DtAttrToFederatesMap;
   typedef std::map< DtFederateHandle,  DtAttributeHandleSet > DtFedToAttributesMap;

   DtAttributeHandleSet myRemoteRequestSet;

   DtAttributeHandleSet myRemoteCanceledRequestSet;
   DtAttrToFederatesMap myRemoteRequestsByAttr;

   DtAttrToFederatesMap myPendingConfirmByAttr;
   DtAttributeHandleSet myPendingConfirmSet;

   DtFedToAttributesMap myUnavailableRequestsByFed;
};



#endif