Lines Matching defs:conn_handler
108 void graceful_shutdown(ConnectionHandler *conn_handler) {
109 if (conn_handler->get_graceful_shutdown()) {
115 conn_handler->set_graceful_shutdown(true);
119 conn_handler->accept_pending_connection();
120 conn_handler->delete_acceptor();
122 conn_handler->graceful_shutdown_worker();
124 auto single_worker = conn_handler->get_single_worker();
129 ev_break(conn_handler->get_loop());
138 void reopen_log(ConnectionHandler *conn_handler) {
147 conn_handler->worker_reopen_log_files();
153 auto conn_handler = static_cast<ConnectionHandler *>(w->data);
173 graceful_shutdown(conn_handler);
176 reopen_log(conn_handler);
186 auto conn_handler = static_cast<ConnectionHandler *>(w->data);
188 if (conn_handler->quic_ipc_read() != 0) {
223 auto conn_handler = static_cast<ConnectionHandler *>(w->data);
224 const auto &old_ticket_keys = conn_handler->get_ticket_keys();
262 conn_handler->set_ticket_keys(nullptr);
263 conn_handler->set_ticket_keys_to_worker(nullptr);
278 conn_handler->set_ticket_keys(ticket_keys);
279 conn_handler->set_ticket_keys_to_worker(ticket_keys);
286 auto conn_handler = static_cast<ConnectionHandler *>(w->data);
287 auto dispatcher = conn_handler->get_tls_ticket_key_memcached_dispatcher();
292 req->cb = [conn_handler, w](MemcachedRequest *req, MemcachedResult res) {
297 conn_handler->on_tls_ticket_key_network_error(w);
300 conn_handler->on_tls_ticket_key_not_found(w);
311 conn_handler->on_tls_ticket_key_not_found(w);
319 conn_handler->on_tls_ticket_key_not_found(w);
348 conn_handler->on_tls_ticket_key_not_found(w);
356 conn_handler->on_tls_ticket_key_not_found(w);
362 conn_handler->on_tls_ticket_key_not_found(w);
382 conn_handler->on_tls_ticket_key_get_success(ticket_keys, w);
470 auto conn_handler = std::make_unique<ConnectionHandler>(loop, gen);
473 conn_handler->set_neverbleed(nb.get());
477 conn_handler->set_quic_ipc_fd(wpconf->quic_ipc_fd);
478 conn_handler->set_quic_lingering_worker_processes(
483 conn_handler->add_acceptor(
484 std::make_unique<AcceptHandler>(&addr, conn_handler.get()));
498 ssl_ctx = conn_handler->create_tls_ticket_key_memcached_ssl_ctx();
501 conn_handler->set_tls_ticket_key_memcached_dispatcher(
508 renew_ticket_key_timer.data = conn_handler.get();
528 conn_handler->set_ticket_keys(std::move(ticket_keys));
535 renew_ticket_key_timer.data = conn_handler.get();
588 conn_handler->set_quic_keying_materials(std::move(qkms));
590 conn_handler->set_cid_prefixes(wpconf->cid_prefixes);
591 conn_handler->set_quic_lingering_worker_processes(
596 rv = conn_handler->create_single_worker();
614 rv = conn_handler->create_worker_thread(config->num_worker);
630 conn_handler->unload_bpf_objects();
641 ipcev.data = conn_handler.get();
647 quic_ipcev.data = conn_handler.get();
653 conn_handler->set_enable_acceptor_on_ocsp_completion(true);
654 conn_handler->disable_acceptor();
657 conn_handler->proceed_next_cert_ocsp();
670 conn_handler->cancel_ocsp_update();
672 // Destroy SSL_CTX held in conn_handler before killing neverbleed
675 conn_handler.reset();