2020-10-15 18:23:18 +00:00
|
|
|
#include "pubsub.h"
|
2021-11-01 20:35:54 +00:00
|
|
|
#include "memmgr.h"
|
|
|
|
#include "check.h"
|
2022-06-20 14:54:48 +00:00
|
|
|
#include "mutex.h"
|
2021-11-01 20:35:54 +00:00
|
|
|
|
|
|
|
#include <m-list.h>
|
|
|
|
|
|
|
|
struct FuriPubSubSubscription {
|
|
|
|
FuriPubSubCallback callback;
|
|
|
|
void* callback_context;
|
|
|
|
};
|
|
|
|
|
|
|
|
LIST_DEF(FuriPubSubSubscriptionList, FuriPubSubSubscription, M_POD_OPLIST);
|
|
|
|
|
|
|
|
struct FuriPubSub {
|
|
|
|
FuriPubSubSubscriptionList_t items;
|
|
|
|
osMutexId_t mutex;
|
|
|
|
};
|
|
|
|
|
|
|
|
FuriPubSub* furi_pubsub_alloc() {
|
2022-02-18 19:53:46 +00:00
|
|
|
FuriPubSub* pubsub = malloc(sizeof(FuriPubSub));
|
2020-10-15 18:23:18 +00:00
|
|
|
|
[FL-781] FURI, CLI, stdlib: stdout hooks, integration between subsystems, uniform printf usage (#311)
* FURI stdglue: stdout hooks, local and global, ISR safe printf. Uniform newlines for terminal/debug output. Power: prevent sleep while core 2 has not started.
* Furi record, stdglue: check mutex allocation
* remove unused test
* Furi stdglue: buferized output, dynamically allocated state. Furi record: dynamically allocated state. Input dump: proper line ending. Hal VCP: dynamically allocated state.
* Interrupt manager: explicitly init list.
* Makefile: cleanup rules, fix broken dfu upload. F4: add compiler stack protection options.
* BLE: call debug uart callback on transmission complete
* FreeRTOS: add configUSE_NEWLIB_REENTRANT
* API HAL Timebase: fix issue with idle thread stack corruption caused by systick interrupt. BT: cleanup debug info output. FreeRTOS: disable reentry for newlib.
* F4: update stack protection CFLAGS to match used compiller
* F4: disable compiller stack protection because of incompatibility with current compiller
* Makefile: return openocd logs to gdb
* BLE: fixed pin, moar power, ble trace info.
* Prevent sleep when connection is active
* Makefile: return serial port to upload rule, add workaround for mac os
* Furi: prevent usage of stack for cmsis functions.
* F4: add missing includes, add debugger breakpoints
* Applications: per app stack size.
* Furi: honor kernel state in stdglue
* FreeRTOS: remove unused hooks
* Cleanup and format sources
Co-authored-by: DrZlo13 <who.just.the.doctor@gmail.com>
2021-01-29 00:09:33 +00:00
|
|
|
pubsub->mutex = osMutexNew(NULL);
|
2021-11-01 20:35:54 +00:00
|
|
|
furi_assert(pubsub->mutex);
|
2020-10-15 18:23:18 +00:00
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
FuriPubSubSubscriptionList_init(pubsub->items);
|
2020-10-15 18:23:18 +00:00
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
return pubsub;
|
2020-10-15 18:23:18 +00:00
|
|
|
}
|
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
void furi_pubsub_free(FuriPubSub* pubsub) {
|
|
|
|
furi_assert(pubsub);
|
2020-10-15 18:23:18 +00:00
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
furi_check(FuriPubSubSubscriptionList_size(pubsub->items) == 0);
|
2020-10-15 18:23:18 +00:00
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
FuriPubSubSubscriptionList_clear(pubsub->items);
|
2020-10-15 18:23:18 +00:00
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
furi_check(osMutexDelete(pubsub->mutex) == osOK);
|
2020-10-15 18:23:18 +00:00
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
free(pubsub);
|
|
|
|
}
|
2020-10-15 18:23:18 +00:00
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
FuriPubSubSubscription*
|
|
|
|
furi_pubsub_subscribe(FuriPubSub* pubsub, FuriPubSubCallback callback, void* callback_context) {
|
|
|
|
furi_check(osMutexAcquire(pubsub->mutex, osWaitForever) == osOK);
|
|
|
|
// put uninitialized item to the list
|
|
|
|
FuriPubSubSubscription* item = FuriPubSubSubscriptionList_push_raw(pubsub->items);
|
|
|
|
|
|
|
|
// initialize item
|
|
|
|
item->callback = callback;
|
|
|
|
item->callback_context = callback_context;
|
|
|
|
|
|
|
|
furi_check(osMutexRelease(pubsub->mutex) == osOK);
|
|
|
|
|
|
|
|
return item;
|
2020-10-15 18:23:18 +00:00
|
|
|
}
|
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
void furi_pubsub_unsubscribe(FuriPubSub* pubsub, FuriPubSubSubscription* pubsub_subscription) {
|
|
|
|
furi_assert(pubsub);
|
|
|
|
furi_assert(pubsub_subscription);
|
|
|
|
|
|
|
|
furi_check(osMutexAcquire(pubsub->mutex, osWaitForever) == osOK);
|
|
|
|
bool result = false;
|
|
|
|
|
|
|
|
// iterate over items
|
|
|
|
FuriPubSubSubscriptionList_it_t it;
|
|
|
|
for(FuriPubSubSubscriptionList_it(it, pubsub->items); !FuriPubSubSubscriptionList_end_p(it);
|
|
|
|
FuriPubSubSubscriptionList_next(it)) {
|
|
|
|
const FuriPubSubSubscription* item = FuriPubSubSubscriptionList_cref(it);
|
2020-10-15 18:23:18 +00:00
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
// if the iterator is equal to our element
|
|
|
|
if(item == pubsub_subscription) {
|
|
|
|
FuriPubSubSubscriptionList_remove(pubsub->items, it);
|
|
|
|
result = true;
|
|
|
|
break;
|
|
|
|
}
|
2020-10-15 18:23:18 +00:00
|
|
|
}
|
2021-11-01 20:35:54 +00:00
|
|
|
|
|
|
|
furi_check(osMutexRelease(pubsub->mutex) == osOK);
|
|
|
|
furi_check(result);
|
2020-10-15 18:23:18 +00:00
|
|
|
}
|
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
void furi_pubsub_publish(FuriPubSub* pubsub, void* message) {
|
|
|
|
furi_check(osMutexAcquire(pubsub->mutex, osWaitForever) == osOK);
|
2020-10-15 18:23:18 +00:00
|
|
|
|
2021-11-01 20:35:54 +00:00
|
|
|
// iterate over subscribers
|
|
|
|
FuriPubSubSubscriptionList_it_t it;
|
|
|
|
for(FuriPubSubSubscriptionList_it(it, pubsub->items); !FuriPubSubSubscriptionList_end_p(it);
|
|
|
|
FuriPubSubSubscriptionList_next(it)) {
|
|
|
|
const FuriPubSubSubscription* item = FuriPubSubSubscriptionList_cref(it);
|
|
|
|
item->callback(message, item->callback_context);
|
2020-10-15 18:23:18 +00:00
|
|
|
}
|
2021-11-01 20:35:54 +00:00
|
|
|
|
|
|
|
furi_check(osMutexRelease(pubsub->mutex) == osOK);
|
2020-10-15 18:23:18 +00:00
|
|
|
}
|