| /third_party/nghttp2/src/ |
| H A D | shrpx_connection_handler.cc | 201 WorkerEvent wev{}; in worker_reopen_log_files()
203 wev.type = WorkerEventType::REOPEN_LOG; in worker_reopen_log_files()
205 worker->send(std::move(wev)); in worker_reopen_log_files()
212 WorkerEvent wev{}; in worker_replace_downstream()
214 wev.type = WorkerEventType::REPLACE_DOWNSTREAM; in worker_replace_downstream()
215 wev.downstreamconf = downstreamconf; in worker_replace_downstream()
217 worker->send(std::move(wev)); in worker_replace_downstream()
455 WorkerEvent wev{}; in graceful_shutdown_worker()
456 wev.type = WorkerEventType::GRACEFUL_SHUTDOWN; in graceful_shutdown_worker()
458 worker->send(std::move(wev)); in graceful_shutdown_worker()
[all...] |
| H A D | shrpx_worker.cc | 456 WorkerEvent wev; in process_events() local
470 wev = std::move(q_.front()); in process_events()
480 switch (wev.type) { in process_events()
483 WLOG(INFO, this) << "WorkerEvent: client_fd=" << wev.client_fd in process_events()
484 << ", addrlen=" << wev.client_addrlen; in process_events()
493 close(wev.client_fd); in process_events()
499 tls::accept_connection(this, wev.client_fd, &wev.client_addr.sa, in process_events()
500 wev.client_addrlen, wev in process_events()
[all...] |
| H A D | h2load.cc | 482 ev_io_init(&wev, writecb, 0, EV_WRITE);
485 wev.data = this;
652 ev_io_set(&wev, fd, EV_WRITE); in connect()
654 ev_io_start(worker->loop, &wev); in connect()
738 ev_io_stop(worker->loop, &wev); in disconnect()
1310 ev_io_start(worker->loop, &wev); in write_clear()
1319 ev_io_stop(worker->loop, &wev); in write_clear()
1329 ev_io_stop(worker->loop, &wev); in connected()
1359 ev_io_stop(worker->loop, &wev); in tls_handshake()
1362 ev_io_start(worker->loop, &wev); in tls_handshake()
[all...] |
| H A D | nghttp.cc | 614 ev_io_init(&wev, writecb, 0, EV_WRITE); in HttpClient()
617 wev.data = this; in HttpClient()
746 ev_io_set(&wev, fd, EV_WRITE); in initiate_connection()
748 ev_io_start(loop, &wev); in initiate_connection()
770 ev_io_stop(loop, &wev); in disconnect()
839 ev_io_start(loop, &wev); in write_clear()
849 ev_io_stop(loop, &wev); in write_clear()
887 ev_io_stop(loop, &wev); in connected()
1327 ev_io_stop(loop, &wev); in tls_handshake()
1331 ev_io_start(loop, &wev); in tls_handshake()
[all...] |
| H A D | shrpx_memcached_connection.cc | 202 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
205 ev_set_cb(&conn_.wev, connectcb); in initiate_connection()
233 ev_set_cb(&conn_.wev, writecb); in connected()
|
| H A D | shrpx_connection.h | 171 ev_io wev; member
|
| H A D | shrpx_connection.cc | 70 wlimit(loop, &wev, write_limit.rate, write_limit.burst),
80 ev_io_init(&wev, writecb, fd, EV_WRITE); in read_timeout()
83 wev.data = this; in read_timeout()
|
| H A D | nghttp.h | 272 ev_io wev; member
|
| H A D | h2load.h | 335 ev_io wev; member
|
| H A D | shrpx_http_downstream_connection.cc | 441 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
1567 ev_set_cb(&conn_.wev, writecb); in connected()
1598 ev_feed_event(conn_.loop, &conn_.wev, EV_WRITE); in actual_signal_write()
|
| H A D | shrpx_http2_session.cc | 425 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
545 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
609 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
1841 ev_io *Http2Session::get_wev() { return &conn_.wev; } in get_wev()
|
| H A D | shrpx_live_check.cc | 317 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
|
| H A D | shrpx_http3_upstream.cc | 1936 if (faddr->fd != conn->wev.fd) { in signal_write_upstream_addr()
1937 if (ev_is_active(&conn->wev)) { in signal_write_upstream_addr()
1938 ev_io_stop(handler_->get_loop(), &conn->wev); in signal_write_upstream_addr()
1941 ev_io_set(&conn->wev, faddr->fd, EV_WRITE); in signal_write_upstream_addr()
|
| H A D | h2load_quic.cc | 631 ev_io_stop(worker->loop, &wev); in write_quic()
|
| H A D | shrpx_client_handler.cc | 1253 ev_io *ClientHandler::get_wev() { return &conn_.wev; } in get_wev()
|