root/src/eventer/eventer.h

/*
 * Copyright (c) 2007, OmniTI Computer Consulting, Inc.
 * All rights reserved.
 */

#ifndef _EVENTER_EVENTER_H
#define _EVENTER_EVENTER_H

#include "noit_defines.h"
#include <sys/time.h>
#include <sys/socket.h>

#define EVENTER_READ       0x01
#define EVENTER_WRITE      0x02
#define EVENTER_EXCEPTION  0x04
#define EVENTER_TIMER      0x08

/* All of these functions act like their POSIX couterparts with two
 * additional arguments.  The first is the mask they require o be active
 * to make progress in the event of an EAGAIN.  The second is a closure
 * which is the event itself.
 */
typedef int (*eventer_fd_accept_t)
            (int, struct sockaddr *, socklen_t *, int *mask, void *closure);
typedef int (*eventer_fd_read_t)
            (int, void *, size_t, int *mask, void *closure);
typedef int (*eventer_fd_write_t)
            (int, const void *, size_t, int *mask, void *closure);
typedef int (*eventer_fd_close_t)
            (int, int *mask, void *closure);

typedef struct _fd_opset {
  eventer_fd_accept_t accept;
  eventer_fd_read_t   read;
  eventer_fd_write_t  write;
  eventer_fd_close_t  close;
} *eventer_fd_opset_t;

typedef struct _event *eventer_t;
typedef int (*eventer_func_t)
            (eventer_t e, int mask, void *closure, struct timeval *tv);

struct _event {
  eventer_func_t      callback;
  struct timeval      whence;
  int                 fd;
  int                 mask;
  eventer_fd_opset_t  opset;
  void *closure;
};

API_EXPORT(eventer_t) eventer_alloc();
API_EXPORT(void)      eventer_free(eventer_t);
API_EXPORT(int)       eventer_timecompare(void *a, void *b);

typedef struct _eventer_impl {
  const char         *name;
  int               (*init)();
  int               (*propset)(const char *key, const char *value);
  void              (*add)(eventer_t e);
  void              (*remove)(eventer_t e);
  void              (*update)(eventer_t e);
  eventer_t         (*remove_fd)(int fd);
  int               (*loop)();
} *eventer_impl_t;

/* This is the "chosen one" */
extern eventer_impl_t __eventer;

API_EXPORT(int) eventer_choose(const char *name);

#define eventer_propset       __eventer->propset
#define eventer_init          __eventer->init
#define eventer_add           __eventer->add
#define eventer_remove        __eventer->remove
#define eventer_update        __eventer->update
#define eventer_remove_fd     __eventer->remove_fd
#define eventer_attach        __eventer->attach
#define eventer_loop          __eventer->loop

#endif