mirror of
https://github.com/QuantumLeaps/qpc.git
synced 2025-01-28 07:03:10 +08:00
842 lines
24 KiB
C
842 lines
24 KiB
C
//============================================================================
|
|
// QP/C Real-Time Embedded Framework (RTEF)
|
|
// Version 8.0.2
|
|
//
|
|
// Copyright (C) 2005 Quantum Leaps, LLC. All rights reserved.
|
|
//
|
|
// Q u a n t u m L e a P s
|
|
// ------------------------
|
|
// Modern Embedded Software
|
|
//
|
|
// SPDX-License-Identifier: GPL-3.0-or-later OR LicenseRef-QL-commercial
|
|
//
|
|
// This software is dual-licensed under the terms of the open-source GNU
|
|
// General Public License (GPL) or under the terms of one of the closed-
|
|
// source Quantum Leaps commercial licenses.
|
|
//
|
|
// Redistributions in source code must retain this top-level comment block.
|
|
// Plagiarizing this software to sidestep the license obligations is illegal.
|
|
//
|
|
// NOTE:
|
|
// The GPL does NOT permit the incorporation of this code into proprietary
|
|
// programs. Please contact Quantum Leaps for commercial licensing options,
|
|
// which expressly supersede the GPL and are designed explicitly for
|
|
// closed-source distribution.
|
|
//
|
|
// Quantum Leaps contact information:
|
|
// <www.state-machine.com/licensing>
|
|
// <info@state-machine.com>
|
|
//============================================================================
|
|
#ifndef QP_H_
|
|
#define QP_H_
|
|
|
|
//============================================================================
|
|
#define QP_VERSION_STR "8.0.2"
|
|
#define QP_VERSION 802U
|
|
// <VER>=802 <DATE>=250120
|
|
#define QP_RELEASE 0x6AEAB45DU
|
|
|
|
//============================================================================
|
|
// default configuration settings
|
|
//! @cond INTERNAL
|
|
|
|
#ifndef Q_SIGNAL_SIZE
|
|
#define Q_SIGNAL_SIZE 2U
|
|
#endif
|
|
|
|
#ifndef QF_MAX_ACTIVE
|
|
#define QF_MAX_ACTIVE 32U
|
|
#endif
|
|
|
|
#if (QF_MAX_ACTIVE > 64U)
|
|
#error QF_MAX_ACTIVE exceeds the maximum of 64U;
|
|
#endif
|
|
|
|
#ifndef QF_MAX_TICK_RATE
|
|
#define QF_MAX_TICK_RATE 1U
|
|
#endif
|
|
|
|
#if (QF_MAX_TICK_RATE > 15U)
|
|
#error QF_MAX_TICK_RATE exceeds the maximum of 15U;
|
|
#endif
|
|
|
|
#ifndef QF_MAX_EPOOL
|
|
#define QF_MAX_EPOOL 3U
|
|
#endif
|
|
|
|
#if (QF_MAX_EPOOL > 15U)
|
|
#error QF_MAX_EPOOL exceeds the maximum of 15U;
|
|
#endif
|
|
|
|
#ifndef QF_TIMEEVT_CTR_SIZE
|
|
#define QF_TIMEEVT_CTR_SIZE 4U
|
|
#endif
|
|
|
|
#if (QF_TIMEEVT_CTR_SIZE > 4U)
|
|
#error QF_TIMEEVT_CTR_SIZE defined incorrectly, expected 1U, 2U, or 4U;
|
|
#endif
|
|
|
|
#ifndef QF_EVENT_SIZ_SIZE
|
|
#define QF_EVENT_SIZ_SIZE 2U
|
|
#endif
|
|
|
|
#if (QF_EVENT_SIZ_SIZE > 4U)
|
|
#error QF_EVENT_SIZ_SIZE defined incorrectly, expected 1U, 2U, or 4U;
|
|
#endif
|
|
|
|
//! @endcond
|
|
|
|
//============================================================================
|
|
// global types/utilities
|
|
|
|
typedef int int_t;
|
|
typedef int enum_t;
|
|
typedef float float32_t;
|
|
typedef double float64_t;
|
|
|
|
#define Q_UNUSED_PAR(par_) ((void)(par_))
|
|
#define Q_DIM(array_) (sizeof(array_) / sizeof((array_)[0U]))
|
|
#define Q_UINT2PTR_CAST(type_, uint_) ((type_ *)(uint_))
|
|
|
|
//============================================================================
|
|
extern char const QP_versionStr[24];
|
|
|
|
// QSignal type
|
|
#if (Q_SIGNAL_SIZE == 1U)
|
|
typedef uint8_t QSignal;
|
|
#elif (Q_SIGNAL_SIZE == 2U)
|
|
typedef uint16_t QSignal;
|
|
#elif (Q_SIGNAL_SIZE == 4U)
|
|
typedef uint32_t QSignal;
|
|
#endif
|
|
|
|
//============================================================================
|
|
//! @class QEvt
|
|
typedef struct QEvt {
|
|
QSignal sig; //!< @public @memberof QEvt
|
|
uint8_t poolNum_; //!< @private @memberof QEvt
|
|
uint8_t volatile refCtr_; //!< @private @memberof QEvt
|
|
} QEvt;
|
|
|
|
#define QEVT_INITIALIZER(sig_) { (QSignal)(sig_), 0x00U, 0xE0U }
|
|
//! @public @memberof QEvt
|
|
static inline void QEvt_ctor(QEvt * const me,
|
|
enum_t const sig)
|
|
{
|
|
me->sig = (QSignal)sig;
|
|
me->poolNum_ = 0x00U;
|
|
me->refCtr_ = 0xE0U;
|
|
}
|
|
|
|
//! @public @memberof QEvt
|
|
static inline QEvt * QEvt_init(QEvt * const me,
|
|
uint8_t const dummy)
|
|
{
|
|
Q_UNUSED_PAR(dummy);
|
|
return me;
|
|
}
|
|
|
|
typedef QEvt const * QEvtPtr;
|
|
|
|
#define QEVT_DYNAMIC ((uint8_t)0)
|
|
#define Q_EVT_CAST(class_) ((class_ const *)(e))
|
|
|
|
//============================================================================
|
|
// QEP (hierarchical event processor) types
|
|
|
|
typedef uint_fast8_t QState;
|
|
typedef QState (*QStateHandler)(void * const me, QEvt const * const e);
|
|
typedef QState (*QActionHandler)(void * const me);
|
|
|
|
struct QXThread; // forward declarsation
|
|
typedef void (* QXThreadHandler )(struct QXThread * const me);
|
|
|
|
typedef struct QMState {
|
|
struct QMState const *superstate; //!< @private @memberof QMState
|
|
QStateHandler const stateHandler; //!< @private @memberof QMState
|
|
QActionHandler const entryAction; //!< @private @memberof QMState
|
|
QActionHandler const exitAction; //!< @private @memberof QMState
|
|
QActionHandler const initAction; //!< @private @memberof QMState
|
|
} QMState;
|
|
|
|
typedef struct QMTranActTable {
|
|
QMState const *target; //!< @private @memberof QMTranActTable
|
|
QActionHandler const act[1]; //!< @private @memberof QMTranActTable
|
|
} QMTranActTable;
|
|
|
|
union QAsmAttr {
|
|
QStateHandler fun; //!< @private @memberof QAsmAttr
|
|
QActionHandler act; //!< @private @memberof QAsmAttr
|
|
QXThreadHandler thr; //!< @private @memberof QAsmAttr
|
|
QMTranActTable const *tatbl; //!< @private @memberof QAsmAttr
|
|
struct QMState const *obj; //!< @private @memberof QAsmAttr
|
|
};
|
|
|
|
#define Q_STATE_CAST(handler_) ((QStateHandler)(handler_))
|
|
#define Q_ACTION_CAST(action_) ((QActionHandler)(action_))
|
|
#define Q_ACTION_NULL ((QActionHandler)0)
|
|
|
|
//============================================================================
|
|
//! @class QAsm
|
|
typedef struct {
|
|
struct QAsmVtable const * vptr; //!< @protected @memberof QAsm
|
|
union QAsmAttr state; //!< @protected @memberof QAsm
|
|
union QAsmAttr temp; //!< @protected @memberof QAsm
|
|
} QAsm;
|
|
|
|
// All possible values returned from state/action handlers
|
|
// NOTE: The ordering is important for algorithmic correctness.
|
|
#define Q_RET_SUPER ((QState)0U)
|
|
#define Q_RET_UNHANDLED ((QState)1U)
|
|
|
|
// handled and do not need to "bubble up"
|
|
#define Q_RET_HANDLED ((QState)2U)
|
|
#define Q_RET_IGNORED ((QState)3U)
|
|
|
|
// entry/exit
|
|
#define Q_RET_ENTRY ((QState)4U)
|
|
#define Q_RET_EXIT ((QState)5U)
|
|
|
|
// no side effects
|
|
#define Q_RET_NULL ((QState)6U)
|
|
|
|
// transitions need to execute transition-action table in ::QMsm
|
|
#define Q_RET_TRAN ((QState)7U)
|
|
#define Q_RET_TRAN_INIT ((QState)8U)
|
|
|
|
// transitions that additionally clobber me->state
|
|
#define Q_RET_TRAN_HIST ((QState)9U)
|
|
|
|
// Reserved signals by the QP-framework.
|
|
#define Q_EMPTY_SIG ((QSignal)0U)
|
|
#define Q_ENTRY_SIG ((QSignal)1U)
|
|
#define Q_EXIT_SIG ((QSignal)2U)
|
|
#define Q_INIT_SIG ((QSignal)3U)
|
|
#define Q_USER_SIG ((enum_t)4)
|
|
|
|
//! @protected @memberof QAsm
|
|
static inline void QAsm_ctor(QAsm * const me) {
|
|
me->vptr = (struct QAsmVtable *)0;
|
|
me->state.fun = (QStateHandler)0;
|
|
me->temp.fun = (QStateHandler)0;
|
|
}
|
|
|
|
struct QAsmVtable {
|
|
void (*init)(QAsm * const me, void const * const e,
|
|
uint_fast8_t const qsId);
|
|
void (*dispatch)(QAsm * const me, QEvt const * const e,
|
|
uint_fast8_t const qsId);
|
|
bool (*isIn)(QAsm * const me, QStateHandler const s);
|
|
#ifdef Q_SPY
|
|
QStateHandler (*getStateHandler)(QAsm * const me);
|
|
#endif // Q_SPY
|
|
};
|
|
|
|
#ifdef Q_SPY
|
|
#define QASM_INIT(me_, par_, qsId_) \
|
|
(*((QAsm *)(me_))->vptr->init)((QAsm *)(me_), (par_), (qsId_))
|
|
#define QASM_DISPATCH(me_, e_, qsId_) \
|
|
(*((QAsm *)(me_))->vptr->dispatch)((QAsm *)(me_), (e_), (qsId_))
|
|
#define QASM_IS_IN(me_, state_) \
|
|
(*((QAsm *)(me_))->vptr->isIn)((QAsm *)(me_), (state_))
|
|
#else
|
|
#define QASM_INIT(me_, par_, dummy) \
|
|
(*((QAsm *)(me_))->vptr->init)((QAsm *)(me_), (par_), 0U)
|
|
#define QASM_DISPATCH(me_, e_, dummy) \
|
|
(*((QAsm *)(me_))->vptr->dispatch)((QAsm *)(me_), (e_), 0U)
|
|
#endif // ndef Q_SPY
|
|
|
|
#define Q_ASM_UPCAST(ptr_) ((QAsm *)(ptr_))
|
|
|
|
//============================================================================
|
|
//! @class QHsm
|
|
//! @extends QAsm
|
|
typedef struct {
|
|
QAsm super; //!< @protected @memberof QHsm
|
|
} QHsm;
|
|
|
|
//! @protected @memberof QHsm
|
|
void QHsm_ctor(QHsm * const me,
|
|
QStateHandler const initial);
|
|
|
|
//! @private @memberof QHsm
|
|
void QHsm_init_(
|
|
QAsm * const me,
|
|
void const * const e,
|
|
uint_fast8_t const qsId);
|
|
|
|
//! @private @memberof QHsm
|
|
void QHsm_dispatch_(
|
|
QAsm * const me,
|
|
QEvt const * const e,
|
|
uint_fast8_t const qsId);
|
|
|
|
//! @private @memberof QHsm
|
|
bool QHsm_isIn_(
|
|
QAsm * const me,
|
|
QStateHandler const state);
|
|
|
|
#ifdef Q_SPY
|
|
//! @private @memberof QHsm
|
|
QStateHandler QHsm_getStateHandler_(QAsm * const me);
|
|
#endif // def Q_SPY
|
|
|
|
//! @protected @memberof QHsm
|
|
QState QHsm_top(QHsm const * const me,
|
|
QEvt const * const e);
|
|
|
|
//! @public @memberof QHsm
|
|
static inline QStateHandler QHsm_state(QHsm const * const me) {
|
|
return me->super.state.fun;
|
|
}
|
|
|
|
//! @public @memberof QHsm
|
|
QStateHandler QHsm_childState(QHsm * const me,
|
|
QStateHandler const parent);
|
|
|
|
#define Q_HSM_UPCAST(ptr_) ((QHsm *)(ptr_))
|
|
|
|
#define Q_TRAN(target_) \
|
|
((Q_ASM_UPCAST(me))->temp.fun = Q_STATE_CAST(target_), \
|
|
(QState)Q_RET_TRAN)
|
|
#define Q_TRAN_HIST(hist_) \
|
|
((Q_ASM_UPCAST(me))->temp.fun = (hist_), \
|
|
(QState)Q_RET_TRAN_HIST)
|
|
#define Q_SUPER(super_) \
|
|
((Q_ASM_UPCAST(me))->temp.fun = Q_STATE_CAST(super_), \
|
|
(QState)Q_RET_SUPER)
|
|
#define Q_HANDLED() ((QState)Q_RET_HANDLED)
|
|
#define Q_UNHANDLED() ((QState)Q_RET_UNHANDLED)
|
|
|
|
//============================================================================
|
|
//! @class QMsm
|
|
//! @extends QAsm
|
|
typedef struct {
|
|
QAsm super; //!< @protected @memberof QMsm
|
|
} QMsm;
|
|
|
|
//! @protected @memberof QMsm
|
|
void QMsm_ctor(QMsm * const me,
|
|
QStateHandler const initial);
|
|
|
|
//! @private @memberof QMsm
|
|
void QMsm_init_(
|
|
QAsm * const me,
|
|
void const * const e,
|
|
uint_fast8_t const qsId);
|
|
|
|
//! @private @memberof QMsm
|
|
void QMsm_dispatch_(
|
|
QAsm * const me,
|
|
QEvt const * const e,
|
|
uint_fast8_t const qsId);
|
|
|
|
//! @private @memberof QMsm
|
|
bool QMsm_isIn_(
|
|
QAsm * const me,
|
|
QStateHandler const state);
|
|
|
|
#ifdef Q_SPY
|
|
//! @public @memberof QMsm
|
|
QStateHandler QMsm_getStateHandler_(QAsm * const me);
|
|
#endif // def Q_SPY
|
|
|
|
//! @public @memberof QMsm
|
|
static inline QMState const * QMsm_stateObj(QMsm const * const me) {
|
|
return me->super.state.obj;
|
|
}
|
|
|
|
//! @public @memberof QMsm
|
|
QMState const * QMsm_childStateObj(QMsm const * const me,
|
|
QMState const * const parent);
|
|
//============================================================================
|
|
// QEP-macros
|
|
|
|
#define Q_MSM_UPCAST(ptr_) ((QMsm *)(ptr_))
|
|
#ifdef Q_SPY
|
|
#define QM_ENTRY(state_) \
|
|
((Q_ASM_UPCAST(me))->temp.obj = (state_), (QState)Q_RET_ENTRY)
|
|
#define QM_EXIT(state_) \
|
|
((Q_ASM_UPCAST(me))->temp.obj = (state_), (QState)Q_RET_EXIT)
|
|
#else
|
|
#define QM_ENTRY(dummy) ((QState)Q_RET_ENTRY)
|
|
#define QM_EXIT(dummy) ((QState)Q_RET_EXIT)
|
|
#endif // ndef Q_SPY
|
|
|
|
#define QM_TRAN(tatbl_) ((Q_ASM_UPCAST(me))->temp.tatbl \
|
|
= (struct QMTranActTable const *)(tatbl_), (QState)Q_RET_TRAN)
|
|
|
|
#define QM_TRAN_INIT(tatbl_) ((Q_ASM_UPCAST(me))->temp.tatbl \
|
|
= (struct QMTranActTable const *)(tatbl_), (QState)Q_RET_TRAN_INIT)
|
|
|
|
#define QM_TRAN_HIST(history_, tatbl_) \
|
|
((((Q_ASM_UPCAST(me))->state.obj = (history_)), \
|
|
((Q_ASM_UPCAST(me))->temp.tatbl = \
|
|
(struct QMTranActTable const *)(tatbl_))), (QState)Q_RET_TRAN_HIST)
|
|
|
|
#define QM_HANDLED() ((QState)Q_RET_HANDLED)
|
|
#define QM_UNHANDLED() ((QState)Q_RET_UNHANDLED)
|
|
#define QM_SUPER() ((QState)Q_RET_SUPER)
|
|
#define QM_STATE_NULL ((QMState *)0)
|
|
|
|
//============================================================================
|
|
// QF (active object framework) types
|
|
|
|
typedef uint16_t QPrioSpec;
|
|
|
|
#if (QF_TIMEEVT_CTR_SIZE == 1U)
|
|
typedef uint8_t QTimeEvtCtr;
|
|
#elif (QF_TIMEEVT_CTR_SIZE == 2U)
|
|
typedef uint16_t QTimeEvtCtr;
|
|
#elif (QF_TIMEEVT_CTR_SIZE == 4U)
|
|
typedef uint32_t QTimeEvtCtr;
|
|
#endif // (QF_TIMEEVT_CTR_SIZE == 4U)
|
|
|
|
#if (QF_MAX_ACTIVE <= 8U)
|
|
typedef uint8_t QPSetBits;
|
|
#elif (8U < QF_MAX_ACTIVE) && (QF_MAX_ACTIVE <= 16U)
|
|
typedef uint16_t QPSetBits;
|
|
#elif (16U < QF_MAX_ACTIVE)
|
|
typedef uint32_t QPSetBits;
|
|
#endif // (16U < QF_MAX_ACTIVE)
|
|
|
|
#ifndef QF_LOG2
|
|
uint_fast8_t QF_LOG2(QPSetBits const bitmask);
|
|
#endif // ndef QF_LOG2
|
|
|
|
//============================================================================
|
|
//! @class QPSet
|
|
typedef struct {
|
|
//! @private @memberof QPSet
|
|
QPSetBits bits[((QF_MAX_ACTIVE + (8U*sizeof(QPSetBits))) - 1U)
|
|
/ (8U*sizeof(QPSetBits))];
|
|
} QPSet;
|
|
|
|
//! @public @memberof QPSet
|
|
static inline void QPSet_setEmpty(QPSet * const me) {
|
|
me->bits[0] = 0U;
|
|
#if (QF_MAX_ACTIVE > 32)
|
|
me->bits[1] = 0U;
|
|
#endif
|
|
}
|
|
|
|
//! @public @memberof QPSet
|
|
static inline bool QPSet_isEmpty(QPSet const * const me) {
|
|
#if (QF_MAX_ACTIVE <= 32U)
|
|
return (me->bits[0] == 0U);
|
|
#else
|
|
return (me->bits[0] == 0U) ? (me->bits[1] == 0U) : false;
|
|
#endif
|
|
}
|
|
|
|
//! @public @memberof QPSet
|
|
static inline bool QPSet_notEmpty(QPSet const * const me) {
|
|
#if (QF_MAX_ACTIVE <= 32U)
|
|
return (me->bits[0] != 0U);
|
|
#else
|
|
return (me->bits[0] != 0U) ? true : (me->bits[1] != 0U);
|
|
#endif
|
|
}
|
|
|
|
//! @public @memberof QPSet
|
|
static inline bool QPSet_hasElement(QPSet const * const me,
|
|
uint_fast8_t const n)
|
|
{
|
|
#if (QF_MAX_ACTIVE <= 32U)
|
|
return (me->bits[0] & ((QPSetBits)1U << (n - 1U))) != 0U;
|
|
#else
|
|
return (n <= 32U)
|
|
? ((me->bits[0] & ((QPSetBits)1U << (n - 1U))) != 0U)
|
|
: ((me->bits[1] & ((QPSetBits)1U << (n - 33U))) != 0U);
|
|
#endif
|
|
}
|
|
|
|
//! @public @memberof QPSet
|
|
static inline void QPSet_insert(QPSet * const me,
|
|
uint_fast8_t const n)
|
|
{
|
|
#if (QF_MAX_ACTIVE <= 32U)
|
|
me->bits[0] = (me->bits[0] | ((QPSetBits)1U << (n - 1U)));
|
|
#else
|
|
if (n <= 32U) {
|
|
me->bits[0] = (me->bits[0] | ((QPSetBits)1U << (n - 1U)));
|
|
}
|
|
else {
|
|
me->bits[1] = (me->bits[1] | ((QPSetBits)1U << (n - 33U)));
|
|
}
|
|
#endif
|
|
}
|
|
|
|
//! @public @memberof QPSet
|
|
static inline void QPSet_remove(QPSet * const me,
|
|
uint_fast8_t const n)
|
|
{
|
|
#if (QF_MAX_ACTIVE <= 32U)
|
|
me->bits[0] = (me->bits[0] & (QPSetBits)(~((QPSetBits)1U << (n - 1U))));
|
|
#else
|
|
if (n <= 32U) {
|
|
(me->bits[0] = (me->bits[0] & ~((QPSetBits)1U << (n - 1U))));
|
|
}
|
|
else {
|
|
(me->bits[1] = (me->bits[1] & ~((QPSetBits)1U << (n - 33U))));
|
|
}
|
|
#endif
|
|
}
|
|
|
|
//! @public @memberof QPSet
|
|
static inline uint_fast8_t QPSet_findMax(QPSet const * const me) {
|
|
#if (QF_MAX_ACTIVE <= 32U)
|
|
return QF_LOG2(me->bits[0]);
|
|
#else
|
|
return (me->bits[1] != 0U)
|
|
? (QF_LOG2(me->bits[1]) + 32U)
|
|
: (QF_LOG2(me->bits[0]));
|
|
#endif
|
|
}
|
|
|
|
//! @struct QSubscrList
|
|
typedef struct {
|
|
QPSet set; //!< @private @memberof QSubscrList
|
|
} QSubscrList;
|
|
|
|
struct QEQueue; // forward declaration
|
|
|
|
//============================================================================
|
|
//! @class QActive
|
|
//! @extends QAsm
|
|
typedef struct QActive {
|
|
QAsm super; //!< @protected @memberof QActive
|
|
uint8_t prio; //!< @protected @memberof QActive
|
|
uint8_t pthre; //!< @protected @memberof QActive
|
|
|
|
#ifdef QACTIVE_THREAD_TYPE
|
|
QACTIVE_THREAD_TYPE thread; //!< @protected @memberof QActive
|
|
#endif // def QACTIVE_THREAD_TYPE
|
|
|
|
#ifdef QACTIVE_OS_OBJ_TYPE
|
|
QACTIVE_OS_OBJ_TYPE osObject; //!< @protected @memberof QActive
|
|
#endif // def QACTIVE_OS_OBJ_TYPE
|
|
|
|
#ifdef QACTIVE_EQUEUE_TYPE
|
|
QACTIVE_EQUEUE_TYPE eQueue; //!< @protected @memberof QActive
|
|
#endif // def QACTIVE_EQUEUE_TYPE
|
|
} QActive;
|
|
|
|
//! @static @private @memberof QActive
|
|
extern QActive * QActive_registry_[QF_MAX_ACTIVE + 1U];
|
|
|
|
//! @static @private @memberof QActive
|
|
extern QSubscrList * QActive_subscrList_;
|
|
|
|
//! @static @private @memberof QActive
|
|
extern enum_t QActive_maxPubSignal_;
|
|
|
|
//! @protected @memberof QActive
|
|
void QActive_ctor(QActive * const me,
|
|
QStateHandler const initial);
|
|
|
|
//! @public @memberof QActive
|
|
void QActive_setAttr(QActive * const me,
|
|
uint32_t attr1,
|
|
void const * attr2);
|
|
|
|
//! @public @memberof QActive
|
|
void QActive_start(QActive * const me,
|
|
QPrioSpec const prioSpec,
|
|
QEvtPtr * const qSto,
|
|
uint_fast16_t const qLen,
|
|
void * const stkSto,
|
|
uint_fast16_t const stkSize,
|
|
void const * const par);
|
|
|
|
#ifdef QACTIVE_CAN_STOP
|
|
//! @protected @memberof QActive
|
|
void QActive_stop(QActive * const me);
|
|
#endif // def QACTIVE_CAN_STOP
|
|
|
|
//! @private @memberof QActive
|
|
void QActive_register_(QActive * const me);
|
|
|
|
//! @private @memberof QActive
|
|
void QActive_unregister_(QActive * const me);
|
|
|
|
//! @private @memberof QActive
|
|
bool QActive_post_(QActive * const me,
|
|
QEvt const * const e,
|
|
uint_fast16_t const margin,
|
|
void const * const sender);
|
|
|
|
//! @private @memberof QActive
|
|
void QActive_postLIFO_(QActive * const me,
|
|
QEvt const * const e);
|
|
|
|
//! @private @memberof QActive
|
|
QEvt const * QActive_get_(QActive * const me);
|
|
|
|
//! @static @public @memberof QActive
|
|
void QActive_psInit(
|
|
QSubscrList * const subscrSto,
|
|
enum_t const maxSignal);
|
|
|
|
//! @static @private @memberof QActive
|
|
void QActive_publish_(
|
|
QEvt const * const e,
|
|
void const * const sender,
|
|
uint_fast8_t const qsId);
|
|
|
|
//! @protected @memberof QActive
|
|
void QActive_subscribe(QActive const * const me,
|
|
enum_t const sig);
|
|
|
|
//! @protected @memberof QActive
|
|
void QActive_unsubscribe(QActive const * const me,
|
|
enum_t const sig);
|
|
|
|
//! @protected @memberof QActive
|
|
void QActive_unsubscribeAll(QActive const * const me);
|
|
|
|
//! @protected @memberof QActive
|
|
bool QActive_defer(QActive const * const me,
|
|
struct QEQueue * const eq,
|
|
QEvt const * const e);
|
|
|
|
//! @protected @memberof QActive
|
|
bool QActive_recall(QActive * const me,
|
|
struct QEQueue * const eq);
|
|
|
|
//! @protected @memberof QActive
|
|
uint_fast16_t QActive_flushDeferred(QActive const * const me,
|
|
struct QEQueue * const eq,
|
|
uint_fast16_t const num);
|
|
|
|
//! @private @memberof QActive
|
|
void QActive_evtLoop_(QActive * const me);
|
|
|
|
//============================================================================
|
|
//! @class QMActive
|
|
//! @extends QActive
|
|
typedef struct {
|
|
QActive super; //!< @protected @memberof QMActive
|
|
} QMActive;
|
|
|
|
//! @protected @memberof QMActive
|
|
void QMActive_ctor(QMActive * const me,
|
|
QStateHandler const initial);
|
|
|
|
//============================================================================
|
|
//! @class QTimeEvt
|
|
//! @extends QEvt
|
|
typedef struct QTimeEvt {
|
|
QEvt super; //!< @protected @memberof QTimeEvt
|
|
|
|
struct QTimeEvt * volatile next; //!< @private @memberof QTimeEvt
|
|
void * act; //!< @private @memberof QTimeEvt
|
|
QTimeEvtCtr volatile ctr; //!< @private @memberof QTimeEvt
|
|
QTimeEvtCtr interval; //!< @private @memberof QTimeEvt
|
|
uint8_t tickRate; //!< @private @memberof QTimeEvt
|
|
uint8_t flags; //!< @private @memberof QTimeEvt
|
|
} QTimeEvt;
|
|
|
|
//! @public @memberof QTimeEvt
|
|
void QTimeEvt_ctorX(QTimeEvt * const me,
|
|
QActive * const act,
|
|
enum_t const sig,
|
|
uint_fast8_t const tickRate);
|
|
|
|
//! @public @memberof QTimeEvt
|
|
void QTimeEvt_armX(QTimeEvt * const me,
|
|
uint32_t const nTicks,
|
|
uint32_t const interval);
|
|
|
|
//! @public @memberof QTimeEvt
|
|
bool QTimeEvt_disarm(QTimeEvt * const me);
|
|
|
|
//! @public @memberof QTimeEvt
|
|
bool QTimeEvt_rearm(QTimeEvt * const me,
|
|
uint32_t const nTicks);
|
|
|
|
//! @public @memberof QTimeEvt
|
|
bool QTimeEvt_wasDisarmed(QTimeEvt * const me);
|
|
|
|
//! @public @memberof QTimeEvt
|
|
QTimeEvtCtr QTimeEvt_currCtr(QTimeEvt const * const me);
|
|
|
|
//! @static @private @memberof QTimeEvt
|
|
void QTimeEvt_init(void);
|
|
|
|
//! @static @private @memberof QTimeEvt
|
|
void QTimeEvt_tick_(
|
|
uint_fast8_t const tickRate,
|
|
void const * const sender);
|
|
|
|
//! @private @memberof QTimeEvt
|
|
QTimeEvt * QTimeEvt_expire_(QTimeEvt * const me,
|
|
QTimeEvt * const prev_link,
|
|
QActive const * const act,
|
|
uint_fast8_t const tickRate);
|
|
|
|
#ifdef Q_UTEST
|
|
//! @static @private @memberof QTimeEvt
|
|
void QTimeEvt_tick1_(
|
|
uint_fast8_t const tickRate,
|
|
void const * const sender);
|
|
#endif // def Q_UTEST
|
|
|
|
//! @static @public @memberof QTimeEvt
|
|
bool QTimeEvt_noActive(uint_fast8_t const tickRate);
|
|
|
|
//! @static @private @memberof QTimeEvt
|
|
extern QTimeEvt QTimeEvt_timeEvtHead_[QF_MAX_TICK_RATE];
|
|
|
|
//============================================================================
|
|
//! @class QTicker
|
|
//! @extends QActive
|
|
typedef struct {
|
|
QActive super; //!< @protected @memberof QTicker
|
|
} QTicker;
|
|
|
|
//! @public @memberof QTicker
|
|
void QTicker_ctor(QTicker * const me,
|
|
uint_fast8_t const tickRate);
|
|
|
|
//! @private @memberof QTicker
|
|
void QTicker_init_(
|
|
QAsm * const me,
|
|
void const * const par,
|
|
uint_fast8_t const qsId);
|
|
|
|
//! @private @memberof QTicker
|
|
void QTicker_dispatch_(
|
|
QAsm * const me,
|
|
QEvt const * const e,
|
|
uint_fast8_t const qsId);
|
|
|
|
//! @private @memberof QTicker
|
|
void QTicker_trig_(
|
|
QActive * const me,
|
|
void const * const sender);
|
|
|
|
//============================================================================
|
|
// QF base facilities
|
|
|
|
//! @static @public @memberof QF
|
|
void QF_init(void);
|
|
|
|
//! @static @public @memberof QF
|
|
void QF_stop(void);
|
|
|
|
//! @static @public @memberof QF
|
|
int_t QF_run(void);
|
|
|
|
//! @static @public @memberof QF
|
|
uint_fast16_t QF_getQueueMin(uint_fast8_t const prio);
|
|
|
|
//! @static @public @memberof QF
|
|
void QF_onStartup(void);
|
|
|
|
//! @static @public @memberof QF
|
|
void QF_onCleanup(void);
|
|
|
|
#ifdef QF_ON_CONTEXT_SW
|
|
//! @static @public @memberof QF
|
|
void QF_onContextSw(
|
|
QActive * prev,
|
|
QActive * next);
|
|
#endif // def QF_ON_CONTEXT_SW
|
|
|
|
#define Q_PRIO(prio_, pthre_) ((QPrioSpec)((prio_) | ((pthre_) << 8U)))
|
|
#define QF_NO_MARGIN ((uint_fast16_t)0xFFFFU)
|
|
|
|
//============================================================================
|
|
// QF dynamic memory facilities
|
|
|
|
//! @static @public @memberof QF
|
|
void QF_poolInit(
|
|
void * const poolSto,
|
|
uint_fast32_t const poolSize,
|
|
uint_fast16_t const evtSize);
|
|
|
|
//! @static @public @memberof QF
|
|
uint_fast16_t QF_poolGetMaxBlockSize(void);
|
|
|
|
//! @static @public @memberof QF
|
|
uint_fast16_t QF_getPoolMin(uint_fast8_t const poolNum);
|
|
|
|
//! @static @private @memberof QF
|
|
QEvt * QF_newX_(
|
|
uint_fast16_t const evtSize,
|
|
uint_fast16_t const margin,
|
|
enum_t const sig);
|
|
|
|
//! @static @public @memberof QF
|
|
void QF_gc(QEvt const * const e);
|
|
|
|
//! @static @private @memberof QF
|
|
QEvt const * QF_newRef_(
|
|
QEvt const * const e,
|
|
void const * const evtRef);
|
|
|
|
//! @static @private @memberof QF
|
|
void QF_deleteRef_(void const * const evtRef);
|
|
|
|
//! @static @public @memberof QF
|
|
void QF_gcFromISR(QEvt const * const e);
|
|
|
|
#ifdef QEVT_PAR_INIT
|
|
#define Q_NEW(evtT_, sig_, ...) \
|
|
(evtT_##_init((evtT_ *)QF_newX_((uint_fast16_t)sizeof(evtT_), \
|
|
QF_NO_MARGIN, (sig_)), __VA_ARGS__))
|
|
#define Q_NEW_X(evtT_, margin_, sig_, ...) \
|
|
(evtT_##_init((evtT_ *)QF_newX_((uint_fast16_t)sizeof(evtT_), \
|
|
(margin_), (sig_)), __VA_ARGS__))
|
|
#else
|
|
#define Q_NEW(evtT_, sig_) \
|
|
((evtT_ *)QF_newX_((uint_fast16_t)sizeof(evtT_), \
|
|
QF_NO_MARGIN, (enum_t)(sig_)))
|
|
#define Q_NEW_X(evtT_, margin_, sig_) \
|
|
((evtT_ *)QF_newX_((uint_fast16_t)sizeof(evtT_), \
|
|
(margin_), (enum_t)(sig_)))
|
|
#endif // QEVT_PAR_INIT
|
|
|
|
#define Q_NEW_REF(evtRef_, evtT_) \
|
|
((evtRef_) = (evtT_ const *)QF_newRef_(e, (evtRef_)))
|
|
#define Q_DELETE_REF(evtRef_) do { \
|
|
QF_deleteRef_((evtRef_)); \
|
|
(evtRef_) = (void *)0; \
|
|
} while (false)
|
|
|
|
#ifdef Q_SPY
|
|
#define QACTIVE_POST(me_, e_, sender_) \
|
|
((void)QActive_post_((me_), (e_), QF_NO_MARGIN, (sender_)))
|
|
#define QACTIVE_POST_X(me_, e_, margin_, sender_) \
|
|
(QActive_post_((me_), (e_), (margin_), (sender_)))
|
|
#define QACTIVE_PUBLISH(e_, sender_) \
|
|
(QActive_publish_((e_), (void const *)(sender_), (sender_)->prio))
|
|
#define QTIMEEVT_TICK_X(tickRate_, sender_) (QTimeEvt_tick_((tickRate_), (sender_)))
|
|
#define QTICKER_TRIG(ticker_, sender_) (QTicker_trig_((ticker_), (sender_)))
|
|
#else
|
|
#define QACTIVE_POST(me_, e_, dummy) \
|
|
((void)QActive_post_((me_), (e_), QF_NO_MARGIN, (void *)0))
|
|
#define QACTIVE_POST_X(me_, e_, margin_, dummy) \
|
|
(QActive_post_((me_), (e_), (margin_), (void *)0))
|
|
#define QACTIVE_PUBLISH(e_, dummy) (QActive_publish_((e_), (void *)0, 0U))
|
|
#define QTIMEEVT_TICK_X(tickRate_, dummy) (QTimeEvt_tick_((tickRate_), (void *)0))
|
|
#define QTICKER_TRIG(ticker_, sender_) (QTicker_trig_((ticker_), (void *)0))
|
|
#endif // ndef Q_SPY
|
|
|
|
#define QACTIVE_POST_LIFO(me_, e_) (QActive_postLIFO_((me_), (e_)))
|
|
#define QTIMEEVT_TICK(sender_) QTIMEEVT_TICK_X(0U, (sender_))
|
|
|
|
#ifndef QF_CRIT_EXIT_NOP
|
|
#define QF_CRIT_EXIT_NOP() ((void)0)
|
|
#endif // ndef QF_CRIT_EXIT_NOP
|
|
|
|
//============================================================================
|
|
// memory protection facilities
|
|
|
|
#ifdef QF_MEM_ISOLATE
|
|
#error Memory isolation not supported in this QP edition, need SafeQP
|
|
#endif // def QF_MEM_ISOLATE
|
|
|
|
#endif // QP_H_
|