libevent学习四

标签：libevent   c   

构建event_base

在你开始使用任何Libevent前，你需要先创建一个或多个event_base。每个event_base管理着一个event的集合，并可以检测出哪些event被激活了。如果event_base使用了锁，就可以在多线程中安全的访问它。但要注意它的主poll函数只能被单个线程运行。如果你想用多个线程运行IO迭代器，你需要为每个线程分配一个event_base。

注：在以后的版本中，Libevent可能提供对跨线程event的支持。

每个event_base都有一个“方法”或主IO函数，用来确定哪些event已经被准备好。其中包括：

1. select

2. poll

3. epoll

4. kqueue

5. devpoll

6. evport

7. win32

使用者可以通过环境变量来禁用某个指定的主函数。如果你想去关掉kqueue函数，可以设置EVENT_NOKQUEUE这个环境变量等。如果你想在程序内部关掉，可以看下面对event_config_avoid_method的介绍：

设定默认的event_base

函数event_base_new()会创建一个默认设置的event_base。它根据相应的环境变量，返回一个指向event_base的指针。如果错误返回NULL。

默认它会自动选择系统所支持的最快的主函数。

接口

struct event_base *event_base_new(void);

定制自己的event_base
如果你想定制自己的event_base，你需要使用到event_config。event_config是个不对外开放的结构体。它保存着你对event_base偏好设定的相关信息。你可以通过传入event_config到event_base_new_with_config()来创建event_base。

接口

struct event_config *event_config_new(void);
struct event_base *event_base_new_with_config(const struct event_config *cfg);
void event_config_free(struct event_config *cfg);

接口

int event_config_avoid_method(struct event_config *cfg, const char *method);

enum event_method_feature {
    EV_FEATURE_ET = 0x01,
    EV_FEATURE_O1 = 0x02,
    EV_FEATURE_FDS = 0x04,
};
int event_config_require_features(struct event_config *cfg,
                                  enum event_method_feature feature);

enum event_base_config_flag {
    EVENT_BASE_FLAG_NOLOCK = 0x01,
    EVENT_BASE_FLAG_IGNORE_ENV = 0x02,
    EVENT_BASE_FLAG_STARTUP_IOCP = 0x04,
    EVENT_BASE_FLAG_NO_CACHE_TIME = 0x08,
    EVENT_BASE_FLAG_EPOLL_USE_CHANGELIST = 0x10,
    EVENT_BASE_FLAG_PRECISE_TIMER = 0x20
};
int event_config_set_flag(struct event_config *cfg,
    enum event_base_config_flag flag);

一些用在event_config_require_features的feature有：

EV_FEATURE_ET：要求主函数支持edge-triggered。（边缘模式）

EV_FEATURE_O1：要求主函数增加，删除event或某个event被激活的算法复杂度都是O(1)。

EV_FEATURE_FDS：要求主函数可以处理任意的文件描述符，而不仅仅是socket。

event_config_set_flag使用到的值有：

EVENT_BASE_FLAG_NOLOCK：不给event_base分配锁。设置这个选项可能为你节省一点花费在加锁，解锁上的时间，但是在多线程情况下，会变得不安全。

EVENT_BASE_FLAG_IGNORE_ENV：当选择使用哪个主函数时，不检查EVENT_*的环境变量。使用前要想清楚，因为它会让你在调试你的程序时，变得困难。

EVENT_BASE_FLAG_STARTUP_IOCP：只用在Windows上，在启动时就启用必要的IOCP逻辑调度。而不是按需。

EVENT_BASE_FLAG_NO_CACHE_TIME：不是在事件循环每次准备执行超时回调时检测当前时间，而是在每次超时回调后进行检测。注意，这会消耗更多的CPU时间。

EVENT_BASE_FLAG_EPOLL_USE_CHANGLIST：告诉Libevent，如果使用的主函数是epoll，使用更高效的“changelist”模式。如果同一个fd的状态在进入下一次循环前就被修改，epoll-changelist可以避免不必要的系统调用。但要注意的是，如果Libevent使用的fd被dup()函数克隆，那它可能会触发一个内核错误。如果你没有使用epoll，它是不起作用的。你可以通过设定EVENT_EPOLL_USE_CHANGLIST环境变量去启用epoll-changelist。
EVENT_BASE_FLAG_PRECISE_TIMER：默认情况下，Libevent会尝试去使用系统提供的效率最高的计时器。如果有一个计时器虽然比较慢，但是有更高的精确度。这个flag会让Libevent去使用它。

接口

int event_config_set_num_cpus_hint(struct event_config *cfg, int cpus)

int event_config_set_max_dispatch_interval(struct event_config *cfg,
    const struct timeval *max_interval, int max_callbacks,
    int min_priority);

例子：避免优先级反转

struct event_config *cfg;
struct event_base *base;

cfg = event_config_new();
if (!cfg)
   /* Handle error */;

/* I'm going to have events running at two priorities.  I expect that
   some of my priority-1 events are going to have pretty slow callbacks,
   so I don't want more than 100 msec to elapse (or 5 callbacks) before
   checking for priority-0 events. */
struct timeval msec_100 = { 0, 100*1000 };
event_config_set_max_dispatch_interval(cfg, &msec_100, 5, 1);

base = event_base_new_with_config(cfg);
if (!base)
   /* Handle error */;

event_base_priority_init(base, 2);

接口

const char **event_get_supported_methods(void);

例：

int i;
const char **methods = event_get_supported_methods();
printf("Starting Libevent %s.  Available methods are:\n",
    event_get_version());
for (i=0; methods[i] != NULL; ++i) {
    printf("    %s\n", methods[i]);
}

const char *event_base_get_method(const struct event_base *base);
enum event_method_feature event_base_get_features(const struct event_base *base);

例：

struct event_base *base;
enum event_method_feature f;

base = event_base_new();
if (!base) {
    puts("Couldn't get an event_base!");
} else {
    printf("Using Libevent with backend method %s.",
        event_base_get_method(base));
    f = event_base_get_features(base);
    if ((f & EV_FEATURE_ET))
        printf("  Edge-triggered events are supported.");
    if ((f & EV_FEATURE_O1))
        printf("  O(1) event notification is supported.");
    if ((f & EV_FEATURE_FDS))
        printf("  All FD types are supported.");
    puts("");
}

接口

void event_base_free(struct event_base *base);

Libevent支持在一个event_base中设置多个优先级。默认它只支持一个基本的优先级。你可以通过调用event_base_priority_init()来设置优先级的数量。

接口

int event_base_priority_init(struct event_base *base, int n_priorities);

它有个最大常量的限制EVENT_MAX_PRIORITIES。

注：这个方法必须在任何events被激活前被调用。最好在创建event_base后就调用它。

查看当前的event_base支持多少个优先级。可用调用：

接口

int event_base_get_npriorities(struct event_base *base);

fork()后重新初始化event_base
在调用fork()后，event相关的数据可能变脏。所以，如果你想在fork后的进程中继续使用event_base，你需要去重新初始化它。

接口

int event_reinit(struct event_base *base);

例：

struct event_base *base = event_base_new();

/* ... add some events to the event_base ... */

if (fork()) {
    /* In parent */
    continue_running_parent(base); /*...*/
} else {
    /* In child */
    event_reinit(base);
    continue_running_child(base); /*...*/
}

libevent学习四

标签：libevent   c   

原文地址：http://blog.csdn.net/huanzai2/article/details/43026009