14 #include <vlutil/vlMachineTypes.h>
17 #include <vl/globalObjectDesignator.h>
18 #include <vl/environmentProcessRepository.h>
20 #include <MAK/EnvironmentProcess/ServantPtr.h>
21 #include <MAK/EnvironmentProcess/ProxyPtr.h>
22 #include <MAK/EnvironmentProcess/ImmutablePublicationStatePtr.h>
23 #include <MAK/EnvironmentProcess/SubscriptionInfoPtr.h>
31 namespace DtTenaBroker
40 class DT_DLL_MAKLROM DtEnvironmentProcessInterface:
public DtObjectInterface
46 class DtEnvironmentProcessServantObject :
public DtTenaServantObject
51 DtEnvironmentProcessServantObject( MAK::EnvironmentProcess::ServantPtr sp):myServantPtr(sp){}
54 virtual ~DtEnvironmentProcessServantObject() {}
57 virtual const MAK::EnvironmentProcess::ServantPtr servant()
const {
return myServantPtr;}
60 virtual MAK::EnvironmentProcess::ServantPtr servant() {
return myServantPtr;}
64 MAK::EnvironmentProcess::ServantPtr myServantPtr;
71 DtEnvironmentProcessInterface(DtExerciseConn* exConn);
74 virtual ~DtEnvironmentProcessInterface();
78 virtual DtTenaServantObject* createServantObject(DtExerciseConn* exConn);
81 virtual void processServantCleanup(DtTenaServantObject* servantObject);
84 virtual void subscribe();
87 virtual bool needUpdate(
const DtStateRepository& stateRep,
88 const DtStateRepository& asSeenByRemote,
89 bool useThresholding =
true);
92 virtual void decode(
const DtTenaServantObject* servant,
93 DtStateRepository* stateRep)
const;
96 virtual void encode(DtTenaServantObject* servant,
97 const DtStateRepository* stateRep,
98 TENA::Time::Pointer timeForStamping,
99 bool forceUpdate =
false);
102 virtual DtReflectedObject *createReflectedObject()
const;
105 virtual void processAddition(MAK::EnvironmentProcess::ProxyPtr
const &proxy);
108 virtual void processUpdate(MAK::EnvironmentProcess::ProxyPtr
const &proxy);
111 virtual void processRemoval(MAK::EnvironmentProcess::ProxyPtr
const &proxy);
116 virtual void decode(
const MAK::EnvironmentProcess::ImmutablePublicationStatePtr pubStatePtr,
117 DtStateRepository* stateRep)
const;
122 DtEnvironmentProcessInterface(
const DtEnvironmentProcessInterface &other);
125 DtEnvironmentProcessInterface& operator=(
const DtEnvironmentProcessInterface &other);
130 MAK::EnvironmentProcess::SubscriptionInfoPtr mySubscriptionInfoPtr;
131 typedef std::map<MAK::EnvironmentProcess::ProxyPtr,DtReflectedObject*> ProxyToRefObjMap;
132 ProxyToRefObjMap myRefEnvironmentProcessMap;
133 ProxyToRefObjMap myEnvProcWaitList;