Searched refs:wev (Results 1 - 25 of 37) sorted by relevance

12

/tldk/app/nginx/src/os/win32/
H A Dngx_wsasend.c19 ngx_event_t *wev; local
22 wev = c->write;
24 if (!wev->ready) {
45 wev->ready = 0;
57 wev->ready = 0;
61 wev->error = 1;
74 ngx_event_t *wev; local
78 wev = c->write;
80 if (!wev->ready) {
85 "wev
[all...]
H A Dngx_wsasend_chain.c23 ngx_event_t *wev; local
29 wev = c->write;
31 if (!wev->ready) {
105 wev->error = 1;
119 wev->ready = 0;
137 ngx_event_t *wev; local
144 wev = c->write;
146 if (!wev->ready) {
151 "wev->complete: %d", wev
[all...]
/tldk/app/nginx/src/os/unix/
H A Dngx_send.c18 ngx_event_t *wev; local
20 wev = c->write;
24 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) {
25 (void) ngx_connection_error(c, wev->kq_errno,
27 wev->error = 1;
41 wev->ready = 0;
53 wev->ready = 0;
58 wev->ready = 0;
68 wev->error = 1;
H A Dngx_udp_send.c18 ngx_event_t *wev; local
20 wev = c->write;
31 wev->error = 1;
44 wev->ready = 0;
51 wev->error = 1;
H A Dngx_darwin_sendfile_chain.c40 ngx_event_t *wev; local
47 wev = c->write;
49 if (!wev->ready) {
55 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) {
56 (void) ngx_connection_error(c, wev->kq_errno,
58 wev->error = 1;
150 wev->error = 1;
198 wev->ready = 0;
H A Dngx_writev_chain.c19 ngx_event_t *wev; local
23 wev = c->write;
25 if (!wev->ready) {
31 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) {
32 (void) ngx_connection_error(c, wev->kq_errno,
34 wev->error = 1;
96 wev->ready = 0;
H A Dngx_freebsd_sendfile_chain.c42 ngx_event_t *wev; local
53 wev = c->write;
55 if (!wev->ready) {
61 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) {
62 (void) ngx_connection_error(c, wev->kq_errno,
64 wev->error = 1;
147 wev->error = 1;
209 wev->error = 1;
315 wev->ready = 0;
325 wev
[all...]
H A Dngx_linux_sendfile_chain.c55 ngx_event_t *wev; local
60 wev = c->write;
62 if (!wev->ready) {
117 wev->error = 1;
142 wev->error = 1;
202 wev->ready = 0;
317 ngx_event_t *wev; local
339 wev = c->write;
346 * if wev->complete is set, this means that a write event
351 if (wev
[all...]
H A Dngx_solaris_sendfilev_chain.c54 ngx_event_t *wev; local
57 wev = c->write;
59 if (!wev->ready) {
178 wev->error = 1;
220 wev->ready = 0;
H A Dngx_udp_sendmsg_chain.c24 ngx_event_t *wev; local
28 wev = c->write;
30 if (!wev->ready) {
36 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) {
37 (void) ngx_connection_error(c, wev->kq_errno,
39 wev->error = 1;
98 wev->ready = 0;
H A Dngx_channel.c202 ngx_event_t *ev, *rev, *wev; local
214 wev = c->write;
217 wev->log = cycle->log;
220 wev->channel = 1;
222 ev = (event == NGX_READ_EVENT) ? rev : wev;
/tldk/app/nginx/src/event/
H A Dngx_event_connect.c31 ngx_event_t *rev, *wev; local
175 wev = c->write;
178 wev->log = pc->log;
246 wev->ready = 1;
270 wev->ready = 1;
296 if (ngx_add_event(wev, NGX_WRITE_EVENT, event) != NGX_OK) {
305 wev->ready = 1;
H A Dngx_event_acceptex.c97 ngx_event_t *rev, *wev; local
165 wev = c->write;
168 wev->ovlp.event = wev;
172 wev->ready = 1;
175 wev->log = c->log;
H A Dngx_event.c332 ngx_handle_write_event(ngx_event_t *wev, size_t lowat) argument
337 c = wev->data;
348 if (!wev->active && !wev->ready) {
349 if (ngx_add_event(wev, NGX_WRITE_EVENT,
363 if (!wev->active && !wev->ready) {
364 if (ngx_add_event(wev, NGX_WRITE_EVENT, NGX_LEVEL_EVENT)
373 if (wev->active && wev
571 ngx_event_t *rev, *wev; local
[all...]
H A Dngx_event_accept.c30 ngx_event_t *rev, *wev; local
231 wev = c->write;
233 wev->ready = 1;
247 wev->log = log;
327 ngx_event_t *rev, *wev; local
565 wev = c->write;
567 wev->ready = 1;
570 wev->log = log;
H A Dngx_event_openssl_stapling.c113 static void ngx_ssl_ocsp_write_handler(ngx_event_t *wev);
1066 ngx_ssl_ocsp_write_handler(ngx_event_t *wev) argument
1072 c = wev->data;
1075 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, wev->log, 0,
1078 if (wev->timedout) {
1079 ngx_log_error(NGX_LOG_ERR, wev->log, NGX_ETIMEDOUT,
1098 wev->handler = ngx_ssl_ocsp_dummy_handler;
1100 if (wev->timer_set) {
1101 ngx_del_timer(wev);
1104 if (ngx_handle_write_event(wev,
[all...]
H A Dngx_event_pipe.c27 ngx_event_t *rev, *wev; local
82 wev = p->downstream->write;
83 if (ngx_handle_write_event(wev, p->send_lowat) != NGX_OK) {
87 if (!wev->delayed) {
88 if (wev->active && !wev->ready) {
89 ngx_add_timer(wev, p->send_timeout);
91 } else if (wev->timer_set) {
92 ngx_del_timer(wev);
/tldk/app/nginx/src/tldk/
H A Dtldk_event.c80 ts->wev = ev;
113 ts->wev = NULL;
198 post_event(tt[i]->wev, &ngx_posted_events, flags, EV_SEND);
203 post_event(te[i]->wev, &ngx_posted_events, flags, EV_ERR);
H A Dtldk_sock.h61 ngx_event_t *wev; member in struct:tldk_sock
/tldk/app/nginx/src/event/modules/
H A Dngx_devpoll_module.c349 ngx_event_t *rev, *wev; local
516 wev = c->write;
518 if ((revents & POLLOUT) && wev->active) {
519 wev->ready = 1;
522 ngx_post_event(wev, &ngx_posted_events);
525 wev->handler(wev);
H A Dngx_eventport_module.c444 ngx_event_t *ev, *rev, *wev; local
555 wev = c->write;
558 wev->active = 0;
595 wev->ready = 1;
598 ngx_post_event(wev, &ngx_posted_events);
601 wev->handler(wev);
H A Dngx_epoll_module.c791 ngx_event_t *rev, *wev; local
906 wev = c->write;
908 if ((revents & EPOLLOUT) && wev->active) {
910 if (c->fd == -1 || wev->instance != instance) {
922 wev->ready = 1;
924 wev->complete = 1;
928 ngx_post_event(wev, &ngx_posted_events);
931 wev->handler(wev);
/tldk/app/nginx/src/http/v2/
H A Dngx_http_v2.c55 static void ngx_http_v2_write_handler(ngx_event_t *wev);
419 ngx_http_v2_write_handler(ngx_event_t *wev) argument
425 c = wev->data;
428 if (wev->timedout) {
440 if (wev->timer_set) {
441 ngx_del_timer(wev);
472 ngx_event_t *wev; local
483 wev = c->write;
485 if (!wev->ready) {
515 if (ngx_handle_write_event(wev, clc
2143 ngx_event_t *wev; local
2713 ngx_event_t *rev, *wev; local
4303 ngx_event_t *wev; local
[all...]
H A Dngx_http_v2_filter_module.c1343 ngx_event_t *wev; local
1356 wev = fc->write;
1358 wev->active = 0;
1359 wev->ready = 1;
1361 if (!fc->error && wev->delayed) {
1365 ngx_post_event(wev, &ngx_posted_events);
1375 ngx_event_t *wev; local
1426 wev = stream->request->connection->write;
1428 wev->active = 0;
1429 wev
[all...]
/tldk/app/nginx/src/core/
H A Dngx_connection.c1033 ngx_event_t *rev, *wev; local
1069 wev = c->write;
1074 c->write = wev;
1081 ngx_memzero(wev, sizeof(ngx_event_t));
1084 wev->instance = !instance;
1087 wev->index = NGX_INVALID_INDEX;
1090 wev->data = c;
1092 wev->write = 1;

Completed in 19 milliseconds

12