dRefObjList.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1992-2010 VT MAK
** All rights reserved.
*********************************************************************/



#ifndef DtDisReflectedObjectList_H_
#define DtDisReflectedObjectList_H_

#if DtDIS


#include <vlutil/vlMachineTypes.h>
#include <vlutil/vlTime.h>
#include "refObjCbInfo.h"
#include <vlutil/vlHashlist.h>

class DT_DLL_VL DtExerciseConn;
class DT_DLL_VL DtHlaObject;
class DT_DLL_VL DtStateMsg;
class DT_DLL_VL DtReflectedObject;
class DT_DLL_VL DtBaseHashKey;

typedef bool (*DtDiscoveryCondition)(DtReflectedObject* refObj, void* usr);

class DT_DLL_VL DtReflectedObjectList
{

public:

   DtReflectedObjectList(DtExerciseConn* exConn);

   virtual ~DtReflectedObjectList();

   virtual DtReflectedObject* firstObj() const;
   virtual DtReflectedObject* lastObj() const;

  virtual int count() const;

   virtual DtReflectedObject* lookupObj(const DtBaseHashKey& key) const;

   virtual DtExerciseConn* exerciseConn() const;

   virtual void addObjectAdditionCallback(
      DtReflectedObjectCallbackFunction cb, void* userData);
   virtual void removeObjectAdditionCallback(
      DtReflectedObjectCallbackFunction cb, void* userData);

   virtual void addObjectRemovalCallback(
      DtReflectedObjectCallbackFunction cb, void* userData);
   virtual void removeObjectRemovalCallback(
      DtReflectedObjectCallbackFunction cb, void* userData);

   virtual void print() const;

   virtual void setTimeoutProcessing(bool onOff);

   virtual void setTimeoutInterval(DtTime time);
   virtual DtTime timeoutInterval();

   virtual void setDiscoveryCondition(DtDiscoveryCondition fn, void* usr);

   virtual void clearDiscoveryCondition();

protected:

   DtReflectedObjectList(const DtReflectedObjectList& orig);

   DtReflectedObjectList& operator=(const DtReflectedObjectList& orig);

protected:

   virtual DtReflectedObject* newReflectedObj(const DtStateMsg& msg) = 0;

   virtual DtReflectedObject* processStateMessage(const DtStateMsg& msg);

   virtual void doTimeouts();

   virtual void removeAndDelete(DtReflectedObject* obj,
      char* msg = NULL);

   virtual void objectAdded(DtReflectedObject* object);

   virtual bool shouldBeTimedOut(DtReflectedObject* object);

   void emptyLists();
   void emptyCallbackLists();

   virtual void processObjectAdditionCallbacks(
      DtReflectedObject* object);
   virtual void processObjectRemovalCallbacks(
      DtReflectedObject* object);

   virtual const DtBaseHashKey&
      hashKeyFromStateMessage(const DtStateMsg* msg) = 0;

   virtual int acceptPdu(const DtStateMsg&) const;

  virtual bool readyToAdd(DtReflectedObject* obj);

protected:

   static void doTimeoutsPostDrainCb(void* usr);

protected:

   DtExerciseConn* myExConn;
   DtIntrusiveList myObjectAddedCallbacks;
   DtIntrusiveList myObjectRemovedCallbacks;
   DtIntrusiveList myObjectList;
   DtIntrusiveList myWaitList;
   DtHashlist myObjectHashlist;
   DtHashlist myWaitHashlist;
   DtTime myTimeoutInterval;
   bool myTimeoutProcessingFlag;
   DtDiscoveryCondition myDiscoveryCondition;
   void* myDiscoveryConditionParameter;
};

#endif   
#endif