mirror of
https://github.com/ByteWelder/Tactility.git
synced 2026-02-18 19:03:16 +00:00
3ea02d912f
- WiFi Connect app is now hidden by default, but accessible at the bottom of the WiFi Manage app when WiFi is turned on. - WiFi service now turns on WiFi when calling connect() and WiFi is not on. - Removed `blocking` option for `service::loader::startApp()`. This feature was unused and complex. - Various apps: Moved private headers into Private/ folder. - Various apps: created start() function for easy starting. - Added documentation to all TactilityC APIs - Refactored various `enum` into `class enum` - Refactor M5Stack `initBoot()` (but VBus is still 0V for some reason)
78 lines
2.1 KiB
C++
78 lines
2.1 KiB
C++
#include <kernel/Kernel.h>
|
|
#include "Dispatcher.h"
|
|
#include "Check.h"
|
|
|
|
namespace tt {
|
|
|
|
#define TAG "dispatcher"
|
|
#define BACKPRESSURE_WARNING_COUNT 100
|
|
#define WAIT_FLAG 1
|
|
|
|
Dispatcher::Dispatcher() :
|
|
mutex(Mutex::Type::Normal)
|
|
{}
|
|
|
|
Dispatcher::~Dispatcher() {
|
|
// Wait for Mutex usage
|
|
mutex.acquire(TtWaitForever);
|
|
mutex.release();
|
|
}
|
|
|
|
void Dispatcher::dispatch(Function function, std::shared_ptr<void> context) {
|
|
auto message = std::make_shared<DispatcherMessage>(function, std::move(context));
|
|
// Mutate
|
|
if (mutex.lock(1000 / portTICK_PERIOD_MS)) {
|
|
queue.push(std::move(message));
|
|
if (queue.size() == BACKPRESSURE_WARNING_COUNT) {
|
|
TT_LOG_W(TAG, "Backpressure: You're not consuming fast enough (100 queued)");
|
|
}
|
|
tt_check(mutex.unlock());
|
|
// Signal
|
|
eventFlag.set(WAIT_FLAG);
|
|
} else {
|
|
TT_LOG_E(TAG, LOG_MESSAGE_MUTEX_LOCK_FAILED);
|
|
}
|
|
}
|
|
|
|
uint32_t Dispatcher::consume(TickType_t timeout) {
|
|
// Wait for signal and clear
|
|
TickType_t start_ticks = kernel::getTicks();
|
|
if (eventFlag.wait(WAIT_FLAG, TtFlagWaitAny, timeout) == WAIT_FLAG) {
|
|
eventFlag.clear(WAIT_FLAG);
|
|
} else {
|
|
return 0;
|
|
}
|
|
|
|
TickType_t ticks_remaining = TT_MAX(timeout - (kernel::getTicks() - start_ticks), 0);
|
|
|
|
TT_LOG_I(TAG, "Dispatcher continuing (%d ticks)", (int)ticks_remaining);
|
|
|
|
// Mutate
|
|
bool processing = true;
|
|
uint32_t consumed = 0;
|
|
do {
|
|
if (mutex.lock(ticks_remaining / portTICK_PERIOD_MS)) {
|
|
if (!queue.empty()) {
|
|
auto item = queue.front();
|
|
queue.pop();
|
|
consumed++;
|
|
processing = !queue.empty();
|
|
// Don't keep lock as callback might be slow
|
|
tt_check(mutex.unlock());
|
|
item->function(item->context);
|
|
} else {
|
|
processing = false;
|
|
tt_check(mutex.unlock());
|
|
}
|
|
|
|
} else {
|
|
TT_LOG_E(TAG, LOG_MESSAGE_MUTEX_LOCK_FAILED);
|
|
}
|
|
|
|
} while (processing);
|
|
|
|
return consumed;
|
|
}
|
|
|
|
} // namespace
|