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