EventDispatcher.h

Go to the documentation of this file.

/*
 * EventDispatcher.h
 *
 *  Created on: 06.12.2012
 *      Author: morgenro
 */

#ifndef EVENTDISPATCHER_H_
#define EVENTDISPATCHER_H_

#include "core/Event.h"
#include "core/EventSwitch.h"
#include "core/EventReceiver.h"
#include <ibrcommon/thread/Mutex.h>
#include <ibrcommon/thread/MutexLock.h>
#include <list>

namespace dtn
{
        namespace core
        {
                template<class E>
                class EventDispatcher {
                private:
                        EventDispatcher() : _processor(*this), _stat_count(0)
                        { };

                        class EventProcessorImpl : public EventProcessor {
                        public:
                                EventProcessorImpl(EventDispatcher<E> &dispatcher)
                                : _dispatcher(dispatcher) { };

                                virtual ~EventProcessorImpl() { };

                                void process(const Event *evt)
                                {
                                        ibrcommon::MutexLock l(_dispatcher._dispatch_lock);
                                        for (std::list<EventReceiver*>::iterator iter = _dispatcher._receivers.begin();
                                                        iter != _dispatcher._receivers.end(); ++iter)
                                        {
                                                EventReceiver &receiver = (**iter);
                                                receiver.raiseEvent(evt);
                                        }

                                        _dispatcher._stat_count++;
                                }

                                EventDispatcher<E> &_dispatcher;
                        };

                        void _reset() {
                                ibrcommon::MutexLock l(_dispatch_lock);
                                _stat_count = 0;
                        }

                        void _raise(Event *evt)
                        {
                                _processor.process(evt);
                                delete evt;
                        }

                        void _queue(Event *evt)
                        {
                                // raise the new event
                                dtn::core::EventSwitch::queue( _processor, evt );
                        }

                        void _add(EventReceiver *receiver) {
                                ibrcommon::MutexLock l(_dispatch_lock);
                                _receivers.push_back(receiver);
                        }

                        void _remove(const EventReceiver *receiver) {
                                ibrcommon::MutexLock l(_dispatch_lock);
                                for (std::list<EventReceiver*>::iterator iter = _receivers.begin(); iter != _receivers.end(); ++iter)
                                {
                                        if ((*iter) == receiver)
                                        {
                                                _receivers.erase(iter);
                                                break;
                                        }
                                }
                        }

                        static EventDispatcher<E>& instance() {
                                static EventDispatcher<E> i;
                                return i;
                        }

                public:
                        virtual ~EventDispatcher() { };

                        static void raise(Event *evt) {
                                instance()._raise(evt);
                        }

                        static void queue(Event *evt) {
                                instance()._queue(evt);
                        }

                        static void add(EventReceiver *receiver) {
                                instance()._add(receiver);
                        }

                        static void remove(const EventReceiver *receiver) {
                                instance()._remove(receiver);
                        }

                        static void resetCounter() {
                                instance()._reset();
                        }

                        static size_t getCounter() {
                                return instance()._stat_count;
                        }

                private:
                        ibrcommon::Mutex _dispatch_lock;
                        std::list<EventReceiver*> _receivers;
                        EventProcessorImpl _processor;
                        size_t _stat_count;
                };
        }
}

#endif /* EVENTDISPATCHER_H_ */