X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Feventl.h;h=515b7f290ff8a505f0dda575d358c300fcecc0ae;hb=37ae4386bd764d62ae43c68df1560be55ff813ca;hp=e22b90e8f11d3deac145f49d839af2e2c8a16d91;hpb=29e02dd1c6ecdbb2cb1546324d460b3e0dcd2435;p=pazpar2-moved-to-github.git diff --git a/src/eventl.h b/src/eventl.h index e22b90e..515b7f2 100644 --- a/src/eventl.h +++ b/src/eventl.h @@ -1,5 +1,5 @@ /* This file is part of Pazpar2. - Copyright (C) 2006-2010 Index Data + Copyright (C) Index Data Pazpar2 is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free @@ -25,8 +25,6 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA struct iochan; typedef void (*IOC_CALLBACK)(struct iochan *i, int event); -typedef int (*IOC_SOCKETFUN)(struct iochan *i); -typedef int (*IOC_MASKFUN)(struct iochan *i); typedef struct iochan_man_s *iochan_man_t; @@ -39,8 +37,6 @@ typedef struct iochan #define EVENT_EXCEPT 0x04 #define EVENT_TIMEOUT 0x08 IOC_CALLBACK fun; - IOC_SOCKETFUN socketfun; - IOC_MASKFUN maskfun; void *data; int destroyed; time_t last_event; @@ -51,16 +47,18 @@ typedef struct iochan iochan_man_t man; char *name; struct iochan *next; + int poll_offset; } *IOCHAN; -iochan_man_t iochan_man_create(int no_threads); -void iochan_add(iochan_man_t man, IOCHAN chan); +iochan_man_t iochan_man_create(int no_threads, int max_sockets); +int iochan_add(iochan_man_t man, IOCHAN chan, int slack); void iochan_man_events(iochan_man_t man); void iochan_man_destroy(iochan_man_t *mp); +void iochan_destroy(IOCHAN chan); -#define iochan_destroy(i) (void)((i)->destroyed = 1) #define iochan_getfd(i) ((i)->fd) +#define iochan_setfd(i, d) ((i)->fd = d) #define iochan_getdata(i) ((i)->data) #define iochan_setdata(i, d) ((i)->data = d) #define iochan_setflags(i, d) ((i)->flags = d) @@ -69,15 +67,9 @@ void iochan_man_destroy(iochan_man_t *mp); #define iochan_getflag(i, d) ((i)->flags & d ? 1 : 0) #define iochan_settimeout(i, t) ((i)->max_idle = (t), (i)->last_event = time(0)) #define iochan_activity(i) ((i)->last_event = time(0)) -#define iochan_setsocketfun(i, f) ((i)->socketfun = (f)) -#define iochan_getsocketfun(i) ((i)->socketfun) -#define iochan_setmaskfun(i, f) ((i)->maskfun = (f)) -#define iochan_getmaskfun(i) ((i)->maskfun) IOCHAN iochan_create(int fd, IOC_CALLBACK cb, int flags, const char *name); -void pazpar2_sleep(double d); - #endif /* * Local variables: