X-Git-Url: https://hackdaworld.org/gitweb/?a=blobdiff_plain;f=event%2Fevent.c;h=fb3c82efb261cce36bca804be3661b492264a1d0;hb=HEAD;hp=398a1ddc5ba930c96c7b39247585a54bea741d79;hpb=a88d4856f5c836896fc18f14d736c42c9d366352;p=my-code%2Fapi.git diff --git a/event/event.c b/event/event.c index 398a1dd..fb3c82e 100644 --- a/event/event.c +++ b/event/event.c @@ -30,6 +30,14 @@ int event_set_timeout(t_event *event,int sec,int usec) { return E_SUCCESS; } +int event_set_immediately(t_event *event,unsigned char value) { + + if(value==IMM_TRUE) + event->immediately=value; + + return E_SUCCESS; +} + int event_math(int fd,t_event *event,char rw,char ar) { if(ar==ADD) { @@ -54,6 +62,7 @@ int event_start(t_event *event,void *ptr, int s_ret; struct timeval tv; + struct timeval *tv_ptr; /* switch on event system */ event->status=ENABLED; @@ -64,8 +73,11 @@ int event_start(t_event *event,void *ptr, event->wfds=event->wfds_o; tv=event->timeout; + if((tv.tv_sec==0)&&(tv.tv_usec==0)&&(!(event->immediately))) tv_ptr=NULL; + else tv_ptr=&tv; + if((s_ret=select(event->maxfd+1,&(event->rfds),&(event->wfds),NULL, - &tv))==-1) { + tv_ptr))==-1) { perror("[event] select call"); return E_ERROR; } @@ -89,6 +101,13 @@ int event_start(t_event *event,void *ptr, return E_SUCCESS; } +int event_check(t_event *event,int fd) { + + if(FD_ISSET(fd,&(event->wfds))|FD_ISSET(fd,&(event->rfds))) return E_FD_YES; + else return E_FD_NO; + +} + int event_stop(t_event *event) { dprintf(event->outfd,"[event] shutdown\n");