UNIXworkcode

/* * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. * * Copyright 2013 Olaf Wintermann. All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. */ #ifndef EVENT_H #define EVENT_H #include "../public/nsapi.h" #include <cx/string.h> #ifdef __cplusplus extern "C" { #endif #define EV_MAX_EVENTS 64 #define EV_IDLE_TIMEOUT 120 #define EV_IDLE_LOOP_CTN 16 typedef struct EVHandler { EventHandler **instances; uint32_t numins; uint32_t current; } EVHandler; typedef struct event_handler_conf { cxstring name; int nthreads; int isdefault; } EventHandlerConfig; typedef struct EVReturn { Session *sn; Request *rq; int ret; } EVReturn; typedef struct EVWatchList EVWatchList; typedef void(*evwatchlist_destroyfunc)(EventHandler *h, EVWatchList *item); struct EVWatchList { time_t created; time_t expire; evwatchlist_destroyfunc destroy; void *data1; void *data2; int intdata; EVWatchList *prev; EVWatchList *next; }; typedef struct EventHandler { /* * return call list */ EVReturn fnreturn[EV_MAX_EVENTS]; /* * number of fnreturn entries */ int numret; EVWatchList *watchlist_begin; EVWatchList *watchlist_end; } EventHandler; void shutdown_eventhandlers_wait(void); void evhandler_shutdown(EVHandler *h); void evhandler_close(EVHandler *h); void evhandler_wait_and_destroy(EVHandler *h); int create_event_handler(EventHandlerConfig *cfg); int check_event_handler_cfg(); EVHandler* get_default_event_handler(); EVHandler* get_event_handler(const char *name); EventHandler* ev_instance(EVHandler *ev); void watchlist_add(EVWatchList **begin, EVWatchList **end, EVWatchList *elm); void watchlist_remove(EVWatchList **begin, EVWatchList **end, EVWatchList *elm); void watchlist_check(EventHandler *h, time_t t); /* implementation in event_$platform */ EVHandler* evhandler_create(EventHandlerConfig *cfg); void ev_instance_close(EventHandler *h); void ev_instance_shutdown(EventHandler *h); void ev_instance_wait(EventHandler *h); int ev_pollin(EventHandler *h, int fd, Event *event); int ev_pollout(EventHandler *h, int fd, Event *event); int ev_remove_poll(EventHandler *h, int fd); int ev_send(EventHandler *h, Event *event); int ev_aioread(int fd, aiocb_s *cb); int ev_aiowrite(int fd, aiocb_s *cb); int ev_free_event(EventHandler *h, Event *event); void ev_saf_return(EventHandler *h, Session *sn, Request *rq, int ret); void ev_watchlist_add(EventHandler *h, EVWatchList *elm); void ev_watchlist_remove(EventHandler *h, EVWatchList *elm); #ifdef __cplusplus } #endif #endif /* EVENT_H */