src/Events/Events_Loop.cpp

   1 // File:        Events_Loop.hxx
   2 // Created:     Thu Mar 13 2014
   3 // Author:      Mikhail PONIKAROV
   4
   5 #include <Events_Loop.h>
   6
   7 #include <string>
   8 #include <cstring>
   9
  10 using namespace std;
  11
  12 Events_Loop* Events_Loop::loop()
  13 {
  14   // initialized on initialization of the application
  15   static Events_Loop MAIN_LOOP;
  16   return &MAIN_LOOP;
  17 }
  18
  19 Events_ID Events_Loop::eventByName(const char* theName)
  20 {
  21   ///! All events created in this session, uniquely identified by the text and char pointer
  22   static map<string, char*> CREATED_EVENTS;
  23   char* aResult;
  24   string aName(theName);
  25   map<string, char*>::iterator aFound = CREATED_EVENTS.find(aName);
  26   if (aFound == CREATED_EVENTS.end()) { //not created yet
  27     aResult = strdup(theName); // copy to make unique internal pointer
  28     CREATED_EVENTS[aName] = aResult;
  29   } else
  30     aResult = aFound->second;
  31
  32   return Events_ID(aResult);
  33 }
  34
  35 void Events_Loop::send(Events_Message& theMessage)
  36 {
  37   // TO DO: make it in thread and wit husage of semaphores
  38
  39   map<char*, map<void*, list<Events_Listener*> > >::iterator aFindID = myListeners.find(
  40       theMessage.eventID().eventText());
  41   if (aFindID != myListeners.end()) {
  42     map<void*, list<Events_Listener*> >::iterator aFindSender = aFindID->second.find(
  43         theMessage.sender());
  44     if (aFindSender != aFindID->second.end()) {
  45       list<Events_Listener*>& aListeners = aFindSender->second;
  46       for(list<Events_Listener*>::iterator aL = aListeners.begin(); aL != aListeners.end(); aL++)
  47         (*aL)->processEvent(&theMessage);
  48     }
  49     if (theMessage.sender()) { // also call for NULL senders registered
  50       aFindSender = aFindID->second.find(NULL);
  51       if (aFindSender != aFindID->second.end()) {
  52         list<Events_Listener*>& aListeners = aFindSender->second;
  53         for(list<Events_Listener*>::iterator aL = aListeners.begin(); aL != aListeners.end(); aL++)
  54           (*aL)->processEvent(&theMessage);
  55       }
  56     }
  57   }
  58 }
  59
  60 void Events_Loop::registerListener(Events_Listener* theListener, const Events_ID theID,
  61                                   void* theSender)
  62 {
  63   map<char*, map<void*, list<Events_Listener*> > >::iterator aFindID = myListeners.find(
  64       theID.eventText());
  65   if (aFindID == myListeners.end()) { // create container associated with ID
  66     myListeners[theID.eventText()] = map<void*, list<Events_Listener*> >();
  67     aFindID = myListeners.find(theID.eventText());
  68   }
  69
  70   map<void*, list<Events_Listener*> >::iterator aFindSender = aFindID->second.find(theSender);
  71   if (aFindSender == aFindID->second.end()) { // create container associated with sender
  72     aFindID->second[theSender] = list<Events_Listener*>();
  73     aFindSender = aFindID->second.find(theSender);
  74   }
  75   // check that listener was not registered wit hsuch parameters before
  76   list<Events_Listener*>& aListeners = aFindSender->second;
  77   for(list<Events_Listener*>::iterator aL = aListeners.begin(); aL != aListeners.end(); aL++)
  78     if (*aL == theListener)
  79       return; // avoid duplicates
  80
  81   aListeners.push_back(theListener);
  82 }