src/event/ngx_event.h - nginx - Git at Google

 #ifndef _NGX_EVENT_H_INCLUDED_
 #define _NGX_EVENT_H_INCLUDED_


 #include <ngx_config.h>
 #include <ngx_types.h>
 #include <ngx_time.h>
 #include <ngx_socket.h>
 #include <ngx_log.h>
 #include <ngx_alloc.h>
 #include <ngx_array.h>

 /* STUB */
 #define NGX_LOWAT   10000

 #define NGX_INVALID_INDEX  0x80000000

 typedef struct ngx_event_s       ngx_event_t;

 #if (HAVE_IOCP)
 typedef struct {
     WSAOVERLAPPED    ovlp;
     ngx_event_t     *event;
     int              error;
 } ngx_event_ovlp_t;
 #endif


 struct ngx_event_s {
     void            *data;

     int            (*event_handler)(ngx_event_t *ev);
     int            (*close_handler)(ngx_event_t *ev);
     void            *context;
     char            *action;

     unsigned int     index;

     ngx_event_t     *prev;     /* queue in mutex(), aio_read(), aio_write()  */
     ngx_event_t     *next;     /*                                            */

     int            (*timer_handler)(ngx_event_t *ev);
     ngx_event_t     *timer_prev;
     ngx_event_t     *timer_next;

     ngx_msec_t       timer_delta;
     ngx_msec_t       timer;

     ngx_log_t       *log;

     int              available; /* kqueue only:                              */
                                 /*   accept: number of sockets that wait     */
                                 /*           to be accepted                  */
                                 /*   read:   bytes to read                   */
                                 /*   write:  available space in buffer       */
                                 /* otherwise:                                */
                                 /*   accept: 1 if accept many, 0 otherwise   */

     unsigned         oneshot:1;

 #if 0
     unsigned         listening:1;
 #endif
     unsigned         write:1;

     unsigned         active:1;
     unsigned         ready:1;
     unsigned         timedout:1;
     unsigned         blocked:1;
     unsigned         timer_set:1;

     unsigned         process:1;
     unsigned         read_discarded:1;

     unsigned         unexpected_eof:1;

 #if (HAVE_DEFERRED_ACCEPT)
     unsigned         deferred_accept:1;
 #endif

 #if (HAVE_KQUEUE)
     unsigned         eof:1;
     int              error;
 #endif

 #if (HAVE_LOWAT_EVENT) /* kqueue's NOTE_LOWAT */
     int              lowat;
 #endif


 #if (HAVE_AIO)

 #if (HAVE_IOCP)
     ngx_event_ovlp_t ovlp;
 #else
     struct aiocb     aiocb;
 #endif

 #endif


 #if 0
     void            *thr_ctx;   /* event thread context if $(CC) doesn't
                                    understand __thread declaration
                                    and pthread_getspecific() is too costly */

 #if (NGX_EVENT_T_PADDING)
     int              padding[NGX_EVENT_T_PADDING];  /* event should not cross
                                                        cache line in SMP */
 #endif
 #endif
 };

 typedef enum {
     NGX_SELECT_EVENT_N = 0,
 #if (HAVE_POLL)
     NGX_POLL_EVENT_N,
 #endif
 #if (HAVE_DEVPOLL)
     NGX_DEVPOLL_EVENT_N,
 #endif
 #if (HAVE_KQUEUE)
     NGX_KQUEUE_EVENT_N,
 #endif
 #if (HAVE_AIO)
     NGX_AIO_EVENT_N,
 #endif
 #if (HAVE_IOCP)
     NGX_IOCP_EVENT_N,
 #endif
     NGX_DUMMY_EVENT_N    /* avoid comma at end of enumerator list */
 } ngx_event_type_e ;

 typedef struct {
     int  (*add)(ngx_event_t *ev, int event, u_int flags);
     int  (*del)(ngx_event_t *ev, int event, u_int flags);
     void (*timer)(ngx_event_t *ev, ngx_msec_t timer);
     int  (*process)(ngx_log_t *log);
     int  (*read)(ngx_event_t *ev, char *buf, size_t size);
 /*
     int  (*write)(ngx_event_t *ev, char *buf, size_t size);
 */
 } ngx_event_actions_t;


 /* Event filter requires to read/write the whole data -
    select, poll, /dev/poll, kqueue. */
 #define NGX_HAVE_LEVEL_EVENT    1

 /* Event filter is deleted after notification - select, poll, kqueue.
    Using /dev/poll, epoll it can be implemented with additional syscall */
 #define NGX_HAVE_ONESHOT_EVENT  2

 /* Event filter notifies only changes and initial level - kqueue */
 #define NGX_HAVE_CLEAR_EVENT    4

 /* Event filter has kqueue features - eof flag, errno, available data, etc */
 #define NGX_HAVE_KQUEUE_EVENT   8

 /* Event filter supports low water mark - kqueue's NOTE_LOWAT,
    early kqueue implementations have no NOTE_LOWAT so we need separate flag */
 #define NGX_HAVE_LOWAT_EVENT    16

 /* Event filter notifies only changes (edges) but not initial level - epoll */
 #define NGX_HAVE_EDGE_EVENT     32

 /* No need to add or delete event filters - rt signals */
 #define NGX_HAVE_SIGIO_EVENT    64

 /* No need to add or delete event filters - overlapped, aio_read, aioread */
 #define NGX_HAVE_AIO_EVENT      128

 /* Need to add socket or halde only once - i/o completion port.
    It also requires to set HAVE_AIO_EVENT and NGX_HAVE_AIO_EVENT */
 #define NGX_HAVE_IOCP_EVENT     256


 /* Event filter is deleted before closing file. Has no meaning
    for select, poll, epoll.

    kqueue:     kqueue deletes event filters for file that closed
                so we need only to delete filters in user-level batch array
    /dev/poll:  we need to flush POLLREMOVE event before closing file */
 #define NGX_CLOSE_EVENT         1


 #if (HAVE_KQUEUE)

 #define NGX_READ_EVENT     EVFILT_READ
 #define NGX_WRITE_EVENT    EVFILT_WRITE

 #define NGX_LEVEL_EVENT    0
 #define NGX_ONESHOT_EVENT  EV_ONESHOT

 #ifndef HAVE_CLEAR_EVENT
 #define HAVE_CLEAR_EVENT   1
 #endif

 #if (HAVE_CLEAR_EVENT)
 #define NGX_CLEAR_EVENT    EV_CLEAR
 #endif

 #elif (HAVE_POLL) || (HAVE_DEVPOLL)

 #define NGX_READ_EVENT     POLLIN
 #define NGX_WRITE_EVENT    POLLOUT

 #define NGX_LEVEL_EVENT    0
 #define NGX_ONESHOT_EVENT  1

 #else

 #define NGX_READ_EVENT     0
 #define NGX_WRITE_EVENT    1

 #define NGX_LEVEL_EVENT    0
 #define NGX_ONESHOT_EVENT  1

 #endif /* HAVE_KQUEUE */

 #if (USE_KQUEUE)

 #define ngx_init_events      ngx_kqueue_init
 #define ngx_process_events   ngx_kqueue_process_events
 #define ngx_add_event        ngx_kqueue_add_event
 #define ngx_del_event        ngx_kqueue_del_event
 #if 0
 #define ngx_add_timer        ngx_kqueue_add_timer
 #else
 #define ngx_add_timer        ngx_event_add_timer
 #endif
 #define ngx_event_recv       ngx_event_recv_core

 #else

 #define ngx_init_events     (ngx_event_init[ngx_event_type])
 #define ngx_process_events   ngx_event_actions.process
 #define ngx_add_event        ngx_event_actions.add
 #define ngx_del_event        ngx_event_actions.del

 #if 0
 #define ngx_add_timer        ngx_event_actions.timer
 #else
 #define ngx_add_timer        ngx_event_add_timer
 #endif

 #if (HAVE_IOCP_EVENT)
 #define ngx_event_recv       ngx_event_wsarecv
 #elif (HAVE_AIO_EVENT)
 #define ngx_event_recv       ngx_event_aio_read
 #else
 #define ngx_event_recv       ngx_event_recv_core
 #endif

 #endif

 #define ngx_del_timer        ngx_event_del_timer


 extern ngx_event_t          *ngx_read_events;
 extern ngx_event_t          *ngx_write_events;
 extern ngx_connection_t     *ngx_connections;

 #if !(USE_KQUEUE)
 extern ngx_event_actions_t   ngx_event_actions;
 extern ngx_event_type_e      ngx_event_type;
 extern int                   ngx_event_flags;
 #endif


 ssize_t ngx_event_recv_core(ngx_connection_t *c, char *buf, size_t size);
 int ngx_event_close_connection(ngx_event_t *ev);


 void ngx_pre_thread(ngx_array_t *ls, ngx_pool_t *pool, ngx_log_t *log);
 void ngx_worker(ngx_log_t *log);


 #endif /* _NGX_EVENT_H_INCLUDED_ */
	#ifndef _NGX_EVENT_H_INCLUDED_
	#define _NGX_EVENT_H_INCLUDED_


	#include <ngx_config.h>
	#include <ngx_types.h>
	#include <ngx_time.h>
	#include <ngx_socket.h>
	#include <ngx_log.h>
	#include <ngx_alloc.h>
	#include <ngx_array.h>

	/* STUB */
	#define NGX_LOWAT 10000

	#define NGX_INVALID_INDEX 0x80000000

	typedef struct ngx_event_s ngx_event_t;

	#if (HAVE_IOCP)
	typedef struct {
	WSAOVERLAPPED ovlp;
	ngx_event_t *event;
	int error;
	} ngx_event_ovlp_t;
	#endif


	struct ngx_event_s {
	void *data;

	int (event_handler)(ngx_event_t ev);
	int (close_handler)(ngx_event_t ev);
	void *context;
	char *action;

	unsigned int index;

	ngx_event_t prev; / queue in mutex(), aio_read(), aio_write() */
	ngx_event_t next; / */

	int (timer_handler)(ngx_event_t ev);
	ngx_event_t *timer_prev;
	ngx_event_t *timer_next;

	ngx_msec_t timer_delta;
	ngx_msec_t timer;

	ngx_log_t *log;

	int available; /* kqueue only: */
	/* accept: number of sockets that wait */
	/* to be accepted */
	/* read: bytes to read */
	/* write: available space in buffer */
	/* otherwise: */
	/* accept: 1 if accept many, 0 otherwise */

	unsigned oneshot:1;

	#if 0
	unsigned listening:1;
	#endif
	unsigned write:1;

	unsigned active:1;
	unsigned ready:1;
	unsigned timedout:1;
	unsigned blocked:1;
	unsigned timer_set:1;

	unsigned process:1;
	unsigned read_discarded:1;

	unsigned unexpected_eof:1;

	#if (HAVE_DEFERRED_ACCEPT)
	unsigned deferred_accept:1;
	#endif

	#if (HAVE_KQUEUE)
	unsigned eof:1;
	int error;
	#endif

	#if (HAVE_LOWAT_EVENT) /* kqueue's NOTE_LOWAT */
	int lowat;
	#endif


	#if (HAVE_AIO)

	#if (HAVE_IOCP)
	ngx_event_ovlp_t ovlp;
	#else
	struct aiocb aiocb;
	#endif

	#endif


	#if 0
	void thr_ctx; / event thread context if $(CC) doesn't
	understand __thread declaration
	and pthread_getspecific() is too costly */

	#if (NGX_EVENT_T_PADDING)
	int padding[NGX_EVENT_T_PADDING]; /* event should not cross
	cache line in SMP */
	#endif
	#endif
	};

	typedef enum {
	NGX_SELECT_EVENT_N = 0,
	#if (HAVE_POLL)
	NGX_POLL_EVENT_N,
	#endif
	#if (HAVE_DEVPOLL)
	NGX_DEVPOLL_EVENT_N,
	#endif
	#if (HAVE_KQUEUE)
	NGX_KQUEUE_EVENT_N,
	#endif
	#if (HAVE_AIO)
	NGX_AIO_EVENT_N,
	#endif
	#if (HAVE_IOCP)
	NGX_IOCP_EVENT_N,
	#endif
	NGX_DUMMY_EVENT_N /* avoid comma at end of enumerator list */
	} ngx_event_type_e ;

	typedef struct {
	int (add)(ngx_event_t ev, int event, u_int flags);
	int (del)(ngx_event_t ev, int event, u_int flags);
	void (timer)(ngx_event_t ev, ngx_msec_t timer);
	int (process)(ngx_log_t log);
	int (read)(ngx_event_t ev, char *buf, size_t size);
	/*
	int (write)(ngx_event_t ev, char *buf, size_t size);
	*/
	} ngx_event_actions_t;


	/* Event filter requires to read/write the whole data -
	select, poll, /dev/poll, kqueue. */
	#define NGX_HAVE_LEVEL_EVENT 1

	/* Event filter is deleted after notification - select, poll, kqueue.
	Using /dev/poll, epoll it can be implemented with additional syscall */
	#define NGX_HAVE_ONESHOT_EVENT 2

	/* Event filter notifies only changes and initial level - kqueue */
	#define NGX_HAVE_CLEAR_EVENT 4

	/* Event filter has kqueue features - eof flag, errno, available data, etc */
	#define NGX_HAVE_KQUEUE_EVENT 8

	/* Event filter supports low water mark - kqueue's NOTE_LOWAT,
	early kqueue implementations have no NOTE_LOWAT so we need separate flag */
	#define NGX_HAVE_LOWAT_EVENT 16

	/* Event filter notifies only changes (edges) but not initial level - epoll */
	#define NGX_HAVE_EDGE_EVENT 32

	/* No need to add or delete event filters - rt signals */
	#define NGX_HAVE_SIGIO_EVENT 64

	/* No need to add or delete event filters - overlapped, aio_read, aioread */
	#define NGX_HAVE_AIO_EVENT 128

	/* Need to add socket or halde only once - i/o completion port.
	It also requires to set HAVE_AIO_EVENT and NGX_HAVE_AIO_EVENT */
	#define NGX_HAVE_IOCP_EVENT 256


	/* Event filter is deleted before closing file. Has no meaning
	for select, poll, epoll.

	kqueue: kqueue deletes event filters for file that closed
	so we need only to delete filters in user-level batch array
	/dev/poll: we need to flush POLLREMOVE event before closing file */
	#define NGX_CLOSE_EVENT 1


	#if (HAVE_KQUEUE)

	#define NGX_READ_EVENT EVFILT_READ
	#define NGX_WRITE_EVENT EVFILT_WRITE

	#define NGX_LEVEL_EVENT 0
	#define NGX_ONESHOT_EVENT EV_ONESHOT

	#ifndef HAVE_CLEAR_EVENT
	#define HAVE_CLEAR_EVENT 1
	#endif

	#if (HAVE_CLEAR_EVENT)
	#define NGX_CLEAR_EVENT EV_CLEAR
	#endif

	#elif (HAVE_POLL) \|\| (HAVE_DEVPOLL)

	#define NGX_READ_EVENT POLLIN
	#define NGX_WRITE_EVENT POLLOUT

	#define NGX_LEVEL_EVENT 0
	#define NGX_ONESHOT_EVENT 1

	#else

	#define NGX_READ_EVENT 0
	#define NGX_WRITE_EVENT 1

	#define NGX_LEVEL_EVENT 0
	#define NGX_ONESHOT_EVENT 1

	#endif /* HAVE_KQUEUE */

	#if (USE_KQUEUE)

	#define ngx_init_events ngx_kqueue_init
	#define ngx_process_events ngx_kqueue_process_events
	#define ngx_add_event ngx_kqueue_add_event
	#define ngx_del_event ngx_kqueue_del_event
	#if 0
	#define ngx_add_timer ngx_kqueue_add_timer
	#else
	#define ngx_add_timer ngx_event_add_timer
	#endif
	#define ngx_event_recv ngx_event_recv_core

	#else

	#define ngx_init_events (ngx_event_init[ngx_event_type])
	#define ngx_process_events ngx_event_actions.process
	#define ngx_add_event ngx_event_actions.add
	#define ngx_del_event ngx_event_actions.del

	#if 0
	#define ngx_add_timer ngx_event_actions.timer
	#else
	#define ngx_add_timer ngx_event_add_timer
	#endif

	#if (HAVE_IOCP_EVENT)
	#define ngx_event_recv ngx_event_wsarecv
	#elif (HAVE_AIO_EVENT)
	#define ngx_event_recv ngx_event_aio_read
	#else
	#define ngx_event_recv ngx_event_recv_core
	#endif

	#endif

	#define ngx_del_timer ngx_event_del_timer



	extern ngx_event_t *ngx_read_events;
	extern ngx_event_t *ngx_write_events;
	extern ngx_connection_t *ngx_connections;

	#if !(USE_KQUEUE)
	extern ngx_event_actions_t ngx_event_actions;
	extern ngx_event_type_e ngx_event_type;
	extern int ngx_event_flags;
	#endif


	ssize_t ngx_event_recv_core(ngx_connection_t c, char buf, size_t size);
	int ngx_event_close_connection(ngx_event_t *ev);


	void ngx_pre_thread(ngx_array_t ls, ngx_pool_t pool, ngx_log_t *log);
	void ngx_worker(ngx_log_t *log);


	#endif /* _NGX_EVENT_H_INCLUDED_ */