X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FModuleManager.cci;h=db78d8572f691169f3d4e510540c73f5fac6ec1f;hb=81f84badf27b66dbadec9890646ca1193e998505;hp=fff83bc631f010224c1363e0d3b6dde0a389f676;hpb=f73fa16ed5abdce272ac77f8b8b9ef2b9922c266;p=senf.git diff --git a/PPI/ModuleManager.cci b/PPI/ModuleManager.cci index fff83bc..db78d85 100644 --- a/PPI/ModuleManager.cci +++ b/PPI/ModuleManager.cci @@ -1,8 +1,8 @@ // $Id$ // -// Copyright (C) 2007 -// Fraunhofer Institute for Open Communication Systems (FOKUS) -// Competence Center NETwork research (NET), St. Augustin, GERMANY +// Copyright (C) 2007 +// Fraunhofer Institute for Open Communication Systems (FOKUS) +// Competence Center NETwork research (NET), St. Augustin, GERMANY // Stefan Bund // // This program is free software; you can redistribute it and/or modify @@ -50,12 +50,69 @@ prefix_ void senf::ppi::ModuleManager::unregisterModule(module::Module & module) moduleRegistry_.end()); } +prefix_ void senf::ppi::ModuleManager::registerInitializable(Initializable & i) +{ + initQueue_.push_back(&i); + initRunner_.enable(); +} + +prefix_ void senf::ppi::ModuleManager::unregisterInitializable(Initializable & i) +{ + initQueue_.erase( + std::remove(initQueue_.begin(), initQueue_.end(), & i), + initQueue_.end()); + if (initQueue_.empty()) + initRunner_.disable(); +} + +prefix_ bool senf::ppi::ModuleManager::initializableRegistered(Initializable const & i) + const +{ + return std::find(initQueue_.begin(), initQueue_.end(), &i) != initQueue_.end(); +} + prefix_ bool senf::ppi::ModuleManager::running() const { return running_; } +/////////////////////////////////////////////////////////////////////////// +// senf::ppi::ModuleManager::Initializable + +prefix_ senf::ppi::ModuleManager::Initializable::Initializable() +{ + enqueueInitializable(); +} + +prefix_ senf::ppi::ModuleManager::Initializable::~Initializable() +{ + dequeueInitializable(); +} + +prefix_ void senf::ppi::ModuleManager::Initializable::enqueueInitializable() +{ + moduleManager().registerInitializable(*this); +} + +prefix_ void senf::ppi::ModuleManager::Initializable::dequeueInitializable() +{ + moduleManager().unregisterInitializable(*this); +} + +prefix_ bool senf::ppi::ModuleManager::Initializable::initializationScheduled() + const +{ + return moduleManager().initializableRegistered(*this); +} + +prefix_ senf::ppi::ModuleManager::ModuleManager & +senf::ppi::ModuleManager::Initializable::moduleManager() + const +{ + return ModuleManager::instance(); +} + ///////////////////////////////cci.e/////////////////////////////////////// #undef prefix_