您的位置:首页 > 运维架构 > Linux

libevent事件处理程序struct event解析

2017-01-16 10:05 337 查看
struct event

{

//ev_next,ev_active_next和ev_signal_next都是双向链表节点指针;它们是libevent对 //不同事件类型和在不同的时期,对事件的管理时使用到的字段。

//libevent使用双向链表保存所有注册的I/O和Signal事件,ev_next就是该I/O事件在//链表中的位置;称此链表为“已注册事件链表”;

//同样ev_signal_next就是signal事件在signal事件链表中的位置;

//ev_active_next:libevent将所有的激活事件放入到链表active list中,然后遍历active list执行调度,ev_active_next就指明了event在active list中的位置;

TAILQ_ENTRY(event)ev_active_next;

TAILQ_ENTRY(event)ev_next;

/*for managing timeouts */

//min_heap_idx和ev_timeout,如果是timeout事件,它们是event在小根堆中的索引//和超时值,libevent使用小根堆来管理定时事件

union

{

TAILQ_ENTRY(event)ev_next_with_common_timeout;

intmin_heap_idx;

}ev_timeout_pos;

//对于I/O事件,是绑定的文件描述符;对于signal事件,是绑定的信号;

evutil_socket_tev_fd;

//该事件所属的反应堆实例,这是一个event_base结构体

structevent_base *ev_base;

union

{

/*used for io events */

struct

{

TAILQ_ENTRY(event)ev_io_next;

structtimeval ev_timeout;

}ev_io;

/*used by signal events */

struct

{

TAILQ_ENTRY(event) ev_signal_next;

//事件就绪执行时,调用ev_callback的次数,通常为1;

shortev_ncalls;

/*Allows deletes in callback */

short*ev_pncalls;

}ev_signal;

}_ev;

//事件类型

//I/O事件: EV_WRITE和EV_READ

//定时事件:EV_TIMEOUT

//信号: EV_SIGNAL

//辅助选项:EV_PERSIST,表明是一个永久事件

shortev_events;

//记录了当前激活事件的类型,是读事件还是写事件等.

shortev_res; /* result passed toevent callback */

//当前事件的状态,比如EVLIST_INIT

shortev_flags;

//优先级

ev_uint8_tev_pri; /* smaller numbers are higherpriority */

////终止方式三种:EV_CLOSURE_SIGNALEV_CLOSURE_PERSIST EV_CLOSURE_NONE

ev_uint8_tev_closure;

//超时值

structtimeval ev_timeout;

/*allows us to adopt for different types of events */

//event的回调函数,被ev_base调用,执行事件处理程序,这是一个函数指针,原型为:void (*ev_callback)(int fd, short events, void *arg)

void(*ev_callback)(evutil_socket_t, short, void *arg);

//ev_arg表明可以是任意类型的数据,在设置event时指定;

void*ev_arg;

};

本文重点说明ev_flags ev_res ev_closure这三个变量用途及生命周期。

一、ev_flags:记录了该事件的状态,包括如下几种状态

#define EVLIST_TIMEOUT 0x01

#define EVLIST_INSERTED 0x02 事件已经插入到事件列表中。

#define EVLIST_SIGNAL 0x04

#define EVLIST_ACTIVE 0x08 事件处于激活状态

#define EVLIST_INTERNAL 0x10 ??

#define EVLIST_INIT 0x80 事件已经初始化

1.在event_assign函数(大部分事件初始化都是在该函数中)中,

ev_flags被初始化为EVLIST_INIT。

2.在event_add_internal里调用event_queue_insert(base,ev, EVLIST_INSERTED)函数,在event_queue_insert函数中,

ev_flags被设置为EVLIST_INIT| EVLIST_INSERTED。

3. 当事件被激活时调用event_active_nolock函数,该函数内部再次调用event_queue_insert(base, ev, EVLIST_ACTIVE);

此时ev_flags被设置为EVLIST_INIT| EVLIST_INSERTED| EVLIST_ACTIVE。

4.在事件执行的时候在event_process_active_single_queue中, 调用event_queue_remove(base,ev, EVLIST_ACTIVE);

通过ev->ev_flags&= ~queue语句,将激活状态取消,

此时ev_flags被设置为EVLIST_INIT| EVLIST_INSERTED

5.当端口结束工作时,会调用, event_del(struct event *ev),该函数调用event_del_internal(ev),在event_del_internal中,会将该事件从哈希表和所有的事件队列中删除。

此时ev_flags被重新设置为EVLIST_INIT

这样一个ev_flags的设置周期基本就结束了。

由上可见,ev_flags的作用主要是指出当前的event处于何种状态,相应的函数可以根据该状态作出判断,比如event_del_internal中可以判断该事件如果激活,则从激活队列中删除,如果是已经插入,则还要从插入队列中删除。

以上只是ev_flag的基本用途,在timeout事件中应该还有其他用途。

二、ev_res:记录了该事件的状态

包括如下几种状态, 记录了当前激活事件的类型,是读事件还是写事件等

1.在event_assign函数(大部分事件初始化都是在该函数中)中,

ev_flags被初始化为0。

2.在事件激活时,调用evmap_io_active(structevent_base *base, evutil_socket_t fd, shortevents),函数,在该函数内部,调用event_active_nolock(ev,ev->ev_events & events, 1);,该函数调用如下语句:

ev->ev_res = res;

作用:

在event_persist_closure(struct event_base *base, structevent *ev)函数或其他类似函数中,

回调函数通过如下回调函数,利用ev->ev_res值

(*ev->ev_callback)(ev->ev_fd,ev->ev_res, ev->ev_arg);

告知订阅端该事件类型。

三、ev_closure:终止方式三种

设置回调函数类型:

#define EV_CLOSURE_NONE 0

#define EV_CLOSURE_SIGNAL 1

#define EV_CLOSURE_PERSIST 2

1.在event_assign函数(大部分事件初始化都是在该函数中)中,

// switch(event的类型)

//EV_SIGNAL: ev->ev_closure =EV_CLOSURE_SIGNAL;

//EV_PERSIST: ev->ev_closure =EV_CLOSURE_PERSIST;

//其他:ev->ev_closure = EV_CLOSURE_NONE;

2.在event_process_active_single_queue(struct event_base *base,structevent_list *activeq)函数中,如下语句所示:

switch (ev->ev_closure)

{caseEV_CLOSURE_SIGNAL:

event_signal_closure(base,ev);

break;

caseEV_CLOSURE_PERSIST:

event_persist_closure(base,ev);

break;

default:

caseEV_CLOSURE_NONE:

EVBASE_RELEASE_LOCK(base,th_base_lock);

(*ev->ev_callback)(

ev->ev_fd,ev->ev_res, ev->ev_arg);

break;

}

根据ev->ev_closure的类型,调用不同的回调函数。

所以,ev->ev_closure的作用就是告诉在事件处理时调用不同的处理函数。
http://blog.csdn.net/jiayp004/article/details/14000183
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  linux libevent stru
相关文章推荐