/*
 * 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_task_t              *task;

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