scheduler_comm.c 文件参考

#include <rtdbg.h>
#include <rtthread.h>

scheduler_comm.c 的引用(Include)关系图:

浏览该文件的源代码.

宏定义
#define	DBG_TAG   "kernel.sched"
#define	DBG_LVL   DBG_INFO

函数
void	rt_sched_thread_init_ctx (struct rt_thread *thread, rt_uint32_t tick, rt_uint8_t priority)
rt_err_t	rt_sched_thread_timer_start (struct rt_thread *thread)
rt_err_t	rt_sched_thread_timer_stop (struct rt_thread *thread)
rt_uint8_t	rt_sched_thread_get_stat (struct rt_thread *thread)
rt_uint8_t	rt_sched_thread_get_curr_prio (struct rt_thread *thread)
rt_uint8_t	rt_sched_thread_get_init_prio (struct rt_thread *thread)
rt_uint8_t	rt_sched_thread_is_suspended (struct rt_thread *thread)
rt_err_t	rt_sched_thread_close (struct rt_thread *thread)
rt_err_t	rt_sched_thread_yield (struct rt_thread *thread)
rt_err_t	rt_sched_thread_ready (struct rt_thread *thread)
rt_err_t	rt_sched_tick_increase (rt_tick_t tick)
rt_err_t	rt_sched_thread_change_priority (struct rt_thread *thread, rt_uint8_t priority)

宏定义说明

DBG_TAG

#define DBG_TAG   "kernel.sched"

在文件 scheduler_comm.c 第 13 行定义.

DBG_LVL

#define DBG_LVL   DBG_INFO

在文件 scheduler_comm.c 第 14 行定义.

函数说明

rt_sched_thread_init_ctx()

void rt_sched_thread_init_ctx	(	struct rt_thread *	thread,
		rt_uint32_t	tick,
		rt_uint8_t	priority )

在文件 scheduler_comm.c 第 19 行定义.

{
    /* setup thread status */
    RT_SCHED_CTX(thread).stat  = RT_THREAD_INIT;
 
#ifdef RT_USING_SMP
    /* not bind on any cpu */
    RT_SCHED_CTX(thread).bind_cpu = RT_CPUS_NR;
    RT_SCHED_CTX(thread).oncpu = RT_CPU_DETACHED;
#endif /* RT_USING_SMP */
 
    rt_sched_thread_init_priv(thread, tick, priority);
}

引用了 RT_SCHED_CTX , 以及 RT_THREAD_INIT.

rt_sched_thread_timer_start()

rt_err_t rt_sched_thread_timer_start

(

struct rt_thread *

thread

)

在文件 scheduler_comm.c 第 33 行定义.

{
    RT_SCHED_DEBUG_IS_LOCKED;
    RT_SCHED_CTX(thread).sched_flag_ttmr_set = 1;
    return RT_EOK;
}

引用了 RT_SCHED_CTX , 以及 RT_SCHED_DEBUG_IS_LOCKED.

这是这个函数的调用关系图:

rt_sched_thread_timer_stop()

rt_err_t rt_sched_thread_timer_stop

(

struct rt_thread *

thread

)

在文件 scheduler_comm.c 第 40 行定义.

{
    rt_err_t error;
    RT_SCHED_DEBUG_IS_LOCKED;
 
    if (RT_SCHED_CTX(thread).sched_flag_ttmr_set)
    {
        error = rt_timer_stop(&thread->thread_timer);
 
        /* mask out timer flag no matter stop success or not */
        RT_SCHED_CTX(thread).sched_flag_ttmr_set = 0;
    }
    else
    {
        error = RT_EOK;
    }
    return error;
}

引用了 RT_SCHED_CTX, RT_SCHED_DEBUG_IS_LOCKED, rt_timer_stop() , 以及 rt_thread::thread_timer.

函数调用图:

这是这个函数的调用关系图:

rt_sched_thread_get_stat()

rt_uint8_t rt_sched_thread_get_stat

(

struct rt_thread *

thread

)

在文件 scheduler_comm.c 第 59 行定义.

{
    RT_SCHED_DEBUG_IS_LOCKED;
    return RT_SCHED_CTX(thread).stat & RT_THREAD_STAT_MASK;
}

引用了 RT_SCHED_CTX, RT_SCHED_DEBUG_IS_LOCKED , 以及 RT_THREAD_STAT_MASK.

这是这个函数的调用关系图:

rt_sched_thread_get_curr_prio()

rt_uint8_t rt_sched_thread_get_curr_prio

(

struct rt_thread *

thread

)

在文件 scheduler_comm.c 第 65 行定义.

{
    RT_SCHED_DEBUG_IS_LOCKED;
    return RT_SCHED_PRIV(thread).current_priority;
}

引用了 RT_SCHED_DEBUG_IS_LOCKED , 以及 RT_SCHED_PRIV.

这是这个函数的调用关系图:

rt_sched_thread_get_init_prio()

rt_uint8_t rt_sched_thread_get_init_prio

(

struct rt_thread *

thread

)

在文件 scheduler_comm.c 第 71 行定义.

{
    /* read only fields, so lock is unecessary */
    return RT_SCHED_PRIV(thread).init_priority;
}

引用了 RT_SCHED_PRIV.

这是这个函数的调用关系图:

rt_sched_thread_is_suspended()

rt_uint8_t rt_sched_thread_is_suspended

(

struct rt_thread *

thread

)

注解

Caller must hold the scheduler lock

在文件 scheduler_comm.c 第 80 行定义.

{
    RT_SCHED_DEBUG_IS_LOCKED;
    return (RT_SCHED_CTX(thread).stat & RT_THREAD_SUSPEND_MASK) == RT_THREAD_SUSPEND_MASK;
}

引用了 RT_SCHED_CTX, RT_SCHED_DEBUG_IS_LOCKED, RT_THREAD_SUSPEND_MASK , 以及 stat().

函数调用图:

这是这个函数的调用关系图:

rt_sched_thread_close()

rt_err_t rt_sched_thread_close

(

struct rt_thread *

thread

)

在文件 scheduler_comm.c 第 86 行定义.

{
    RT_SCHED_DEBUG_IS_LOCKED;
    RT_SCHED_CTX(thread).stat = RT_THREAD_CLOSE;
    return RT_EOK;
}

引用了 RT_SCHED_CTX, RT_SCHED_DEBUG_IS_LOCKED , 以及 RT_THREAD_CLOSE.

这是这个函数的调用关系图:

rt_sched_thread_yield()

rt_err_t rt_sched_thread_yield

(

struct rt_thread *

thread

)

在文件 scheduler_comm.c 第 93 行定义.

{
    RT_SCHED_DEBUG_IS_LOCKED;
 
    RT_SCHED_PRIV(thread).remaining_tick = RT_SCHED_PRIV(thread).init_tick;
    RT_SCHED_CTX(thread).stat |= RT_THREAD_STAT_YIELD;
 
    return RT_EOK;
}

引用了 RT_SCHED_CTX, RT_SCHED_DEBUG_IS_LOCKED, RT_SCHED_PRIV , 以及 RT_THREAD_STAT_YIELD.

这是这个函数的调用关系图:

rt_sched_thread_ready()

rt_err_t rt_sched_thread_ready

(

struct rt_thread *

thread

)

Quiet timeout timer first if set. and don't continue if we failed, because it probably means that a timeout ISR racing to resume thread before us.

在文件 scheduler_comm.c 第 103 行定义.

{
    rt_err_t error;
 
    RT_SCHED_DEBUG_IS_LOCKED;
 
    if (!rt_sched_thread_is_suspended(thread))
    {
        /* failed to proceed, and that's possibly due to a racing condition */
        error = -RT_EINVAL;
    }
    else
    {
        if (RT_SCHED_CTX(thread).sched_flag_ttmr_set)
        {
            error = rt_sched_thread_timer_stop(thread);
        }
        else
        {
            error = RT_EOK;
        }
 
        if (!error)
        {
            /* remove from suspend list */
            rt_list_remove(&RT_THREAD_LIST_NODE(thread));
 
        #ifdef RT_USING_SMART
            thread->wakeup_handle.func = RT_NULL;
        #endif
 
            /* insert to schedule ready list and remove from susp list */
            rt_sched_insert_thread(thread);
        }
    }
 
    return error;
}

引用了 rt_list_remove(), RT_NULL, RT_SCHED_CTX, RT_SCHED_DEBUG_IS_LOCKED, rt_sched_thread_is_suspended(), rt_sched_thread_timer_stop() , 以及 RT_THREAD_LIST_NODE.

函数调用图:

这是这个函数的调用关系图:

rt_sched_tick_increase()

rt_err_t rt_sched_tick_increase

(

rt_tick_t

tick

)

在文件 scheduler_comm.c 第 147 行定义.

{
    struct rt_thread *thread;
    rt_sched_lock_level_t slvl;
 
    thread = rt_thread_self();
 
    rt_sched_lock(&slvl);
 
    if(RT_SCHED_PRIV(thread).remaining_tick > tick)
    {
        RT_SCHED_PRIV(thread).remaining_tick -= tick;
    }
    else
    {
        RT_SCHED_PRIV(thread).remaining_tick = 0;
    }
 
    if (RT_SCHED_PRIV(thread).remaining_tick)
    {
        rt_sched_unlock(slvl);
    }
    else
    {
        rt_sched_thread_yield(thread);
 
        /* request a rescheduling even though we are probably in an ISR */
        rt_sched_unlock_n_resched(slvl);
    }
 
    return RT_EOK;
}

引用了 rt_sched_lock(), RT_SCHED_PRIV, rt_sched_thread_yield(), rt_sched_unlock(), rt_sched_unlock_n_resched() , 以及 rt_thread_self().

函数调用图:

这是这个函数的调用关系图:

rt_sched_thread_change_priority()

rt_err_t rt_sched_thread_change_priority	(	struct rt_thread *	thread,
		rt_uint8_t	priority )

Update priority of the target thread

在文件 scheduler_comm.c 第 183 行定义.

{
    RT_ASSERT(priority < RT_THREAD_PRIORITY_MAX);
    RT_SCHED_DEBUG_IS_LOCKED;
 
    /* for ready thread, change queue; otherwise simply update the priority */
    if ((RT_SCHED_CTX(thread).stat & RT_THREAD_STAT_MASK) == RT_THREAD_READY)
    {
        /* remove thread from schedule queue first */
        rt_sched_remove_thread(thread);
 
        /* change thread priority */
        RT_SCHED_PRIV(thread).current_priority = priority;
 
        /* recalculate priority attribute */
#if RT_THREAD_PRIORITY_MAX > 32
        RT_SCHED_PRIV(thread).number = RT_SCHED_PRIV(thread).current_priority >> 3;               /* 5bit */
        RT_SCHED_PRIV(thread).number_mask = 1 << RT_SCHED_PRIV(thread).number;
        RT_SCHED_PRIV(thread).high_mask = 1 << (RT_SCHED_PRIV(thread).current_priority & 0x07);   /* 3bit */
#else
        RT_SCHED_PRIV(thread).number_mask = 1 << RT_SCHED_PRIV(thread).current_priority;
#endif /* RT_THREAD_PRIORITY_MAX > 32 */
        RT_SCHED_CTX(thread).stat = RT_THREAD_INIT;
 
        /* insert thread to schedule queue again */
        rt_sched_insert_thread(thread);
    }
    else
    {
        RT_SCHED_PRIV(thread).current_priority = priority;
 
        /* recalculate priority attribute */
#if RT_THREAD_PRIORITY_MAX > 32
        RT_SCHED_PRIV(thread).number = RT_SCHED_PRIV(thread).current_priority >> 3;               /* 5bit */
        RT_SCHED_PRIV(thread).number_mask = 1 << RT_SCHED_PRIV(thread).number;
        RT_SCHED_PRIV(thread).high_mask = 1 << (RT_SCHED_PRIV(thread).current_priority & 0x07);   /* 3bit */
#else
        RT_SCHED_PRIV(thread).number_mask = 1 << RT_SCHED_PRIV(thread).current_priority;
#endif /* RT_THREAD_PRIORITY_MAX > 32 */
    }
 
    return RT_EOK;
}

引用了 RT_ASSERT, RT_SCHED_CTX, RT_SCHED_DEBUG_IS_LOCKED, RT_SCHED_PRIV, RT_THREAD_INIT, RT_THREAD_READY, RT_THREAD_STAT_MASK , 以及 stat().

函数调用图:

这是这个函数的调用关系图: