diff options
Diffstat (limited to '')
| -rw-r--r-- | src/nxt_event_fd.h | 110 |
1 files changed, 110 insertions, 0 deletions
diff --git a/src/nxt_event_fd.h b/src/nxt_event_fd.h new file mode 100644 index 00000000..dd8d1c20 --- /dev/null +++ b/src/nxt_event_fd.h @@ -0,0 +1,110 @@ + +/* + * Copyright (C) Igor Sysoev + * Copyright (C) NGINX, Inc. + */ + +#ifndef _NXT_EVENT_FD_H_INCLUDED_ +#define _NXT_EVENT_FD_H_INCLUDED_ + + +typedef enum { + /* A completely inactive event. */ + NXT_EVENT_INACTIVE = 0, + + /* + * An event presents in the kernel but disabled after oneshot. + * Used by epoll. + */ + NXT_EVENT_DISABLED, + + /* + * An event is active in the kernel but blocked by application. + * Used by kqueue, epoll, eventport, devpoll, and pollset. + */ + NXT_EVENT_BLOCKED, + + /* + * An active oneshot event. + * Used by epoll, devpoll, pollset, poll, and select. + */ + NXT_EVENT_ONESHOT, + + /* An active level-triggered event. Used by eventport. */ + NXT_EVENT_LEVEL, + + /* An active event. */ + NXT_EVENT_DEFAULT, +} nxt_event_fd_state_t; + + +#define \ +nxt_event_fd_is_disabled(state) \ + ((state) < NXT_EVENT_ONESHOT) + + +#define \ +nxt_event_fd_is_active(state) \ + ((state) >= NXT_EVENT_ONESHOT) + + +struct nxt_event_fd_s { + void *data; + + /* Both are int's. */ + nxt_socket_t fd; + nxt_err_t error; + + /* The flags should also be prefetched by nxt_work_queue_pop(). */ + +#if (NXT_64BIT) + uint8_t read; + uint8_t write; + uint8_t log_error; + uint8_t read_ready; + uint8_t write_ready; + uint8_t closed; + uint8_t timedout; +#if (NXT_HAVE_EPOLL) + uint8_t epoll_eof:1; + uint8_t epoll_error:1; +#endif +#if (NXT_HAVE_KQUEUE) + uint8_t kq_eof; +#endif + +#else /* NXT_32BIT */ + nxt_event_fd_state_t read:3; + nxt_event_fd_state_t write:3; + nxt_socket_error_level_t log_error:3; + unsigned read_ready:1; + unsigned write_ready:1; + unsigned closed:1; + unsigned timedout:1; +#if (NXT_HAVE_EPOLL) + unsigned epoll_eof:1; + unsigned epoll_error:1; +#endif +#if (NXT_HAVE_KQUEUE) + unsigned kq_eof:1; +#endif +#endif /* NXT_64BIT */ + +#if (NXT_HAVE_KQUEUE) + /* nxt_err_t is int. */ + nxt_err_t kq_errno; + /* struct kevent.data is intptr_t, however int32_t is enough. */ + int32_t kq_available; +#endif + + nxt_work_queue_t *read_work_queue; + nxt_work_handler_t read_handler; + nxt_work_queue_t *write_work_queue; + nxt_work_handler_t write_handler; + nxt_work_handler_t error_handler; + + nxt_log_t *log; +}; + + +#endif /* _NXT_EVENT_FD_H_INCLUDED_ */ |