VR-Exchange 2.6 API Documentation
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
environmentProcessInterface.h
Go to the documentation of this file.
1 /****************************************************************************
2  * Copyright (c) 2013 VT MAK
3  * All rights reserved.
4  ****************************************************************************/
5 
9 
10 #if DtTENA
11 
12 #pragma once
13 
14 #include <vlutil/vlMachineTypes.h>
15 #include <makLromMapper/makLromMapExport.h>
16 #include <vlTena/objectInterface.h>
17 #include <vl/globalObjectDesignator.h>
18 #include <vl/environmentProcessRepository.h>
19 
20 #include <MAK/EnvironmentProcess/ServantPtr.h>
21 #include <MAK/EnvironmentProcess/ProxyPtr.h>
22 #include <MAK/EnvironmentProcess/ImmutablePublicationStatePtr.h>
23 #include <MAK/EnvironmentProcess/SubscriptionInfoPtr.h>
24 
25 #include <list>
26 #include <map>
27 
28 namespace MAKVrExchange
29 {
30 
31  namespace DtTenaBroker
32  {
33 
40  class DT_DLL_MAKLROM DtEnvironmentProcessInterface: public DtObjectInterface
41  {
42  protected:
43 
46  class DtEnvironmentProcessServantObject : public DtTenaServantObject
47  {
48  public:
49 
51  DtEnvironmentProcessServantObject( MAK::EnvironmentProcess::ServantPtr sp):myServantPtr(sp){}
52 
54  virtual ~DtEnvironmentProcessServantObject() {}
55 
57  virtual const MAK::EnvironmentProcess::ServantPtr servant() const { return myServantPtr;}
58 
60  virtual MAK::EnvironmentProcess::ServantPtr servant() { return myServantPtr;}
61 
62  protected:
63 
64  MAK::EnvironmentProcess::ServantPtr myServantPtr;
65 
66  };
67 
68  public:
69 
71  DtEnvironmentProcessInterface(DtExerciseConn* exConn);
72 
74  virtual ~DtEnvironmentProcessInterface();
75 
78  virtual DtTenaServantObject* createServantObject(DtExerciseConn* exConn);
79 
81  virtual void processServantCleanup(DtTenaServantObject* servantObject);
82 
84  virtual void subscribe();
85 
87  virtual bool needUpdate(const DtStateRepository& stateRep,
88  const DtStateRepository& asSeenByRemote,
89  bool useThresholding = true);
90 
92  virtual void decode(const DtTenaServantObject* servant,
93  DtStateRepository* stateRep)const;
94 
96  virtual void encode(DtTenaServantObject* servant,
97  const DtStateRepository* stateRep,
98  TENA::Time::Pointer timeForStamping,
99  bool forceUpdate = false);
100 
102  virtual DtReflectedObject *createReflectedObject()const;
103 
105  virtual void processAddition(MAK::EnvironmentProcess::ProxyPtr const &proxy);
106 
108  virtual void processUpdate(MAK::EnvironmentProcess::ProxyPtr const &proxy);
109 
111  virtual void processRemoval(MAK::EnvironmentProcess::ProxyPtr const &proxy);
112 
113  protected:
114 
116  virtual void decode(const MAK::EnvironmentProcess::ImmutablePublicationStatePtr pubStatePtr,
117  DtStateRepository* stateRep)const;
118 
119  private:
120 
122  DtEnvironmentProcessInterface(const DtEnvironmentProcessInterface &other);
123 
125  DtEnvironmentProcessInterface& operator=(const DtEnvironmentProcessInterface &other);
126 
127  protected:
128 
130  MAK::EnvironmentProcess::SubscriptionInfoPtr mySubscriptionInfoPtr;
131  typedef std::map<MAK::EnvironmentProcess::ProxyPtr,DtReflectedObject*> ProxyToRefObjMap;
132  ProxyToRefObjMap myRefEnvironmentProcessMap;
133  ProxyToRefObjMap myEnvProcWaitList;
134 
135  };
136 
137  }
138 }
139 
140 #endif // DtTENA
Document ID: Generated on Wed Jan 30 18:15:18 EST 2019 from SVN revision 195534
Copyright © 2005-2019 VT MÄK. All Rights Reserved (www.mak.com)