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 (unsigned int i = 0; i < _members.size(); i++)
88 FGSubsystemGroup::init ()
90 for (unsigned int i = 0; i < _members.size(); i++)
91 _members[i]->subsystem->init();
95 FGSubsystemGroup::reinit ()
97 for (unsigned int i = 0; i < _members.size(); i++)
98 _members[i]->subsystem->reinit();
102 FGSubsystemGroup::bind ()
104 for (unsigned int i = 0; i < _members.size(); i++)
105 _members[i]->subsystem->bind();
109 FGSubsystemGroup::unbind ()
111 for (unsigned int i = 0; i < _members.size(); i++)
112 _members[i]->subsystem->unbind();
116 FGSubsystemGroup::update (double delta_time_sec)
118 for (unsigned int i = 0; i < _members.size(); i++)
119 _members[i]->update(delta_time_sec); // indirect call
123 FGSubsystemGroup::suspend ()
125 for (unsigned int i = 0; i < _members.size(); i++)
126 _members[i]->subsystem->suspend();
130 FGSubsystemGroup::resume ()
132 for (unsigned int i = 0; i < _members.size(); i++)
133 _members[i]->subsystem->resume();
137 FGSubsystemGroup::is_suspended () const
143 FGSubsystemGroup::set_subsystem (const string &name, FGSubsystem * subsystem,
146 Member * member = get_member(name, true);
147 if (member->subsystem != 0)
148 delete member->subsystem;
150 member->subsystem = subsystem;
151 member->min_step_sec = min_step_sec;
155 FGSubsystemGroup::get_subsystem (const string &name)
157 Member * member = get_member(name);
159 return member->subsystem;
165 FGSubsystemGroup::remove_subsystem (const string &name)
167 for (unsigned int i = 0; i < _members.size(); i++) {
168 if (name == _members[i]->name) {
169 _members.erase(_members.begin() + i);
176 FGSubsystemGroup::has_subsystem (const string &name) const
178 return (((FGSubsystemGroup *)this)->get_member(name) != 0);
181 FGSubsystemGroup::Member *
182 FGSubsystemGroup::get_member (const string &name, bool create)
184 for (unsigned int i = 0; i < _members.size(); i++) {
185 if (_members[i]->name == name)
189 Member * member = new Member;
190 _members.push_back(member);
199 ////////////////////////////////////////////////////////////////////////
200 // Implementation of FGSubsystemGroup::Member
201 ////////////////////////////////////////////////////////////////////////
204 FGSubsystemGroup::Member::Member ()
212 FGSubsystemGroup::Member::Member (const Member &)
217 FGSubsystemGroup::Member::~Member ()
219 // FIXME: causes a crash
224 FGSubsystemGroup::Member::update (double delta_time_sec)
226 elapsed_sec += delta_time_sec;
227 if (elapsed_sec >= min_step_sec) {
228 if (!subsystem->is_suspended()) {
229 subsystem->update(elapsed_sec);
237 ////////////////////////////////////////////////////////////////////////
238 // Implementation of FGSubsystemMgr.
239 ////////////////////////////////////////////////////////////////////////
242 FGSubsystemMgr::FGSubsystemMgr ()
246 FGSubsystemMgr::~FGSubsystemMgr ()
251 FGSubsystemMgr::init ()
253 for (int i = 0; i < MAX_GROUPS; i++)
258 FGSubsystemMgr::reinit ()
260 for (int i = 0; i < MAX_GROUPS; i++)
265 FGSubsystemMgr::bind ()
267 for (int i = 0; i < MAX_GROUPS; i++)
272 FGSubsystemMgr::unbind ()
274 for (int i = 0; i < MAX_GROUPS; i++)
279 FGSubsystemMgr::update (double delta_time_sec)
281 for (int i = 0; i < MAX_GROUPS; i++) {
282 _groups[i].update(delta_time_sec);
287 FGSubsystemMgr::suspend ()
289 for (int i = 0; i < MAX_GROUPS; i++)
290 _groups[i].suspend();
294 FGSubsystemMgr::resume ()
296 for (int i = 0; i < MAX_GROUPS; i++)
301 FGSubsystemMgr::is_suspended () const
307 FGSubsystemMgr::add (const char * name, FGSubsystem * subsystem,
308 GroupType group, double min_time_sec)
310 SG_LOG(SG_GENERAL, SG_INFO, "Adding subsystem " << name);
311 get_group(group)->set_subsystem(name, subsystem, min_time_sec);
313 if (_subsystem_map.find(name) != _subsystem_map.end()) {
314 SG_LOG(SG_GENERAL, SG_ALERT, "Adding duplicate subsystem " << name);
315 throw sg_exception("duplicate subsystem");
317 _subsystem_map[name] = subsystem;
321 FGSubsystemMgr::get_group (GroupType group)
323 return &(_groups[group]);
327 FGSubsystemMgr::get_subsystem (const string &name)
329 map<string,FGSubsystem *>::iterator s =_subsystem_map.find(name);
331 if (s == _subsystem_map.end())