| /f-stack/app/nginx-1.16.1/src/event/ |
| H A D | ngx_event.h | 325 #define NGX_READ_EVENT EVFILT_READ macro
358 #define NGX_READ_EVENT POLLIN macro
367 #define NGX_READ_EVENT (EPOLLIN|EPOLLRDHUP) macro
383 #define NGX_READ_EVENT POLLIN macro
392 #define NGX_READ_EVENT 0 macro
|
| H A D | ngx_event.c | 305 if (ngx_add_event(rev, NGX_READ_EVENT, NGX_CLEAR_EVENT) in ngx_handle_read_event()
319 if (ngx_add_event(rev, NGX_READ_EVENT, NGX_LEVEL_EVENT) in ngx_handle_read_event()
329 if (ngx_del_event(rev, NGX_READ_EVENT, NGX_LEVEL_EVENT | flags) in ngx_handle_read_event()
343 if (ngx_add_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { in ngx_handle_read_event()
351 if (ngx_del_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { in ngx_handle_read_event()
875 if (ngx_del_event(old->read, NGX_READ_EVENT, NGX_CLOSE_EVENT) in ngx_event_process_init()
916 if (ngx_add_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { in ngx_event_process_init()
929 if (ngx_add_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { in ngx_event_process_init()
947 if (ngx_add_event(rev, NGX_READ_EVENT, NGX_EXCLUSIVE_EVENT) in ngx_event_process_init()
958 if (ngx_add_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { in ngx_event_process_init()
|
| H A D | ngx_event_accept.c | 380 if (ngx_add_event(c->read, NGX_READ_EVENT, 0) == NGX_ERROR) {
418 if (ngx_del_event(c->read, NGX_READ_EVENT, NGX_DISABLE_EVENT)
|
| H A D | ngx_event_connect.c | 321 if (ngx_add_event(rev, NGX_READ_EVENT, event) != NGX_OK) {
|
| /f-stack/app/nginx-1.16.1/src/event/modules/ |
| H A D | ngx_poll_module.c | 129 if (event == NGX_READ_EVENT) { in ngx_poll_add_event()
131 #if (NGX_READ_EVENT != POLLIN) in ngx_poll_add_event()
182 if (event == NGX_READ_EVENT) { in ngx_poll_del_event()
184 #if (NGX_READ_EVENT != POLLIN) in ngx_poll_del_event()
|
| H A D | ngx_win32_select_module.c | 143 if ((event == NGX_READ_EVENT && ev->write) in ngx_select_add_event()
152 if ((event == NGX_READ_EVENT && max_read >= FD_SETSIZE) in ngx_select_add_event()
161 if (event == NGX_READ_EVENT) { in ngx_select_add_event()
197 if (event == NGX_READ_EVENT) { in ngx_select_del_event()
|
| H A D | ngx_win32_poll_module.c | 148 if (event == NGX_READ_EVENT) { in ngx_poll_add_event()
150 #if (NGX_READ_EVENT != POLLIN) in ngx_poll_add_event()
204 if (event == NGX_READ_EVENT) { in ngx_poll_del_event()
206 #if (NGX_READ_EVENT != POLLIN) in ngx_poll_del_event()
|
| H A D | ngx_devpoll_module.c | 224 #if (NGX_READ_EVENT != POLLIN) in ngx_devpoll_add_event()
225 event = (event == NGX_READ_EVENT) ? POLLIN : POLLOUT; in ngx_devpoll_add_event()
248 #if (NGX_READ_EVENT != POLLIN) in ngx_devpoll_del_event()
249 event = (event == NGX_READ_EVENT) ? POLLIN : POLLOUT; in ngx_devpoll_del_event()
|
| H A D | ngx_select_module.c | 142 if ((event == NGX_READ_EVENT && ev->write) in ngx_select_add_event()
151 if (event == NGX_READ_EVENT) { in ngx_select_add_event()
189 if (event == NGX_READ_EVENT) { in ngx_select_del_event()
|
| H A D | ngx_ff_host_event_module.c | 160 if (event == NGX_READ_EVENT) { in ngx_ff_epoll_add_event()
163 #if (NGX_READ_EVENT != EPOLLIN|EPOLLRDHUP) in ngx_ff_epoll_add_event()
227 if (event == NGX_READ_EVENT) { in ngx_ff_epoll_del_event()
|
| H A D | ngx_eventport_module.c | 322 if (event == NGX_READ_EVENT) { in ngx_eventport_add_event()
325 #if (NGX_READ_EVENT != POLLIN) in ngx_eventport_add_event()
380 if (event == NGX_READ_EVENT) { in ngx_eventport_del_event()
|
| H A D | ngx_epoll_module.c | 591 if (event == NGX_READ_EVENT) { in ngx_epoll_add_event()
594 #if (NGX_READ_EVENT != EPOLLIN|EPOLLRDHUP) in ngx_epoll_add_event()
664 if (event == NGX_READ_EVENT) { in ngx_epoll_del_event()
|
| /f-stack/app/nginx-1.16.1/src/os/unix/ |
| H A D | ngx_channel.c | 226 ev = (event == NGX_READ_EVENT) ? rev : wev;
|
| H A D | ngx_process_cycle.c | 1224 if (ngx_add_channel_event(cycle, ngx_channel, NGX_READ_EVENT, in ngx_worker_process_init()
1335 if (ngx_add_event(ev, NGX_READ_EVENT, 0) == NGX_ERROR) { in ngx_channel_handler()
|
| /f-stack/app/nginx-1.16.1/src/core/ |
| H A D | ngx_connection.c | 1114 ngx_del_event(c->read, NGX_READ_EVENT, 0); in ngx_close_listening_sockets()
1117 ngx_del_event(c->read, NGX_READ_EVENT, NGX_CLOSE_EVENT); in ngx_close_listening_sockets()
1282 ngx_del_event(c->read, NGX_READ_EVENT, NGX_CLOSE_EVENT);
|
| H A D | ngx_resolver.c | 4468 if (ngx_add_event(rev, NGX_READ_EVENT, event) != NGX_OK) { in ngx_udp_connect()
4644 if (ngx_add_event(rev, NGX_READ_EVENT, event) != NGX_OK) {
|
| /f-stack/app/nginx-1.16.1/src/http/ |
| H A D | ngx_http_request.c | 2865 if (ngx_del_event(r->connection->read, NGX_READ_EVENT, 0) != NGX_OK) { in ngx_http_block_reading()
2971 if (ngx_del_event(rev, NGX_READ_EVENT, 0) != NGX_OK) { in ngx_http_test_reading()
|
| H A D | ngx_http_upstream.c | 1331 event = ev->write ? NGX_WRITE_EVENT : NGX_READ_EVENT; in ngx_http_upstream_check_broken_connection()
1458 event = ev->write ? NGX_WRITE_EVENT : NGX_READ_EVENT; in ngx_http_upstream_check_broken_connection()
|