libowfat/io_internal.h

#include "io.h"
#include "array.h"
#ifdef __MINGW32__
#include "socket.h"
extern HANDLE io_comport;
#else
#include "haveepoll.h"
#include "havekqueue.h"
#include "havedevpoll.h"
#include "havesigio.h"
#ifdef HAVE_SIGIO
#define _GNU_SOURCE
#include <signal.h>
#endif
#endif

typedef struct {
  tai6464 timeout;
  unsigned int wantread:1;
  unsigned int wantwrite:1;
  unsigned int canread:1;
  unsigned int canwrite:1;
  unsigned int nonblock:1;
  unsigned int inuse:1;
#ifdef __MINGW32__
  unsigned int readqueued:2;
  unsigned int writequeued:2;
  unsigned int acceptqueued:2;
  unsigned int connectqueued:2;
  unsigned int sendfilequeued:2;
  unsigned int listened:1;
#endif
  long next_read;
  long next_write;
  void* cookie;
  void* mmapped;
  long maplen;
  uint64 mapofs;
#ifdef __MINGW32__
  OVERLAPPED or,ow,os;	/* overlapped for read+accept, write+connect, sendfile */
  HANDLE /* fd, */ mh;
  char inbuf[8192];
  int bytes_read,bytes_written;
  DWORD errorcode;
  SOCKET next_accept;
#endif
} io_entry;

extern array io_fds;
extern uint64 io_wanted_fds;
extern array io_pollfds;

extern long first_readable;
extern long first_writeable;

extern enum __io_waitmode {
  UNDECIDED,
  POLL
#ifdef HAVE_KQUEUE
  ,KQUEUE
#endif
#ifdef HAVE_EPOLL
  ,EPOLL
#endif
#ifdef HAVE_SIGIO
  ,_SIGIO
#endif
#ifdef HAVE_DEVPOLL
  ,DEVPOLL
#endif
#ifdef __MINGW32__
  ,COMPLETIONPORT
#endif
} io_waitmode;

#if defined(HAVE_KQUEUE) || defined(HAVE_EPOLL) || defined(HAVE_DEVPOLL)
extern int io_master;
#endif
#if defined(HAVE_SIGIO)
extern int io_signum;
extern sigset_t io_ss;

extern long alt_firstread;
extern long alt_firstwrite;
#endif

int64 io_waituntil2(int64 milliseconds);

void io_sigpipe(void);

#define debug_printf(x)
beginnings of the io library 2003-09-02 00:14:04 +00:00			`#include "io.h"`
			`#include "array.h"`
further Windoze support (test/io5.c works, gatling still doesn't) This is just to get gatling to work, I may remove it again after that. 2005-09-09 22:12:23 +00:00			`#ifdef __MINGW32__`
			`#include "socket.h"`
			`extern HANDLE io_comport;`
			`#else`
more kqueue/epoll 2003-09-06 01:15:00 +00:00			`#include "haveepoll.h"`
			`#include "havekqueue.h"`
broken lose32 port using mingw (don't use!!!) initial Solaris /dev/poll port 2003-11-06 20:47:59 +00:00			`#include "havedevpoll.h"`
add sigio support extend code to cope with edge triggered event notification add io_eagain() so that you can notify io_wait if accept() returned EAGAIN 2003-09-12 22:03:51 +00:00			`#include "havesigio.h"`
			`#ifdef HAVE_SIGIO`
			`#define _GNU_SOURCE`
			`#include <signal.h>`
			`#endif`
broken lose32 port using mingw (don't use!!!) initial Solaris /dev/poll port 2003-11-06 20:47:59 +00:00			`#endif`

beginnings of the io library 2003-09-02 00:14:04 +00:00			`typedef struct {`
duh one extra zero 2003-11-11 19:50:42 +00:00			`tai6464 timeout;`
beginnings of the io library 2003-09-02 00:14:04 +00:00			`unsigned int wantread:1;`
			`unsigned int wantwrite:1;`
			`unsigned int canread:1;`
			`unsigned int canwrite:1;`
			`unsigned int nonblock:1;`
			`unsigned int inuse:1;`
further Windoze support (test/io5.c works, gatling still doesn't) This is just to get gatling to work, I may remove it again after that. 2005-09-09 22:12:23 +00:00			`#ifdef __MINGW32__`
			`unsigned int readqueued:2;`
			`unsigned int writequeued:2;`
			`unsigned int acceptqueued:2;`
			`unsigned int connectqueued:2;`
			`unsigned int sendfilequeued:2;`
			`unsigned int listened:1;`
			`#endif`
write a small socket server with io_wait integration and add and debug io framework enough to support the test program 2003-09-05 22:59:40 +00:00			`long next_read;`
			`long next_write;`
add iob_adds add cookies to io 2003-09-10 00:28:51 +00:00			`void* cookie;`
use mmap on BSD without sendfile 2003-11-15 00:11:24 +00:00			`void* mmapped;`
			`long maplen;`
			`uint64 mapofs;`
broken lose32 port using mingw (don't use!!!) initial Solaris /dev/poll port 2003-11-06 20:47:59 +00:00			`#ifdef __MINGW32__`
further Windoze support (test/io5.c works, gatling still doesn't) This is just to get gatling to work, I may remove it again after that. 2005-09-09 22:12:23 +00:00			`OVERLAPPED or,ow,os; /* overlapped for read+accept, write+connect, sendfile */`
add iob_free and man page for iob_reset. check in some windoze compat crap (still does not compile through for windoze) 2005-03-08 14:56:36 +00:00			`HANDLE /* fd, */ mh;`
further Windoze support (test/io5.c works, gatling still doesn't) This is just to get gatling to work, I may remove it again after that. 2005-09-09 22:12:23 +00:00			`char inbuf[8192];`
			`int bytes_read,bytes_written;`
			`DWORD errorcode;`
			`SOCKET next_accept;`
broken lose32 port using mingw (don't use!!!) initial Solaris /dev/poll port 2003-11-06 20:47:59 +00:00			`#endif`
beginnings of the io library 2003-09-02 00:14:04 +00:00			`} io_entry;`

add sigio support extend code to cope with edge triggered event notification add io_eagain() so that you can notify io_wait if accept() returned EAGAIN 2003-09-12 22:03:51 +00:00			`extern array io_fds;`
			`extern uint64 io_wanted_fds;`
			`extern array io_pollfds;`
reverse return code for safemult API to conform to newer djb APIs 2003-09-05 21:25:51 +00:00
add sigio support extend code to cope with edge triggered event notification add io_eagain() so that you can notify io_wait if accept() returned EAGAIN 2003-09-12 22:03:51 +00:00			`extern long first_readable;`
			`extern long first_writeable;`
write a small socket server with io_wait integration and add and debug io framework enough to support the test program 2003-09-05 22:59:40 +00:00
explicitly define extern globals 2004-03-06 10:35:09 +00:00			`extern enum __io_waitmode {`
more kqueue/epoll 2003-09-06 01:15:00 +00:00			`UNDECIDED,`
			`POLL`
			`#ifdef HAVE_KQUEUE`
			`,KQUEUE`
			`#endif`
			`#ifdef HAVE_EPOLL`
			`,EPOLL`
			`#endif`
add sigio support extend code to cope with edge triggered event notification add io_eagain() so that you can notify io_wait if accept() returned EAGAIN 2003-09-12 22:03:51 +00:00			`#ifdef HAVE_SIGIO`
			`,_SIGIO`
			`#endif`
broken lose32 port using mingw (don't use!!!) initial Solaris /dev/poll port 2003-11-06 20:47:59 +00:00			`#ifdef HAVE_DEVPOLL`
			`,DEVPOLL`
			`#endif`
add -D_REENTRANT to CFLAGS so libowfat can be used in multi-threaded programs 2005-09-02 21:11:58 +00:00			`#ifdef __MINGW32__`
			`,COMPLETIONPORT`
			`#endif`
more kqueue/epoll 2003-09-06 01:15:00 +00:00			`} io_waitmode;`

broken lose32 port using mingw (don't use!!!) initial Solaris /dev/poll port 2003-11-06 20:47:59 +00:00			`#if defined(HAVE_KQUEUE) \|\| defined(HAVE_EPOLL) \|\| defined(HAVE_DEVPOLL)`
add sigio support extend code to cope with edge triggered event notification add io_eagain() so that you can notify io_wait if accept() returned EAGAIN 2003-09-12 22:03:51 +00:00			`extern int io_master;`
			`#endif`
			`#if defined(HAVE_SIGIO)`
			`extern int io_signum;`
			`extern sigset_t io_ss;`

			`extern long alt_firstread;`
			`extern long alt_firstwrite;`
more kqueue/epoll 2003-09-06 01:15:00 +00:00			`#endif`

reverse return code for safemult API to conform to newer djb APIs 2003-09-05 21:25:51 +00:00			`int64 io_waituntil2(int64 milliseconds);`
add sigio support extend code to cope with edge triggered event notification add io_eagain() so that you can notify io_wait if accept() returned EAGAIN 2003-09-12 22:03:51 +00:00
add some man pages 2004-02-27 17:04:02 +00:00			`void io_sigpipe(void);`

add sigio support extend code to cope with edge triggered event notification add io_eagain() so that you can notify io_wait if accept() returned EAGAIN 2003-09-12 22:03:51 +00:00			`#define debug_printf(x)`