zoukankan      html  css  js  c++  java
  • Linux0.11内核剖析--内核代码(kernel)--sched.c

    1、概述

    linux/kernel/目录下共包括 10 个 C 语言文件和 2 个汇编语言文件以及一个 kernel 下编译文件的管理配置文件 Makefile。其中三个子目录中代码注释的将放在后面的文章进行。本文主要对这 13 个代码文件进行注释。 首先我们对所有程序的基本功能进行概括性地总体介绍, 以便一开始就对这 12 个文件所实现的功能和它们之间的相互调用关系有个大致的了解,然后逐一对代码进行详细地注释。
    本文地址:http://www.cnblogs.com/archimedes/p/linux011-kernel-sched.html,转载请注明源地址。

    linux/kernel/目录

    1 总体功能描述
    该目录下的代码文件从功能上可以分为三类,一类是硬件(异常)中断处理程序文件,一类是系统调用服务处理程序文件,另一类是进程调度等通用功能文件。参见图。我们现在根据这个分类方式,从实现的功能上进行更详细的说明。

    硬件中断处理类程序
    主要包括两个代码文件: asm.s 和 traps.c 文件。 asm.s 用于实现大部分硬件异常所引起的中断的汇编语言处理过程。而 traps.c 程序则实现了 asm.s 的中断处理过程中调用的 c 函数。另外几个硬件中断处理程序在文件 system_call.s 和 mm/page.s 中实现。
    中断信号通常可以分为两类: 硬件中断和软件中断(异常)。 每个中断是由 0-255 之间的一个数字来标识。对于中断 int0--int31(0x00--0x1f),每个中断的功能是由 Intel 固定设定或保留用的, 属于软件中断,但 Intel 称之为异常。因为是由 CPU 执行指令时探测到异常时引起的。通常还可分为故障(Fault)和陷阱(traps) 两 类 。 中 断 int32--int255 (0x20--0xff) 可以由用户自己设定 。 在 Linux 系统中 , 则 将int32--int47(0x20--0x2f)对应于 8259A 中断控制芯片发出的硬件中断请求信号 IRQ0-IRQ15;并把程序编程发出的系统调用(system_call)中断设置为 int128(0x80)。在将控制权交给中断处理程序之前, CPU 会首先将至少 12 字节的信息压入中断处理程序的堆栈中。这种情况与一个长调用(段间子程序调用)比较相象。 CPU 会将代码段选择符和返回地址的偏移值压入堆栈。另一个与段间调用比较相象的地方是 80386 将信息压入到了目的代码的堆栈上,而不是被中断代码的堆栈。另外, CPU 还总是将标志寄存器 EFLAGS 的内容压入堆栈。如果优先级别发生了变化,比如从用户级改变到内核系统级, CPU 还会将原代码的堆栈段值和堆栈指针压入中断程序的堆栈中。对于具有优先级改变时堆栈的内容示意图如图所示:

    asm.s 代码文件主要涉及对 Intel 保留中断 int0--int16 的处理,其余保留的中断 int17-int31 由 Intel 公司留作今后扩充使用。对应于中断控制器芯片各 IRQ 发出的 int32-int47 的 16 个处理程序将分别在各种硬件(如时钟、 键盘、 软盘、 数学协处理器、 硬盘等) 初始化程序中处理。 Linux 系统调用中断 int128(0x80)的处理则将在kernel/system_call.s 中给出。各个中断的具体定义见代码注释后其它信息一节中的说明。由于有些异常引起中断时, CPU 内部会产生一个出错代码压入堆栈(异常中断 int 8 和 int10 - int 14),见图 5.1 所示, 而其它的中断却并不带有这个出错代码(例如被零除出错和边界检查出错等), 因此, asm.s程序中将所有中断的处理根据是否携带出错代码而分别进行处理。但处理流程还是一样的。对一个硬件异常所引起的中断的处理过程见下图所示:

    mktime.c 程序

    功能描述:
    该该程序只有一个函数 mktime(),仅供内核使用。计算从1970年1月1日0时起到开机当日经过的秒数,作为开机时间。
    linux/kernel/mktime.c 程序:

    /*
     *  linux/kernel/mktime.c
     *
     *  (C) 1991  Linus Torvalds
     */
    
    #include <time.h>
    
    /*
     * 这不是库函数,它仅供内核使用。因此我们不关心小于 1970 年的年份等,但假定一切均很正常。
     * 同样,时间区域 TZ 问题也先忽略。我们只是尽可能简单地处理问题。最好能找到一些公开的库函数
     * (尽管我认为 minix 的时间函数是公开的)。
     * 另外,我恨那个设置 1970 年开始的人 - 难道他们就不能选择从一个闰年开始?我恨格里高利历、
     * 罗马教皇、主教,我什么都不在乎。我是个脾气暴躁的人。
     */
    #define MINUTE 60            // 1 分钟的秒数。
    #define HOUR (60*MINUTE)    // 1 小时的秒数。
    #define DAY (24*HOUR)        // 1 天的秒数。
    #define YEAR (365*DAY)        // 1 年的秒数。
    
    /* 有趣的是我们考虑进了闰年 */
     // 下面以年为界限,定义了每个月开始时的秒数时间数组。
    static int month[12] = {
        0,
        DAY*(31),
        DAY*(31+29),
        DAY*(31+29+31),
        DAY*(31+29+31+30),
        DAY*(31+29+31+30+31),
        DAY*(31+29+31+30+31+30),
        DAY*(31+29+31+30+31+30+31),
        DAY*(31+29+31+30+31+30+31+31),
        DAY*(31+29+31+30+31+30+31+31+30),
        DAY*(31+29+31+30+31+30+31+31+30+31),
        DAY*(31+29+31+30+31+30+31+31+30+31+30)
    };
    
    // 该函数计算从 1970 年 1 月 1 日 0 时起到开机当日经过的秒数,作为开机时间。
    long kernel_mktime(struct tm * tm)
    {
        long res;
        int year;
        year = tm->tm_year - 70;// 从 70 年到现在经过的年数(2 位表示方式),因此会有2000年问题。
    
    /*  为了获得正确的闰年数,这里需要这样一个魔幻偏值(y+1).*/
        res = YEAR*year + DAY*((year+1)/4);    // 这些年经过的秒数时间+每个闰年时多1天的秒数时间,在加上当年到当月时的秒数。
        res += month[tm->tm_mon];
    /*  以及(y+2)。如果(y+2)不是闰年,那么我们就必须进行调整(减去一天的秒数时间)。*/
        if (tm->tm_mon>1 && ((year+2)%4))
            res -= DAY;
        res += DAY*(tm->tm_mday-1);  // 再加上本月过去的天数的秒数时间。
        res += HOUR*tm->tm_hour;    // 再加上当天过去的小时数的秒数时间。
        res += MINUTE*tm->tm_min;   // 再加上 1 小时内过去的分钟数的秒数时间。    
        res += tm->tm_sec;          // 再加上 1 分钟内已过的秒数。
        return res;                 // 即等于从 1970 年以来经过的秒数时间。
    }

    PS:闰年的基本计算方法是:
    如果 y 能被 4 除尽且不能被 100 除尽,或者能被 400 除尽,则 y 是闰年。

    sched.c 程序

    1 功能描述
    sched.c 是内核中有关任务调度函数的程序,其中包括有关调度的基本函数(sleep_on、 wakeup、schedule 等)以及一些简单的系统调用函数(比如 getpid())。另外 Linus 为了编程的方便,考虑到软盘驱动器程序定时的需要,也将操作软盘的几个函数放到了这里。这几个基本函数的代码虽然不长,但有些抽象,比较难以理解。这里仅对调度函数 schedule()作一些说明。schedule()函数首先对所有任务(进程)进行检测,唤醒任何一个已经得到信号的任务。

    具体方法是针对任务数组中的每个任务,检查其报警定时值 alarm。如果任务的 alarm 时间已经过期(alarm<jiffies),则在它的信号位图中设置 SIGALRM 信号, 然后清 alarm 值。 jiffies 是系统从开机开始算起的滴答数( 10ms/滴答)。在 sched.h 中定义。如果进程的信号位图中除去被阻塞的信号外还有其它信号,并且任务处于可中断睡眠状态( TASK_INTERRUPTIBLE),则置任务为就绪状态( TASK_RUNNING)。

    随后是调度函数的核心处理部分。这部分代码根据进程的时间片和优先权调度机制,来选择随后要执行的任务。它首先循环检查任务数组中的所有任务,根据每个就绪态任务剩余执行时间的值 counter,选取该值最大的一个任务,并利用 switch_to()函数切换到该任务。若所有就绪态任务的该值都等于零,表示此刻所有任务的时间片都已经运行完,于是就根据任务的优先权值 priority,重置每个任务的运行时间片值 counter,再重新执行循环检查所有任务的执行时间片值。

    另一个值得一提的函数是 sleep_on(),该函数虽然很短,却要比schedule()函数难理解。这里用图示的方法加以解释。简单地说, sleep_on()函数的主要功能是当一个进程(或任务)所请求的资源正忙或不在内存中时暂时切换出去,放在等待队列中等待一段时间。当切换回来后再继续运行。放入等待队列的方式是利用了函数中的 tmp 指针作为各个正在等待任务的联系。函数中共牵涉到对三个任务指针操作: *p、 tmp 和 current, *p 是等待队列头指针,如文件系统内存i 节点的 i_wait 指针、内存缓冲操作中的 buffer_wait 指针等; tmp 是临时指针; current 是当前任务指针。对于这些指针在内存中的变化情况我们可以用下面的示意图说明。图中的长条表示内存字节序列。

    sleep_on() 函数中指针变化示意图

    当刚进入该函数时,队列头指针*p 指向已经在等待队列中等待的任务结构(进程描述符)。当然,在系统刚开始执行时,等待队列上无等待任务。因此上图中的原等待任务在刚开始时是不存在的,此时*p 指向 NULL。通过指针操作,在调用调度程序之前,队列头指针指向了当前任务结构,而函数中的临时指针 tmp 指向了原等待任务。从而通过该临时指针的作用,在该函数被嵌套调用时,程序就隐式地构筑出一个等待队列。从下面的图 5.6 中,我们可以更容易地理解 sleep_on()函数的等待队列形成过程。图中示出了当向队列头部插入第三个任务时的情况。

    sleep_on() 函数的隐式任务等待队列。
    还有一个函数 interruptible_sleep_on(),它的结构与 sleep_on()的基本类似,只是在进行调度之前是把当前任务置成了可中断等待状态,并在本任务被唤醒后还需要队列上是否有后来的等待任务,若有,则调度它们先运行。在内核 0.12 开始,这两个函数被合二为一,仅用任务的状态作为参数来区分这两种情况。
    linux/kernel/sched.c 程序

    /*
     *  linux/kernel/sched.c
     *
     *  (C) 1991  Linus Torvalds
     */
    
    /*
     * 'sched.c' 是主要的内核文件。其中包括有关调度的基本函数(sleep_on、wakeup、schedule 等)以及
     * 一些简单的系统调用函数( 比如 getpid() ,仅从当前任务中获取一个字段)。
     */
    #include <linux/sched.h>    // 调度程序头文件。定义了任务结构 task_struct、第 1 个初始任务的数据。
                                 // 还有一些以宏的形式定义的有关描述符参数设置和获取的嵌入式汇编函数程序。
    #include <linux/kernel.h>    // 内核头文件。含有一些内核常用函数的原形定义。
    #include <linux/sys.h>        // 系统调用头文件。含有 72 个系统调用 C 函数处理程序,以'sys_'开头。
    #include <linux/fdreg.h>    // 软驱头文件。含有软盘控制器参数的一些定义。
    #include <asm/system.h>        // 系统头文件。定义了设置或修改描述符/中断门等的嵌入式汇编宏。
    #include <asm/io.h>            // io 头文件。定义硬件端口输入/输出宏汇编语句。
    #include <asm/segment.h>    // 段操作头文件。定义了有关段寄存器操作的嵌入式汇编函数。
    
    #include <signal.h>            // 信号头文件。定义信号符号常量, sigaction 结构,操作函数原型。
    
    #define _S(nr) (1<<((nr)-1))    // 取信号 nr 在信号位图中对应位的二进制数值。信号编号 1-32。
                                    // 比如信号 5 的位图数值 = 1<<(5-1) = 16 = 00010000b。
    
    #define _BLOCKABLE (~(_S(SIGKILL) | _S(SIGSTOP)))    // 除了 SIGKILL 和 SIGSTOP 信号以外其它都是
                                                           // 可阻塞的(…10111111111011111111b)。
    
    // 显示任务号 nr 的进程号、进程状态和内核堆栈空闲字节数(大约)。
    void show_task(int nr,struct task_struct * p)
    {
        int i,j = 4096-sizeof(struct task_struct);
    
        printk("%d: pid=%d, state=%d, ",nr,p->pid,p->state);
        i=0;
        while (i<j && !((char *)(p+1))[i])    // 检测指定任务数据结构以后等于 0 的字节数。
            i++;
        printk("%d (of %d) chars free in kernel stack
    
    ",i,j);
    }
    
    // 显示所有任务的任务号、进程号、进程状态和内核堆栈空闲字节数(大约)。
    void show_stat(void)
    {
        int i;
    
        for (i=0;i<NR_TASKS;i++)    // NR_TASKS 是系统能容纳的最大进程(任务)数量(64 个),
            if (task[i])    // 定义在 include/kernel/sched.h 第 4 行。
                show_task(i,task[i]);
    }
    
    // 定义每个时间片的滴答数
    #define LATCH (1193180/HZ)
    
    extern void mem_use(void);    // [??]没有任何地方定义和引用该函数。
    
    extern int timer_interrupt(void);     // 时钟中断处理程序(kernel/system_call.s,176)。
    extern int system_call(void);        // 系统调用中断处理程序(kernel/system_call.s,80)。
    
    union task_union {    // 定义任务联合(任务结构成员和 stack 字符数组程序成员)。
        struct task_struct task;    // 因为一个任务数据结构与其堆栈放在同一内存页中,所以
        char stack[PAGE_SIZE];        // 从堆栈段寄存器 ss 可以获得其数据段选择符。
    };
    
    static union task_union init_task = {INIT_TASK,};    // 定义初始任务的数据(sched.h 中)。
    
    long volatile jiffies=0;    // 从开机开始算起的滴答数时间值(10ms/滴答)。
    // 前面的限定符 volatile,英文解释是易变、不稳定的意思。这里是要求 gcc 不要对该变量进行优化
    // 处理,也不要挪动位置,因为也许别的程序会来修改它的值。
    
    long startup_time=0;    // 开机时间。从 1970:0:0:0 开始计时的秒数。
    struct task_struct *current = &(init_task.task);    // 当前任务指针(初始化为初始任务)。
    struct task_struct *last_task_used_math = NULL;        // 使用过协处理器任务的指针。
    
    struct task_struct * task[NR_TASKS] = {&(init_task.task), };    // 定义任务指针数组。
    
    long user_stack [ PAGE_SIZE>>2 ] ;    // 定义系统堆栈指针,4K。指针指在最后一项。
    
    struct {    // 该结构用于设置堆栈 ss:esp(数据段选择符,指针),见 head.s,第 23 行。
        long * a;
        short b;
        } stack_start = { & user_stack [PAGE_SIZE>>2] , 0x10 };
    /*
     * 将当前协处理器内容保存到老协处理器状态数组中,并将当前任务的协处理器
     * 内容加载进协处理器。
     */
     // 当任务被调度交换过以后,该函数用以保存原任务的协处理器状态(上下文)并恢复新调度进来的
     // 当前任务的协处理器执行状态。
    void math_state_restore()
    {
        if (last_task_used_math == current)    // 如果任务没变则返回(上一个任务就是当前任务)。
            return;    // 这里所指的"上一个任务"是刚被交换出去的任务。
        __asm__("fwait");    // 在发送协处理器命令之前要先发 WAIT 指令。
        if (last_task_used_math) {    // 如果上个任务使用了协处理器,则保存其状态。
            __asm__("fnsave %0"::"m" (last_task_used_math->tss.i387));
        }
        last_task_used_math=current;// 现在,last_task_used_math 指向当前任务,
                                       // 以备当前任务被交换出去时使用。
        if (current->used_math) {    // 如果当前任务用过协处理器,则恢复其状态。
            __asm__("frstor %0"::"m" (current->tss.i387));
        } else {    // 否则的话说明是第一次使用,
            __asm__("fninit"::);    // 于是就向协处理器发初始化命令,
            current->used_math=1;    // 并设置使用了协处理器标志。
        }
    }
    
    /*
     * 'schedule()'是调度函数。这是个很好的代码!没有任何理由对它进行修改,因为它可以在所有的
     * 环境下工作(比如能够对 IO-边界处理很好的响应等)。只有一件事值得留意,那就是这里的信号
     * 处理代码。
     * 注意!!任务 0 是个闲置('idle') 任务,只有当没有其它任务可以运行时才调用它。它不能被杀
     * 死,也不能睡眠。任务 0 中的状态信息'state' 是从来不用的。
     */
    void schedule(void)
    {
        int i,next,c;
        struct task_struct ** p;    // 任务结构指针的指针。
    
    /* 检测 alarm(进程的报警定时值),唤醒任何已得到信号的可中断任务 */
    // 从任务数组中最后一个任务开始检测 alarm。
        for(p = &LAST_TASK ; p > &FIRST_TASK ; --p)
            if (*p) {
    // 如果任务的 alarm 时间已经过期(alarm<jiffies), 则在信号位图中置 SIGALRM 信号,然后清 alarm。
    // jiffies 是系统从开机开始算起的滴答数(10ms/滴答)。定义在 sched.h 第 139 行。
                if ((*p)->alarm && (*p)->alarm < jiffies) {
                        (*p)->signal |= (1<<(SIGALRM-1));
                        (*p)->alarm = 0;
                    }
    // 如果信号位图中除被阻塞的信号外还有其它信号,并且任务处于可中断状态,则置任务为就绪状态。
     // 其中'~(_BLOCKABLE & (*p)->blocked)'用于忽略被阻塞的信号,但 SIGKILL 和 SIGSTOP 不能被阻塞。
                if (((*p)->signal & ~(_BLOCKABLE & (*p)->blocked)) &&
                (*p)->state==TASK_INTERRUPTIBLE)
                    (*p)->state=TASK_RUNNING;    //置为就绪(可执行)状态。
            }
    
    /* 这里是调度程序的主要部分 */
        while (1) {
            c = -1;
            next = 0;
            i = NR_TASKS;
            p = &task[NR_TASKS];
    // 这段代码也是从任务数组的最后一个任务开始循环处理,并跳过不含任务的数组槽。比较每个就绪
    // 状态任务的 counter(任务运行时间的递减滴答计数)值,哪一个值大,运行时间还不长,next 就
    // 指向哪个的任务号。
            while (--i) {
                if (!*--p)
                    continue;
                if ((*p)->state == TASK_RUNNING && (*p)->counter > c)
                    c = (*p)->counter, next = i;
            }
            // 如果比较得出有 counter 值大于 0 的结果,则退出 124 行开始的循环,执行任务切换(141 行)。
            if (c) break;
    // 否则就根据每个任务的优先权值,更新每一个任务的 counter 值,然后回到 125 行重新比较。
    // counter 值的计算方式为 counter = counter /2 + priority。[右边 counter=0??]
            for(p = &LAST_TASK ; p > &FIRST_TASK ; --p)
                if (*p)
                    (*p)->counter = ((*p)->counter >> 1) +
                            (*p)->priority;
        }
        switch_to(next);    // 切换到任务号为 next 的任务,并运行之。
    }
    
    //// pause()系统调用。转换当前任务的状态为可中断的等待状态,并重新调度。
     // 该系统调用将导致进程进入睡眠状态,直到收到一个信号。该信号用于终止进程或者使进程调用
     // 一个信号捕获函数。只有当捕获了一个信号,并且信号捕获处理函数返回, pause()才会返回。
     // 此时 pause() 返回值应该是-1,并且 errno 被置为 EINTR。这里还没有完全实现(直到 0.95 版)。
    int sys_pause(void)
    {
        current->state = TASK_INTERRUPTIBLE;
        schedule();
        return 0;
    }
    
    // 把当前任务置为不可中断的等待状态,并让睡眠队列头的指针指向当前任务。
    // 只有明确地唤醒时才会返回。该函数提供了进程与中断处理程序之间的同步机制。
    // 函数参数*p 是放置等待任务的队列头指针。(参见列表后的说明)。
    void sleep_on(struct task_struct **p)
    {
        struct task_struct *tmp;
    
    // 若指针无效,则退出。(指针所指的对象可以是 NULL,但指针本身不会为 0)。
        if (!p)
            return;
        if (current == &(init_task.task))    // 如果当前任务是任务 0,则死机(impossible!)。
            panic("task[0] trying to sleep");
        tmp = *p;    // 让 tmp 指向已经在等待队列上的任务(如果有的话)。
        *p = current;    // 将睡眠队列头的等待指针指向当前任务。
        current->state = TASK_UNINTERRUPTIBLE;    // 将当前任务置为不可中断的等待状态。
        schedule();    // 重新调度。
    
        // 只有当这个等待任务被唤醒时,调度程序才又返回到这里,则表示进程已被明确地唤醒。
        // 既然大家都在等待同样的资源,那么在资源可用时,就有必要唤醒所有等待该资源的进程。该函数
         // 嵌套调用,也会嵌套唤醒所有等待该资源的进程。然后系统会根据这些进程的优先条件,重新调度
         // 应该由哪个进程首先使用资源。也即让这些进程竞争上岗。
        if (tmp)    // 若还存在等待的任务,则也将其置为就绪状态(唤醒)。
            tmp->state=0;
    }
    
    // 将当前任务置为可中断的等待状态,并放入*p 指定的等待队列中。参见列表后对 sleep_on()的说明。
    void interruptible_sleep_on(struct task_struct **p)
    {
        struct task_struct *tmp;
    
        if (!p)
            return;
        if (current == &(init_task.task))
            panic("task[0] trying to sleep");
        tmp=*p;
        *p=current;
    repeat:    current->state = TASK_INTERRUPTIBLE;
        schedule();
    // 如果等待队列中还有等待任务,并且队列头指针所指向的任务不是当前任务时,则将该等待任务置为
    // 可运行的就绪状态,并重新执行调度程序。当指针*p 所指向的不是当前任务时,表示在当前任务被放
    // 入队列后,又有新的任务被插入等待队列中,因此,既然本任务是可中断的,就应该首先执行所有
    // 其它的等待任务。
        if (*p && *p != current) {
            (**p).state=0;
            goto repeat;
        }
    // 下面一句代码有误,应该是*p = tmp,让队列头指针指向其余等待任务,否则在当前任务之前插入
    // 等待队列的任务均被抹掉了。参见图 4.3。
        *p=NULL;
        if (tmp)
            tmp->state=0;    
    }
    
    // 唤醒指定任务*p。
    void wake_up(struct task_struct **p)
    {
        if (p && *p) {
            (**p).state=0;    // 置为就绪(可运行)状态。
            *p=NULL;
        }
    }
    
    /*
    * 好了,从这里开始是一些有关软盘的子程序,本不应该放在内核的主要部分中的。将它们放在这里
    * 是因为软驱需要一个时钟,而放在这里是最方便的办法。
    */
    static struct task_struct * wait_motor[4] = {NULL,NULL,NULL,NULL};
    static int  mon_timer[4]={0,0,0,0};
    static int moff_timer[4]={0,0,0,0};
    unsigned char current_DOR = 0x0C;    // 数字输出寄存器(初值:允许 DMA 和请求中断、启动 FDC)。
    
    // 指定软盘到正常运转状态所需延迟滴答数(时间)。
    // nr -- 软驱号(0-3),返回值为滴答数。
    int ticks_to_floppy_on(unsigned int nr)
    {
        extern unsigned char selected;    // 当前选中的软盘号(kernel/blk_drv/floppy.c,122)。
        unsigned char mask = 0x10 << nr;    // 所选软驱对应数字输出寄存器中启动马达比特位。
    
        if (nr>3)
            panic("floppy_on: nr>3");    // 最多 4 个软驱。
        moff_timer[nr]=10000;        /* 100 s = very big :-) */
        cli();                /* use floppy_off to turn it off */
        mask |= current_DOR;
        // 如果不是当前软驱,则首先复位其它软驱的选择位,然后置对应软驱选择位。
        if (!selected) {
            mask &= 0xFC;
            mask |= nr;
        }
    // 如果数字输出寄存器的当前值与要求的值不同,则向 FDC 数字输出端口输出新值(mask) 。并且如果
    // 要求启动的马达还没有启动,则置相应软驱的马达启动定时器值(HZ/2 = 0.5 秒或 50 个滴答)。
    // 此后更新当前数字输出寄存器值 current_DOR。
        if (mask != current_DOR) {
            outb(mask,FD_DOR);
            if ((mask ^ current_DOR) & 0xf0)
                mon_timer[nr] = HZ/2;
            else if (mon_timer[nr] < 2)
                mon_timer[nr] = 2;
            current_DOR = mask;
        }
        sti();
        return mon_timer[nr];
    }
    
    // 等待指定软驱马达启动所需时间。
    void floppy_on(unsigned int nr)
    {
        cli();    // 关中断。
        while (ticks_to_floppy_on(nr))    // 如果马达启动定时还没到,就一直把当前进程置
            sleep_on(nr+wait_motor);    // 为不可中断睡眠状态并放入等待马达运行的队列中。
        sti();    // 开中断。
    }
    
    // 置关闭相应软驱马达停转定时器(3 秒)。
    void floppy_off(unsigned int nr)
    {
        moff_timer[nr]=3*HZ;
    }
    
    // 软盘定时处理子程序。更新马达启动定时值和马达关闭停转计时值。该子程序是在时钟定时
    // 中断中被调用,因此每一个滴答(10ms)被调用一次,更新马达开启或停转定时器的值。如果某
    // 一个马达停转定时到,则将数字输出寄存器马达启动位复位。
    void do_floppy_timer(void)
    {
        int i;
        unsigned char mask = 0x10;
    
        for (i=0 ; i<4 ; i++,mask <<= 1) {
            if (!(mask & current_DOR))    // 如果不是 DOR 指定的马达则跳过。
                continue;
            if (mon_timer[i]) {
                if (!--mon_timer[i])
                    wake_up(i+wait_motor);    // 如果马达启动定时到则唤醒进程。
            } else if (!moff_timer[i]) {    // 如果马达停转定时到则
                current_DOR &= ~mask;    // 复位相应马达启动位,并
                outb(current_DOR,FD_DOR);    // 更新数字输出寄存器。
            } else
                moff_timer[i]--;        // 马达停转计时递减。
        }
    }
    
    #define TIME_REQUESTS 64    // 最多可有 64 个定时器链表(64 个任务)。
    
    // 定时器链表结构和定时器数组。
    static struct timer_list {
        long jiffies;    // 定时滴答数。
        void (*fn)();    // 定时处理程序。
        struct timer_list * next;    // 下一个定时器。
    } timer_list[TIME_REQUESTS], * next_timer = NULL;
    
    // 添加定时器。输入参数为指定的定时值(滴答数)和相应的处理程序指针。
    // jiffies – 以 10 毫秒计的滴答数;*fn()- 定时时间到时执行的函数。
    void add_timer(long jiffies, void (*fn)(void))
    {
        struct timer_list * p;
    
    // 如果定时处理程序指针为空,则退出。
        if (!fn)
            return;
        cli();
        // 如果定时值<=0,则立刻调用其处理程序。并且该定时器不加入链表中。
        if (jiffies <= 0)
            (fn)();
        else {
            // 从定时器数组中,找一个空闲项。
            for (p = timer_list ; p < timer_list + TIME_REQUESTS ; p++)
                if (!p->fn)
                    break;
            // 如果已经用完了定时器数组,则系统崩溃
            if (p >= timer_list + TIME_REQUESTS)
                panic("No more time requests free");
            // 向定时器数据结构填入相应信息。并链入链表头
            p->fn = fn;
            p->jiffies = jiffies;
            p->next = next_timer;
            next_timer = p;
    // 链表项按定时值从小到大排序。在排序时减去排在前面需要的滴答数,这样在处理定时器时只要
    // 查看链表头的第一项的定时是否到期即可。 [[?? 这段程序好象没有考虑周全。如果新插入的定时
    // 器值 < 原来头一个定时器值时,也应该将所有后面的定时值均减去新的第 1 个的定时值。]]
            while (p->next && p->next->jiffies < p->jiffies) {
                p->jiffies -= p->next->jiffies;
                fn = p->fn;
                p->fn = p->next->fn;
                p->next->fn = fn;
                jiffies = p->jiffies;
                p->jiffies = p->next->jiffies;
                p->next->jiffies = jiffies;
                p = p->next;
            }
        }
        sti();
    }
    
    //// 时钟中断 C 函数处理程序,在 kernel/system_call.s 中的_timer_interrupt(176 行)被调用。
    // 参数 cpl 是当前特权级 0 或 3,0 表示内核代码在执行。
    // 对于一个进程由于执行时间片用完时,则进行任务切换。并执行一个计时更新工作。
    void do_timer(long cpl)
    {
        extern int beepcount;    // 扬声器发声时间滴答数(kernel/chr_drv/console.c,697)
        extern void sysbeepstop(void);    // 关闭扬声器(kernel/chr_drv/console.c,691)
    
    // 如果发声计数次数到,则关闭发声。(向 0x61 口发送命令,复位位 0 和 1。位 0 控制 8253
     // 计数器 2 的工作,位 1 控制扬声器)。
        if (beepcount)
            if (!--beepcount)
                sysbeepstop();
    
    // 如果当前特权级(cpl)为 0(最高,表示是内核程序在工作),则将超级用户运行时间 stime 递增;
    // 如果 cpl > 0,则表示是一般用户程序在工作,增加 utime。
        if (cpl)
            current->utime++;
        else
            current->stime++;
    
    // 如果有用户的定时器存在,则将链表第 1 个定时器的值减 1。如果已等于 0,则调用相应的处理
     // 程序,并将该处理程序指针置为空。然后去掉该项定时器。
        if (next_timer) {    // next_timer 是定时器链表的头指针(见 270 行)。
            next_timer->jiffies--;
            while (next_timer && next_timer->jiffies <= 0) {
                void (*fn)(void);    // 这里插入了一个函数指针定义!! ! 
                
                fn = next_timer->fn;
                next_timer->fn = NULL;
                next_timer = next_timer->next;
                (fn)();    // 调用处理函数。
            }
        }
    // 如果当前软盘控制器 FDC 的数字输出寄存器中马达启动位有置位的,则执行软盘定时程序(245 行)。
        if (current_DOR & 0xf0)
            do_floppy_timer();
        if ((--current->counter)>0) return;    // 如果进程运行时间还没完,则退出。
        current->counter=0;
        if (!cpl) return;    // 对于超级用户程序,不依赖 counter 值进行调度。
        schedule();
    }
    
    // 系统调用功能 - 设置报警定时时间值(秒)。
     // 如果已经设置过 alarm 值,则返回旧值,否则返回 0。
    int sys_alarm(long seconds)
    {
        int old = current->alarm;
    
        if (old)
            old = (old - jiffies) / HZ;
        current->alarm = (seconds>0)?(jiffies+HZ*seconds):0;
        return (old);
    }
    
    // 取当前进程号 pid。
    int sys_getpid(void)
    {
        return current->pid;
    }
    
    // 取父进程号 ppid。
    int sys_getppid(void)
    {
        return current->father;
    }
    
    // 取用户号 uid。
    int sys_getuid(void)
    {
        return current->uid;
    }
    
    // 取 euid。
    int sys_geteuid(void)
    {
        return current->euid;
    }
    
    // 取组号 gid。
    int sys_getgid(void)
    {
        return current->gid;
    }
    
    // 取 egid。
    int sys_getegid(void)
    {
        return current->egid;
    }
    
    // 系统调用功能 -- 降低对 CPU 的使用优先权(有人会用吗?)。
     // 应该限制 increment 大于 0,否则的话,可使优先权增大!!
    int sys_nice(long increment)
    {
        if (current->priority-increment>0)
            current->priority -= increment;
        return 0;
    }
    
    // 调度程序的初始化子程序。
    void sched_init(void)
    {
        int i;
        struct desc_struct * p;    // 描述符表结构指针。
    
        if (sizeof(struct sigaction) != 16)    // sigaction 是存放有关信号状态的结构。
            panic("Struct sigaction MUST be 16 bytes");
        // 设置初始任务(任务 0)的任务状态段描述符和局部数据表描述符(include/asm/system.h,65)。
        set_tss_desc(gdt+FIRST_TSS_ENTRY,&(init_task.task.tss));
        set_ldt_desc(gdt+FIRST_LDT_ENTRY,&(init_task.task.ldt));
        // 清任务数组和描述符表项(注意 i=1 开始,所以初始任务的描述符还在)。
        p = gdt+2+FIRST_TSS_ENTRY;
        for(i=1;i<NR_TASKS;i++) {
            task[i] = NULL;
            p->a=p->b=0;
            p++;
            p->a=p->b=0;
            p++;
        }
    
    /* 清除标志寄存器中的位 NT,这样以后就不会有麻烦 */
     // NT 标志用于控制程序的递归调用(Nested Task)。当 NT 置位时,那么当前中断任务执行
     // iret 指令时就会引起任务切换。NT 指出 TSS 中的 back_link 字段是否有效。
        __asm__("pushfl ; andl $0xffffbfff,(%esp) ; popfl");    // 复位 NT 标志。
        ltr(0);        // 将任务 0 的 TSS 加载到任务寄存器 tr。
        lldt(0);    // 将局部描述符表加载到局部描述符表寄存器。
    // 注意!!是将 GDT 中相应 LDT 描述符的选择符加载到 ldtr。只明确加载这一次,以后新任务
     // LDT 的加载,是 CPU 根据 TSS 中的 LDT 项自动加载。
     // 下面代码用于初始化 8253 定时器。
        outb_p(0x36,0x43);        /* binary, mode 3, LSB/MSB, ch 0 */
        outb_p(LATCH & 0xff , 0x40);    /* LSB */ // 定时值低字节。
        outb(LATCH >> 8 , 0x40);    /* MSB */    // 定时值高字节。
        // 设置时钟中断处理程序句柄(设置时钟中断门)。
        set_intr_gate(0x20,&timer_interrupt);
        // 修改中断控制器屏蔽码,允许时钟中断。
        outb(inb_p(0x21)&~0x01,0x21);
        // 设置系统调用中断门。
        set_system_gate(0x80,&system_call);
    }

    其它信息

    软盘控制器编程
    在编程时需要访问 4 个端口,分别对应一个或多个寄存器。对于 1.2M 的软盘控制器有以下一些端口。

    数字输出端口(数字控制端口)是一个 8 位寄存器,它控制驱动器马达开启、驱动器选择、启动/复位 FDC 以及允许/禁止 DMA 及中断请求。

    FDC 的主状态寄存器也是一个 8 位寄存器,用于反映软盘控制器 FDC 和软盘驱动器 FDD 的基本状态。 通常, 在 CPU 向 FDC 发送命令之前或从 FDC 获取操作结果之前, 都要读取主状态寄存器的状态位,以判别当前 FDC 数据寄存器是否就绪,以及确定数据传送的方向。

    FDC 的数据端口对应多个寄存器(只写型命令寄存器和参数寄存器、只读型结果寄存器),但任一时刻只能有一个寄存器出现在数据端口 0x3f5。在访问只写型寄存器时,主状态控制的 DIO 方向位必须为 0( CPU Æ FDC),访问只读型寄存器时则反之。在读取结果时只有在 FDC 不忙之后才算读完结果,通常结果数据最多有 7 个字节。

    软盘控制器共可以接受 15 条命令。每个命令均经历三个阶段:命令阶段、执行阶段和结果阶段。命令阶段是 CPU 向 FDC 发送命令字节和参数字节。 每条命令的第一个字节总是命令字节(命令码)。其后跟着 0--8 字节的参数。

    执行阶段是 FDC 执行命令规定的操作。在执行阶段 CPU 是不加干预的,一般是通过 FDC 发出中断请求获知命令执行的结束。如果 CPU 发出的 FDC 命令是传送数据,则 FDC 可以以中断方式或 DMA 方式进行。中断方式每次传送 1 字节。 DMA 方式是在 DMA 控制器管理下, FDC 与内存进行数据的传输直至全部数据传送完。 此时 DMA 控制器会将传输字节计数终止信号通知 FDC,最后由 FDC 发出中断请求信号告知 CPU 执行阶段结束。

    结果阶段是由 CPU 读取 FDC 数据寄存器返回值,从而获得 FDC 命令执行的结果。返回结果数据的长度为 0--7 字节。对于没有返回结果数据的命令,则应向 FDC 发送检测中断状态命令获得操作的状态。

    参考资料

    Linux内核完全注释(赵炯)

  • 相关阅读:
    转:专题五线程同步——事件构造
    转:专题四线程同步
    转:专题三线程池中的I/O线程
    转:[C# 开发技巧]如何防止程序多次运行
    转:专题二线程池中的工作者线程
    转:专题一线程基础
    C# 设置按钮快捷键
    jmeter链接多台负载机报错
    java读取properties
    使用Runtime.getRuntime().exec()方法的几个陷阱
  • 原文地址:https://www.cnblogs.com/wuyudong/p/linux011-kernel-sched.html
Copyright © 2011-2022 走看看