Home
last modified time | relevance | path

Searched refs:wev (Results 1 – 25 of 36) sorted by relevance

12

/f-stack/app/nginx-1.16.1/src/os/unix/
H A Dngx_send.c18 ngx_event_t *wev; in ngx_unix_send() local
20 wev = c->write; in ngx_unix_send()
24 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) { in ngx_unix_send()
25 (void) ngx_connection_error(c, wev->kq_errno, in ngx_unix_send()
27 wev->error = 1; in ngx_unix_send()
41 wev->ready = 0; in ngx_unix_send()
53 wev->ready = 0; in ngx_unix_send()
58 wev->ready = 0; in ngx_unix_send()
68 wev->error = 1; in ngx_unix_send()
H A Dngx_udp_send.c18 ngx_event_t *wev; in ngx_udp_unix_send() local
20 wev = c->write; in ngx_udp_unix_send()
31 wev->error = 1; in ngx_udp_unix_send()
44 wev->ready = 0; in ngx_udp_unix_send()
51 wev->error = 1; in ngx_udp_unix_send()
H A Dngx_freebsd_sendfile_chain.c42 ngx_event_t *wev; in ngx_freebsd_sendfile_chain() local
53 wev = c->write; in ngx_freebsd_sendfile_chain()
55 if (!wev->ready) { in ngx_freebsd_sendfile_chain()
61 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) { in ngx_freebsd_sendfile_chain()
62 (void) ngx_connection_error(c, wev->kq_errno, in ngx_freebsd_sendfile_chain()
64 wev->error = 1; in ngx_freebsd_sendfile_chain()
147 wev->error = 1; in ngx_freebsd_sendfile_chain()
209 wev->error = 1; in ngx_freebsd_sendfile_chain()
315 wev->ready = 0; in ngx_freebsd_sendfile_chain()
325 wev->ready = 0; in ngx_freebsd_sendfile_chain()
H A Dngx_darwin_sendfile_chain.c40 ngx_event_t *wev; in ngx_darwin_sendfile_chain() local
47 wev = c->write; in ngx_darwin_sendfile_chain()
49 if (!wev->ready) { in ngx_darwin_sendfile_chain()
55 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) { in ngx_darwin_sendfile_chain()
56 (void) ngx_connection_error(c, wev->kq_errno, in ngx_darwin_sendfile_chain()
58 wev->error = 1; in ngx_darwin_sendfile_chain()
150 wev->error = 1; in ngx_darwin_sendfile_chain()
198 wev->ready = 0; in ngx_darwin_sendfile_chain()
H A Dngx_linux_sendfile_chain.c55 ngx_event_t *wev; in ngx_linux_sendfile_chain() local
60 wev = c->write; in ngx_linux_sendfile_chain()
62 if (!wev->ready) { in ngx_linux_sendfile_chain()
117 wev->error = 1; in ngx_linux_sendfile_chain()
142 wev->error = 1; in ngx_linux_sendfile_chain()
202 wev->ready = 0; in ngx_linux_sendfile_chain()
317 ngx_event_t *wev; in ngx_linux_sendfile_thread() local
339 wev = c->write; in ngx_linux_sendfile_thread()
351 if (wev->complete) { in ngx_linux_sendfile_thread()
359 wev->error = 1; in ngx_linux_sendfile_thread()
[all …]
H A Dngx_writev_chain.c19 ngx_event_t *wev; in ngx_writev_chain() local
23 wev = c->write; in ngx_writev_chain()
25 if (!wev->ready) { in ngx_writev_chain()
31 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) { in ngx_writev_chain()
32 (void) ngx_connection_error(c, wev->kq_errno, in ngx_writev_chain()
34 wev->error = 1; in ngx_writev_chain()
96 wev->ready = 0; in ngx_writev_chain()
H A Dngx_channel.c202 ngx_event_t *ev, *rev, *wev; local
214 wev = c->write;
217 rev->belong_to_host = wev->belong_to_host = 1;
221 wev->log = cycle->log;
224 wev->channel = 1;
226 ev = (event == NGX_READ_EVENT) ? rev : wev;
H A Dngx_udp_sendmsg_chain.c24 ngx_event_t *wev; in ngx_udp_unix_sendmsg_chain() local
28 wev = c->write; in ngx_udp_unix_sendmsg_chain()
30 if (!wev->ready) { in ngx_udp_unix_sendmsg_chain()
36 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) { in ngx_udp_unix_sendmsg_chain()
37 (void) ngx_connection_error(c, wev->kq_errno, in ngx_udp_unix_sendmsg_chain()
39 wev->error = 1; in ngx_udp_unix_sendmsg_chain()
98 wev->ready = 0; in ngx_udp_unix_sendmsg_chain()
H A Dngx_solaris_sendfilev_chain.c54 ngx_event_t *wev; in ngx_solaris_sendfilev_chain() local
57 wev = c->write; in ngx_solaris_sendfilev_chain()
59 if (!wev->ready) { in ngx_solaris_sendfilev_chain()
178 wev->error = 1; in ngx_solaris_sendfilev_chain()
220 wev->ready = 0; in ngx_solaris_sendfilev_chain()
/f-stack/app/redis-5.0.5/deps/hiredis/adapters/
H A Dlibevent.h39 struct event *rev, *wev; member
66 event_add(e->wev,NULL); in redisLibeventAddWrite()
71 event_del(e->wev); in redisLibeventDelWrite()
77 event_del(e->wev); in redisLibeventCleanup()
103 e->wev = event_new(base, c->fd, EV_WRITE, redisLibeventWriteEvent, e); in redisLibeventAttach()
105 event_add(e->wev, NULL); in redisLibeventAttach()
H A Dlibev.h43 ev_io rev, wev; member
92 ev_io_start(EV_A_ &e->wev); in redisLibevAddWrite()
102 ev_io_stop(EV_A_ &e->wev); in redisLibevDelWrite()
131 e->wev.data = e; in redisLibevAttach()
143 ev_io_init(&e->wev,redisLibevWriteEvent,c->fd,EV_WRITE); in redisLibevAttach()
/f-stack/app/nginx-1.16.1/src/event/modules/
H A Dngx_ff_host_event_module.c332 ngx_event_t *rev, *wev; in ngx_ff_epoll_process_events() local
414 wev = c->write; in ngx_ff_epoll_process_events()
416 if ((revents & EPOLLOUT) && wev->active) { in ngx_ff_epoll_process_events()
418 if (c->fd == -1 || wev->instance != instance) { in ngx_ff_epoll_process_events()
430 wev->ready = 1; in ngx_ff_epoll_process_events()
432 wev->complete = 1; in ngx_ff_epoll_process_events()
434 wev->handler(wev); in ngx_ff_epoll_process_events()
H A Dngx_devpoll_module.c349 ngx_event_t *rev, *wev; in ngx_devpoll_process_events() local
516 wev = c->write; in ngx_devpoll_process_events()
518 if ((revents & POLLOUT) && wev->active) { in ngx_devpoll_process_events()
519 wev->ready = 1; in ngx_devpoll_process_events()
522 ngx_post_event(wev, &ngx_posted_events); in ngx_devpoll_process_events()
525 wev->handler(wev); in ngx_devpoll_process_events()
H A Dngx_eventport_module.c444 ngx_event_t *ev, *rev, *wev; in ngx_eventport_process_events() local
555 wev = c->write; in ngx_eventport_process_events()
558 wev->active = 0; in ngx_eventport_process_events()
595 wev->ready = 1; in ngx_eventport_process_events()
598 ngx_post_event(wev, &ngx_posted_events); in ngx_eventport_process_events()
601 wev->handler(wev); in ngx_eventport_process_events()
H A Dngx_epoll_module.c791 ngx_event_t *rev, *wev; in ngx_epoll_process_events() local
906 wev = c->write; in ngx_epoll_process_events()
908 if ((revents & EPOLLOUT) && wev->active) { in ngx_epoll_process_events()
910 if (c->fd == -1 || wev->instance != instance) { in ngx_epoll_process_events()
922 wev->ready = 1; in ngx_epoll_process_events()
924 wev->complete = 1; in ngx_epoll_process_events()
928 ngx_post_event(wev, &ngx_posted_events); in ngx_epoll_process_events()
931 wev->handler(wev); in ngx_epoll_process_events()
/f-stack/app/nginx-1.16.1/src/event/
H A Dngx_event.c366 ngx_handle_write_event(ngx_event_t *wev, size_t lowat) in ngx_handle_write_event() argument
371 c = wev->data; in ngx_handle_write_event()
382 if (!wev->active && !wev->ready) { in ngx_handle_write_event()
383 if (ngx_add_event(wev, NGX_WRITE_EVENT, in ngx_handle_write_event()
397 if (!wev->active && !wev->ready) { in ngx_handle_write_event()
407 if (wev->active && wev->ready) { in ngx_handle_write_event()
421 if (!wev->active && !wev->ready) { in ngx_handle_write_event()
429 if (wev->oneshot && wev->ready) { in ngx_handle_write_event()
654 ngx_event_t *rev, *wev; in ngx_event_process_init() local
805 wev = cycle->write_events; in ngx_event_process_init()
[all …]
H A Dngx_event_connect.c31 ngx_event_t *rev, *wev; local
199 wev = c->write;
202 wev->log = pc->log;
279 wev->ready = 1;
303 wev->ready = 1;
329 if (ngx_add_event(wev, NGX_WRITE_EVENT, event) != NGX_OK) {
338 wev->ready = 1;
H A Dngx_event_accept.c25 ngx_event_t *rev, *wev; local
230 wev = c->write;
233 rev->belong_to_host = wev->belong_to_host = ev->belong_to_host;
236 wev->ready = 1;
250 wev->log = log;
H A Dngx_event_pipe.c27 ngx_event_t *rev, *wev; in ngx_event_pipe() local
82 wev = p->downstream->write; in ngx_event_pipe()
83 if (ngx_handle_write_event(wev, p->send_lowat) != NGX_OK) { in ngx_event_pipe()
87 if (!wev->delayed) { in ngx_event_pipe()
88 if (wev->active && !wev->ready) { in ngx_event_pipe()
89 ngx_add_timer(wev, p->send_timeout); in ngx_event_pipe()
91 } else if (wev->timer_set) { in ngx_event_pipe()
92 ngx_del_timer(wev); in ngx_event_pipe()
H A Dngx_event_openssl_stapling.c113 static void ngx_ssl_ocsp_write_handler(ngx_event_t *wev);
1071 ngx_ssl_ocsp_write_handler(ngx_event_t *wev) in ngx_ssl_ocsp_write_handler() argument
1077 c = wev->data; in ngx_ssl_ocsp_write_handler()
1080 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, wev->log, 0, in ngx_ssl_ocsp_write_handler()
1083 if (wev->timedout) { in ngx_ssl_ocsp_write_handler()
1084 ngx_log_error(NGX_LOG_ERR, wev->log, NGX_ETIMEDOUT, in ngx_ssl_ocsp_write_handler()
1103 wev->handler = ngx_ssl_ocsp_dummy_handler; in ngx_ssl_ocsp_write_handler()
1105 if (wev->timer_set) { in ngx_ssl_ocsp_write_handler()
1106 ngx_del_timer(wev); in ngx_ssl_ocsp_write_handler()
1117 if (!wev->timer_set) { in ngx_ssl_ocsp_write_handler()
[all …]
H A Dngx_event_udp.c39 ngx_event_t *rev, *wev; in ngx_event_recvmsg() local
347 wev = c->write; in ngx_event_recvmsg()
350 wev->ready = 1; in ngx_event_recvmsg()
353 wev->log = log; in ngx_event_recvmsg()
/f-stack/app/nginx-1.16.1/src/http/
H A Dngx_http_request.c2741 ngx_event_t *wev; in ngx_http_set_write_handler() local
2751 wev = r->connection->write; in ngx_http_set_write_handler()
2753 if (wev->ready && wev->delayed) { in ngx_http_set_write_handler()
2758 if (!wev->delayed) { in ngx_http_set_write_handler()
2780 wev = c->write; in ngx_http_writer()
2787 if (wev->timedout) { in ngx_http_writer()
2796 if (wev->delayed || r->aio) { in ngx_http_writer()
2800 if (!wev->delayed) { in ngx_http_writer()
2824 if (!wev->delayed) { in ngx_http_writer()
3078 wev = c->write; in ngx_http_set_keepalive()
[all …]
/f-stack/app/nginx-1.16.1/src/http/v2/
H A Dngx_http_v2.c455 c = wev->data; in ngx_http_v2_write_handler()
458 if (wev->timedout) { in ngx_http_v2_write_handler()
513 wev = c->write; in ngx_http_v2_send_output_queue()
515 if (!wev->ready) { in ngx_http_v2_send_output_queue()
590 if (!wev->ready) { in ngx_http_v2_send_output_queue()
2329 wev->handler(wev); in ngx_http_v2_state_window_update()
2361 wev->ready = 1; in ngx_http_v2_state_window_update()
2364 wev->handler(wev); in ngx_http_v2_state_window_update()
3063 wev->write = 1; in ngx_http_v2_create_stream()
3069 fc->write = wev; in ngx_http_v2_create_stream()
[all …]
/f-stack/app/nginx-1.16.1/src/mail/
H A Dngx_mail_auth_http_module.c63 static void ngx_mail_auth_http_write_handler(ngx_event_t *wev);
236 ngx_mail_auth_http_write_handler(ngx_event_t *wev) in ngx_mail_auth_http_write_handler() argument
244 c = wev->data; in ngx_mail_auth_http_write_handler()
249 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, wev->log, 0, in ngx_mail_auth_http_write_handler()
252 if (wev->timedout) { in ngx_mail_auth_http_write_handler()
253 ngx_log_error(NGX_LOG_ERR, wev->log, NGX_ETIMEDOUT, in ngx_mail_auth_http_write_handler()
278 if (wev->timer_set) { in ngx_mail_auth_http_write_handler()
279 ngx_del_timer(wev); in ngx_mail_auth_http_write_handler()
282 if (ngx_handle_write_event(wev, 0) != NGX_OK) { in ngx_mail_auth_http_write_handler()
292 if (!wev->timer_set) { in ngx_mail_auth_http_write_handler()
[all …]
/f-stack/app/nginx-1.16.1/src/core/
H A Dngx_connection.c1170 ngx_event_t *rev, *wev; in ngx_get_connection() local
1206 wev = c->write; in ngx_get_connection()
1211 c->write = wev; in ngx_get_connection()
1218 ngx_memzero(wev, sizeof(ngx_event_t)); in ngx_get_connection()
1221 wev->instance = !instance; in ngx_get_connection()
1224 wev->index = NGX_INVALID_INDEX; in ngx_get_connection()
1227 wev->data = c; in ngx_get_connection()
1229 wev->write = 1; in ngx_get_connection()
1232 rev->belong_to_host = wev->belong_to_host = is_fstack_fd(s) ? 0 : 1; in ngx_get_connection()

12