Linux并发与同步专题 (3) 信号量

static inline int __sched __down_common(struct semaphore *sem, long state,
                                long timeout)
{
    struct task_struct *task = current;-------------------得到当前进程结构
    struct semaphore_waiter waiter;-----------------------struct semaphore_waiter数据结构用于描述获取信号量失败的进程，每个进程会有一个semaphore_waiter数据结构，并把当前进程放到信号量sem的成员变量wait_list链表中。
    list_add_tail(&waiter.list, &sem->wait_list);---------将waiter加入到信号量sem->waiter_list尾部
    waiter.task = task;-----------------------------------waiter.task指向当前正在运行的进程。
    waiter.up = false;
    for (;;) {
        if (signal_pending_state(state, task))------------根据不同state和当前信号pending情况，决定是否进入interrupted处理。
            goto interrupted;
        if (unlikely(timeout <= 0))-----------------------timeout设置错误
            goto timed_out;
        __set_task_state(task, state);--------------------设置当前进程task->state。
        raw_spin_unlock_irq(&sem->lock);------------------下面即将睡眠，这里释放了spinlock锁，和down()中的获取spinlock锁对应。
        timeout = schedule_timeout(timeout);--------------主动让出CPU，相当于当前进程睡眠。
        raw_spin_lock_irq(&sem->lock);--------------------重新获取spinlock锁，在down()会重新释放锁。这里保证了schedule_timeout()不在spinlock环境中。
        if (waiter.up)------------------------------------waiter.up为true时，说明睡眠在waiter_list队列中的进程被该信号量的up操作唤醒。
            return 0;
    }
 timed_out:
    list_del(&waiter.list);
    return -ETIME;
 interrupted:
    list_del(&waiter.list);
    return -EINTR;
}

static inline int signal_pending_state(long state, struct task_struct *p){ 　　if (!(state & (TASK_INTERRUPTIBLE | TASK_WAKEKILL)))---------------------对于TASK_UNINTERRUPTIBLE，返回0，继续睡眠。TASK_INTERRUPTIBLE和TASK_WAKEKILL则往下继续判断。 　　　　return 0; 　　if (!signal_pending(p))--------------------------------------------------TASK_INTERRUPTIBLE和TASK_WAKEKILL情况，如果没有信号pending，则返回0，继续睡眠. 　　　　return 0;

　　return (state & TASK_INTERRUPTIBLE) || __fatal_signal_pending(p);--------如果是TASK_INTERRUPTIBLE或有SIGKILL信号未处理，则返回1，中断睡眠等待。}