libevent源码浅析(一)

loop函数将进入事件监测循环。

int
event_base_loop(struct　event_base　*base,　int　flags)
{

............................................
.......................................
///校准时间，非Monotonic时钟这个函数将会立即返回。
timeout_correct(base,　&tv);

tv_p　=　&tv;
if　(!base->event_count_active　&&　!(flags　&　EVLOOP_NONBLOCK))　{
timeout_next(base,　&tv_p);
}　else　{
/*
*　if　we　have　active　events,　we　just　poll　new　events
*　without　waiting.
*/
evutil_timerclear(&tv);
}

/*　If　we　have　no　events,　we　just　exit　*/
if　(!event_haveevents(base))　{
event_debug(("%s:　no　events　registered.",　__func__));
return　(1);
}

/*　update　last　old　time　*/
gettime(base,　&base->event_tv);

/*　clear　time　cache　*/
base->tv_cache.tv_sec　=　0;
///调用相应的事件引擎处理函数
res　=　evsel->dispatch(base,　evbase,　tv_p);

if　(res　==　-1)
return　(-1);
gettime(base,　&base->tv_cache);
///超时处理函数（下面紧接着会介绍)
timeout_process(base);

if　(base->event_count_active)　{
event_process_active(base);
if　(!base->event_count_active　&&　(flags　&　EVLOOP_ONCE))
done　=　1;
}　else　if　(flags　&　EVLOOP_NONBLOCK)
done　=　1;
}
..................................................
}

超时处理函数

void
timeout_process(struct　event_base　*base)
{
struct　timeval　now;
struct　event　*ev;

if　(min_heap_empty(&base->timeheap))
return;

gettime(base,　&now);
///遍历定时器
while　((ev　=　min_heap_top(&base->timeheap)))　{
if　(evutil_timercmp(&ev->ev_timeout,　&now,　>))
break;
/*　delete　this　event　from　the　I/O　queues　*/
event_del(ev);

event_debug(("timeout_process:　call　%p",
ev->ev_callback));
///激活此事件
event_active(ev,　EV_TIMEOUT,　1);
}
}

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!