event loop

事件循环

一旦你向event_base注册了一些event，那你接下来会希望Libevent等待事件的发生并且通知你。

接口

#define EVLOOP_ONCE             0x01
#define EVLOOP_NONBLOCK         0x02
#define EVLOOP_NO_EXIT_ON_EMPTY 0x04

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

你可以通过设置flags参数去改变event_base_loop()的行为。如果EVLOOP_ONCE被设置，那循环会发生阻塞，去等一些event变成“活跃的”，然后遍历运行这些活跃的event。如果EVLOOP_NONBLOCK被设置，循环不会阻塞去等待event被触发：它只会检查是否有event准备好去触发，如果有直接调用它们的回调。

通常，如果已经当前没有活跃或还未处理完的event，那么循环就会退出。你可以通过设置EVLOOP_NO_EXIT_ON_EMPTY去覆盖默认的退出。例如，如果你想稍后从其他的线程增加event。如果设置了EVLOOP_NO_EXIT_ON_EMPTY，循环会持续运行直到人为的调用了event_base_loopbreak()，或event_base_loopexit()，或发生错误。

当它结束时，正常退出event_base_loop()返回0， 如果发生错误返回-1，如果是由于没有活跃的event而退出，则返回1。

为了增加理解，这里有个对于event_base_loop的总结：
伪代码

while (any events are registered with the loop,
        or EVLOOP_NO_EXIT_ON_EMPTY was set) {

    if (EVLOOP_NONBLOCK was set, or any events are already active)
        If any registered events have triggered, mark them active.
    else
        Wait until at least one event has triggered, and mark it active.

    for (p = 0; p < n_priorities; ++p) {
       if (any event with priority of p is active) {
          Run all active events with priority of p.
          break; /* Do not run any events of a less important priority */
       }
    }

    if (EVLOOP_ONCE was set or EVLOOP_NONBLOCK was set)
       break;
}

接口

int event_base_dispatch(struct event_base *base);

循环终止
如果你想提前终止一个event循环。你可以有两个选择，这两个方法稍有不同。

接口

int event_base_loopexit(struct event_base *base,
                        const struct timeval *tv);
int event_base_loopbreak(struct event_base *base);

event_base_loopbreak()可以直接退出循环。不同于event_base_loopexit(base, NULL)，它会在结束当前event后直接退出。

注意当没有event循环在运行时，调用event_base_loopexit(base, NULL)和event_base_loopbreak(base)产生的处理是不同的：如果下一个循环（使用了EVLOOP_ONCE）被调用loopexit会使下一个启动的event 循环停止。而loopbreak只对当前正在运行的event循环有影响，如果当前没有循环在运行，则不会有任何作用。

这两个方法均成功返回0，失败返回-1。
例子：直接结束

#include <event2/event.h>

/* Here's a callback function that calls loopbreak */
void cb(int sock, short what, void *arg)
{
    struct event_base *base = arg;
    event_base_loopbreak(base);
}

void main_loop(struct event_base *base, evutil_socket_t watchdog_fd)
{
    struct event *watchdog_event;

    /* Construct a new event to trigger whenever there are any bytes to
       read from a watchdog socket.  When that happens, we'll call the
       cb function, which will make the loop exit immediately without
       running any other active events at all.
     */
    watchdog_event = event_new(base, watchdog_fd, EV_READ, cb, base);

    event_add(watchdog_event, NULL);

    event_base_dispatch(base);
}

#include <event2/event.h>

void run_base_with_ticks(struct event_base *base)
{
  struct timeval ten_sec;

  ten_sec.tv_sec = 10;
  ten_sec.tv_usec = 0;

  /* Now we run the event_base for a series of 10-second intervals, printing
     "Tick" after each.  For a much better way to implement a 10-second
     timer, see the section below about persistent timer events. */
  while (1) {
     /* This schedules an exit ten seconds from now. */
     event_base_loopexit(base, &ten_sec);

     event_base_dispatch(base);
     puts("Tick");
  }
}

接口

int event_base_got_exit(struct event_base *base);
int event_base_got_break(struct event_base *base);

重新检测event

通常，Libevent会检测event，然后运行高优先级的被激活的event，然后再重新检测，这样循环。但有时你可能想终止Libevent后，再继续运行它。通过类比event_base_loopbreak()，你可以通过下面这个方法：

接口

int event_base_loopcontinue(struct event_base *);

获取内部缓存时间

有时你想在event回调里面获得一个粗略时间，你不需要调用gettimeofday()（因为gettimeofday()是系统调用，未避免内核和用户的上下文切换，你应该尽量避免系统调用）。

在一个回调内部，你可以请求Libevent提供它开始运行这轮回调时的时间：

接口

int event_base_gettimeofday_cached(struct event_base *base,
    struct timeval *tv_out);

注意当Libevent开始运行回调时，时间就会被缓存，它多多少少都会有些不准确。如果你的回调花了很长时间，会导致时间更加不准确。你可以通过以下方法去强制更新缓存时间：

接口

int event_base_update_cache_time(struct event_base *base);

输出event_base状态

接口

void event_base_dump_events(struct event_base *base, FILE *f);

为每个event都运行一个方法

接口

typedef int (*event_base_foreach_event_cb)(const struct event_base *,
    const struct event *, void *);

int event_base_foreach_event(struct event_base *base,
                             event_base_foreach_event_cb fn,
                             void *arg);

如果想继续运行，回调方法必须返回0，返回其他值会终止迭代。无论回调方法最终返回什么值，都会被event_base_foreach_function()方法返回。
你提供的的回调方法一定不要去修改任何它接收的event，也不要从event_base中添加或删除任何event，也不要修改其他任何在event_base中的event。否则未定义的情况可能会发生，包括宕机等。

在调用event_base_foreach_event()期间，会持有event_base的锁：这会阻止其他线程去使用event_base，所以确保你的回调不会运行很长时间。

libevent学习五