xf_ntask.h

浏览该文件的文档.

 
#ifndef __XF_NTASK_H__
#define __XF_NTASK_H__
 
/* ==================== [Includes] ========================================== */
 
#include "../kernel/xf_task_kernel.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
/* ==================== [Defines] =========================================== */
 
#define XF_TASK_TYPE_NTASK XF_TASK_TYPE_ntask
 
/* ==================== [Typedefs] ========================================== */
 
typedef struct _xf_ntask_sem_t {
    uint32_t count;
} xf_ntask_sem_t;
 
typedef int(*xf_ntask_compare_func_t)(xf_task_t task);
 
typedef enum _xf_ntask_status_t {
    XF_NTASK_NONE = -1,
    XF_NTASK_WAITING,
    XF_NTASK_YIELDED,
    XF_NTASK_EXITED,
    XF_NTASK_ENDED,
    XF_NTASK_FINSHED,
} xf_ntask_status_t;
 
/* ==================== [Global Prototypes] ================================= */
 
static inline
xf_task_t xf_ntask_create_with_manager(xf_task_manager_t manager, xf_task_func_t func, void *func_arg,
                                       uint16_t priority)
{
    return xf_task_create_with_manager(manager, XF_TASK_TYPE_NTASK, func, func_arg, priority, NULL);
}
 
void xf_ntask_set_compare(xf_task_t task, xf_ntask_compare_func_t compare);
 
int xf_ntask_args_get_int(xf_task_t *task, const char *name);
 
float xf_ntask_args_get_float(xf_task_t *task, const char *name);
 
void *xf_ntask_args_get_array(xf_task_t *task, const char *name);
 
xf_err_t xf_ntask_args_set_int(xf_task_t *task, const char *name, int value);
 
xf_err_t xf_ntask_args_set_float(xf_task_t *task, const char *name, float value);
 
xf_err_t xf_ntask_args_set_array(xf_task_t *task, const char *name, void *value, unsigned int size, unsigned int len);
 
uint32_t xf_ntask_get_lc(xf_task_t *task, const char *name);
 
xf_err_t xf_ntask_set_lc(xf_task_t *task, const char *name, uint32_t lc);
 
xf_ntask_status_t xf_ntask_get_exit_status(xf_task_t *task);
 
xf_err_t xf_ntask_set_exit_status(xf_task_t *task, xf_ntask_status_t status);
 
bool xf_ntask_lc_is_first(xf_task_t *task, const char *name);
 
/* ==================== [Macros] ============================================ */
 
#define XF_NTASK_BEGIN(ntask)       \
    xf_task_t *_ntask = ntask;      \
    switch (xf_ntask_get_lc(ntask, __func__)) \
    {                               \
    case 0:
 
#define XF_NTASK_END()    \
    }                          \
    xf_ntask_set_lc(_ntask, __func__, 0); \
    if(xf_ntask_lc_is_first(_ntask, __func__)) { \
        xf_ntask_set_exit_status(_ntask, XF_NTASK_FINSHED); \
    } else {                    \
        xf_ntask_set_exit_status(_ntask, XF_NTASK_ENDED); \
    }\
    return
 
#define xf_ntask_yield()               \
    do                                      \
    {                                       \
        xf_task_trigger(_ntask);             \
        xf_ntask_set_lc(_ntask, __func__, __LINE__);   \
        xf_ntask_set_exit_status(_ntask, XF_NTASK_YIELDED); \
        return;                             \
    case __LINE__:;                         \
    } while (0)
 
#define xf_ntask_until(compare_cb)             \
    do                                      \
    {                                       \
        xf_ntask_set_compare(_ntask, compare_cb);      \
        xf_ntask_set_lc(_ntask, __func__, __LINE__);   \
        xf_ntask_set_exit_status(_ntask, XF_NTASK_WAITING); \
        return;                             \
    case __LINE__:;                         \
    } while (0)
 
#define xf_ntask_delay(delay_ms)     \
    do                                      \
    {                                       \
        xf_task_set_delay(_ntask, delay_ms); \
        xf_ntask_set_lc(_ntask, __func__, __LINE__);   \
        xf_ntask_set_exit_status(_ntask, XF_NTASK_WAITING); \
        return;                             \
    case __LINE__:;                         \
    } while (0)
 
#define xf_ntask_until_timeout(compare_cb, timeout_ms) \
    do                                      \
    {                                       \
        xf_task_set_delay(_ntask, timeout_ms); \
        xf_ntask_set_compare(_ntask, compare_cb);      \
        xf_ntask_set_lc(_ntask, __func__, __LINE__);   \
        xf_ntask_set_exit_status(_ntask, XF_NTASK_WAITING); \
        return;                             \
    case __LINE__:;                         \
    } while (0)
 
#define xf_ntask_exit()                \
    do                                      \
    {                                       \
        xf_ntask_set_lc(_ntask, __func__, 0);                \
        if(xf_ntask_lc_is_first(_ntask, __func__)) {         \
            xf_ntask_set_exit_status(_ntask, XF_NTASK_FINSHED);   \
        } else {                        \
            xf_ntask_set_exit_status(_ntask, XF_NTASK_ENDED);     \
        }                               \
        return;                         \
    } while (0)
 
typedef void xf_async_t;
 
#define xf_await(func)                      \
    case __LINE__:                          \
    func;\
    int _async_status = xf_ntask_get_exit_status(_ntask);\
    if (_async_status == XF_NTASK_YIELDED || _async_status == XF_NTASK_WAITING) \
    {\
        xf_ntask_set_lc(_ntask, __func__, __LINE__);   \
        return;                             \
    }\
    else\
    {\
        xf_ntask_set_exit_status(_ntask, XF_NTASK_NONE);\
    }
 
#ifdef __cplusplus
} /* extern "C" */
#endif
 
#endif // __XF_NTASK_H__