Linux 内核实时调度类 ⑦ ( 实时调度类核心函数源码分析 | dequeue_task_rt 函数 | 从执行队列中移除进程 )

Posted 2022-04-05 韩曙亮

文章目录

• 一、dequeue_task_rt 函数 ( 从执行队列中移除进程 )
• 二、update_curr_rt 函数 ( 更新调度信息 )

本篇博客中 , 开始分析 struct sched_class rt_sched_class 结构体变量 中的各个 函数指针 指向的 函数源码 ;

rt_sched_class 结构体 在 Linux 内核源码的 linux-5.6.18\\kernel\\sched\\rt.c 源文件中定义 , 实时调度 相关的 核心函数 也定义在该源码中 ;

一、dequeue_task_rt 函数 ( 从执行队列中移除进程 )

---

dequeue_task_rt 函数简介 :

dequeue_task_rt 函数用于 更新 " 调度信息 " ,

将 " 实时调度实体 " sched_rt_entity 从 " 执行队列 " ( 红黑树 ) 中 删除 ,

然后将 被删除的 " 实时调度实体 " 添加到 " 执行队列 " ( 红黑树 ) 末尾 ;

dequeue_task_rt 函数分析 :

update_curr_rt(rq); 的作用是 更新 " 调度信息 " ,

dequeue_rt_entity(rt_se, flags); 作用是 将 " 实时调度实体 " rt_se , 从 " 执行队列 " ( 红黑树 ) 中删除 , 被删除的 " 实时调度实体 " 添加到 " 执行队列 " ( 红黑树 ) 末尾 ;

dequeue_pushable_task(rq, p); 作用是 将 进程 从 哈希表 中删除 ;

dequeue_task_rt 函数源码 :

static void dequeue_task_rt(struct rq *rq, struct task_struct *p, int flags)

	struct sched_rt_entity *rt_se = &p->rt;

	update_curr_rt(rq);
	dequeue_rt_entity(rt_se, flags);

	dequeue_pushable_task(rq, p);

源码路径 : linux-5.6.18\\kernel\\sched\\rt.c#1381

二、update_curr_rt 函数 ( 更新调度信息 )

---

update_curr_rt(rq); 的作用是 更新 " 调度信息 " ;

update_curr_rt 函数源码 :

/*
 * Update the current task's runtime statistics. Skip current tasks that
 * are not in our scheduling class.
 */
static void update_curr_rt(struct rq *rq)

	struct task_struct *curr = rq->curr;
	struct sched_rt_entity *rt_se = &curr->rt;
	u64 delta_exec;
	u64 now;

	if (curr->sched_class != &rt_sched_class)
		return;

	now = rq_clock_task(rq);
	delta_exec = now - curr->se.exec_start;
	if (unlikely((s64)delta_exec <= 0))
		return;

	schedstat_set(curr->se.statistics.exec_max,
		      max(curr->se.statistics.exec_max, delta_exec));

	curr->se.sum_exec_runtime += delta_exec;
	account_group_exec_runtime(curr, delta_exec);

	curr->se.exec_start = now;
	cgroup_account_cputime(curr, delta_exec);

	if (!rt_bandwidth_enabled())
		return;

	for_each_sched_rt_entity(rt_se) 
		struct rt_rq *rt_rq = rt_rq_of_se(rt_se);

		if (sched_rt_runtime(rt_rq) != RUNTIME_INF) 
			raw_spin_lock(&rt_rq->rt_runtime_lock);
			rt_rq->rt_time += delta_exec;
			if (sched_rt_runtime_exceeded(rt_rq))
				resched_curr(rq);
			raw_spin_unlock(&rt_rq->rt_runtime_lock);
		
	

源码路径 : linux-5.6.18\\kernel\\sched\\rt.c#994