Initial version.

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_ */