changed EventHandler set in EventNotifier to shared_ptr
This commit is contained in:
@@ -22,8 +22,8 @@ class EventNotifier
|
||||
public:
|
||||
virtual ~EventNotifier() = default;
|
||||
|
||||
virtual void register_event_handler(EventHandler* handler) = 0;
|
||||
virtual void unregister_event_handler(EventHandler* handler) = 0;
|
||||
virtual void register_event_handler(std::shared_ptr<EventHandler> handler) = 0;
|
||||
virtual void unregister_event_handler(std::shared_ptr<EventHandler> handler) = 0;
|
||||
|
||||
virtual void distribute_event(const Event &event) = 0;
|
||||
};
|
||||
|
||||
@@ -39,14 +39,14 @@ EventNotifier::~EventNotifier()
|
||||
delete this->event_queue;
|
||||
}
|
||||
|
||||
void EventNotifier::register_event_handler(EventHandler *handler)
|
||||
void EventNotifier::register_event_handler(std::shared_ptr<EventHandler> handler)
|
||||
{
|
||||
std::lock_guard<std::mutex> event_handler_guard(event_handler_mutex);
|
||||
this->event_handlers.insert(handler);
|
||||
CLOG(INFO, INPUT_LOGGER) << "New Eventhandler at adress " << handler << " was registered.";
|
||||
}
|
||||
|
||||
void EventNotifier::unregister_event_handler(EventHandler *handler)
|
||||
void EventNotifier::unregister_event_handler(std::shared_ptr<EventHandler> handler)
|
||||
{
|
||||
std::lock_guard<std::mutex> event_handler_guard(event_handler_mutex);
|
||||
this->event_handlers.erase(handler);
|
||||
|
||||
@@ -35,8 +35,8 @@ public:
|
||||
explicit EventNotifier(utility::IBlockingQueue<Event> *queue);
|
||||
~EventNotifier() override;
|
||||
|
||||
void register_event_handler(EventHandler *handler) override;
|
||||
void unregister_event_handler(EventHandler *handler) override;
|
||||
void register_event_handler(std::shared_ptr<EventHandler> handler) override;
|
||||
void unregister_event_handler(std::shared_ptr<EventHandler> handler) override;
|
||||
|
||||
void distribute_event(const Event &event) override;
|
||||
|
||||
@@ -45,7 +45,7 @@ private:
|
||||
|
||||
private:
|
||||
utility::IBlockingQueue<Event> *event_queue;
|
||||
std::set<EventHandler *> event_handlers;
|
||||
std::set<std::shared_ptr<EventHandler>> event_handlers;
|
||||
|
||||
bool is_running;
|
||||
std::thread notify_thread;
|
||||
|
||||
@@ -22,12 +22,12 @@ event_notifier(std::move(event_notifier)), detector(std::move(detector)), events
|
||||
CLOG(INFO, INPUT_LOGGER) << "Created InputDriver";
|
||||
}
|
||||
|
||||
void InputDriver::register_event_handler(EventHandler *handler)
|
||||
void InputDriver::register_event_handler(std::shared_ptr<EventHandler> handler)
|
||||
{
|
||||
this->event_notifier->register_event_handler(handler);
|
||||
}
|
||||
|
||||
void InputDriver::unregister_event_handler(EventHandler *handler)
|
||||
void InputDriver::unregister_event_handler(std::shared_ptr<EventHandler> handler)
|
||||
{
|
||||
this->event_notifier->unregister_event_handler(handler);
|
||||
}
|
||||
|
||||
@@ -27,8 +27,8 @@ class InputDriver : public input::InputDriver
|
||||
public:
|
||||
|
||||
InputDriver(std::shared_ptr<EventNotifier> event_notifier, std::unique_ptr<Detector> detector, std::map<std::string, std::shared_ptr<Event>> events);
|
||||
void register_event_handler(EventHandler *handler) override;
|
||||
void unregister_event_handler(EventHandler *handler) override;
|
||||
void register_event_handler(std::shared_ptr<EventHandler> handler) override;
|
||||
void unregister_event_handler(std::shared_ptr<EventHandler> handler) override;
|
||||
|
||||
boost::optional<std::shared_ptr<Event>> get_event(std::string name) override;
|
||||
|
||||
|
||||
Reference in New Issue
Block a user