| /third_party/nghttp2/src/ |
| D | shrpx_connection_handler.cc | 201 WorkerEvent wev{}; in worker_reopen_log_files() local
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() local
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() local
456 wev.type = WorkerEventType::GRACEFUL_SHUTDOWN; in graceful_shutdown_worker()
458 worker->send(std::move(wev)); in graceful_shutdown_worker()
[all …]
|
| D | shrpx_worker.cc | 455 WorkerEvent wev; in process_events() local
469 wev = std::move(q_.front()); in process_events()
479 switch (wev.type) { in process_events()
482 WLOG(INFO, this) << "WorkerEvent: client_fd=" << wev.client_fd in process_events()
483 << ", addrlen=" << wev.client_addrlen; in process_events()
492 close(wev.client_fd); in process_events()
498 tls::accept_connection(this, wev.client_fd, &wev.client_addr.sa, in process_events()
499 wev.client_addrlen, wev.faddr); in process_events()
504 close(wev.client_fd); in process_events()
537 replace_downstream_config(wev.downstreamconf); in process_events()
[all …]
|
| D | nghttp.cc | 615 ev_io_init(&wev, writecb, 0, EV_WRITE); in HttpClient()
618 wev.data = this; in HttpClient()
747 ev_io_set(&wev, fd, EV_WRITE); in initiate_connection()
749 ev_io_start(loop, &wev); in initiate_connection()
771 ev_io_stop(loop, &wev); in disconnect()
840 ev_io_start(loop, &wev); in write_clear()
850 ev_io_stop(loop, &wev); in write_clear()
888 ev_io_stop(loop, &wev); in connected()
1328 ev_io_stop(loop, &wev); in tls_handshake()
1332 ev_io_start(loop, &wev); in tls_handshake()
[all …]
|
| D | h2load.cc | 481 ev_io_init(&wev, writecb, 0, EV_WRITE);
484 wev.data = this;
643 ev_io_set(&wev, fd, EV_WRITE); in connect()
645 ev_io_start(worker->loop, &wev); in connect()
729 ev_io_stop(worker->loop, &wev); in disconnect()
1301 ev_io_start(worker->loop, &wev); in write_clear()
1310 ev_io_stop(worker->loop, &wev); in write_clear()
1320 ev_io_stop(worker->loop, &wev); in connected()
1350 ev_io_stop(worker->loop, &wev); in tls_handshake()
1353 ev_io_start(worker->loop, &wev); in tls_handshake()
[all …]
|
| 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()
|
| D | shrpx_connection.h | 171 ev_io wev; member
|
| D | shrpx_connection.cc | 69 wlimit(loop, &wev, write_limit.rate, write_limit.burst),
80 ev_io_init(&wev, writecb, fd, EV_WRITE);
83 wev.data = this;
|
| D | nghttp.h | 272 ev_io wev; member
|
| D | shrpx_http_downstream_connection.cc | 441 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
1552 ev_set_cb(&conn_.wev, writecb); in connected()
1583 ev_feed_event(conn_.loop, &conn_.wev, EV_WRITE); in actual_signal_write()
|
| 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()
|
| D | h2load.h | 335 ev_io wev; member
|
| D | shrpx_http3_upstream.cc | 1895 if (faddr->fd != conn->wev.fd) { in signal_write_upstream_addr()
1896 if (ev_is_active(&conn->wev)) { in signal_write_upstream_addr()
1897 ev_io_stop(handler_->get_loop(), &conn->wev); in signal_write_upstream_addr()
1900 ev_io_set(&conn->wev, faddr->fd, EV_WRITE); in signal_write_upstream_addr()
|
| D | shrpx_live_check.cc | 317 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
|
| D | h2load_quic.cc | 576 ev_io_stop(worker->loop, &wev); in write_quic()
|
| D | shrpx_client_handler.cc | 1253 ev_io *ClientHandler::get_wev() { return &conn_.wev; } in get_wev()
|