您当前的位置: 首页 >  linux

韩曙亮

暂无认证

  • 0浏览

    0关注

    1068博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

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

韩曙亮 发布时间:2022-04-01 11:58:03 ,浏览量:0

文章目录
  • 一、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 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

关注
打赏
1663594092
查看更多评论
立即登录/注册

微信扫码登录

0.0438s