nevrax.org : docs

00001 
+00007 /* Copyright, 2000 Nevrax Ltd.
+00008  *
+00009  * This file is part of NEVRAX NEL.
+00010  * NEVRAX NEL is free software; you can redistribute it and/or modify
+00011  * it under the terms of the GNU General Public License as published by
+00012  * the Free Software Foundation; either version 2, or (at your option)
+00013  * any later version.
+00014 
+00015  * NEVRAX NEL is distributed in the hope that it will be useful, but
+00016  * WITHOUT ANY WARRANTY; without even the implied warranty of
+00017  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+00018  * General Public License for more details.
+00019 
+00020  * You should have received a copy of the GNU General Public License
+00021  * along with NEVRAX NEL; see the file COPYING. If not, write to the
+00022  * Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
+00023  * MA 02111-1307, USA.
+00024  */
+00025 
+00026 #include "stdmisc.h"
+00027 
+00028 #include "nel/misc/event_server.h"
+00029 #include "nel/misc/event_listener.h"
+00030 #include "nel/misc/event_emitter.h"
+00031 #include "nel/misc/events.h"
+00032 
+00033 
+00034 namespace NLMISC {
+00035 
+00036 
+00037 
+00038 /*------------------------------------------------------------------*\
+00039                                                         postEvent()
+00040 \*------------------------------------------------------------------*/
+00041 void CEventServer::postEvent(CEvent * event)
+00042 {
+00043         _Events.push_back(event);
+00044 }
+00045 
+00046 
+00047 
+00048 /*------------------------------------------------------------------*\
+00049                                                         pump()
+00050 \*------------------------------------------------------------------*/
+00051 void CEventServer::pump()
+00052 {
+00053         std::list<IEventEmitter*>::iterator item = _Emitters.begin();
+00054         
+00055         // getting events from emitters
+00056         while(item!=_Emitters.end())
+00057         {
+00058                 // ask emitters to submit their events to server
+00059                 (*item)->submitEvents(*this);
+00060                 item++;
+00061         }
+00062 
+00063         
+00064         std::list<CEvent*>::iterator itev = _Events.begin();
+00065         
+00066         while(itev!=_Events.end())
+00067         {
+00068                 // pump event
+00069                 bool bDelete=pumpEvent(*itev);
+00070                 if (bDelete)
+00071                         delete *itev;
+00072                 itev=_Events.erase (itev);
+00073         }
+00074 }
+00075 
+00076 
+00077 /*------------------------------------------------------------------*\
+00078                                                         pumpEvent()
+00079 \*------------------------------------------------------------------*/
+00080 bool CEventServer::pumpEvent(CEvent* event)
+00081 {
+00082         // taking id
+00083         uint64 id = (uint64) *event;
+00084 
+00085         // looking for the first occurence of id
+00086         mapListener::iterator it = _Listeners.find(id);
+00087 
+00088         // calling every callbacks
+00089         while(it!=_Listeners.end() && (uint64)(*it).first == id)
+00090         {
+00091                 (*((*it).second)) (*event);
+00092                 it++;
+00093         }
+00094 
+00095         // delete the pointer
+00096         return true;
+00097 }
+00098 
+00099 
+00100 
+00101 /*------------------------------------------------------------------*\
+00102                                                         addListener()
+00103 \*------------------------------------------------------------------*/
+00104 void CEventServer::addListener(CClassId id, IEventListener* listener )
+00105 {
+00106         _Listeners.insert( mapListener::value_type(id, listener));
+00107 }
+00108 
+00109 
+00110 /*------------------------------------------------------------------*\
+00111                                                         removeListener()
+00112 \*------------------------------------------------------------------*/
+00113 void CEventServer::removeListener(CClassId id, IEventListener* listener )
+00114 {
+00115         // looking for the first occurence of id
+00116         mapListener::iterator it = _Listeners.find(id);
+00117 
+00118         // looking for occurence with the right callback
+00119         while(it!=_Listeners.end() && (*it).first == id)
+00120         {
+00121                 if((*it).second==listener)
+00122                 {
+00123                         // erasing pair
+00124                         _Listeners.erase(it);
+00125                         return;
+00126                 }
+00127                 it++;
+00128         }
+00129 }
+00130 
+00131 
+00132 /*------------------------------------------------------------------*\
+00133                                                         addEmitter()
+00134 \*------------------------------------------------------------------*/
+00135 void CEventServer::addEmitter(IEventEmitter * emitter)
+00136 {
+00137         _Emitters.push_back(emitter);
+00138 }
+00139 
+00140 
+00141 /*------------------------------------------------------------------*\
+00142                                                         removeEmitter()
+00143 \*------------------------------------------------------------------*/
+00144 void CEventServer::removeEmitter(IEventEmitter * emitter)
+00145 {
+00146         _Emitters.remove(emitter);
+00147 }
+00148 
+00149 
+00150 } // NLMISC
+
event_server.cpp
