libevent源码深度剖析十一 时间管理

1static void detect_monotonic(void){
2#if defined(HAVE_CLOCK_GETTIME) && defined(CLOCK_MONOTONIC)
3    struct timespec    ts;
4    if (clock_gettime(CLOCK_MONOTONIC, &ts) == 0)
5        use_monotonic = 1; // 系统支持monotonic时间
6#endif
7}

 1static int gettime(struct event_base *base, struct timeval *tp){
 2    // 如果tv_cache时间缓存已设置，就直接使用
 3    if (base->tv_cache.tv_sec) {
 4        *tp = base->tv_cache;
 5        return (0);
 6    }
 7    // 如果支持monotonic，就用clock_gettime获取monotonic时间
 8#if defined(HAVE_CLOCK_GETTIME) && defined(CLOCK_MONOTONIC)
 9    if (use_monotonic) {
10        struct timespec    ts;
11        if (clock_gettime(CLOCK_MONOTONIC, &ts) == -1)
12            return (-1);
13        tp->tv_sec = ts.tv_sec;
14        tp->tv_usec = ts.tv_nsec / 1000;
15        return (0);
16    }
17#endif
18    // 否则只能取得系统当前时间
19    return (evutil_gettimeofday(tp, NULL));
20}

 1int event_base_loop(struct event_base *base, int flags){
 2    // 清空时间缓存
 3    base->tv_cache.tv_sec = 0;
 4    while(!done){
 5        timeout_correct(base, &tv); // 时间校正
 6        // 更新event_tv到tv_cache指示的时间或者当前时间（第一次）
 7         // event_tv <--- tv_cache
 8        gettime(base, &base->event_tv);
 9        // 清空时间缓存-- 时间点1
10        base->tv_cache.tv_sec = 0;
11        // 等待I/O事件就绪
12        res = evsel->dispatch(base, evbase, tv_p);
13        // 缓存tv_cache存储了当前时间的值-- 时间点2
14         // tv_cache <--- now
15        gettime(base, &base->tv_cache);
16        // .. 处理就绪事件
17    }
18    // 退出时也要清空时间缓存
19    base->tv_cache.tv_sec = 0;
20    return (0);
21}

 1static void timeout_correct(struct event_base *base, struct timeval *tv){
 2    struct event **pev;
 3    unsigned int size;
 4    struct timeval off;
 5    if (use_monotonic) // monotonic时间就直接返回，无需调整
 6        return;
 7    gettime(base, tv); // tv <---tv_cache
 8    // 根据前面的分析可以知道event_tv应该小于tv_cache
 9    // 如果tv < event_tv表明用户向前调整时间了，需要校正时间
10    if (evutil_timercmp(tv, &base->event_tv, >=)) {
11        base->event_tv = *tv;
12        return;
13    }
14    // 计算时间差值
15    evutil_timersub(&base->event_tv, tv, &off);
16    // 调整定时事件小根堆
17    pev = base->timeheap.p;
18    size = base->timeheap.n;
19    for (; size-- > 0; ++pev) {
20        struct timeval *ev_tv = &(**pev).ev_timeout;
21        evutil_timersub(ev_tv, &off, ev_tv);
22    }
23    base->event_tv = *tv; // 更新event_tv为tv_cache
24}