granicus.if.org Git - icinga2/blob - lib/base/loader.cpp

   1 /* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
   2
   3 #include "base/loader.hpp"
   4 #include "base/logger.hpp"
   5 #include "base/exception.hpp"
   6 #include "base/application.hpp"
   7
   8 using namespace icinga;
   9
  10 boost::thread_specific_ptr<std::priority_queue<DeferredInitializer> >& Loader::GetDeferredInitializers()
  11 {
  12         static boost::thread_specific_ptr<std::priority_queue<DeferredInitializer> > initializers;
  13         return initializers;
  14 }
  15
  16 void Loader::ExecuteDeferredInitializers()
  17 {
  18         if (!GetDeferredInitializers().get())
  19                 return;
  20
  21         while (!GetDeferredInitializers().get()->empty()) {
  22                 DeferredInitializer initializer = GetDeferredInitializers().get()->top();
  23                 GetDeferredInitializers().get()->pop();
  24                 initializer();
  25         }
  26 }
  27
  28 void Loader::AddDeferredInitializer(const std::function<void()>& callback, int priority)
  29 {
  30         if (!GetDeferredInitializers().get())
  31                 GetDeferredInitializers().reset(new std::priority_queue<DeferredInitializer>());
  32
  33         GetDeferredInitializers().get()->push(DeferredInitializer(callback, priority));
  34 }
  35