src/engine/Dispatcher.cxx

   1 #include "Dispatcher.hxx"
   2 #include "Node.hxx"
   3 #include <iostream>
   4
   5 using namespace YACS::ENGINE;
   6
   7 Observer::~Observer()
   8 {
   9 }
  10
  11 void Observer::notifyObserver(Node* object, const std::string& event)
  12 {
  13   std::cerr << "notifyObserver " << event << object << std::endl;
  14 }
  15
  16 Dispatcher* Dispatcher::_singleton = 0;
  17
  18 Dispatcher::~Dispatcher()
  19 {
  20   Dispatcher::_singleton =0;
  21 }
  22
  23 Dispatcher* Dispatcher::getDispatcher()
  24 {
  25   if ( !Dispatcher::_singleton )
  26     {
  27        Dispatcher::_singleton =new Dispatcher;
  28     }
  29   return Dispatcher::_singleton;
  30 }
  31
  32 void Dispatcher::setDispatcher(Dispatcher* dispatcher)
  33 {
  34   Dispatcher::_singleton=dispatcher;
  35 }
  36
  37 void Dispatcher::printObservers()
  38 {
  39   std::cerr << "Dispatcher::printObservers " << std::endl;
  40   typedef std::map< std::pair<Node*,std::string> , std::set<Observer*> >::iterator it;
  41   typedef std::set<Observer*>::iterator jt;
  42
  43   for(it i=_observers.begin();i!=_observers.end();i++)
  44     {
  45       std::cerr << "Node*: " << (*i).first.first << " event: " << (*i).first.second << std::endl;
  46       for(jt j=(*i).second.begin();j!=(*i).second.end();j++)
  47         {
  48           std::cerr << "observer: " << *j << std::endl;
  49         }
  50     }
  51 }
  52
  53 void Dispatcher::dispatch(Node* object, const std::string& event)
  54 {
  55   //std::cerr << "Dispatcher::dispatch " << event << std::endl;
  56   typedef std::set<Observer*>::iterator jt;
  57   std::pair<Node*,std::string> key(object,event);
  58   if(_observers.count(key) != 0)
  59     {
  60       for(jt iter=_observers[key].begin();iter!=_observers[key].end();iter++)
  61         {
  62           (*iter)->notifyObserver(object,event);
  63         }
  64     }
  65 }
  66
  67 void Dispatcher::addObserver(Observer* observer,Node* object, const std::string& event)
  68 {
  69   _observers[std::pair<Node*,std::string>(object,event)].insert(observer);
  70 //  printObservers();
  71 }
  72
  73 void Dispatcher::removeObserver(Observer* observer,Node* object, const std::string& event)
  74 {
  75   _observers[std::pair<Node*,std::string>(object,event)].erase(observer);
  76 //  printObservers();
  77 }