Lines Matching refs:ConnectionHandler
58 auto h = static_cast<ConnectionHandler *>(w->data); in acceptor_disable_cb()
72 auto h = static_cast<ConnectionHandler *>(w->data); in ocsp_cb()
87 auto h = static_cast<ConnectionHandler *>(w->data); in ocsp_read_cb()
95 auto h = static_cast<ConnectionHandler *>(w->data); in ocsp_chld_cb()
109 auto h = static_cast<ConnectionHandler *>(w->data); in serial_event_async_cb()
115 ConnectionHandler::ConnectionHandler(struct ev_loop *loop, std::mt19937 &gen) in ConnectionHandler() function in shrpx::ConnectionHandler
156 ConnectionHandler::~ConnectionHandler() { in ~ConnectionHandler()
192 void ConnectionHandler::set_ticket_keys_to_worker( in set_ticket_keys_to_worker()
199 void ConnectionHandler::worker_reopen_log_files() { in worker_reopen_log_files()
209 void ConnectionHandler::worker_replace_downstream( in worker_replace_downstream()
221 int ConnectionHandler::create_single_worker() { in create_single_worker()
309 int ConnectionHandler::create_worker_thread(size_t num) { in create_worker_thread()
426 void ConnectionHandler::join_worker() { in join_worker()
445 void ConnectionHandler::graceful_shutdown_worker() { in graceful_shutdown_worker()
473 int ConnectionHandler::handle_connection(int fd, sockaddr *addr, int addrlen, in handle_connection()
546 struct ev_loop *ConnectionHandler::get_loop() const { in get_loop()
550 Worker *ConnectionHandler::get_single_worker() const { in get_single_worker()
554 void ConnectionHandler::add_acceptor(std::unique_ptr<AcceptHandler> h) { in add_acceptor()
558 void ConnectionHandler::delete_acceptor() { acceptors_.clear(); } in delete_acceptor()
560 void ConnectionHandler::enable_acceptor() { in enable_acceptor()
566 void ConnectionHandler::disable_acceptor() { in disable_acceptor()
572 void ConnectionHandler::sleep_acceptor(ev_tstamp t) { in sleep_acceptor()
583 void ConnectionHandler::accept_pending_connection() { in accept_pending_connection()
589 void ConnectionHandler::set_ticket_keys( in set_ticket_keys()
597 const std::shared_ptr<TicketKeys> &ConnectionHandler::get_ticket_keys() const { in get_ticket_keys()
601 void ConnectionHandler::set_graceful_shutdown(bool f) { in set_graceful_shutdown()
608 bool ConnectionHandler::get_graceful_shutdown() const { in get_graceful_shutdown()
612 void ConnectionHandler::cancel_ocsp_update() { in cancel_ocsp_update()
641 int ConnectionHandler::start_ocsp_update(const char *cert_file) { in start_ocsp_update()
673 void ConnectionHandler::read_ocsp_chunk() { in read_ocsp_chunk()
702 void ConnectionHandler::handle_ocsp_complete() { in handle_ocsp_complete()
783 void ConnectionHandler::reset_ocsp() { in reset_ocsp()
794 void ConnectionHandler::proceed_next_cert_ocsp() { in proceed_next_cert_ocsp()
833 void ConnectionHandler::set_tls_ticket_key_memcached_dispatcher( in set_tls_ticket_key_memcached_dispatcher()
839 ConnectionHandler::get_tls_ticket_key_memcached_dispatcher() const { in get_tls_ticket_key_memcached_dispatcher()
851 void ConnectionHandler::on_tls_ticket_key_network_error(ev_timer *w) { in on_tls_ticket_key_network_error()
877 void ConnectionHandler::on_tls_ticket_key_not_found(ev_timer *w) { in on_tls_ticket_key_not_found()
894 void ConnectionHandler::on_tls_ticket_key_get_success( in on_tls_ticket_key_get_success()
924 void ConnectionHandler::schedule_next_tls_ticket_key_memcached_get( in schedule_next_tls_ticket_key_memcached_get()
930 SSL_CTX *ConnectionHandler::create_tls_ticket_key_memcached_ssl_ctx() { in create_tls_ticket_key_memcached_ssl_ctx()
951 void ConnectionHandler::set_neverbleed(neverbleed_t *nb) { nb_ = nb; } in set_neverbleed()
954 void ConnectionHandler::handle_serial_event() { in handle_serial_event()
983 void ConnectionHandler::send_replace_downstream( in send_replace_downstream()
989 void ConnectionHandler::send_serial_event(SerialEvent ev) { in send_serial_event()
999 SSL_CTX *ConnectionHandler::get_ssl_ctx(size_t idx) const { in get_ssl_ctx()
1004 ConnectionHandler::get_indexed_ssl_ctx(size_t idx) const { in get_indexed_ssl_ctx()
1010 ConnectionHandler::get_quic_indexed_ssl_ctx(size_t idx) const { in get_quic_indexed_ssl_ctx()
1015 void ConnectionHandler::set_enable_acceptor_on_ocsp_completion(bool f) { in set_enable_acceptor_on_ocsp_completion()
1020 int ConnectionHandler::forward_quic_packet( in forward_quic_packet()
1045 void ConnectionHandler::set_quic_keying_materials( in set_quic_keying_materials()
1051 ConnectionHandler::get_quic_keying_materials() const { in get_quic_keying_materials()
1055 void ConnectionHandler::set_cid_prefixes( in set_cid_prefixes()
1062 ConnectionHandler::match_quic_lingering_worker_process_cid_prefix( in match_quic_lingering_worker_process_cid_prefix()
1078 std::vector<BPFRef> &ConnectionHandler::get_quic_bpf_refs() { in get_quic_bpf_refs()
1082 void ConnectionHandler::unload_bpf_objects() { in unload_bpf_objects()
1097 void ConnectionHandler::set_quic_ipc_fd(int fd) { quic_ipc_fd_ = fd; } in set_quic_ipc_fd()
1099 void ConnectionHandler::set_quic_lingering_worker_processes( in set_quic_lingering_worker_processes()
1104 int ConnectionHandler::forward_quic_packet_to_lingering_worker_process( in forward_quic_packet_to_lingering_worker_process()
1159 int ConnectionHandler::quic_ipc_read() { in quic_ipc_read()