src/event.c

   1 /* event.c -- event management stuff
   2  *
   3  * author: hackbard@hackdaworld.dyndns.org
   4  *
   5  */
   6
   7 #include "event.h"
   8
   9 int event_init(t_event *event) {
  10
  11   puts("[event] initializing event system ...");
  12
  13   event->maxfd=0;
  14
  15   FD_ZERO(&(event->rfds));
  16   FD_ZERO(&(event->rfds_o));
  17   FD_ZERO(&(event->wfds));
  18   FD_ZERO(&(event->wfds_o));
  19
  20   return E_SUCCESS;
  21 }
  22
  23 int event_math(int fd,t_event *event,char rw,char ar) {
  24
  25   if(ar==ADD) {
  26     if(rw==READ) FD_SET(fd,&(event->rfds_o));
  27     else FD_SET(fd,&(event->wfds_o));
  28     if(fd>event->maxfd) event->maxfd=fd;
  29   } else {
  30     if(rw==READ) FD_CLR(fd,&(event->rfds_o));
  31     else FD_CLR(fd,&(event->wfds_o));
  32     if(fd==event->maxfd) event->maxfd-=1;
  33   }
  34
  35   printf("[event] %c fd %d to %c file descriptor set\n",ar==ADD?'+':'-',fd,
  36                                                         rw==READ?'r':'w');
  37
  38   return E_SUCCESS;
  39 }
  40
  41 int event_start(t_event *event,void *ptr,
  42                 int (*callback0)(t_event *event,void *ptr),
  43                 int (*callback1)(t_event *event,void *ptr)) {
  44
  45   int s_ret;
  46   struct timeval tv;
  47
  48   /* switch on event system */
  49   event->status=ENABLED;
  50
  51   while(event->status&ENABLED) {
  52
  53     event->rfds=event->rfds_o;
  54     event->wfds=event->wfds_o;
  55     tv=event->timeout;
  56
  57     if((s_ret=select(event->maxfd+1,&(event->rfds),&(event->wfds),NULL,
  58                      &tv))==-1) {
  59       perror("[event] select call");
  60       return E_ERROR;
  61     }
  62
  63     if(s_ret) {
  64       /* 1+ fd(s) available for reading/writing */
  65       if(callback0(event,ptr)==CALLBACK_ERROR) {
  66         puts("[event] callback0 returned error");
  67         return E_ERROR;
  68       }
  69     }
  70
  71     /* usual stuff to be executed */
  72     if(callback1(event,ptr)==CALLBACK_ERROR) {
  73       puts("[event] callback returned error");
  74       return E_ERROR;
  75     }
  76
  77   }
  78
  79   return E_SUCCESS;
  80 }
  81
  82 int event_stop(t_event *event) {
  83
  84   puts("[event] shutdown");
  85   event->status=DISABLED;
  86
  87   return E_SUCCESS;
  88 }