libevent源码深度剖析七 事件主循环

 1int event_base_loop(struct event_base *base, int flags){
 2    const struct eventop *evsel = base->evsel;
 3    void *evbase = base->evbase;
 4    struct timeval tv;
 5    struct timeval *tv_p;
 6    int res, done;
 7    // 清空时间缓存
 8    base->tv_cache.tv_sec = 0;
 9    // evsignal_base是全局变量，在处理signal时，用于指名signal所属的event_base实例
10    if (base->sig.ev_signal_added)
11        evsignal_base = base;
12    done = 0;
13    while (!done) { // 事件主循环
14        // 查看是否需要跳出循环，程序可以调用event_loopexit_cb()设置event_gotterm标记
15        // 调用event_base_loopbreak()设置event_break标记
16        if (base->event_gotterm) {
17            base->event_gotterm = 0;
18            break;
19        }
20        if (base->event_break) {
21            base->event_break = 0;
22            break;
23        }
24        // 校正系统时间，如果系统使用的是非MONOTONIC时间，用户可能会向后调整了系统时间
25        // 在timeout_correct函数里，比较last wait time和当前时间，如果当前时间< last wait time
26        // 表明时间有问题，这是需要更新timer_heap中所有定时事件的超时时间。
27        timeout_correct(base, &tv);
28        // 根据timer heap中事件的最小超时时间，计算系统I/O demultiplexer的最大等待时间
29        tv_p = &tv;
30        if (!base->event_count_active && !(flags & EVLOOP_NONBLOCK)) {
31            timeout_next(base, &tv_p);
32        } else {
33            // 依然有未处理的就绪时间，就让I/O demultiplexer立即返回，不必等待
34            // 下面会提到，在libevent中，低优先级的就绪事件可能不能立即被处理
35            evutil_timerclear(&tv);
36        }
37        // 如果当前没有注册事件，就退出
38        if (!event_haveevents(base)) {
39            event_debug(("%s: no events registered.", __func__));
40            return (1);
41        }
42        // 更新last wait time，并清空time cache
43        gettime(base, &base->event_tv);
44        base->tv_cache.tv_sec = 0;
45        // 调用系统I/O demultiplexer等待就绪I/O events，可能是epoll_wait，或者select等；
46        // 在evsel->dispatch()中，会把就绪signal event、I/O event插入到激活链表中
47        res = evsel->dispatch(base, evbase, tv_p);
48        if (res == -1)
49            return (-1);
50        // 将time cache赋值为当前系统时间
51        gettime(base, &base->tv_cache);
52        // 检查heap中的timer events，将就绪的timer event从heap上删除，并插入到激活链表中
53        timeout_process(base);
54        // 调用event_process_active()处理激活链表中的就绪event，调用其回调函数执行事件处理
55        // 该函数会寻找最高优先级（priority值越小优先级越高）的激活事件链表，
56        // 然后处理链表中的所有就绪事件；
57        // 因此低优先级的就绪事件可能得不到及时处理；
58        if (base->event_count_active) {
59            event_process_active(base);
60            if (!base->event_count_active && (flags & EVLOOP_ONCE))
61                done = 1;
62        } else if (flags & EVLOOP_NONBLOCK)
63            done = 1;
64    }
65    // 循环结束，清空时间缓存
66    base->tv_cache.tv_sec = 0;
67    event_debug(("%s: asked to terminate loop.", __func__));
68    return (0);
69}