VR-Forces 4.3 Class Documentation
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
aggregateSimDataProcessor.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/aggregateState.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 DtAggregateStateRepository;
23 class DtVrfRemoteController;
24 
25 namespace makVrv
26 {
27  class DtSimEntryObjectAgent;
28 
29  namespace DT_PROTOCOL_NAMESPACE
30  {
31  class DtVrlinkConnection;
32  class DtAggregateExistenceListener;
33  class DtVrlinkAggregateStateListener;
34  }
35 }
36 
37 namespace makVrf
38 {
39  class DtAggregateStateObjectAgent;
40 
41  namespace VRF_PROTOCOL_NAMESPACE
42  {
43 
45  class VRF_PROTOCOL_EXPORT DtAggregateSimDataProcessor : public makVrv::DtSimDataProcessorInterface
46  {
47  public:
49  static DtAggregateSimDataProcessor* findInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);
50 
52  static void registerInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim,DtAggregateSimDataProcessor*);
53 
55  DtAggregateSimDataProcessor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim,
56  DtVrfRemoteController* remote);
57 
59  virtual ~DtAggregateSimDataProcessor();
60 
62  void postDrainInput();
63 
65  void setObjectUpdateRate(makVrv::DtUniqueID uniqueId, makVrv::DtSimEntryUpdater::UpdateRate rate);
66 
68  void forceObjectUpdate(makVrv::DtUniqueID uniqueId);
69 
71  void aggregateDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);
72 
74  void aggregateToBeDeleted(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);
75 
77  virtual void createAndSendState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener,
78  DtAggregateStateObjectAgent& objectDriver, bool forceUpdate = false);
79  virtual bool setState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener,
80  DtVrlinkNetworkUpdateSimulatedAggregateState& state, const DtRwProperties& stateProperties,
81  bool forceStatePropertyUpdate = false);
82 
83  protected:
84 
85  static void postDrainInput(void* usr);
86 
87  virtual void slot_postUpdateCallback(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener&);
88  virtual void slot_damageStateSet(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener*);
89 
90  virtual void slot_modelSetChanged();
91 
92  virtual bool updateState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener, bool forceUpdate = false);
93  virtual bool updateExtendedState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);
94 
95  protected:
96 
97  //A Listener and a driver which will be updated with it.
98  class AggregateStateUpdater
99  {
100  public:
101 
102  AggregateStateUpdater(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener,
103  DtAggregateStateObjectAgent& driver, DtAggregateSimDataProcessor& processor);
104 
105  AggregateStateUpdater(const AggregateStateUpdater& orig);
106 
107  AggregateStateUpdater& operator=(const AggregateStateUpdater& orig);
108 
109  //Are the updaters equal
110  bool operator==(const AggregateStateUpdater& orig) const;
111 
113  void update(double timeT);
114 
115  protected:
116 
117  makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener* myListener;
118  DtAggregateStateObjectAgent* myObjectAgent;
119  DtAggregateSimDataProcessor* myProcessor;
120  };
121 
122  typedef std::set<makVrv::DtUniqueID> AggregateIdList;
123 
124  struct AggregateSimDataInstance
125  {
126  makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener* myListener;
127  DtAggregateStateObjectAgent* myAgent;
128  makVrv::DtSimEntryUpdater::UpdateRate myRate;
129  };
130 
131  typedef std::map<makVrv::DtUniqueID,AggregateSimDataInstance > AggregateAgentMap;
132 
133  typedef makVrv::DtBalancedUpdater<AggregateStateUpdater> AggregateUpdaterGroup;
134  typedef std::map<makVrv::DtSimEntryUpdater::UpdateRate,AggregateUpdaterGroup>
135  AggregateUpdateGroupMap;
136 
137  protected:
138  makVrv::DtSignalConnectionManager myConnections;
139 
140  makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& mySimulation;
141  makVrv::DT_PROTOCOL_NAMESPACE::DtAggregateExistenceListener& myListener;
142  DtTimedSection myTimer;
143  makVrv::DtSimEntryObjectAgent* mySimEntryAgent;
144 
145  AggregateAgentMap myAggregateAgents;
146  AggregateUpdateGroupMap myRefreshRateGroups;
147  AggregateIdList myForceUpdateList;
148  DtVrfRemoteController* myRemoteController;
149 
150  typedef boost::unordered_map<makVrv::DtUniqueID, DtVrlinkNetworkUpdateSimulatedAggregateState> AggregateStates;
151  AggregateStates myAggregateStates;
152 
154  typedef std::map<std::string, std::pair<DtRwProperties*, int> > BaseStateMap;
155  BaseStateMap myBaseStateMap;
156 
157  std::map<makVrv::DtUniqueID, DtString> myExtendedLabels;
158  std::map<makVrv::DtUniqueID, bool> myNeedsForcedUpdate;
159 
160  std::string myLastMarkingText;
161  };
162  }
163 }
Document ID: Generated on Wed Mar 11 21:20:57 EDT 2015 from SVN revision 150940
Copyright © 2005-2014 VT MÄK. All Rights Reserved (www.mak.com)