fc043da9c6
* FuriHal: UART refactoring * ApiSymbols: add furi_record_destroy * FuriHal: cleanup serial API, add logging configuration in RTC * FuriHal: hide private part in _i header. Toolbox: cleanup value index. SystemSettings: logging device and baudrate. * FuriHal: RTC logging method documentation * Synchronize API Symbols * Furi: mark HEAP_PRINT_DEBUG as broken * FuriHal: furi_hal_serial, add custom IRQ func * Fix PR review issues * FuriHal: UART add reception DMA (#3220) * FuriHal: add DMA serial rx mode * usb_uart_bridge: switch to working with DMA * Sync api symbol versions * FuriHal: update serial docs and api * FuriHal: Selial added similar API for simple reception mode as with DMA * FuriHal: Update API target H18 * API: ver API H7 * FuriHal: Serial error processing * FuriHal: fix furi_hal_serial set baudrate * Sync api symbols * FuriHal: cleanup serial isr and various flag handling procedures * FuriHal: cleanup and simplify serial API * Debug: update UART Echo serial related flags * FuriHal: update serial API symbols naming * FuriHalSerial: various improvements and PR review fixes * FuriHal: proper ISR function signatures --------- Co-authored-by: Aleksandr Kutuzov <alleteam@gmail.com> Co-authored-by: hedger <hedger@users.noreply.github.com> Co-authored-by: SkorP <skorpionm@yandex.ru> Co-authored-by: Skorpionm <85568270+Skorpionm@users.noreply.github.com>
128 lines
3.2 KiB
C
128 lines
3.2 KiB
C
#include "mutex.h"
|
|
#include "check.h"
|
|
#include "common_defines.h"
|
|
|
|
#include <FreeRTOS.h>
|
|
#include <semphr.h>
|
|
|
|
FuriMutex* furi_mutex_alloc(FuriMutexType type) {
|
|
furi_assert(!FURI_IS_IRQ_MODE());
|
|
|
|
SemaphoreHandle_t hMutex = NULL;
|
|
|
|
if(type == FuriMutexTypeNormal) {
|
|
hMutex = xSemaphoreCreateMutex();
|
|
} else if(type == FuriMutexTypeRecursive) {
|
|
hMutex = xSemaphoreCreateRecursiveMutex();
|
|
} else {
|
|
furi_crash("Programming error");
|
|
}
|
|
|
|
furi_check(hMutex != NULL);
|
|
|
|
if(type == FuriMutexTypeRecursive) {
|
|
/* Set LSB as 'recursive mutex flag' */
|
|
hMutex = (SemaphoreHandle_t)((uint32_t)hMutex | 1U);
|
|
}
|
|
|
|
/* Return mutex ID */
|
|
return ((FuriMutex*)hMutex);
|
|
}
|
|
|
|
void furi_mutex_free(FuriMutex* instance) {
|
|
furi_assert(!FURI_IS_IRQ_MODE());
|
|
furi_assert(instance);
|
|
|
|
vSemaphoreDelete((SemaphoreHandle_t)((uint32_t)instance & ~1U));
|
|
}
|
|
|
|
FuriStatus furi_mutex_acquire(FuriMutex* instance, uint32_t timeout) {
|
|
SemaphoreHandle_t hMutex;
|
|
FuriStatus stat;
|
|
uint32_t rmtx;
|
|
|
|
hMutex = (SemaphoreHandle_t)((uint32_t)instance & ~1U);
|
|
|
|
/* Extract recursive mutex flag */
|
|
rmtx = (uint32_t)instance & 1U;
|
|
|
|
stat = FuriStatusOk;
|
|
|
|
if(FURI_IS_IRQ_MODE()) {
|
|
stat = FuriStatusErrorISR;
|
|
} else if(hMutex == NULL) {
|
|
stat = FuriStatusErrorParameter;
|
|
} else {
|
|
if(rmtx != 0U) {
|
|
if(xSemaphoreTakeRecursive(hMutex, timeout) != pdPASS) {
|
|
if(timeout != 0U) {
|
|
stat = FuriStatusErrorTimeout;
|
|
} else {
|
|
stat = FuriStatusErrorResource;
|
|
}
|
|
}
|
|
} else {
|
|
if(xSemaphoreTake(hMutex, timeout) != pdPASS) {
|
|
if(timeout != 0U) {
|
|
stat = FuriStatusErrorTimeout;
|
|
} else {
|
|
stat = FuriStatusErrorResource;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/* Return execution status */
|
|
return (stat);
|
|
}
|
|
|
|
FuriStatus furi_mutex_release(FuriMutex* instance) {
|
|
SemaphoreHandle_t hMutex;
|
|
FuriStatus stat;
|
|
uint32_t rmtx;
|
|
|
|
hMutex = (SemaphoreHandle_t)((uint32_t)instance & ~1U);
|
|
|
|
/* Extract recursive mutex flag */
|
|
rmtx = (uint32_t)instance & 1U;
|
|
|
|
stat = FuriStatusOk;
|
|
|
|
if(FURI_IS_IRQ_MODE()) {
|
|
stat = FuriStatusErrorISR;
|
|
} else if(hMutex == NULL) {
|
|
stat = FuriStatusErrorParameter;
|
|
} else {
|
|
if(rmtx != 0U) {
|
|
if(xSemaphoreGiveRecursive(hMutex) != pdPASS) {
|
|
stat = FuriStatusErrorResource;
|
|
}
|
|
} else {
|
|
if(xSemaphoreGive(hMutex) != pdPASS) {
|
|
stat = FuriStatusErrorResource;
|
|
}
|
|
}
|
|
}
|
|
|
|
/* Return execution status */
|
|
return (stat);
|
|
}
|
|
|
|
FuriThreadId furi_mutex_get_owner(FuriMutex* instance) {
|
|
SemaphoreHandle_t hMutex;
|
|
FuriThreadId owner;
|
|
|
|
hMutex = (SemaphoreHandle_t)((uint32_t)instance & ~1U);
|
|
|
|
if((hMutex == NULL)) {
|
|
owner = 0;
|
|
} else if(FURI_IS_IRQ_MODE()) {
|
|
owner = (FuriThreadId)xSemaphoreGetMutexHolderFromISR(hMutex);
|
|
} else {
|
|
owner = (FuriThreadId)xSemaphoreGetMutexHolder(hMutex);
|
|
}
|
|
|
|
/* Return owner thread ID */
|
|
return (owner);
|
|
}
|