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