]> hackdaworld.org Git - my-code/api.git/blob - event/event.c
hopefully final bugfix to not et segfaulst using list_next
[my-code/api.git] / event / 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,int outfd) {
10
11   dprintf(outfd,"[event] initializing event system ...\n");
12
13   event->maxfd=0;
14
15   event->outfd=outfd;
16
17   FD_ZERO(&(event->rfds));
18   FD_ZERO(&(event->rfds_o));
19   FD_ZERO(&(event->wfds));
20   FD_ZERO(&(event->wfds_o));
21
22   return E_SUCCESS;
23 }
24
25 int event_set_timeout(t_event *event,int sec,int usec) {
26
27   event->timeout.tv_sec=sec;
28   event->timeout.tv_usec=usec;
29
30   return E_SUCCESS;
31 }
32
33 int event_math(int fd,t_event *event,char rw,char ar) {
34
35   if(ar==ADD) {
36     if(rw==READ) FD_SET(fd,&(event->rfds_o));
37     else FD_SET(fd,&(event->wfds_o));
38     if(fd>event->maxfd) event->maxfd=fd;
39   } else {
40     if(rw==READ) FD_CLR(fd,&(event->rfds_o));
41     else FD_CLR(fd,&(event->wfds_o));
42     if(fd==event->maxfd) event->maxfd-=1;
43   }
44
45   dprintf(event->outfd,"[event] %c fd %d to %c file descriptor set\n",
46           ar==ADD?'+':'-',fd,rw==READ?'r':'w');
47
48   return E_SUCCESS;
49 }
50
51 int event_start(t_event *event,void *ptr,
52                 int (*callback0)(t_event *event,void *ptr),
53                 int (*callback1)(t_event *event,void *ptr)) {
54
55   int s_ret;
56   struct timeval tv;
57   struct timeval *tv_ptr;
58
59   /* switch on event system */
60   event->status=ENABLED;
61
62   while(event->status&ENABLED) {
63
64     event->rfds=event->rfds_o;
65     event->wfds=event->wfds_o;
66     tv=event->timeout;
67
68     if((tv.tv_sec==0)&&(tv.tv_usec==0)) tv_ptr=NULL;
69     else tv_ptr=&tv;
70
71     if((s_ret=select(event->maxfd+1,&(event->rfds),&(event->wfds),NULL,
72                      tv_ptr))==-1) {
73       perror("[event] select call");
74       return E_ERROR;
75     }
76
77     if(s_ret) {
78       /* 1+ fd(s) available for reading/writing */
79       if(callback0(event,ptr)==CALLBACK_ERROR) {
80         dprintf(event->outfd,"[event] callback0 returned error\n");
81         return E_ERROR;
82       }
83     }
84
85     /* usual stuff to be executed */
86     if(callback1(event,ptr)==CALLBACK_ERROR) {
87       dprintf(event->outfd,"[event] callback returned error\n");
88       return E_ERROR;
89     }
90
91   }
92
93   return E_SUCCESS;
94 }
95
96 int event_stop(t_event *event) {
97
98   dprintf(event->outfd,"[event] shutdown\n");
99   event->status=DISABLED;
100
101   return E_SUCCESS;
102 }