polybar/include/events/signal_emitter.hpp

106 lines
2.6 KiB
C++
Raw Normal View History

#pragma once
#include "common.hpp"
#include "events/signal_receiver.hpp"
#include "utils/factory.hpp"
#include "utils/mixins.hpp"
POLYBAR_NS
/**
* @brief Holds all signal receivers attached to the emitter
*/
extern signal_receivers_t g_signal_receivers;
/**
* Wrapper used to delegate emitted signals
* to attached signal receivers
*/
class signal_emitter {
public:
2016-12-09 08:40:46 +00:00
using make_type = signal_emitter&;
static make_type make();
2016-12-09 08:02:47 +00:00
explicit signal_emitter() = default;
virtual ~signal_emitter() {}
template <typename Signal>
bool emit(const Signal& sig) {
try {
for (auto&& item : g_signal_receivers.at(id<Signal>())) {
if (item.second->on(sig)) {
return true;
}
}
} catch (...) {
}
return false;
}
template <typename Signal, typename Next, typename... Signals>
bool emit(const Signal& sig) const {
return emit<Signal>(sig) || emit<Next, Signals...>(sig);
}
template <uint8_t Priority, typename Signal, typename... Signals>
void attach(signal_receiver<Priority, Signal, Signals...>* s) {
attach<signal_receiver<Priority, Signal, Signals...>, Signal, Signals...>(s);
}
template <uint8_t Priority, typename Signal, typename... Signals>
void detach(signal_receiver<Priority, Signal, Signals...>* s) {
detach<signal_receiver<Priority, Signal, Signals...>, Signal, Signals...>(s);
}
protected:
template <typename Signal>
uint8_t id() const {
return Signal::id();
}
template <typename Receiver, typename Signal>
void attach(Receiver* s) {
attach(s, id<Signal>());
}
template <typename Receiver, typename Signal, typename Next, typename... Signals>
void attach(Receiver* s) {
attach(s, id<Signal>());
attach<Receiver, Next, Signals...>(s);
}
void attach(signal_receiver_interface* s, uint8_t id) {
g_signal_receivers[id].emplace(s->priority(), s);
}
template <typename Receiver, typename Signal>
void detach(Receiver* s) {
detach(s, id<Signal>());
}
template <typename Receiver, typename Signal, typename Next, typename... Signals>
void detach(Receiver* s) {
detach(s, id<Signal>());
detach<Receiver, Next, Signals...>(s);
}
void detach(signal_receiver_interface* d, uint8_t id) {
try {
auto& prio_map = g_signal_receivers.at(id);
const auto& prio_sink_pair = prio_map.equal_range(d->priority());
for (auto it = prio_sink_pair.first; it != prio_sink_pair.second;) {
if (d == it->second) {
it = prio_map.erase(it);
} else {
++it;
}
}
} catch (...) {
}
}
};
POLYBAR_NS_END