X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Feventl.h;h=515b7f290ff8a505f0dda575d358c300fcecc0ae;hb=37ae4386bd764d62ae43c68df1560be55ff813ca;hp=d565f2f67d5d695947b638bdfd9e6249e8af76b4;hpb=7dbedc4526cc8ec05c785a91b5b0dfae85791579;p=pazpar2-moved-to-github.git diff --git a/src/eventl.h b/src/eventl.h index d565f2f..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; @@ -38,10 +36,7 @@ typedef struct iochan #define EVENT_OUTPUT 0x02 #define EVENT_EXCEPT 0x04 #define EVENT_TIMEOUT 0x08 - int force_event; IOC_CALLBACK fun; - IOC_SOCKETFUN socketfun; - IOC_MASKFUN maskfun; void *data; int destroyed; time_t last_event; @@ -52,29 +47,26 @@ 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) #define iochan_setflag(i, d) ((i)->flags |= d) #define iochan_clearflag(i, d) ((i)->flags &= ~(d)) #define iochan_getflag(i, d) ((i)->flags & d ? 1 : 0) -#define iochan_setevent(i, e) ((i)->force_event = (e)) #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);