447 lines
12 KiB
C
447 lines
12 KiB
C
|
#ifndef OS_API_H
|
|||
|
|
#define OS_API_H
|
|||
|
|
|
|||
|
|
|
|||
|
|
#ifdef __cplusplus
|
|||
|
|
extern "C"
|
|||
|
|
{
|
|||
|
|
#endif
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
#include "generic/typedef.h"
|
|||
|
|
//#include "generic/list.h"
|
|||
|
|
#include "os/os_cpu.h"
|
|||
|
|
#include "os/os_error.h"
|
|||
|
|
#include "os/os_type.h"
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
#define Q_MSG 0x100000
|
|||
|
|
#define Q_EVENT 0x200000
|
|||
|
|
#define Q_CALLBACK 0x300000
|
|||
|
|
#define Q_USER 0x400000
|
|||
|
|
|
|||
|
|
#define OS_DEL_NO_PEND 0u
|
|||
|
|
#define OS_DEL_ALWAYS 1u
|
|||
|
|
|
|||
|
|
#define OS_TASK_DEL_REQ 0x01u
|
|||
|
|
#define OS_TASK_DEL_RES 0x02u
|
|||
|
|
#define OS_TASK_DEL_OK 0x03u
|
|||
|
|
|
|||
|
|
|
|||
|
|
#define OS_TASK_SELF (char *)0x1
|
|||
|
|
#define OS_TASK_FATHER (char *)0x2
|
|||
|
|
|
|||
|
|
|
|||
|
|
#define OS_MSG_KEY 1
|
|||
|
|
#define OS_MSG_TOUCH 2
|
|||
|
|
#define OS_MSG_EVENT 3
|
|||
|
|
#define OS_MSG_CALLBACK 4
|
|||
|
|
#define OS_MSG_DEL_REQ 5
|
|||
|
|
#define OS_MSG_MSG 6
|
|||
|
|
|
|||
|
|
|
|||
|
|
/*struct os_msg {
|
|||
|
|
int type;
|
|||
|
|
int msg;
|
|||
|
|
int err;
|
|||
|
|
u8 deleted;
|
|||
|
|
char ref;
|
|||
|
|
OS_SEM sem;
|
|||
|
|
OS_MUTEX mutex;
|
|||
|
|
struct list_head entry;
|
|||
|
|
u32 data[0];
|
|||
|
|
};*/
|
|||
|
|
|
|||
|
|
/*struct os_msg_callback {
|
|||
|
|
struct os_msg msg;
|
|||
|
|
u8 argc;
|
|||
|
|
u8 sync;
|
|||
|
|
u8 arg_exp;
|
|||
|
|
int argv[8];
|
|||
|
|
void *function;
|
|||
|
|
};*/
|
|||
|
|
|
|||
|
|
#ifdef CONFIG_CPU_BR25
|
|||
|
|
void *os_init();
|
|||
|
|
#else
|
|||
|
|
void os_init();
|
|||
|
|
#endif
|
|||
|
|
void os_start(void);
|
|||
|
|
void os_init_tick(int);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :创建任务
|
|||
|
|
*
|
|||
|
|
* @Param task :任务回调函数
|
|||
|
|
* @Param p_arg :传递给任务回调函数的参数
|
|||
|
|
* @Param prio :任务的优先级
|
|||
|
|
* @Param stksize :任务的堆栈大小, 单位(u32)
|
|||
|
|
* @Param qsize :任务的queue大小，单位(byte)
|
|||
|
|
* @Param name :任务名
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_task_create(void (*task)(void *p_arg),
|
|||
|
|
void *p_arg,
|
|||
|
|
u8 prio,
|
|||
|
|
u32 stksize,
|
|||
|
|
int qsize,
|
|||
|
|
const char *name);
|
|||
|
|
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :获取当前任务名
|
|||
|
|
*
|
|||
|
|
* @Returns :当前任务名
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
const char *os_current_task();
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :删除任务
|
|||
|
|
*
|
|||
|
|
* @Param name :任务名
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_task_del_req(const char *name);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :响应任务删除请求，标记资源已经释放，可以删除当前任
|
|||
|
|
*
|
|||
|
|
* @Param name: 任务名，任务自己可以用OS_TASK_SELF
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_task_del_res(const char *name);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :删除任务
|
|||
|
|
*
|
|||
|
|
* @Param name :任务名
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_task_del(const char *name);
|
|||
|
|
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :延时。中断函数或者关闭系统总中断的情况下不能调用此函数
|
|||
|
|
*
|
|||
|
|
* @Param time_tick :延时时间
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
void os_time_dly(int time_tick);
|
|||
|
|
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :发送Q_USER类型taskq
|
|||
|
|
*
|
|||
|
|
* @Param name :任务名
|
|||
|
|
* @Param argc :后面传入的参数的个数。发送的最大参数个数限制为8个int类型
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_taskq_post(const char *name, int argc, ...);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :非阻塞方式查询taskq
|
|||
|
|
*
|
|||
|
|
* @Param argc :最大可获取的queue长度，单位(int)
|
|||
|
|
* @Param argv :存放queue的buf
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_taskq_accept(int argc, int *argv);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :阻塞方式获取taskq
|
|||
|
|
*
|
|||
|
|
* @Param fmt :保留，传NULL
|
|||
|
|
* @Param argv :存放queue的buf
|
|||
|
|
* @Param argc :最大可获取的queue长度，单位(int)
|
|||
|
|
* @Param tick :阻塞时长，0表示一直阻塞
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_taskq_pend(const char *fmt, int *argv, int argc);
|
|||
|
|
int os_task_pend(const char *fmt, int *argv, int argc);
|
|||
|
|
int __os_taskq_pend(int *argv, int argc, int tick);
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :发送指定类型的taskq
|
|||
|
|
*
|
|||
|
|
* @Param name :任务名
|
|||
|
|
* @Param type :queue类型
|
|||
|
|
* @Param argc :后面传入的参数的个数
|
|||
|
|
* @Param argv
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_taskq_post_type(const char *name, int type, int argc, int *argv);
|
|||
|
|
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :发送Q_MSG类型的taskq
|
|||
|
|
*
|
|||
|
|
* @Param name :任务名
|
|||
|
|
* @Param argc :后面参数的个数
|
|||
|
|
* @Param ...
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_taskq_post_msg(const char *name, int argc, ...);
|
|||
|
|
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :发送Q_EVENT类型的taskq
|
|||
|
|
*
|
|||
|
|
* @Param name :任务名
|
|||
|
|
* @Param argc :后面参数的个数
|
|||
|
|
* @Param ...
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_taskq_post_event(const char *name, int argc, ...);
|
|||
|
|
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :删除指定类型的taskq
|
|||
|
|
*
|
|||
|
|
* @Param name :任务名
|
|||
|
|
* @Param type :taskq的类型
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_taskq_del_type(const char *name, int type);
|
|||
|
|
int os_taskq_del(const char *name, int type);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :清除所有taskq
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_taskq_flush();
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :创建信号量
|
|||
|
|
*
|
|||
|
|
* @Param sem:信号量
|
|||
|
|
* @Param int:初始计数值
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_sem_create(OS_SEM *, int);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :非阻塞方式查询信号量
|
|||
|
|
*
|
|||
|
|
* @Param sem :信号量
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_sem_accept(OS_SEM *);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :阻塞方式获取信号量
|
|||
|
|
*
|
|||
|
|
* @Param sem:信号量
|
|||
|
|
* @Param timeout:等待时长，0表示一直等待
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_sem_pend(OS_SEM *, int timeout);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :发送信号量
|
|||
|
|
*
|
|||
|
|
* @Param sem:信号量
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_sem_post(OS_SEM *);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :信号量删除
|
|||
|
|
*
|
|||
|
|
* @Param sem:信号量
|
|||
|
|
* @Param block:保留
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_sem_del(OS_SEM *, int block);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :信号量设置
|
|||
|
|
*
|
|||
|
|
* @Param sem:信号量
|
|||
|
|
* @Param cnt:计数值
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_sem_set(OS_SEM *, u16 cnt);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :信号量类型是否queueQUEUE_TYPE_COUNTING_SEMAPHORE
|
|||
|
|
*
|
|||
|
|
* @Param : true:信号量匹配, fail:信号量不匹配
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_sem_valid(OS_SEM *);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :判断信号量是否可用
|
|||
|
|
*
|
|||
|
|
* @Param sem:信号量
|
|||
|
|
*
|
|||
|
|
* @Returns :可用数量
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_sem_query(OS_SEM *);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :创建互斥量
|
|||
|
|
*
|
|||
|
|
* @Param mutex: 互斥量
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_mutex_create(OS_MUTEX *);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :非阻塞方式查询互斥量
|
|||
|
|
*
|
|||
|
|
* @Param mutex:互斥量
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_mutex_accept(OS_MUTEX *);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :阻塞方式查询互斥量
|
|||
|
|
*
|
|||
|
|
* @Param mutex:互斥量
|
|||
|
|
* @Param timeout:等待时间，0表示一直等待
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_mutex_pend(OS_MUTEX *, int timeout);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :发送斥量
|
|||
|
|
*
|
|||
|
|
* @Param mutex:互斥量
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_mutex_post(OS_MUTEX *);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :删除斥量
|
|||
|
|
*
|
|||
|
|
* @Param mutex:互斥量
|
|||
|
|
* @Param block:保留
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_mutex_del(OS_MUTEX *, int block);
|
|||
|
|
|
|||
|
|
/* --------------------------------------------------------------------------*/
|
|||
|
|
/**
|
|||
|
|
* @brief :互斥量类型是否queueQUEUE_TYPE_MUTEX
|
|||
|
|
*
|
|||
|
|
* @Param : true:互斥量匹配, fail:互斥量不匹配
|
|||
|
|
*
|
|||
|
|
* @Returns :错误码
|
|||
|
|
*/
|
|||
|
|
/* ----------------------------------------------------------------------------*/
|
|||
|
|
int os_mutex_valid(OS_MUTEX *);
|
|||
|
|
|
|||
|
|
/*struct os_msg *os_message_create(int size);
|
|||
|
|
|
|||
|
|
int os_message_receive(struct os_msg **msg, int block_time);
|
|||
|
|
|
|||
|
|
int os_message_send(const char *task_name, struct os_msg *msg, int msgflg);
|
|||
|
|
|
|||
|
|
int os_message_delete(struct os_msg *msg);*/
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
int os_q_create(OS_QUEUE *pevent, /*void **start, */QS size);
|
|||
|
|
|
|||
|
|
int os_q_del(OS_QUEUE *pevent, u8 opt);
|
|||
|
|
|
|||
|
|
int os_q_flush(OS_QUEUE *pevent);
|
|||
|
|
|
|||
|
|
int os_q_pend(OS_QUEUE *pevent, int timeout, void *msg);
|
|||
|
|
|
|||
|
|
int os_q_post(OS_QUEUE *pevent, void *msg);
|
|||
|
|
|
|||
|
|
int os_q_query(OS_QUEUE *pevent);
|
|||
|
|
|
|||
|
|
int os_q_valid(OS_QUEUE *pevent);
|
|||
|
|
|
|||
|
|
int task_queue_post_event(const char *name, void *data, int len);
|
|||
|
|
|
|||
|
|
#ifdef __cplusplus
|
|||
|
|
}
|
|||
|
|
#endif
|
|||
|
|
#endif
|