|
|
|
|
@ -733,7 +733,7 @@ DEINIT_TCB:
|
|
|
|
|
TaskCBDeInit(taskCB);
|
|
|
|
|
return errRet;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//创建任务,并使该任务进入ready状态,如果就绪队列中没有更高优先级的任务,则运行该任务
|
|
|
|
|
LITE_OS_SEC_TEXT_INIT UINT32 LOS_TaskCreate(UINT32 *taskID, TSK_INIT_PARAM_S *initParam)
|
|
|
|
|
{
|
|
|
|
|
UINT32 ret;
|
|
|
|
|
@ -747,7 +747,7 @@ LITE_OS_SEC_TEXT_INIT UINT32 LOS_TaskCreate(UINT32 *taskID, TSK_INIT_PARAM_S *in
|
|
|
|
|
return LOS_ERRNO_TSK_YIELD_IN_INT;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (OsProcessIsUserMode(OsCurrProcessGet())) {
|
|
|
|
|
if (OsProcessIsUserMode(OsCurrProcessGet())) {//当前进程为用户进程
|
|
|
|
|
initParam->processID = (UINTPTR)OsGetKernelInitProcess();
|
|
|
|
|
} else {
|
|
|
|
|
initParam->processID = (UINTPTR)OsCurrProcessGet();
|
|
|
|
|
@ -773,7 +773,7 @@ LITE_OS_SEC_TEXT_INIT UINT32 LOS_TaskCreate(UINT32 *taskID, TSK_INIT_PARAM_S *in
|
|
|
|
|
|
|
|
|
|
return LOS_OK;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//恢复挂起的任务,是该任务进入ready状态
|
|
|
|
|
LITE_OS_SEC_TEXT_INIT UINT32 LOS_TaskResume(UINT32 taskID)
|
|
|
|
|
{
|
|
|
|
|
UINT32 intSave;
|
|
|
|
|
@ -788,7 +788,7 @@ LITE_OS_SEC_TEXT_INIT UINT32 LOS_TaskResume(UINT32 taskID)
|
|
|
|
|
SCHEDULER_LOCK(intSave);
|
|
|
|
|
|
|
|
|
|
/* clear pending signal */
|
|
|
|
|
taskCB->signal &= ~SIGNAL_SUSPEND;
|
|
|
|
|
taskCB->signal &= ~SIGNAL_SUSPEND;//清楚挂起信号
|
|
|
|
|
|
|
|
|
|
if (taskCB->taskStatus & OS_TASK_STATUS_UNUSED) {
|
|
|
|
|
errRet = LOS_ERRNO_TSK_NOT_CREATED;
|
|
|
|
|
@ -814,13 +814,13 @@ LOS_ERREND:
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Check if needs to do the suspend operation on the running task.
|
|
|
|
|
* Return TRUE, if needs to do the suspension.
|
|
|
|
|
* Return FALSE, if meets following circumstances:
|
|
|
|
|
* 1. Do the suspension across cores, if SMP is enabled
|
|
|
|
|
* 2. Do the suspension when preemption is disabled
|
|
|
|
|
* 3. Do the suspension in hard-irq
|
|
|
|
|
* then LOS_TaskSuspend will directly return with 'ret' value.
|
|
|
|
|
* Check if needs to do the suspend operation on the running task.//检查是否需要对正在运行的任务执行挂起操作。
|
|
|
|
|
* Return TRUE, if needs to do the suspension. //如果需要暂停,返回TRUE。
|
|
|
|
|
* Return FALSE, if meets following circumstances: //如果满足一下情况,则返回FALSE:
|
|
|
|
|
* 1. Do the suspension across cores, if SMP is enabled //1.如果启用了SMP,则跨CPU核执行挂起操作
|
|
|
|
|
* 2. Do the suspension when preemption is disabled //2.当禁用抢占时则挂起
|
|
|
|
|
* 3. Do the suspension in hard-irq //3.在硬中断时则挂起
|
|
|
|
|
* then LOS_TaskSuspend will directly return with 'ret' value. //那么LOS_taskssuspend将直接返回ret值。
|
|
|
|
|
*/
|
|
|
|
|
LITE_OS_SEC_TEXT_INIT STATIC BOOL OsTaskSuspendCheckOnRun(LosTaskCB *taskCB, UINT32 *ret)
|
|
|
|
|
{
|
|
|
|
|
@ -829,20 +829,20 @@ LITE_OS_SEC_TEXT_INIT STATIC BOOL OsTaskSuspendCheckOnRun(LosTaskCB *taskCB, UIN
|
|
|
|
|
|
|
|
|
|
#ifdef LOSCFG_KERNEL_SMP
|
|
|
|
|
/* ASYNCHRONIZED. No need to do task lock checking */
|
|
|
|
|
if (taskCB->currCpu != ArchCurrCpuid()) {
|
|
|
|
|
if (taskCB->currCpu != ArchCurrCpuid()) {//跨CPU核的情况
|
|
|
|
|
taskCB->signal = SIGNAL_SUSPEND;
|
|
|
|
|
LOS_MpSchedule(taskCB->currCpu);
|
|
|
|
|
LOS_MpSchedule(taskCB->currCpu);//task所属CPU执行调度
|
|
|
|
|
return FALSE;
|
|
|
|
|
}
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
if (!OsPreemptableInSched()) {
|
|
|
|
|
if (!OsPreemptableInSched()) {//不能抢占时
|
|
|
|
|
/* Suspending the current core's running task */
|
|
|
|
|
*ret = LOS_ERRNO_TSK_SUSPEND_LOCKED;
|
|
|
|
|
return FALSE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (OS_INT_ACTIVE) {
|
|
|
|
|
if (OS_INT_ACTIVE) {//正在硬抢断时
|
|
|
|
|
/* suspend running task in interrupt */
|
|
|
|
|
taskCB->signal = SIGNAL_SUSPEND;
|
|
|
|
|
return FALSE;
|
|
|
|
|
@ -850,7 +850,7 @@ LITE_OS_SEC_TEXT_INIT STATIC BOOL OsTaskSuspendCheckOnRun(LosTaskCB *taskCB, UIN
|
|
|
|
|
|
|
|
|
|
return TRUE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//任务暂停,参数可以不是当前任务,也就是说A任务可以让B任务处于阻塞状态,挂起指定的任务,然后切换任务
|
|
|
|
|
LITE_OS_SEC_TEXT STATIC UINT32 OsTaskSuspend(LosTaskCB *taskCB)
|
|
|
|
|
{
|
|
|
|
|
UINT32 errRet;
|
|
|
|
|
@ -863,14 +863,14 @@ LITE_OS_SEC_TEXT STATIC UINT32 OsTaskSuspend(LosTaskCB *taskCB)
|
|
|
|
|
return LOS_ERRNO_TSK_ALREADY_SUSPENDED;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if ((tempStatus & OS_TASK_STATUS_RUNNING) &&
|
|
|
|
|
!OsTaskSuspendCheckOnRun(taskCB, &errRet)) {
|
|
|
|
|
if ((tempStatus & OS_TASK_STATUS_RUNNING) &&//如果参数任务正在运行,注意多Cpu core情况,贴着正在运行标签的任务并不一定是当前CPU的执行任务,
|
|
|
|
|
!OsTaskSuspendCheckOnRun(taskCB, &errRet)) {//很有可能是别的CPU core在跑的任务
|
|
|
|
|
return errRet;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return taskCB->ops->suspend(taskCB);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//外部接口,对OsTaskSuspend的封装
|
|
|
|
|
LITE_OS_SEC_TEXT_INIT UINT32 LOS_TaskSuspend(UINT32 taskID)
|
|
|
|
|
{
|
|
|
|
|
UINT32 intSave;
|
|
|
|
|
@ -890,7 +890,7 @@ LITE_OS_SEC_TEXT_INIT UINT32 LOS_TaskSuspend(UINT32 taskID)
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
return errRet;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//设置任务为不使用状态
|
|
|
|
|
STATIC INLINE VOID OsTaskStatusUnusedSet(LosTaskCB *taskCB)
|
|
|
|
|
{
|
|
|
|
|
taskCB->taskStatus |= OS_TASK_STATUS_UNUSED;
|
|
|
|
|
@ -1036,7 +1036,7 @@ LOS_ERREND:
|
|
|
|
|
}
|
|
|
|
|
return ret;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//任务延时等待,释放CPU,等待时间到期后该任务会重新进入ready状态
|
|
|
|
|
LITE_OS_SEC_TEXT UINT32 LOS_TaskDelay(UINT32 tick)
|
|
|
|
|
{
|
|
|
|
|
UINT32 intSave;
|
|
|
|
|
@ -1066,7 +1066,7 @@ LITE_OS_SEC_TEXT UINT32 LOS_TaskDelay(UINT32 tick)
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
return ret;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//获取任务的优先级
|
|
|
|
|
LITE_OS_SEC_TEXT_MINOR UINT16 LOS_TaskPriGet(UINT32 taskID)
|
|
|
|
|
{
|
|
|
|
|
UINT32 intSave;
|
|
|
|
|
@ -1087,7 +1087,7 @@ LITE_OS_SEC_TEXT_MINOR UINT16 LOS_TaskPriGet(UINT32 taskID)
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
return param.priority;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//设置指定任务的优先级
|
|
|
|
|
LITE_OS_SEC_TEXT_MINOR UINT32 LOS_TaskPriSet(UINT32 taskID, UINT16 taskPrio)
|
|
|
|
|
{
|
|
|
|
|
UINT32 intSave;
|
|
|
|
|
@ -1125,12 +1125,12 @@ LITE_OS_SEC_TEXT_MINOR UINT32 LOS_TaskPriSet(UINT32 taskID, UINT16 taskPrio)
|
|
|
|
|
}
|
|
|
|
|
return LOS_OK;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//设置当前任务的优先级
|
|
|
|
|
LITE_OS_SEC_TEXT_MINOR UINT32 LOS_CurTaskPriSet(UINT16 taskPrio)
|
|
|
|
|
{
|
|
|
|
|
return LOS_TaskPriSet(OsCurrTaskGet()->taskID, taskPrio);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//当前任务释放CPU,并将其移到具有相同优先级的就绪任务队列的末尾。
|
|
|
|
|
LITE_OS_SEC_TEXT_MINOR UINT32 LOS_TaskYield(VOID)
|
|
|
|
|
{
|
|
|
|
|
UINT32 intSave;
|
|
|
|
|
@ -1176,7 +1176,7 @@ LITE_OS_SEC_TEXT_MINOR VOID LOS_TaskUnlock(VOID)
|
|
|
|
|
LOS_Schedule();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//获取任务信息,给shell使用的
|
|
|
|
|
LITE_OS_SEC_TEXT_MINOR UINT32 LOS_TaskInfoGet(UINT32 taskID, TSK_INFO_S *taskInfo)
|
|
|
|
|
{
|
|
|
|
|
UINT32 intSave;
|
|
|
|
|
@ -1206,8 +1206,8 @@ LITE_OS_SEC_TEXT_MINOR UINT32 LOS_TaskInfoGet(UINT32 taskID, TSK_INFO_S *taskInf
|
|
|
|
|
taskCB->ops->schedParamGet(taskCB, ¶m);
|
|
|
|
|
taskInfo->usTaskStatus = taskCB->taskStatus;
|
|
|
|
|
taskInfo->usTaskPrio = param.priority;
|
|
|
|
|
taskInfo->uwStackSize = taskCB->stackSize;
|
|
|
|
|
taskInfo->uwTopOfStack = taskCB->topOfStack;
|
|
|
|
|
taskInfo->uwStackSize = taskCB->stackSize;//内核态栈大小
|
|
|
|
|
taskInfo->uwTopOfStack = taskCB->topOfStack;//内核态栈顶位置
|
|
|
|
|
taskInfo->uwEventMask = taskCB->eventMask;
|
|
|
|
|
taskInfo->taskEvent = taskCB->taskEvent;
|
|
|
|
|
taskInfo->pTaskMux = taskCB->taskMux;
|
|
|
|
|
@ -1218,16 +1218,16 @@ LITE_OS_SEC_TEXT_MINOR UINT32 LOS_TaskInfoGet(UINT32 taskID, TSK_INFO_S *taskInf
|
|
|
|
|
}
|
|
|
|
|
taskInfo->acName[LOS_TASK_NAMELEN - 1] = '\0';
|
|
|
|
|
|
|
|
|
|
taskInfo->uwBottomOfStack = TRUNCATE(((UINTPTR)taskCB->topOfStack + taskCB->stackSize),
|
|
|
|
|
taskInfo->uwBottomOfStack = TRUNCATE(((UINTPTR)taskCB->topOfStack + taskCB->stackSize),//这里可以看出栈顶地址是高于栈顶
|
|
|
|
|
OS_TASK_STACK_ADDR_ALIGN);
|
|
|
|
|
taskInfo->uwCurrUsed = (UINT32)(taskInfo->uwBottomOfStack - taskInfo->uwSP);
|
|
|
|
|
taskInfo->uwCurrUsed = (UINT32)(taskInfo->uwBottomOfStack - taskInfo->uwSP);//当前任务栈已使用了多少
|
|
|
|
|
|
|
|
|
|
taskInfo->bOvf = OsStackWaterLineGet((const UINTPTR *)taskInfo->uwBottomOfStack,
|
|
|
|
|
taskInfo->bOvf = OsStackWaterLineGet((const UINTPTR *)taskInfo->uwBottomOfStack,//获取栈的使用情况
|
|
|
|
|
(const UINTPTR *)taskInfo->uwTopOfStack, &taskInfo->uwPeakUsed);
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
return LOS_OK;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//CPU亲和性(affinity)将任务绑定在指定CPU上,用于多核CPU情况,(该函数仅在SMP模式下支持)
|
|
|
|
|
LITE_OS_SEC_TEXT BOOL OsTaskCpuAffiSetUnsafe(UINT32 taskID, UINT16 newCpuAffiMask, UINT16 *oldCpuAffiMask)
|
|
|
|
|
{
|
|
|
|
|
#ifdef LOSCFG_KERNEL_SMP
|
|
|
|
|
@ -1253,17 +1253,17 @@ LITE_OS_SEC_TEXT_MINOR UINT32 LOS_TaskCpuAffiSet(UINT32 taskID, UINT16 cpuAffiMa
|
|
|
|
|
UINT32 intSave;
|
|
|
|
|
UINT16 currCpuMask;
|
|
|
|
|
|
|
|
|
|
if (OS_TID_CHECK_INVALID(taskID)) {
|
|
|
|
|
if (OS_TID_CHECK_INVALID(taskID)) {//检测taskid是否有效,task由task池分配,鸿蒙默认128个任务 ID范围[0:127]
|
|
|
|
|
return LOS_ERRNO_TSK_ID_INVALID;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!(cpuAffiMask & LOSCFG_KERNEL_CPU_MASK)) {
|
|
|
|
|
if (!(cpuAffiMask & LOSCFG_KERNEL_CPU_MASK)) {//检测cpu亲和力
|
|
|
|
|
return LOS_ERRNO_TSK_CPU_AFFINITY_MASK_ERR;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
LosTaskCB *taskCB = OS_TCB_FROM_TID(taskID);
|
|
|
|
|
SCHEDULER_LOCK(intSave);
|
|
|
|
|
if (taskCB->taskStatus & OS_TASK_STATUS_UNUSED) {
|
|
|
|
|
if (taskCB->taskStatus & OS_TASK_STATUS_UNUSED) {//贴有未使用标签的处理
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
return LOS_ERRNO_TSK_NOT_CREATED;
|
|
|
|
|
}
|
|
|
|
|
@ -1271,13 +1271,13 @@ LITE_OS_SEC_TEXT_MINOR UINT32 LOS_TaskCpuAffiSet(UINT32 taskID, UINT16 cpuAffiMa
|
|
|
|
|
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
if (needSched && OS_SCHEDULER_ACTIVE) {
|
|
|
|
|
LOS_MpSchedule(currCpuMask);
|
|
|
|
|
LOS_Schedule();
|
|
|
|
|
LOS_MpSchedule(currCpuMask);//发送信号调度信号给目标cpu
|
|
|
|
|
LOS_Schedule();//申请调度
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return LOS_OK;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//查询任务被绑在哪个cpu上
|
|
|
|
|
LITE_OS_SEC_TEXT_MINOR UINT16 LOS_TaskCpuAffiGet(UINT32 taskID)
|
|
|
|
|
{
|
|
|
|
|
#ifdef LOSCFG_KERNEL_SMP
|
|
|
|
|
@ -1291,18 +1291,18 @@ LITE_OS_SEC_TEXT_MINOR UINT16 LOS_TaskCpuAffiGet(UINT32 taskID)
|
|
|
|
|
|
|
|
|
|
LosTaskCB *taskCB = OS_TCB_FROM_TID(taskID);
|
|
|
|
|
SCHEDULER_LOCK(intSave);
|
|
|
|
|
if (taskCB->taskStatus & OS_TASK_STATUS_UNUSED) {
|
|
|
|
|
if (taskCB->taskStatus & OS_TASK_STATUS_UNUSED) {//任务必须在使用
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
return INVALID_CPU_AFFI_MASK;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
cpuAffiMask = taskCB->cpuAffiMask;
|
|
|
|
|
cpuAffiMask = taskCB->cpuAffiMask;//获取亲和力掩码
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
|
|
|
|
|
return cpuAffiMask;
|
|
|
|
|
#else
|
|
|
|
|
(VOID)taskID;
|
|
|
|
|
return 1;
|
|
|
|
|
return 1;//单核情况直接返回1,0号cpu对应0x01
|
|
|
|
|
#endif
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -1312,14 +1312,14 @@ LITE_OS_SEC_TEXT_MINOR UINT16 LOS_TaskCpuAffiGet(UINT32 taskID)
|
|
|
|
|
LITE_OS_SEC_TEXT_MINOR VOID OsTaskProcSignal(VOID)
|
|
|
|
|
{
|
|
|
|
|
UINT32 ret;
|
|
|
|
|
|
|
|
|
|
//私有且不可中断,无需保护。这个任务在其他cpu核看到它时总是在运行,所以它在执行代码的同时也可以继续接收信号
|
|
|
|
|
/*
|
|
|
|
|
* private and uninterruptable, no protection needed.
|
|
|
|
|
* while this task is always running when others cores see it,
|
|
|
|
|
* so it keeps receiving signals while follow code executing.
|
|
|
|
|
*/
|
|
|
|
|
LosTaskCB *runTask = OsCurrTaskGet();
|
|
|
|
|
if (runTask->signal == SIGNAL_NONE) {
|
|
|
|
|
if (runTask->signal == SIGNAL_NONE) {//意思是其他cpu发起了要干掉你的信号
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -1327,23 +1327,23 @@ LITE_OS_SEC_TEXT_MINOR VOID OsTaskProcSignal(VOID)
|
|
|
|
|
/*
|
|
|
|
|
* clear the signal, and do the task deletion. if the signaled task has been
|
|
|
|
|
* scheduled out, then this deletion will wait until next run.
|
|
|
|
|
*/
|
|
|
|
|
runTask->signal = SIGNAL_NONE;
|
|
|
|
|
*///如果发出信号的任务以出调度就绪队列,则此删除将等待下次运行
|
|
|
|
|
runTask->signal = SIGNAL_NONE;//清除信号
|
|
|
|
|
ret = LOS_TaskDelete(runTask->taskID);
|
|
|
|
|
if (ret != LOS_OK) {
|
|
|
|
|
PRINT_ERR("Task proc signal delete task(%u) failed err:0x%x\n", runTask->taskID, ret);
|
|
|
|
|
}
|
|
|
|
|
} else if (runTask->signal & SIGNAL_SUSPEND) {
|
|
|
|
|
runTask->signal &= ~SIGNAL_SUSPEND;
|
|
|
|
|
} else if (runTask->signal & SIGNAL_SUSPEND) {//意思是其他cpu发起了要挂起你的信号
|
|
|
|
|
runTask->signal &= ~SIGNAL_SUSPEND;//任务贴在被其他cpu挂起的标签
|
|
|
|
|
|
|
|
|
|
/* suspend killed task may fail, ignore the result */
|
|
|
|
|
(VOID)LOS_TaskSuspend(runTask->taskID);
|
|
|
|
|
#ifdef LOSCFG_KERNEL_SMP
|
|
|
|
|
} else if (runTask->signal & SIGNAL_AFFI) {
|
|
|
|
|
runTask->signal &= ~SIGNAL_AFFI;
|
|
|
|
|
} else if (runTask->signal & SIGNAL_AFFI) {//意思是下次调度其他cpu要媾和你
|
|
|
|
|
runTask->signal &= ~SIGNAL_AFFI;//任务贴上被其他CPU媾和的标签
|
|
|
|
|
|
|
|
|
|
/* priority queue has updated, notify the target cpu */
|
|
|
|
|
LOS_MpSchedule((UINT32)runTask->cpuAffiMask);
|
|
|
|
|
LOS_MpSchedule((UINT32)runTask->cpuAffiMask);//发生调度,此任务将移交给媾和CPU运行.
|
|
|
|
|
#endif
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
@ -1416,7 +1416,7 @@ INT32 OsUserProcessOperatePermissionsCheck(const LosTaskCB *taskCB, UINTPTR proc
|
|
|
|
|
|
|
|
|
|
return LOS_OK;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//创建任务之前,检查用户态任务栈的参数,是否地址在用户空间
|
|
|
|
|
LITE_OS_SEC_TEXT_INIT STATIC UINT32 OsCreateUserTaskParamCheck(UINT32 processID, TSK_INIT_PARAM_S *param)
|
|
|
|
|
{
|
|
|
|
|
UserTaskParam *userParam = NULL;
|
|
|
|
|
@ -1426,25 +1426,25 @@ LITE_OS_SEC_TEXT_INIT STATIC UINT32 OsCreateUserTaskParamCheck(UINT32 processID,
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
userParam = ¶m->userParam;
|
|
|
|
|
if ((processID == OS_INVALID_VALUE) && !LOS_IsUserAddress(userParam->userArea)) {
|
|
|
|
|
if ((processID == OS_INVALID_VALUE) && !LOS_IsUserAddress(userParam->userArea)) {//堆地址必须在用户空间
|
|
|
|
|
return OS_INVALID_VALUE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!LOS_IsUserAddress((UINTPTR)param->pfnTaskEntry)) {
|
|
|
|
|
if (!LOS_IsUserAddress((UINTPTR)param->pfnTaskEntry)) {//入口函数必须在用户空间
|
|
|
|
|
return OS_INVALID_VALUE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//堆栈必须在用户空间
|
|
|
|
|
if (userParam->userMapBase && !LOS_IsUserAddressRange(userParam->userMapBase, userParam->userMapSize)) {
|
|
|
|
|
return OS_INVALID_VALUE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//检查堆,栈范围
|
|
|
|
|
if (!LOS_IsUserAddress(userParam->userSP)) {
|
|
|
|
|
return OS_INVALID_VALUE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return LOS_OK;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//创建一个用户态任务
|
|
|
|
|
LITE_OS_SEC_TEXT_INIT UINT32 OsCreateUserTask(UINTPTR processID, TSK_INIT_PARAM_S *initParam)
|
|
|
|
|
{
|
|
|
|
|
UINT32 taskID;
|
|
|
|
|
@ -1453,18 +1453,18 @@ LITE_OS_SEC_TEXT_INIT UINT32 OsCreateUserTask(UINTPTR processID, TSK_INIT_PARAM_
|
|
|
|
|
INT32 policy;
|
|
|
|
|
SchedParam param;
|
|
|
|
|
|
|
|
|
|
ret = OsCreateUserTaskParamCheck(processID, initParam);
|
|
|
|
|
ret = OsCreateUserTaskParamCheck(processID, initParam);//检查参数,堆栈,入口地址必须在用户空间
|
|
|
|
|
if (ret != LOS_OK) {
|
|
|
|
|
return ret;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//这里可看出一个任务有两个栈,内核态栈(内核指定栈大小)和用户态栈(用户指定栈大小)
|
|
|
|
|
initParam->uwStackSize = OS_USER_TASK_SYSCALL_STACK_SIZE;
|
|
|
|
|
initParam->usTaskPrio = OS_TASK_PRIORITY_LOWEST;
|
|
|
|
|
if (processID == OS_INVALID_VALUE) {
|
|
|
|
|
initParam->usTaskPrio = OS_TASK_PRIORITY_LOWEST;//设置最低优先级31级
|
|
|
|
|
if (processID == OS_INVALID_VALUE) {//外面没指定进程ID的处理
|
|
|
|
|
SCHEDULER_LOCK(intSave);
|
|
|
|
|
LosProcessCB *processCB = OsCurrProcessGet();
|
|
|
|
|
initParam->processID = (UINTPTR)processCB;
|
|
|
|
|
initParam->consoleID = processCB->consoleID;
|
|
|
|
|
initParam->consoleID = processCB->consoleID;//任务控制台ID归属
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
ret = LOS_GetProcessScheduler(processCB->processID, &policy, NULL);
|
|
|
|
|
if (ret != LOS_OK) {
|
|
|
|
|
@ -1477,20 +1477,20 @@ LITE_OS_SEC_TEXT_INIT UINT32 OsCreateUserTask(UINTPTR processID, TSK_INIT_PARAM_
|
|
|
|
|
initParam->deadlineUs = param.deadlineUs;
|
|
|
|
|
initParam->periodUs = param.periodUs;
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
initParam->policy = LOS_SCHED_RR;
|
|
|
|
|
initParam->processID = processID;
|
|
|
|
|
initParam->consoleID = 0;
|
|
|
|
|
} else {//进程已经创建
|
|
|
|
|
initParam->policy = LOS_SCHED_RR;//调度方式为抢占式,注意鸿蒙不仅仅只支持抢占式调度方式
|
|
|
|
|
initParam->processID = processID;//进程ID赋值
|
|
|
|
|
initParam->consoleID = 0;//默认0号控制台
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
ret = LOS_TaskCreateOnly(&taskID, initParam);
|
|
|
|
|
ret = LOS_TaskCreateOnly(&taskID, initParam);//只创建task实体,不申请调度
|
|
|
|
|
if (ret != LOS_OK) {
|
|
|
|
|
return OS_INVALID_VALUE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return taskID;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//获取任务的调度方式
|
|
|
|
|
LITE_OS_SEC_TEXT INT32 LOS_GetTaskScheduler(INT32 taskID)
|
|
|
|
|
{
|
|
|
|
|
UINT32 intSave;
|
|
|
|
|
@ -1503,7 +1503,7 @@ LITE_OS_SEC_TEXT INT32 LOS_GetTaskScheduler(INT32 taskID)
|
|
|
|
|
|
|
|
|
|
LosTaskCB *taskCB = OS_TCB_FROM_TID(taskID);
|
|
|
|
|
SCHEDULER_LOCK(intSave);
|
|
|
|
|
if (taskCB->taskStatus & OS_TASK_STATUS_UNUSED) {
|
|
|
|
|
if (taskCB->taskStatus & OS_TASK_STATUS_UNUSED) {//任务不能是没有在使用
|
|
|
|
|
policy = -LOS_EINVAL;
|
|
|
|
|
OS_GOTO_ERREND();
|
|
|
|
|
}
|
|
|
|
|
@ -1515,7 +1515,7 @@ LOS_ERREND:
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
return policy;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//设置任务的调度信息
|
|
|
|
|
LITE_OS_SEC_TEXT INT32 LOS_SetTaskScheduler(INT32 taskID, UINT16 policy, UINT16 priority)
|
|
|
|
|
{
|
|
|
|
|
SchedParam param = { 0 };
|
|
|
|
|
@ -1659,12 +1659,12 @@ UINT32 LOS_TaskDetach(UINT32 taskID)
|
|
|
|
|
SCHEDULER_UNLOCK(intSave);
|
|
|
|
|
return errRet;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//获取最大任务数
|
|
|
|
|
LITE_OS_SEC_TEXT UINT32 LOS_GetSystemTaskMaximum(VOID)
|
|
|
|
|
{
|
|
|
|
|
return g_taskMaxNum;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//任务池中最后一个
|
|
|
|
|
LosTaskCB *OsGetDefaultTaskCB(VOID)
|
|
|
|
|
{
|
|
|
|
|
return &g_taskCBArray[g_taskMaxNum];
|
|
|
|
|
@ -1679,44 +1679,44 @@ LITE_OS_SEC_TEXT VOID OsWriteResourceEventUnsafe(UINT32 events)
|
|
|
|
|
{
|
|
|
|
|
(VOID)OsEventWriteUnsafe(&g_resourceEvent, events, FALSE, NULL);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//资源回收任务
|
|
|
|
|
STATIC VOID OsResourceRecoveryTask(VOID)
|
|
|
|
|
{
|
|
|
|
|
UINT32 ret;
|
|
|
|
|
|
|
|
|
|
while (1) {
|
|
|
|
|
while (1) {//死循环,回收资源不存在退出情况,只要系统在运行资源就需要回收
|
|
|
|
|
ret = LOS_EventRead(&g_resourceEvent, OS_RESOURCE_EVENT_MASK,
|
|
|
|
|
LOS_WAITMODE_OR | LOS_WAITMODE_CLR, LOS_WAIT_FOREVER);
|
|
|
|
|
if (ret & (OS_RESOURCE_EVENT_FREE | OS_RESOURCE_EVENT_OOM)) {
|
|
|
|
|
LOS_WAITMODE_OR | LOS_WAITMODE_CLR, LOS_WAIT_FOREVER);//读取资源事件
|
|
|
|
|
if (ret & (OS_RESOURCE_EVENT_FREE | OS_RESOURCE_EVENT_OOM)) {//收到资源释放或内存异常情况
|
|
|
|
|
OsTaskCBRecycleToFree();
|
|
|
|
|
|
|
|
|
|
OsProcessCBRecycleToFree();
|
|
|
|
|
OsProcessCBRecycleToFree();//回收进程到空闲进程池
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#ifdef LOSCFG_ENABLE_OOM_LOOP_TASK
|
|
|
|
|
if (ret & OS_RESOURCE_EVENT_OOM) {
|
|
|
|
|
(VOID)OomCheckProcess();
|
|
|
|
|
#ifdef LOSCFG_ENABLE_OOM_LOOP_TASK//内存溢出检测任务开关
|
|
|
|
|
if (ret & OS_RESOURCE_EVENT_OOM) {//触发了这个事件
|
|
|
|
|
(VOID)OomCheckProcess();//检查进程的内存溢出情况
|
|
|
|
|
}
|
|
|
|
|
#endif
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//创建一个回收资源的任务
|
|
|
|
|
LITE_OS_SEC_TEXT UINT32 OsResourceFreeTaskCreate(VOID)
|
|
|
|
|
{
|
|
|
|
|
UINT32 ret;
|
|
|
|
|
UINT32 taskID;
|
|
|
|
|
TSK_INIT_PARAM_S taskInitParam;
|
|
|
|
|
|
|
|
|
|
ret = LOS_EventInit((PEVENT_CB_S)&g_resourceEvent);
|
|
|
|
|
ret = LOS_EventInit((PEVENT_CB_S)&g_resourceEvent);//初始化资源事件
|
|
|
|
|
if (ret != LOS_OK) {
|
|
|
|
|
return LOS_NOK;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
(VOID)memset_s((VOID *)(&taskInitParam), sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S));
|
|
|
|
|
taskInitParam.pfnTaskEntry = (TSK_ENTRY_FUNC)OsResourceRecoveryTask;
|
|
|
|
|
taskInitParam.pfnTaskEntry = (TSK_ENTRY_FUNC)OsResourceRecoveryTask;//入口函数
|
|
|
|
|
taskInitParam.uwStackSize = OS_TASK_RESOURCE_STATIC_SIZE;
|
|
|
|
|
taskInitParam.pcName = "ResourcesTask";
|
|
|
|
|
taskInitParam.usTaskPrio = OS_TASK_RESOURCE_FREE_PRIORITY;
|
|
|
|
|
taskInitParam.usTaskPrio = OS_TASK_RESOURCE_FREE_PRIORITY;//5,优先级很高
|
|
|
|
|
ret = LOS_TaskCreate(&taskID, &taskInitParam);
|
|
|
|
|
if (ret == LOS_OK) {
|
|
|
|
|
OS_TCB_FROM_TID(taskID)->taskStatus |= OS_TASK_FLAG_NO_DELETE;
|
|
|
|
|
@ -1724,5 +1724,5 @@ LITE_OS_SEC_TEXT UINT32 OsResourceFreeTaskCreate(VOID)
|
|
|
|
|
return ret;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
LOS_MODULE_INIT(OsResourceFreeTaskCreate, LOS_INIT_LEVEL_KMOD_TASK);
|
|
|
|
|
LOS_MODULE_INIT(OsResourceFreeTaskCreate, LOS_INIT_LEVEL_KMOD_TASK);//资源回收任务初始化
|
|
|
|
|
|
|
|
|
|
|