reflectedObjectList.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2014 VT MAK
 * All rights reserved.
 ****************************************************************************/


#if DtTENA

#pragma once

#include <vlTena/reflectedObjectCallbackInfo.h>
#include <vlutil/vlMachineTypes.h>
#include <vlutil/vlHashlist.h>
#include <vlutil/vlString.h>
#include <vlutil/vlTime.h>
#include <vlutil/vlList.h>
#include <vector>

namespace MAKVrExchange
{

   namespace DtTenaBroker
   {

      class DtExerciseConn;
      class DtReflectedObject;

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

      typedef DtReflectedObject* (*DtCreateReflectedObjFn)( DtExerciseConn* );

      class DT_DLL_VLTENA DtReflectedObjectList
      {
      public:

         DtReflectedObjectList( DtExerciseConn* exConn );

         virtual ~DtReflectedObjectList();

         virtual DtExerciseConn* exerciseConn() const;

         virtual void print();

         virtual void setTimeoutProcessing( bool on );

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

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

         virtual int count() const;

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

         virtual void clearDiscoveryCondition();

         virtual void setReflectedObjectCreationFunction(
            DtCreateReflectedObjFn fn);

         virtual void setUseTenaTimeForSets(bool yesNo);

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

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

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

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

      protected:

         static void objectAdditionCallback(DtReflectedObject *obj, void *userData);

         static void objectRemovalCallback(DtReflectedObject *obj, void *userData);

         virtual void processObjectAddition(DtReflectedObject *);

         virtual void processObjectRemoval(DtReflectedObject *);

         virtual void objectAdded(DtReflectedObject* object);

         void init(const std::vector<DtString>& interfaceNames);

      private:

         DtReflectedObjectList(const DtReflectedObjectList& orig);

         DtReflectedObjectList& operator=(const DtReflectedObjectList& orig);

      protected:

         std::vector<DtString> myInterfaceNames;
         DtExerciseConn* myExConn;
         DtTime myTimeoutInterval;
         bool myTimeoutProcessingFlag;
         DtIntrusiveList myObjectList;

      };

   }
}

#endif