Lines Matching refs:Worker
63 auto worker = static_cast<Worker *>(w->data);
70 auto worker = static_cast<Worker *>(w->data);
83 auto worker = static_cast<Worker *>(w->data);
146 Worker::Worker(struct ev_loop *loop, SSL_CTX *sv_ssl_ctx, SSL_CTX *cl_ssl_ctx,
243 void Worker::replace_downstream_config(
416 Worker::~Worker() {
422 void Worker::schedule_clear_mcpool() {
429 void Worker::wait() {
435 void Worker::run_async() {
445 void Worker::send(WorkerEvent event) {
455 void Worker::process_events() {
575 tls::CertLookupTree *Worker::get_cert_lookup_tree() const { return cert_tree_; }
578 tls::CertLookupTree *Worker::get_quic_cert_lookup_tree() const {
583 std::shared_ptr<TicketKeys> Worker::get_ticket_keys() {
592 void Worker::set_ticket_keys(std::shared_ptr<TicketKeys> ticket_keys) {
603 WorkerStat *Worker::get_worker_stat() { return &worker_stat_; }
605 struct ev_loop *Worker::get_loop() const {
609 SSL_CTX *Worker::get_sv_ssl_ctx() const { return sv_ssl_ctx_; }
611 SSL_CTX *Worker::get_cl_ssl_ctx() const { return cl_ssl_ctx_; }
614 SSL_CTX *Worker::get_quic_sv_ssl_ctx() const { return quic_sv_ssl_ctx_; }
617 void Worker::set_graceful_shutdown(bool f) { graceful_shutdown_ = f; }
619 bool Worker::get_graceful_shutdown() const { return graceful_shutdown_; }
621 MemchunkPool *Worker::get_mcpool() { return &mcpool_; }
623 MemcachedDispatcher *Worker::get_session_cache_memcached_dispatcher() {
627 std::mt19937 &Worker::get_randgen() { return randgen_; }
630 int Worker::create_mruby_context() {
639 mruby::MRubyContext *Worker::get_mruby_context() const {
645 Worker::get_downstream_addr_groups() {
649 ConnectBlocker *Worker::get_connect_blocker() const {
653 const DownstreamConfig *Worker::get_downstream_config() const {
657 ConnectionHandler *Worker::get_connection_handler() const {
662 QUICConnectionHandler *Worker::get_quic_connection_handler() {
667 DNSTracker *Worker::get_dns_tracker() { return &dns_tracker_; }
671 bool Worker::should_attach_bpf() const {
687 bool Worker::should_update_bpf_map() const {
694 uint32_t Worker::compute_sk_index() const {
706 int Worker::setup_quic_server_socket() {
736 int Worker::create_quic_server_socket(UpstreamAddr &faddr) {
1080 const uint8_t *Worker::get_cid_prefix() const { return cid_prefix_.data(); }
1082 const UpstreamAddr *Worker::find_quic_upstream_addr(const Address &local_addr) {