Tekkotsu Homepage

Demos

Overview

Downloads

Dev. Resources

Reference

Credits

EventRouter.cc Go to the documentation of this file. #include "EventRouter.h" #include "Shared/Profiler.h" #include "Behaviors/BehaviorBase.h" #include "Shared/ProjectInterface.h" #include <algorithm> #include "Events/TimerEvent.h" #include "EventTranslator.h" #include "Events/RemoteRouter.h" #include "Events/EventProxy.h" #include <sstream> #ifndef PLATFORM_APERIOS # include "IPC/Thread.h" # include "Shared/MarkScope.h" #endif EventRouter * erouter=NULL; EventRouter::EventRouter() : proxies(), rrouters(), sck(NULL), nextProxyPort(defaultPort+1), timers(), trappers(), listeners(), postings() { for(unsigned int i=0; i<ProcessID::NumProcesses; ++i) { forwards[i]=NULL; } } EventRouter::~EventRouter() { reset(); removeAllTimers(); for(unsigned int i=0; i<ProcessID::NumProcesses; ++i) { delete forwards[i]; forwards[i]=NULL; } //Delete all the event proxies printf("Deleting %zu EventProxies and %zu RemoteRouters\n", proxies.size(), rrouters.size()); for (std::list<EventProxy *>::iterator pi = proxies.begin(); pi != proxies.end(); pi++) delete *pi; //Delete the remote routers for (std::map<int, RemoteRouter *>::iterator mi = rrouters.begin(); mi != rrouters.end(); mi++) delete (*mi).second; } void EventRouter::postEvent(EventBase* e) { processEvent(*e); delete e; } //! @todo handle recursive calls void EventRouter::processTimers() { // cout << "processTimers..." << flush; unsigned int curtime=get_time(); TimerEntry curTimer(curtime); timer_it_t last_it=upper_bound(timers.begin(),timers.end(),&curTimer,TimerEntryPtrCmp()); std::vector<TimerEntry*> process(timers.begin(),last_it); //copy these out for safe keeping for(timer_it_t it=process.begin(); it!=process.end(); it++) //increment the timers we're processing if(!(*it)->repeat) (*it)->next=(unsigned int)-1; else if((*it)->delay==0) (*it)->next=curtime+1; else while((*it)->next<=curtime) (*it)->next+=(*it)->delay; sort(timers.begin(),last_it,TimerEntryPtrCmp()); //re-sort the timers we're processing (at the beginning of timers) inplace_merge(timers.begin(),last_it,timers.end(),TimerEntryPtrCmp()); //now do a merge of the sorted processed stuff and the rest of the list (which is still sorted) // if(process.size()>0) chkTimers(); for(timer_it_t it=process.begin(); it!=process.end(); it++) { // process the timers we say we're going to, can no longer assume anything about the state of the world TimerEvent e((*it)->el,EventBase::timerEGID,(*it)->sid,EventBase::statusETID,(*it)->next-(*it)->delay); try { (*it)->el->processEvent(e); } catch(const std::exception& ex) { std::string msg="Occurred while processing event "+e.getName()+" by "; if(BehaviorBase * beh=dynamic_cast<BehaviorBase*>((*it)->el)) msg+="listener "+beh->getName(); else msg+="unnamed EventListener"; if(!ProjectInterface::uncaughtException(__FILE__,__LINE__,msg.c_str(),&ex)) throw; } catch(...) { std::string msg="Occurred while processing event "+e.getName()+" by "; if(BehaviorBase * beh=dynamic_cast<BehaviorBase*>((*it)->el)) msg+="listener "+beh->getName(); else msg+="unnamed EventListener"; if(!ProjectInterface::uncaughtException(__FILE__,__LINE__,msg.c_str(),NULL)) throw; } postEvent(e); } // if(process.size()>0) chkTimers(); static const TimerEntry deadTimer((unsigned int)-1); // matches all the dead ones as set in the incrementation phase last_it=lower_bound(timers.begin(),timers.end(),&deadTimer,TimerEntryPtrCmp()); //find the beginning of all the non-repeating timers we're clearing for(timer_it_t it=last_it; it!=timers.end(); it++) // delete all of them delete *it; timers.erase(last_it,timers.end()); //and then remove them from the timer list // if(process.size()>0) chkTimers(); // cout << "done" << endl; } /*! timers are unique by EventListener and source ID - can't have two timers for the same el and sid\n * a delay of 0 with repeating will cause an event to be sent at every opportunity, use sparingly\n * a delay of -1U will call removeTimer() if it already exists, otherwise is ignored\n * * @param el the EventListener to send the timer event to * @param sid the source ID to use on that event (if you need to send more info, send a pointer to a struct of your devising, typecasted as int) * @param delay the delay between the first (and future) calls * @param repeat set to true if you want to keep receiving this event, otherwise it will only send once */ void EventRouter::addTimer(EventListener* el, size_t sid, unsigned int delay, bool repeat) { if(delay==-1U) { removeTimer(el,sid); return; } for(timer_it_t it=timers.begin(); it!=timers.end(); it++) if((*it)->el==el && (*it)->sid==sid) { (*it)->Set(delay,repeat); // now put that timer back into the correct place in the ordering (think before touching this! ;) if(it!=timers.begin() && (*it)->next<(*(it-1))->next) rotate(upper_bound(timers.begin(),it,*it,TimerEntryPtrCmp()),it,it+1); else if(it+1!=timers.end() && (*it)->next>(*(it+1))->next) rotate(it,it+1,lower_bound(it+1,timers.end(),*it,TimerEntryPtrCmp())); return; } //didn't find a pre-existing one TimerEntry * add=new TimerEntry(el,sid,delay,repeat); timers.insert(lower_bound(timers.begin(),timers.end(),add,TimerEntryPtrCmp()),add); // chkTimers(); } void EventRouter::removeTimer(EventListener* el) { for(timer_it_t it=timers.begin(); it!=timers.end(); it++) if((*it)->el==el) { delete *it; *it=NULL; } timers.erase(std::remove(timers.begin(),timers.end(),(const TimerEntry*)NULL),timers.end()); } void EventRouter::removeTimer(EventListener* el, size_t sid) { for(timer_it_t it=timers.begin(); it!=timers.end(); it++) if((*it)->el==el && (*it)->sid==sid) { delete *it; timers.erase(it); return; } } void EventRouter::removeAllTimers() { for(timer_it_t it=timers.begin(); it!=timers.end(); it++) delete *it; timers.erase(timers.begin(),timers.end()); } void EventRouter::addListener(EventListener* el, EventBase::EventGeneratorID_t egid) { bool hadListener=hasListeners(egid); listeners.addMapping(el,egid); if(!hadListener) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::activateETID,0,EventBase::EventGeneratorNames[egid],1)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } void EventRouter::addListener(EventListener* el, EventBase::EventGeneratorID_t egid, size_t sid) { bool hadListener=hasListeners(egid); for(unsigned int et=0; et<EventBase::numETIDs; et++) listeners.addMapping(el,egid,sid,(EventBase::EventTypeID_t)et); if(!hadListener) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::activateETID,0,EventBase::EventGeneratorNames[egid],1)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } void EventRouter::addListener(EventListener* el, EventBase::EventGeneratorID_t egid, size_t sid, EventBase::EventTypeID_t etid) { bool hadListener=hasListeners(egid); listeners.addMapping(el,egid,sid,etid); if(!hadListener) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::activateETID,0,EventBase::EventGeneratorNames[egid],1)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } void EventRouter::addListener(EventListener* el, const EventBase& e) { bool hadListener=hasListeners(e.getGeneratorID()); listeners.addMapping(el,e.getGeneratorID(),e.getSourceID(),e.getTypeID()); if(!hadListener) postEvent(EventBase(EventBase::erouterEGID,e.getGeneratorID(),EventBase::activateETID,0,EventBase::EventGeneratorNames[e.getGeneratorID()],1)); else postEvent(EventBase(EventBase::erouterEGID,e.getGeneratorID(),EventBase::statusETID,0,EventBase::EventGeneratorNames[e.getGeneratorID()],1)); } //Start of remote event code------------------ void EventRouter::addRemoteListener(EventListener* el, int host, EventBase::EventGeneratorID_t egid) { RemoteRouter &rr = remoteRouterForHost(host); addListener(el, egid); rr.addListener(egid); } void EventRouter::addRemoteListener(EventListener* el, int host, EventBase::EventGeneratorID_t egid, size_t sid) { RemoteRouter &rr = remoteRouterForHost(host); addListener(el, egid, sid); rr.addListener(egid, sid); } void EventRouter::addRemoteListener(EventListener* el, int host, const EventBase& e){ addRemoteListener(el, host, e.getGeneratorID(), e.getSourceID(), e.getTypeID()); } void EventRouter::addRemoteListener(EventListener* el, int host, EventBase::EventGeneratorID_t egid, size_t sid, EventBase::EventTypeID_t etid) { RemoteRouter &rr = remoteRouterForHost(host); addListener(el, egid, sid, etid); rr.addListener(egid, sid, etid); } void EventRouter::removeRemoteListener(EventListener* el, int host, EventBase::EventGeneratorID_t egid) { RemoteRouter &rr = remoteRouterForHost(host); removeListener(el, egid); rr.removeListener(egid); } void EventRouter::removeRemoteListener(EventListener* el, int host, EventBase::EventGeneratorID_t egid, size_t sid) { RemoteRouter &rr = remoteRouterForHost(host); removeListener(el, egid, sid); rr.removeListener(egid, sid); } void EventRouter::removeRemoteListener(EventListener* el, int host, const EventBase& e) { removeRemoteListener(el, host, e.getGeneratorID(), e.getSourceID(), e.getTypeID()); } void EventRouter::removeRemoteListener(EventListener* el, int host, EventBase::EventGeneratorID_t egid, size_t sid, EventBase::EventTypeID_t etid) { RemoteRouter &rr = remoteRouterForHost(host); removeListener(el, egid, sid, etid); rr.removeListener(egid, sid, etid); } void EventRouter::requestRemoteStateUpdates(int host, RemoteState::StateType type, unsigned int interval) { RemoteRouter &rr = remoteRouterForHost(host); rr.requestStateUpdates(type, interval); } void EventRouter::stopRemoteStateUpdates(int host, RemoteState::StateType type) { RemoteRouter &rr = remoteRouterForHost(host); rr.stopStateUpdates(type); } RemoteRouter &EventRouter::remoteRouterForHost(int host) { RemoteRouter *rr = rrouters[host]; if (rr) { printf("Returning existing remote router for host %s", intToStringIP(host).c_str()); return *rr; } else { rrouters[host] = rr = new RemoteRouter(host); printf("Returning new remote router for host %s", intToStringIP(host).c_str()); return *rr; } } std::string EventRouter::intToStringIP(int ip) { std::stringstream ret; ret << (ip >> 24 & 0xff) << '.' << (ip >> 16 & 0xff) << '.' << (ip >> 8 & 0xff) << '.' << (ip >> 0 & 0xff); return ret.str(); } int EventRouter::stringToIntIP(std::string ip_str) { std::istringstream sstr; sstr.str(ip_str); int ip = 0, b; char c; sstr >> b >> c; ip |= b << 24; sstr >> b >> c; ip |= b << 16; sstr >> b >> c; ip |= b << 8; sstr >> b; ip |= b << 0; return ip; } /* This is called in MMCombo.cc on startup. */ bool EventRouter::serveRemoteEventRequests() { if (sck) return false; sck = wireless->socket(Socket::SOCK_STREAM); wireless->setReceiver(sck, this); wireless->setDaemon(sck, true); wireless->listen(sck, EventRouter::defaultPort); return true; } int EventRouter::processData(char* /* data*/, int bytes) { if (bytes != sizeof(int)) { std::cerr << "Unknown data received" << std::endl; return -1; } int nextPort = nextProxyPort++; std::cout << "Starting EventProxy on port " << nextPort << " for host " << intToStringIP(sck->getPeerAddress()) << std::endl; proxies.push_back(new EventProxy(nextPort)); //Send the port to the RemoteRouter sck->write((byte *)&nextPort, sizeof(int)); //Start listening again wireless->close(sck); return 0; } //End of remote event code void EventRouter::removeListener(EventListener* el) { for(unsigned int eg=0; eg<EventBase::numEGIDs; eg++) { EventBase::EventGeneratorID_t egid=(EventBase::EventGeneratorID_t)eg; if(!listeners.removeMapping(el,egid)) continue; //nothing was removed, don't want to clean up or throw an event listeners.clean(egid); if(!hasListeners(egid)) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::deactivateETID,0,EventBase::EventGeneratorNames[egid],0)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } } void EventRouter::removeListener(EventListener* el, EventBase::EventGeneratorID_t egid) { if(!listeners.removeMapping(el,egid)) return; //nothing was removed, don't want to clean up or throw an event listeners.clean(egid); if(!hasListeners(egid)) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::deactivateETID,0,EventBase::EventGeneratorNames[egid],0)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } void EventRouter::removeListener(EventListener* el, EventBase::EventGeneratorID_t egid, size_t sid) { unsigned int removed=0; for(unsigned int et=0; et<EventBase::numETIDs; et++) removed+=listeners.removeMapping(el,egid,sid,(EventBase::EventTypeID_t)et); if(!removed) return; //nothing was removed, don't want to clean up or throw an event listeners.clean(egid); if(!hasListeners(egid)) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::deactivateETID,0,EventBase::EventGeneratorNames[egid],0)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } void EventRouter::removeListener(EventListener* el, EventBase::EventGeneratorID_t egid, size_t sid, EventBase::EventTypeID_t etid) { if(!listeners.removeMapping(el,egid,sid,etid)) return; //nothing was removed, don't want to clean up or throw an event listeners.clean(egid); if(!hasListeners(egid)) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::deactivateETID,0,EventBase::EventGeneratorNames[egid],0)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } void EventRouter::removeListener(EventListener* el, const EventBase& e) { if(!listeners.removeMapping(el,e.getGeneratorID(),e.getSourceID(),e.getTypeID())) return; //nothing was removed, don't want to clean up or throw an event listeners.clean(e.getGeneratorID()); if(!hasListeners(e.getGeneratorID())) postEvent(EventBase(EventBase::erouterEGID,e.getGeneratorID(),EventBase::deactivateETID,0,EventBase::EventGeneratorNames[e.getGeneratorID()],0)); else postEvent(EventBase(EventBase::erouterEGID,e.getGeneratorID(),EventBase::statusETID,0,EventBase::EventGeneratorNames[e.getGeneratorID()],1)); } void EventRouter::addTrapper(EventTrapper* el, const EventBase& e) { bool hadListener=hasListeners(e.getGeneratorID()); trappers.addMapping(el,e.getGeneratorID(),e.getSourceID(),e.getTypeID()); if(!hadListener) postEvent(EventBase(EventBase::erouterEGID,e.getGeneratorID(),EventBase::activateETID,0,EventBase::EventGeneratorNames[e.getGeneratorID()],1)); else postEvent(EventBase(EventBase::erouterEGID,e.getGeneratorID(),EventBase::statusETID,0,EventBase::EventGeneratorNames[e.getGeneratorID()],1)); } /*! Note that since timers are not broadcast, they cannot be trapped. Only the EventListener which requested the timer will receive that timer. */ void EventRouter::addTrapper(EventTrapper* el, EventBase::EventGeneratorID_t egid) { bool hadListener=hasListeners(egid); trappers.addMapping(el,egid); if(!hadListener) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::activateETID,0,EventBase::EventGeneratorNames[egid],1)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } /*! Note that since timers are not broadcast, they cannot be trapped. Only the EventListener which requested the timer will receive that timer. */ void EventRouter::addTrapper(EventTrapper* el, EventBase::EventGeneratorID_t egid, size_t sid) { bool hadListener=hasListeners(egid); for(unsigned int et=0; et<EventBase::numETIDs; et++) trappers.addMapping(el,egid,sid,(EventBase::EventTypeID_t)et); if(!hadListener) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::activateETID,0,EventBase::EventGeneratorNames[egid],1)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } /*! Note that since timers are not broadcast, they cannot be trapped. Only the EventListener which requested the timer will receive that timer. */ void EventRouter::addTrapper(EventTrapper* el, EventBase::EventGeneratorID_t egid, size_t sid, EventBase::EventTypeID_t etid) { bool hadListener=hasListeners(egid); trappers.addMapping(el,egid,sid,etid); if(!hadListener) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::activateETID,0,EventBase::EventGeneratorNames[egid],1)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } /*! Note that since timers are not broadcast, they cannot be trapped. Only the EventListener which requested the timer will receive that timer. */ void EventRouter::addTrapper(EventTrapper* el) { for(unsigned int eg=0; eg<EventBase::numEGIDs; eg++) addTrapper(el,(EventBase::EventGeneratorID_t)eg); } void EventRouter::removeTrapper(EventTrapper* el, const EventBase& e) { if(!trappers.removeMapping(el,e.getGeneratorID(),e.getSourceID(),e.getTypeID())) return; //nothing was removed, don't want to clean up or throw an event trappers.clean(e.getGeneratorID()); if(!hasListeners(e.getGeneratorID())) postEvent(EventBase(EventBase::erouterEGID,e.getGeneratorID(),EventBase::deactivateETID,0,EventBase::EventGeneratorNames[e.getGeneratorID()],0)); else postEvent(EventBase(EventBase::erouterEGID,e.getGeneratorID(),EventBase::statusETID,0,EventBase::EventGeneratorNames[e.getGeneratorID()],1)); } void EventRouter::removeTrapper(EventTrapper* el, EventBase::EventGeneratorID_t egid) { if(!trappers.removeMapping(el,egid)) return; //nothing was removed, don't want to clean up or throw an event trappers.clean(egid); if(!hasListeners(egid)) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::deactivateETID,0,EventBase::EventGeneratorNames[egid],0)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,EventBase::EventGeneratorNames[egid],1)); } void EventRouter::removeTrapper(EventTrapper* el, EventBase::EventGeneratorID_t egid, size_t sid) { int removed=0; for(unsigned int et=0; et<EventBase::numETIDs; et++) removed+=trappers.removeMapping(el,egid,sid,(EventBase::EventTypeID_t)et); if(!removed) return; //nothing was removed, don't want to clean up or throw an event trappers.clean(egid); if(!hasListeners(egid)) postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::deactivateETID,0,EventBase::EventGeneratorNames[egid],0)); else postEvent(EventBase(EventBase::erouterEGID,egid,EventBase::statusETID,0,