libevent 信号事件实现方式

学会使用libevent，才能真正的掌握其是实现原理，我们先从一个简短的测试用例开始：

   #include <sys/types.h>

   #include <sys/stat.h>

   #include <sys/queue.h>

   #include <unistd.h>

   #include <sys/time.h>

   #include <signal.h>

   #include <fcntl.h>

   #include <stdlib.h>

  #include <stdio.h>

  #include <string.h>

  #include <errno.h>

  #include <event.h>

  int called = ;

  static void signall_cb(int fd, short event, void *arg)

  {

      struct event *signal = arg;

      printf("%s: got signal %d\n", __func__, EVENT_SIGNAL(signal));

      if (called >= )

          event_del(signal);

       called++;

  }

  int main (int argc, char **argv)

  {

      struct event signal_int;

       /* Initalize the event library */

      event_init();

      /* Initalize one event */

      event_set(&signal_int, SIGINT, EV_SIGNAL|EV_PERSIST, signall_cb, &signal_int);

      event_add(&signal_int, NULL);

      event_dispatch();

      return ();

  }

该代码的大体意思是：添加一个信号中断事件，通过CTRL+C，产生中断信号，再调用中断处理函数。

首先分析的是函数是event_init函数，现帖出其具体实现方式

 struct event_base *

  event_base_new(void)

  {

      int i;

      struct event_base *base;

      if ((base = calloc(, sizeof(struct event_base))) == NULL)

          event_err(, "%s: calloc", __func__);

      event_sigcb = NULL;

      event_gotsig = ;

      detect_monotonic();

      /*如果第一次使用初始化，需要将时间缓存保留，在event_base中保留了一个事件*/

      gettime(base, &base->event_tv);

      /*初始化最小堆，这个堆里存储的是时间，在I／O复用的函数里是使用最小堆中堆顶的值

 210     作为等待的时间参数，这里只介绍epoll_wait作为I／O复用的方法，这个值就是函数的最后

 211     一个参数，当等待的时间结束，函数返回，也就代表着可能是定时事件被激活

 212     这样也将定时事件集合到I／O事件*/

      min_heap_ctor(&base->timeheap);

      /*宏作为初始化的,eventqueue是一个event_list，这里面存储着这个event_base所关注的

 215     所有事件*/

      TAILQ_INIT(&base->eventqueue);

      /*这一对套接字是为了将信号事件融合到I／O事件中所特有的，将其中一个套接字添加到被关注的

 218     行列中，信号事件是通过这一对套接字上来传递的，信号到达，其中一个套接字上有I／O事件，

 219     那么信号到达可以让I／O返回，这样便可将信号事件添加到激活队列中去........*/

      base->sig.ev_signal_pair[] = -;

      base->sig.ev_signal_pair[] = -;

      base->evbase = NULL;

      /*寻找合适的I／O复用机制，在这里说明，libevent库使用的I／O机制是在编译的时候确定的

 225     其实evbase和某一个复用机制的关系就像类和对象的关系一样，复用机制是evbase的具体实现

 226     */

      printf("default is selected %d  %d  %d\n", HAVE_EPOLL, ：qHAVE_POLL, HAVE_SELECT);

          /*eventops 是一个全局的结构体，结构体中都是不同内核所支持的几种I／O复用机制*/

      for (i = ; eventops[i] && !base->evbase; i++) {

          base->evsel = eventops[i];

巴特西

libevent 信号事件实现方式

最新文章

热门文章