mirror of
https://github.com/Next-Flip/Momentum-Firmware.git
synced 2026-04-25 03:29:58 -07:00
6d823835df
* Core: event_flag, removing duplicate code * event_loop: add support furi_event_flags * Examples: add missing free in event loop examples * Furi: fix event flag * Sync api symbols * Unit_test: evet_loop_event_flags * Fix multiple waiting list elements handling * Unit_test: add event_loop_event_flag test * FURI: event_loop add restrictions * Fix multiple waiting lists items for good * Improve FuriEventLoop unit tests * Abolish callback return value * Remove return value from callback signature * Use bool level value instead of int32_t * Add unit tests for FuriStreamBuffer * Add unit tests for FuriSemaphore * Speed up test execution * Improve docs * Add a stub for furi os-level primitives * Add more checks for edge cases * Allow event loop notification from ISR * Bump api version Co-authored-by: Aleksandr Kutuzov <alleteam@gmail.com> Co-authored-by: Georgii Surkov <georgii.surkov@outlook.com> Co-authored-by: Georgii Surkov <37121527+gsurkov@users.noreply.github.com>
98 lines
2.4 KiB
C
98 lines
2.4 KiB
C
#pragma once
|
|
|
|
#include "event_loop.h"
|
|
#include "event_loop_link_i.h"
|
|
#include "event_loop_timer_i.h"
|
|
#include "event_loop_tick_i.h"
|
|
|
|
#include <m-list.h>
|
|
#include <m-bptree.h>
|
|
#include <m-i-list.h>
|
|
|
|
#include "thread.h"
|
|
|
|
struct FuriEventLoopItem {
|
|
// Source
|
|
FuriEventLoop* owner;
|
|
|
|
// Tracking item
|
|
FuriEventLoopEvent event;
|
|
FuriEventLoopObject* object;
|
|
const FuriEventLoopContract* contract;
|
|
|
|
// Callback and context
|
|
FuriEventLoopEventCallback callback;
|
|
void* callback_context;
|
|
|
|
// Waiting list
|
|
ILIST_INTERFACE(WaitingList, FuriEventLoopItem);
|
|
};
|
|
|
|
ILIST_DEF(WaitingList, FuriEventLoopItem, M_POD_OPLIST)
|
|
|
|
/* Event Loop RB tree */
|
|
#define FURI_EVENT_LOOP_TREE_RANK (4)
|
|
|
|
BPTREE_DEF2( // NOLINT
|
|
FuriEventLoopTree,
|
|
FURI_EVENT_LOOP_TREE_RANK,
|
|
FuriEventLoopObject*, /* pointer to object we track */
|
|
M_PTR_OPLIST,
|
|
FuriEventLoopItem*, /* pointer to the FuriEventLoopItem */
|
|
M_PTR_OPLIST)
|
|
|
|
#define M_OPL_FuriEventLoopTree_t() BPTREE_OPLIST(FuriEventLoopTree, M_POD_OPLIST)
|
|
|
|
#define FURI_EVENT_LOOP_FLAG_NOTIFY_INDEX (2)
|
|
|
|
typedef enum {
|
|
FuriEventLoopFlagEvent = (1 << 0),
|
|
FuriEventLoopFlagStop = (1 << 1),
|
|
FuriEventLoopFlagTimer = (1 << 2),
|
|
FuriEventLoopFlagPending = (1 << 3),
|
|
} FuriEventLoopFlag;
|
|
|
|
#define FuriEventLoopFlagAll \
|
|
(FuriEventLoopFlagEvent | FuriEventLoopFlagStop | FuriEventLoopFlagTimer | \
|
|
FuriEventLoopFlagPending)
|
|
|
|
typedef enum {
|
|
FuriEventLoopProcessStatusComplete,
|
|
FuriEventLoopProcessStatusIncomplete,
|
|
FuriEventLoopProcessStatusFreeLater,
|
|
} FuriEventLoopProcessStatus;
|
|
|
|
typedef enum {
|
|
FuriEventLoopStateStopped,
|
|
FuriEventLoopStateIdle,
|
|
FuriEventLoopStateProcessing,
|
|
} FuriEventLoopState;
|
|
|
|
typedef struct {
|
|
FuriEventLoopPendingCallback callback;
|
|
void* context;
|
|
} FuriEventLoopPendingQueueItem;
|
|
|
|
LIST_DUAL_PUSH_DEF(PendingQueue, FuriEventLoopPendingQueueItem, M_POD_OPLIST)
|
|
|
|
struct FuriEventLoop {
|
|
// Only works if all operations are done from the same thread
|
|
FuriThreadId thread_id;
|
|
|
|
// Poller state
|
|
volatile FuriEventLoopState state;
|
|
|
|
// Event handling
|
|
FuriEventLoopTree_t tree;
|
|
WaitingList_t waiting_list;
|
|
|
|
// Active timer list
|
|
TimerList_t timer_list;
|
|
// Timer request queue
|
|
TimerQueue_t timer_queue;
|
|
// Pending callback queue
|
|
PendingQueue_t pending_queue;
|
|
// Tick event
|
|
FuriEventLoopTick tick;
|
|
};
|