nginx: src/event/ngx_event.h comparison

comparison src/event/ngx_event.h @ 144:ef8c87afcfc5

nginx-0.0.1-2003-10-12-20:49:16 import

author	Igor Sysoev <igor@sysoev.ru>
date	Sun, 12 Oct 2003 16:49:16 +0000
parents	5526213be452
children	fb61ba77beba

comparison

equal deleted inserted replaced

-:5526213be452
+:ef8c87afcfc5
 struct ngx_event_s {
 void            *data;
 void           (*event_handler)(ngx_event_t *ev);
-#if 0
-int            (*close_handler)(ngx_event_t *ev);
-#endif
 void            *context;
 char            *action;
 unsigned int     index;
 ngx_event_t     *prev;     /* queue in mutex(), aio_read(), aio_write()  */
 ngx_event_t     *next;     /*                                            */
-#if 0
-int            (*timer_handler)(ngx_event_t *ev);
-#endif
 ngx_event_t     *timer_prev;
 ngx_event_t     *timer_next;
 ngx_msec_t       timer_delta;
 ngx_msec_t       timer;
 #if 0
 unsigned         listening:1;
 #endif
 unsigned         write:1;
-unsigned         instance:1;  /* used to detect stale events in kqueue,
+/* used to detect stale events in kqueue, rt signals and epoll */
-rt signals and epoll */
+unsigned         instance:1;
+/*
+* event was passed or would be passed to a kernel;
+* the posted aio operation.
+*/
 unsigned         active:1;
+/* ready event; the complete aio operation */
 unsigned         ready:1;
 unsigned         timedout:1;
+unsigned         timer_set:1;
+#if 1
 unsigned         blocked:1;
-unsigned         timer_set:1;
+#endif
 unsigned         delayed:1;
-unsigned         process:1;
 unsigned         read_discarded:1;
 unsigned         ignore_econnreset:1;
 unsigned         unexpected_eof:1;
 int   (*init)(ngx_cycle_t *cycle);
 void  (*done)(ngx_cycle_t *cycle);
 } ngx_event_actions_t;
-/* The event filter requires to read/write the whole data -
+/*
-select, poll, /dev/poll, kqueue. */
+* The event filter requires to read/write the whole data -
-#define NGX_HAVE_LEVEL_EVENT    0x00000001
+* select, poll, /dev/poll, kqueue.
+*/
-/* The event filter is deleted after a notification without an additional
+#define NGX_USE_LEVEL_EVENT    0x00000001
-syscall - select, poll, kqueue.  */
-#define NGX_HAVE_ONESHOT_EVENT  0x00000002
+/*
+* The event filter is deleted after a notification without an additional
-/* The event filter notifies only the changes and an initial level - kqueue */
+* syscall - select, poll, kqueue.
-#define NGX_HAVE_CLEAR_EVENT    0x00000004
+*/
+#define NGX_USE_ONESHOT_EVENT  0x00000002
-/* The event filter has kqueue features - the eof flag, errno,
-available data, etc */
+/*
-#define NGX_HAVE_KQUEUE_EVENT   0x00000008
+*  The event filter notifies only the changes and an initial level - kqueue.
+*/
-/* The event filter supports low water mark - kqueue's NOTE_LOWAT.
+#define NGX_USE_CLEAR_EVENT    0x00000004
-kqueue in FreeBSD 4.1-4.2 has no NOTE_LOWAT so we need a separate flag */
-#define NGX_HAVE_LOWAT_EVENT    0x00000010
+/*
+* The event filter has kqueue features - the eof flag, errno,
-/* The event filter notifies only the changes (the edges)
+* available data, etc
-but not an initial level - epoll */
+*/
-#define NGX_HAVE_EDGE_EVENT     0x00000020
+#define NGX_HAVE_KQUEUE_EVENT  0x00000008
-/* No need to add or delete the event filters - rt signals */
+/*
-#define NGX_HAVE_SIGIO_EVENT    0x00000040
+* The event filter supports low water mark - kqueue's NOTE_LOWAT.
+* kqueue in FreeBSD 4.1-4.2 has no NOTE_LOWAT so we need a separate flag.
-/* No need to add or delete the event filters - overlapped, aio_read, aioread */
+*/
-#define NGX_HAVE_AIO_EVENT      0x00000080
+#define NGX_HAVE_LOWAT_EVENT   0x00000010
-/* Need to add socket or handle only once - i/o completion port.
+/*
-It also requires HAVE_AIO_EVENT and NGX_HAVE_AIO_EVENT to be set */
+* The event filter notifies only the changes (the edges)
-#define NGX_HAVE_IOCP_EVENT     0x00000100
+* but not an initial level - epoll.
+*/
+#define NGX_USE_EDGE_EVENT     0x00000020
-#define NGX_USE_LEVEL_EVENT     0x00010000
-#define NGX_USE_AIO_EVENT       0x00020000
+/*
+* No need to add or delete the event filters - rt signals.
+*/
-/* Event filter is deleted before closing file.
+#define NGX_USE_SIGIO_EVENT    0x00000040
-Has no meaning for select, poll, epoll.
+/*
-kqueue:     kqueue deletes event filters for file that closed
+* No need to add or delete the event filters - overlapped, aio_read,
-so we need only to delete filters in user-level batch array
+* aioread, io_submit.
-/dev/poll:  we need to flush POLLREMOVE event before closing file */
+*/
+#define NGX_USE_AIO_EVENT      0x00000080
+/*
+* Need to add socket or handle only once - i/o completion port.
+* It also requires HAVE_AIO_EVENT and NGX_HAVE_AIO_EVENT to be set.
+*/
+#define NGX_USE_IOCP_EVENT     0x00000100
+/*
+* The event filter is deleted before the 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
-/* NGX_CLOSE_EVENT is the module flag and it would not go into a kernel
+/*
-so we need to choose the value that would not interfere with any existent
+* NGX_CLOSE_EVENT is the module flag and it would not go into a kernel
-and future flags. kqueue has such values - EV_FLAG1, EV_EOF and EV_ERROR.
+* so we need to choose the value that would not interfere with any existent
-They are reserved and cleared on a kernel entrance */
+* and future flags.  kqueue has such values - EV_FLAG1, EV_EOF and EV_ERROR.
+* They are reserved and cleared on a kernel entrance.
+*/
 #undef  NGX_CLOSE_EVENT
 #define NGX_CLOSE_EVENT    EV_FLAG1
 #define NGX_LEVEL_EVENT    0
 #define NGX_ONESHOT_EVENT  EV_ONESHOT
 ngx_inline static int ngx_handle_read_event(ngx_event_t *rev)
 {
-if (ngx_event_flags & (NGX_HAVE_AIO_EVENT|NGX_HAVE_EDGE_EVENT)) {
+if (ngx_event_flags & (NGX_USE_AIO_EVENT|NGX_USE_EDGE_EVENT)) {
 /* aio, iocp, epoll */
 return NGX_OK;
 }
-if (ngx_event_flags & NGX_HAVE_CLEAR_EVENT) {
+if (ngx_event_flags & NGX_USE_CLEAR_EVENT) {
 /* kqueue */
 if (!rev->active && !rev->ready) {
 if (ngx_add_event(rev, NGX_READ_EVENT, NGX_CLEAR_EVENT)
 return NGX_OK;
 }
+ngx_inline static int ngx_handle_level_read_event(ngx_event_t *rev)
+{
+if (ngx_event_flags & NGX_USE_LEVEL_EVENT) {
+if (!rev->active && !rev->ready) {
+if (ngx_add_event(rev, NGX_READ_EVENT, NGX_LEVEL_EVENT)
+== NGX_ERROR) {
+return NGX_ERROR;
+}
+return NGX_OK;
+}
+if (rev->active && rev->ready) {
+if (ngx_del_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) {
+return NGX_ERROR;
+}
+return NGX_OK;
+}
+}
+return NGX_OK;
+}
 ngx_inline static int ngx_handle_write_event(ngx_event_t *wev, int lowat)
 {
-if (ngx_event_flags & (NGX_HAVE_AIO_EVENT|NGX_HAVE_EDGE_EVENT)) {
+if (ngx_event_flags & (NGX_USE_AIO_EVENT|NGX_USE_EDGE_EVENT)) {
 /* aio, iocp, epoll */
 return NGX_OK;
 }
-if (ngx_event_flags & NGX_HAVE_CLEAR_EVENT) {
+if (ngx_event_flags & NGX_USE_CLEAR_EVENT) {
 /* kqueue */
 #if (HAVE_LOWAT_EVENT) /* kqueue's NOTE_LOWAT */
 return NGX_OK;
 }
+ngx_inline static int ngx_handle_level_write_event(ngx_event_t *wev)
+{
+if (ngx_event_flags & NGX_USE_LEVEL_EVENT) {
+if (!wev->active && !wev->ready) {
+if (ngx_add_event(wev, NGX_WRITE_EVENT, NGX_LEVEL_EVENT)
+== NGX_ERROR) {
+return NGX_ERROR;
+}
+return NGX_OK;
+}
+if (wev->active && wev->ready) {
+if (ngx_del_event(wev, NGX_WRITE_EVENT, 0) == NGX_ERROR) {
+return NGX_ERROR;
+}
+return NGX_OK;
+}
+}
+return NGX_OK;
+}
 /* ***************************** */
 #endif /* _NGX_EVENT_H_INCLUDED_ */

Mercurial > hg > nginx

comparison src/event/ngx_event.h @ 144:ef8c87afcfc5