diff options
| author | Igor Sysoev <igor@sysoev.ru> | 2017-02-07 20:04:56 +0300 |
|---|---|---|
| committer | Igor Sysoev <igor@sysoev.ru> | 2017-02-07 20:04:56 +0300 |
| commit | 059a8642898a6bd4b47d13a1c1d599cd44af7e1c (patch) | |
| tree | e3c8c530a04f1ae44777d5ea4fd6901dc55a8ebf /src/nxt_fd_event.h | |
| parent | e57b95a92333fa7ff558737b0ba2b76894cc0412 (diff) | |
| download | unit-059a8642898a6bd4b47d13a1c1d599cd44af7e1c.tar.gz unit-059a8642898a6bd4b47d13a1c1d599cd44af7e1c.tar.bz2 | |
Event engines refactoring.
Diffstat (limited to '')
| -rw-r--r-- | src/nxt_fd_event.h (renamed from src/nxt_event_fd.h) | 50 |
1 files changed, 30 insertions, 20 deletions
diff --git a/src/nxt_event_fd.h b/src/nxt_fd_event.h index 20cb7a92..ff989394 100644 --- a/src/nxt_event_fd.h +++ b/src/nxt_fd_event.h @@ -4,8 +4,8 @@ * Copyright (C) NGINX, Inc. */ -#ifndef _NXT_EVENT_FD_H_INCLUDED_ -#define _NXT_EVENT_FD_H_INCLUDED_ +#ifndef _NXT_FD_EVENT_H_INCLUDED_ +#define _NXT_FD_EVENT_H_INCLUDED_ typedef enum { @@ -33,22 +33,28 @@ typedef enum { /* An active level-triggered event. Used by eventport. */ NXT_EVENT_LEVEL, - /* An active event. */ + /* + * An active default event. The event type depends on interface: + * edge-triggered for kqueue, and modern epoll; + * level-triggered for old epoll, devpoll, pollset, poll, and select; + * oneshot for kqueue and eventport. + */ NXT_EVENT_DEFAULT, -} nxt_event_fd_state_t; + NXT_EVENT_ACTIVE = NXT_EVENT_DEFAULT, +} nxt_fd_event_state_t; #define \ -nxt_event_fd_is_disabled(state) \ +nxt_fd_event_is_disabled(state) \ ((state) < NXT_EVENT_ONESHOT) #define \ -nxt_event_fd_is_active(state) \ +nxt_fd_event_is_active(state) \ ((state) >= NXT_EVENT_ONESHOT) -struct nxt_event_fd_s { +struct nxt_fd_event_s { void *data; /* Both are int's. */ @@ -58,12 +64,14 @@ struct nxt_event_fd_s { /* The flags should also be prefetched by nxt_work_queue_pop(). */ #if (NXT_64BIT) - uint8_t read; - uint8_t write; - uint8_t log_error; + nxt_fd_event_state_t read:8; /* 3 bits. */ + nxt_fd_event_state_t write:8; /* 3 bits. */ + nxt_socket_error_level_t log_error:8; /* 3 bits. */ uint8_t read_ready; uint8_t write_ready; + uint8_t changing; uint8_t closed; + uint8_t shutdown; uint8_t timedout; #if (NXT_HAVE_EPOLL) uint8_t epoll_eof:1; @@ -74,19 +82,21 @@ struct nxt_event_fd_s { #endif #else /* NXT_32BIT */ - nxt_event_fd_state_t read:3; - nxt_event_fd_state_t write:3; + nxt_fd_event_state_t read:3; + nxt_fd_event_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; + uint8_t read_ready:1; + uint8_t write_ready:1; + uint8_t changing:1; + uint8_t closed:1; + uint8_t shutdown:1; + uint8_t timedout:1; #if (NXT_HAVE_EPOLL) - unsigned epoll_eof:1; - unsigned epoll_error:1; + uint8_t epoll_eof:1; + uint8_t epoll_error:1; #endif #if (NXT_HAVE_KQUEUE) - unsigned kq_eof:1; + uint8_t kq_eof:1; #endif #endif /* NXT_64BIT */ @@ -109,4 +119,4 @@ struct nxt_event_fd_s { }; -#endif /* _NXT_EVENT_FD_H_INCLUDED_ */ +#endif /* _NXT_FD_EVENT_H_INCLUDED_ */ |