3 #include <simgear/debug/logstream.hxx>
4 #include <simgear/misc/exception.hxx>
7 #include "fg_props.hxx"
11 ////////////////////////////////////////////////////////////////////////
12 // Implementation of FGSubsystem
13 ////////////////////////////////////////////////////////////////////////
16 FGSubsystem::FGSubsystem ()
21 FGSubsystem::~FGSubsystem ()
31 FGSubsystem::reinit ()
41 FGSubsystem::unbind ()
46 FGSubsystem::suspend ()
52 FGSubsystem::suspend (bool suspended)
54 _suspended = suspended;
58 FGSubsystem::resume ()
64 FGSubsystem::is_suspended () const
66 if (!_freeze_master_node.valid())
67 _freeze_master_node = fgGetNode("/sim/freeze/master", true);
68 return _suspended || _freeze_master_node->getBoolValue();
73 ////////////////////////////////////////////////////////////////////////
74 // Implementation of FGSubsystemGroup.
75 ////////////////////////////////////////////////////////////////////////
77 FGSubsystemGroup::FGSubsystemGroup ()
81 FGSubsystemGroup::~FGSubsystemGroup ()
83 for (int i = 0; i < _members.size(); i++)
88 FGSubsystemGroup::init ()
90 for (int i = 0; i < _members.size(); i++)
91 _members[i]->subsystem->init();
95 FGSubsystemGroup::reinit ()
97 for (int i = 0; i < _members.size(); i++)
98 _members[i]->subsystem->reinit();
102 FGSubsystemGroup::bind ()
104 for (int i = 0; i < _members.size(); i++)
105 _members[i]->subsystem->bind();
109 FGSubsystemGroup::unbind ()
111 for (int i = 0; i < _members.size(); i++)
112 _members[i]->subsystem->unbind();
116 FGSubsystemGroup::update (double delta_time_sec)
118 if (!is_suspended()) {
119 for (int i = 0; i < _members.size(); i++)
120 _members[i]->update(delta_time_sec); // indirect call
125 FGSubsystemGroup::suspend ()
127 FGSubsystem::suspend();
128 for (int i = 0; i < _members.size(); i++)
129 _members[i]->subsystem->suspend();
133 FGSubsystemGroup::resume ()
135 FGSubsystem::resume();
136 for (int i = 0; i < _members.size(); i++)
137 _members[i]->subsystem->resume();
141 FGSubsystemGroup::is_suspended () const
143 return FGSubsystem::is_suspended();
147 FGSubsystemGroup::set_subsystem (const string &name, FGSubsystem * subsystem,
150 Member * member = get_member(name, true);
151 if (member->subsystem != 0)
152 delete member->subsystem;
154 member->subsystem = subsystem;
155 member->min_step_sec = min_step_sec;
159 FGSubsystemGroup::get_subsystem (const string &name)
161 Member * member = get_member(name);
163 return member->subsystem;
169 FGSubsystemGroup::remove_subsystem (const string &name)
171 for (int i = 0; i < _members.size(); i++) {
172 if (name == _members[i]->name) {
173 _members.erase(_members.begin() + i);
180 FGSubsystemGroup::has_subsystem (const string &name) const
182 return (((FGSubsystemGroup *)this)->get_member(name) != 0);
185 FGSubsystemGroup::Member *
186 FGSubsystemGroup::get_member (const string &name, bool create)
188 for (int i = 0; i < _members.size(); i++) {
189 if (_members[i]->name == name)
193 Member * member = new Member;
194 _members.push_back(member);
203 ////////////////////////////////////////////////////////////////////////
204 // Implementation of FGSubsystemGroup::Member
205 ////////////////////////////////////////////////////////////////////////
208 FGSubsystemGroup::Member::Member ()
216 FGSubsystemGroup::Member::Member (const Member &)
221 FGSubsystemGroup::Member::~Member ()
223 // FIXME: causes a crash
228 FGSubsystemGroup::Member::update (double delta_time_sec)
230 elapsed_sec += delta_time_sec;
231 if (elapsed_sec >= min_step_sec) {
232 subsystem->update(delta_time_sec);
233 elapsed_sec -= min_step_sec;
239 ////////////////////////////////////////////////////////////////////////
240 // Implementation of FGSubsystemMgr.
241 ////////////////////////////////////////////////////////////////////////
244 FGSubsystemMgr::FGSubsystemMgr ()
248 FGSubsystemMgr::~FGSubsystemMgr ()
253 FGSubsystemMgr::init ()
255 for (int i = 0; i < MAX_GROUPS; i++)
260 FGSubsystemMgr::reinit ()
262 for (int i = 0; i < MAX_GROUPS; i++)
267 FGSubsystemMgr::bind ()
269 for (int i = 0; i < MAX_GROUPS; i++)
274 FGSubsystemMgr::unbind ()
276 for (int i = 0; i < MAX_GROUPS; i++)
281 FGSubsystemMgr::update (double delta_time_sec)
283 if (!is_suspended()) {
284 for (int i = 0; i < MAX_GROUPS; i++)
285 _groups[i].update(delta_time_sec);
290 FGSubsystemMgr::suspend ()
292 FGSubsystem::suspend();
293 for (int i = 0; i < MAX_GROUPS; i++)
294 _groups[i].suspend();
298 FGSubsystemMgr::resume ()
300 FGSubsystem::resume();
301 for (int i = 0; i < MAX_GROUPS; i++)
306 FGSubsystemMgr::is_suspended () const
308 return FGSubsystem::is_suspended();
312 FGSubsystemMgr::add (const char * name, FGSubsystem * subsystem,
313 GroupType group, double min_time_sec)
315 SG_LOG(SG_GENERAL, SG_INFO, "Adding subsystem " << name);
316 get_group(group)->set_subsystem(name, subsystem, min_time_sec);
318 if (_subsystem_map.find(name) != _subsystem_map.end()) {
319 SG_LOG(SG_GENERAL, SG_ALERT, "Adding duplicate subsystem " << name);
320 throw sg_exception("duplicate subsystem");
322 _subsystem_map[name] = subsystem;
326 FGSubsystemMgr::get_group (GroupType group)
328 return &(_groups[group]);
332 FGSubsystemMgr::get_subsystem (const string &name)
334 map<string,FGSubsystem *>::iterator s =_subsystem_map.find(name);
336 if (s == _subsystem_map.end())