VR-Forces 4.7 Class Documentation
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
orbatSimDataProcessor.h
Go to the documentation of this file.
1 /*******************************************************************************
2 ** Copyright (c) 2014 MAK Technologies, Inc.
3 ** All rights reserved.
4 *******************************************************************************/
5 
9 
10 #pragma once
11 
12 #include <vrfVrlSharedSource/vrfProtocol.h>
13 
14 #include <vrfGuiCore/orbatState.h>
15 #include <vrvCore/DtSimEntryUpdater.h>
16 #include <vrvCore/DtSimDataProcessorInterface.h>
17 #include <vrvUtil/DtBalancedUpdater.h>
18 #include <vrvUtil/DtSignalConnectionManager.h>
19 
20 #include <vlutil/vlPerformanceStats.h>
21 
22 class DtVrfRemoteController;
23 class DtRwOrbatData;
24 
25 namespace makVrv
26 {
27  class DtSimEntryObjectAgent;
28  class DtEntityStateListener;
29 
30  namespace DT_PROTOCOL_NAMESPACE
31  {
32  class DtVrlinkConnection;
33  class DtAggregateExistenceListener;
34  class DtVrlinkAggregateStateListener;
35  class DtEntityExistenceListener;
36  class DtVrlinkEntityStateListener;
37  }
38 }
39 
40 namespace makVrf
41 {
42  class DtOrbatStateObjectAgent;
43 
44  namespace VRF_PROTOCOL_NAMESPACE
45  {
46  class DtOrbatStateListenerInterface;
47 
49  class VRF_PROTOCOL_EXPORT DtOrbatSimDataProcessor : public makVrv::DtSimDataProcessorInterface
50  {
51  public:
53  static DtOrbatSimDataProcessor* findInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);
54 
56  static void registerInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim,DtOrbatSimDataProcessor*);
57 
59  DtOrbatSimDataProcessor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim,
60  DtVrfRemoteController* remote);
61 
63  virtual ~DtOrbatSimDataProcessor();
64 
66  virtual void postDrainInput();
67 
69  virtual void setObjectUpdateRate(makVrv::DtUniqueID uniqueId, makVrv::DtSimEntryUpdater::UpdateRate rate);
70 
72  virtual void forceObjectUpdate(makVrv::DtUniqueID uniqueId);
73 
75  virtual void aggregateDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);
76 
78  virtual void aggregateToBeDeleted(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);
79 
81  virtual void entityDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& listener);
82 
84  virtual void entityToBeDeleted(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& listener);
85 
87  virtual void addOrbatListener(DtOrbatStateListenerInterface& listener);
88 
90  virtual void removeOrbatListener(DtOrbatStateListenerInterface& listener);
91 
93  virtual void createAndSendState(DtOrbatStateListenerInterface& listener,
94  DtOrbatStateObjectAgent& objectDriver);
95  virtual bool setState(DtOrbatStateListenerInterface& listener, DtOrbatState& state);
96 
97  protected:
98 
99  static void postDrainInput(void* usr);
100 
101  virtual void slot_postAggregateUpdateCallback(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener&);
102  virtual void slot_postEntityUpdateCallback(makVrv::DtEntityStateListener&);
103 
104  protected:
105 
106  //A Listener and a driver which will be updated with it.
107  class OrbatStateUpdater
108  {
109  public:
110 
111  OrbatStateUpdater(DtOrbatStateListenerInterface& listener,
112  DtOrbatStateObjectAgent& driver, DtOrbatSimDataProcessor& processor);
113 
114  OrbatStateUpdater(const OrbatStateUpdater& orig);
115 
116  OrbatStateUpdater& operator=(const OrbatStateUpdater& orig);
117 
118  //Are the updaters equal
119  bool operator==(const OrbatStateUpdater& orig) const;
120 
122  void update(double timeT);
123 
124  protected:
125 
126  DtOrbatStateListenerInterface* myListener;
127  DtOrbatStateObjectAgent* myObjectAgent;
128  DtOrbatSimDataProcessor* myProcessor;
129  };
130 
131  typedef std::set<makVrv::DtUniqueID> OrbatIdList;
132 
133  struct OrbatSimDataInstance
134  {
135  DtOrbatStateListenerInterface* myListener;
136  DtOrbatStateObjectAgent* myAgent;
137  makVrv::DtSimEntryUpdater::UpdateRate myRate;
138  };
139 
140  typedef std::map<makVrv::DtUniqueID,OrbatSimDataInstance > OrbatAgentMap;
141 
142  typedef makVrv::DtBalancedUpdater<OrbatStateUpdater> OrbatUpdaterGroup;
143  typedef std::map<makVrv::DtSimEntryUpdater::UpdateRate,OrbatUpdaterGroup>
144  OrbatUpdateGroupMap;
145 
146  protected:
147  makVrv::DtSignalConnectionManager myConnections;
148 
149  makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& mySimulation;
150  makVrv::DT_PROTOCOL_NAMESPACE::DtAggregateExistenceListener& myAggregateListener;
151  makVrv::DT_PROTOCOL_NAMESPACE::DtEntityExistenceListener& myEntityListener;
152  DtTimedSection myTimer;
153  makVrv::DtSimEntryObjectAgent* mySimEntryAgent;
154 
155  OrbatAgentMap myOrbatAgents;
156  OrbatUpdateGroupMap myRefreshRateGroups;
157  OrbatIdList myForceUpdateList;
158  DtVrfRemoteController* myRemoteController;
159  };
160 
161  class VRF_PROTOCOL_EXPORT DtOrbatSimDataProcessorCreator : public makVrv::DtVirtualBaseClass
162  {
163  public:
165  DtOrbatSimDataProcessorCreator();
166 
167  static DtOrbatSimDataProcessorCreator& instance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn);
168 
171  static void registerInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn,
172  DtOrbatSimDataProcessorCreator* instance);
173 
174  virtual DtOrbatSimDataProcessor* create(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn, DtVrfRemoteController* remote);
175  };
176  }
177 }
Document ID: Generated on Fri Apr 26 21:53:14 EDT 2019 from SVN revision 197883
Copyright © 2005-2019 VT MAK. All Rights Reserved (www.mak.com)