Linux 时钟处理机制

staticinlinevoid__run_timers(structtvec_base*base)

{

structtimer_list*timer;

///关闭中断并且开启自旋锁

spin_lock_irq(&base->lock);

///然后遍历定时器级联表

while(time_after_eq(jiffies,base->timer_jiffies)){

///这里的head和work_list其实表示的就是已经超时的定时器,也就是我们将要处理的定时器.

structlist_headwork_list;

structlist_head*head=&work_list;

///从timer_jiffies得到所在index,其实也就是在tv1中的index

intindex=base->timer_jiffies&TVR_MASK;

///开始处理层叠定时器,这里的这个cascade是一个关键的函数,我们下面会分析,这里只需要知道这个函数其实也就是用来一层层的得到这个定时器处于哪个级别中.

if(!index&&

(!cascade(base,&base->tv2,INDEX(0)))&&

(!cascade(base,&base->tv3,INDEX(1)))&&

!cascade(base,&base->tv4,INDEX(2)))

cascade(base,&base->tv5,INDEX(3));

///更新timer_jiffies.

++base->timer_jiffies;

///用work_list替换掉base->tv1.vec+index.这里因为上面的处理中,就算定时器不在base->tv1中,可是通过cascade的调节,会将base->tv2加入到base->tv1中,或者说base->tv3,以此类推.

list_replace_init(base->tv1.vec+index,&work_list);

///如果这个值不为空说明有已经超时的定时器.这里head也就是work_list,也就是base->tv1

while(!list_empty(head)){

void(*fn)(unsignedlong);

unsignedlongdata;

///取出定时器.

timer=list_first_entry(head,structtimer_list,entry);

fn=timer->function;

data=timer->data;

timer_stats_account_timer(timer);

///设置当前正在处理的定时器为timer(这个主要是针对smp的架构),因为我们是在软中断中进行的,因此要防止多个cpu的并发.

set_running_timer(base,timer);

///删除这个定时器.

detach_timer(timer,1);

spin_unlock_irq(&base->lock);

{

intpreempt_count=preempt_count();

lock_map_acquire(&lockdep_map);

///执行定时器回调函数

fn(data);

.............................................

}

spin_lock_irq(&base->lock);

}

}

///修改base->running_timer为空

set_running_timer(base,NULL);

spin_unlock_irq(&base->lock);

}

if(!index&&

(!cascade(base,&base->tv2,INDEX(0)))&&

(!cascade(base,&base->tv3,INDEX(1)))&&

!cascade(base,&base->tv4,INDEX(2)))

cascade(base,&base->tv5,INDEX(3));

///得到在N级(也就是tv2,tv3...)的定时器表中的slot.这里可以对照我们前面的internal_add_timer加入定时器的情况.

#defineINDEX(N)((base->timer_jiffies>>(TVR_BITS+(N)*TVN_BITS))&TVN_MASK)

staticintcascade(structtvec_base*base,structtvec*tv,intindex)

{

/*cascadeallthetimersfromtvuponelevel*/

structtimer_list*timer,*tmp;

structlist_headtv_list;

///这里实例化tv_list为我们将要处理的链表.并将老的list重新初始化为空.

list_replace_init(tv->vec+index,&tv_list);

/*

*Weareremoving_all_timersfromthelist,sowe

*don'thavetodetachthemindividually.

*/

list_for_each_entry_safe(timer,tmp,&tv_list,entry){

BUG_ON(tbase_get_base(timer->base)!=base);

///重新加入定时器,也就是加入到自己对应的位置

internal_add_timer(base,timer);

}

///然后返回index,这里可以看到如果index为空则说明这个级别的定时器也已经都处理过了,因此我们需要再处理下一个级别.

returnindex;

}

voidrun_local_timers(void)

{

hrtimer_run_queues();

///触发软中断.

raise_softirq(TIMER_SOFTIRQ);

softlockup_tick();

}