《libevent深度剖析三.docxVIP

libevent源码深度剖析七——事件主循环张亮 现在我们已经初步了解了libevent的Reactor组件——event_base和事件管理框架，接下来就是libevent事件处理的中心部分——事件主循环，根据系统提供的事件多路分发机制执行事件循环，对已注册的就绪事件，调用注册事件的回调函数来处理事件。1 阶段性的胜利 Libevent将I/O事件、定时器和信号事件处理很好的结合到了一起，本节也会介绍libevent是如何做到这一点的。 在看完本节的内容后，读者应该会对Libevent的基本框架：事件管理和主循环有比较清晰的认识了，并能够把libevent的事件控制流程清晰的串通起来，剩下的就是一些细节的内容了。2 事件处理主循环 Libevent的事件主循环主要是通过event_base_loop ()函数完成的，其主要操作如下面的流程图所示，event_base_loop所作的就是持续执行下面的循环。??清楚了event_base_loop所作的主要操作，就可以对比源代码看个究竟了，代码结构还是相当清晰的。view plaincopy to clipboardprint?int?event_base_loop(struct?event_base?*base,?int?flags)??{???const?struct?eventop?*evsel?=?base-evsel;???void?*evbase?=?base-evbase;???struct?timeval?tv;???struct?timeval?*tv_p;???int?res,?done;???//?清空时间缓存??base-tv_cache.tv_sec?=?0;???//?evsignal_base是全局变量，在处理signal时，用于指名signal所属的event_base实例??if?(base-sig.ev_signal_added)???evsignal_base?=?base;???done?=?0;???while?(!done)?{?//?事件主循环??//?查看是否需要跳出循环，程序可以调用event_loopexit_cb()设置event_gotterm标记??//?调用event_base_loopbreak()设置event_break标记??if?(base-event_gotterm)?{???base-event_gotterm?=?0;???break;???}???if?(base-event_break)?{???base-event_break?=?0;???break;???}???//?校正系统时间，如果系统使用的是非MONOTONIC时间，用户可能会向后调整了系统时间??//?在timeout_correct函数里，比较last?wait?time和当前时间，如果当前时间?last?wait?time??//?表明时间有问题，这是需要更新timer_heap中所有定时事件的超时时间。??timeout_correct(base,?tv);????//?根据timer?heap中事件的最小超时时间，计算系统I/O?demultiplexer的最大等待时间??tv_p?=?tv;???if?(!base-event_count_active??!(flags??EVLOOP_NONBLOCK))?{???timeout_next(base,?tv_p);???}?else?{???//?依然有未处理的就绪时间，就让I/O?demultiplexer立即返回，不必等待??//?下面会提到，在libevent中，低优先级的就绪事件可能不能立即被处理??evutil_timerclear(tv);???}???//?如果当前没有注册事件，就退出??if?(!event_haveevents(base))?{???event_debug((%s:?no?events?registered.,?__func__));???return?(1);???}???//?更新last?wait?time，并清空time?cache??gettime(base,?base-event_tv);???base-tv_cache.tv_sec?=?0;???//?调用系统I/O?demultiplexer等待就绪I/O?events，可能是epoll_wait，或者select等；??//?在evsel-dispatch()中，会把就绪signal?event、I/O?event插入到激活链表中??res?=?evsel-dispatch(base,?evbase,?tv_p);???if?(res?==?-1)???return?(-