0f8380e8fe
- Add app path get() functions to `TactilityC` - Improved `Dispatcher` and `DispatcherThread` - Improved `PubSub` (type safety) - Created test for `DispatcherThread` and `PubSub` - Save properties files on app exit (various apps) by posting it to the main dispatcher (fixes UI hanging briefly on app exit) - Fixed bug with `SystemSettings` being read from the wrong file path. - `loadPropertiesFile()` now uses `file::readLines()` instead of doing that manually - Increased timer task stack size (required due to issues when reading a properties file for the very first time) - General cleanup - Created `EstimatedPower` driver that uses an ADC pin to measure voltage and estimate the battery charge that is left. - Cleanup of T-Deck board (updated to new style)
89 lines
2.0 KiB
C++
89 lines
2.0 KiB
C++
#pragma once
|
|
|
|
#include "Mutex.h"
|
|
#include <list>
|
|
|
|
namespace tt {
|
|
|
|
/** Publish and subscribe to messages in a thread-safe manner. */
|
|
template<typename DataType>
|
|
class PubSub final {
|
|
|
|
struct Subscription {
|
|
uint64_t id;
|
|
std::function<void(DataType)> callback;
|
|
};
|
|
|
|
typedef std::list<Subscription> Subscriptions;
|
|
uint64_t lastId = 0;
|
|
Subscriptions items;
|
|
Mutex mutex;
|
|
|
|
public:
|
|
|
|
typedef void* SubscriptionHandle;
|
|
|
|
PubSub() = default;
|
|
|
|
~PubSub() {
|
|
if (!items.empty()) {
|
|
TT_LOG_W("Loader", "Destroying PubSub with %d active subscriptions", items.size());
|
|
}
|
|
}
|
|
|
|
/** Start receiving messages at the specified handle (Threadsafe, Re-entrable)
|
|
* @param[in] callback
|
|
* @return subscription instance
|
|
*/
|
|
SubscriptionHandle subscribe(std::function<void(DataType)> callback) {
|
|
mutex.lock();
|
|
items.push_back({
|
|
.id = (++lastId),
|
|
.callback = std::move(callback)
|
|
});
|
|
|
|
mutex.unlock();
|
|
|
|
return reinterpret_cast<SubscriptionHandle>(lastId);
|
|
}
|
|
|
|
/** Stop receiving messages at the specified handle (Threadsafe, Re-entrable.)
|
|
* No use of `tt_pubsub_subscription` allowed after call of this method
|
|
* @param[in] subscription
|
|
*/
|
|
void unsubscribe(SubscriptionHandle subscription) {
|
|
assert(subscription);
|
|
|
|
mutex.lock();
|
|
bool result = false;
|
|
auto id = reinterpret_cast<uint64_t>(subscription);
|
|
for (auto it = items.begin(); it != items.end(); ++it) {
|
|
if (it->id == id) {
|
|
items.erase(it);
|
|
result = true;
|
|
break;
|
|
}
|
|
}
|
|
|
|
mutex.unlock();
|
|
tt_check(result);
|
|
}
|
|
|
|
/** Publish something to all subscribers (Threadsafe, Re-entrable.)
|
|
* @param[in] data the data to publish
|
|
*/
|
|
void publish(DataType data) {
|
|
mutex.lock();
|
|
|
|
// Iterate over subscribers
|
|
for (auto& it : items) {
|
|
it.callback(data);
|
|
}
|
|
|
|
mutex.unlock();
|
|
}
|
|
};
|
|
|
|
|
|
} // namespace
|