| /third_party/nghttp2/src/ |
| D | shrpx_connection_handler.h | 99 const std::shared_ptr<DownstreamConfig> &downstreamconf) in SerialEvent()
100 : type(type), downstreamconf(downstreamconf) {} in SerialEvent()
103 std::shared_ptr<DownstreamConfig> downstreamconf; member
242 const std::shared_ptr<DownstreamConfig> &downstreamconf);
249 worker_replace_downstream(std::shared_ptr<DownstreamConfig> downstreamconf);
|
| D | shrpx_api_downstream_connection.cc | 363 const auto &downstreamconf = new_config.conn.downstream; in handle_backendconfig() local
368 downstreamconf->timeout = src->timeout; in handle_backendconfig()
369 downstreamconf->connections_per_host = src->connections_per_host; in handle_backendconfig()
370 downstreamconf->connections_per_frontend = src->connections_per_frontend; in handle_backendconfig()
371 downstreamconf->request_buffer_size = src->request_buffer_size; in handle_backendconfig()
372 downstreamconf->response_buffer_size = src->response_buffer_size; in handle_backendconfig()
373 downstreamconf->family = src->family; in handle_backendconfig()
428 conn_handler->send_replace_downstream(downstreamconf); in handle_backendconfig()
|
| D | shrpx_live_check.cc | 181 auto &downstreamconf = *get_config()->conn.downstream; in schedule() local
184 std::min(downstreamconf.timeout.max_backoff, base_backoff + dist(gen_)); in schedule()
322 auto &downstreamconf = *get_config()->conn.downstream; in initiate_connection() local
324 conn_.wt.repeat = downstreamconf.timeout.connect; in initiate_connection()
345 auto &downstreamconf = *get_config()->conn.downstream; in connected() local
348 conn_.wt.repeat = downstreamconf.timeout.write; in connected()
705 auto &downstreamconf = get_config()->http2.downstream; in start_settings_timer() local
707 ev_timer_set(&settings_timer_, downstreamconf.timeout.settings, 0.); in start_settings_timer()
|
| D | shrpx_connect_blocker.cc | 89 auto &downstreamconf = *get_config()->conn.downstream; in on_failure() local
92 std::min(downstreamconf.timeout.max_backoff, base_backoff + dist(gen_)); in on_failure()
|
| D | shrpx_config.cc | 94 auto &downstreamconf = http2.downstream; in ~Config() local
96 nghttp2_option_del(downstreamconf.option); in ~Config()
97 nghttp2_session_callbacks_del(downstreamconf.callbacks); in ~Config()
1185 auto &downstreamconf = *config->conn.downstream; in parse_mapping() local
1186 auto &addr_groups = downstreamconf.addr_groups; in parse_mapping()
1211 addr.group = make_string_ref(downstreamconf.balloc, params.group); in parse_mapping()
1215 addr.sni = make_string_ref(downstreamconf.balloc, params.sni); in parse_mapping()
1220 auto &routerconf = downstreamconf.router; in parse_mapping()
1231 auto iov = make_byte_ref(downstreamconf.balloc, raw_pattern.size() + 2); in parse_mapping()
1240 downstreamconf.balloc, StringRef{slash, std::end(raw_pattern)}, in parse_mapping()
[all …]
|
| D | shrpx_connection_handler.cc | 210 std::shared_ptr<DownstreamConfig> downstreamconf) { in worker_replace_downstream() argument
215 wev.downstreamconf = downstreamconf; in worker_replace_downstream()
966 mod_config()->conn.downstream = sev.downstreamconf; in handle_serial_event()
969 single_worker_->replace_downstream_config(sev.downstreamconf); in handle_serial_event()
974 worker_replace_downstream(sev.downstreamconf); in handle_serial_event()
984 const std::shared_ptr<DownstreamConfig> &downstreamconf) { in send_replace_downstream() argument
986 SerialEvent(SerialEventType::REPLACE_DOWNSTREAM, downstreamconf)); in send_replace_downstream()
|
| D | shrpx_worker.h | 302 std::shared_ptr<DownstreamConfig> downstreamconf; member
322 std::shared_ptr<DownstreamConfig> downstreamconf);
371 replace_downstream_config(std::shared_ptr<DownstreamConfig> downstreamconf);
|
| D | shrpx_http_downstream_connection.cc | 304 auto &downstreamconf = *worker_->get_downstream_config(); in initiate_connection() local
446 conn_.wt.repeat = downstreamconf.timeout.connect; in initiate_connection()
873 auto &downstreamconf = *worker_->get_downstream_config(); in detach_downstream() local
876 if (conn_.read_timeout < downstreamconf.timeout.idle_read) { in detach_downstream()
877 conn_.read_timeout = downstreamconf.timeout.idle_read; in detach_downstream()
880 conn_.again_rt(downstreamconf.timeout.idle_read); in detach_downstream()
893 auto &downstreamconf = *worker_->get_downstream_config(); in resume_read() local
896 downstreamconf.request_buffer_size / 2) { in resume_read()
|
| D | shrpx.cc | 2055 auto &downstreamconf = http2conf.downstream; in fill_default_config() local
2058 auto &timeoutconf = downstreamconf.timeout; in fill_default_config()
2062 downstreamconf.window_size = 64_k - 1; in fill_default_config()
2063 downstreamconf.connection_window_size = (1u << 31) - 1; in fill_default_config()
2064 downstreamconf.max_concurrent_streams = 100; in fill_default_config()
2066 downstreamconf.encoder_dynamic_table_size = 4_k; in fill_default_config()
2067 downstreamconf.decoder_dynamic_table_size = 4_k; in fill_default_config()
2069 nghttp2_option_new(&downstreamconf.option); in fill_default_config()
2070 nghttp2_option_set_no_auto_window_update(downstreamconf.option, 1); in fill_default_config()
2071 nghttp2_option_set_peer_max_concurrent_streams(downstreamconf.option, 100); in fill_default_config()
[all …]
|
| D | shrpx_worker.cc | 158 std::shared_ptr<DownstreamConfig> downstreamconf) in Worker() argument
206 replace_downstream_config(std::move(downstreamconf));
244 std::shared_ptr<DownstreamConfig> downstreamconf) { in replace_downstream_config() argument
254 downstreamconf_ = downstreamconf; in replace_downstream_config()
258 auto groups = downstreamconf->addr_groups; in replace_downstream_config()
538 replace_downstream_config(wev.downstreamconf); in process_events()
|
| D | shrpx_downstream.cc | 643 auto &downstreamconf = *worker->get_downstream_config(); in request_buf_full() local
645 downstreamconf.request_buffer_size; in request_buf_full()
753 auto &downstreamconf = *worker->get_downstream_config(); in response_buf_full() local
755 return response_buf_.rleft() >= downstreamconf.response_buffer_size; in response_buf_full()
|
| D | shrpx_http2_session.cc | 387 auto &downstreamconf = *get_config()->conn.downstream; in initiate_connection() local
429 conn_.wt.repeat = downstreamconf.timeout.connect; in initiate_connection()
626 conn_.wt.repeat = downstreamconf.timeout.connect; in initiate_connection()
890 auto &downstreamconf = get_config()->http2.downstream; in start_settings_timer() local
892 ev_timer_set(&settings_timer_, downstreamconf.timeout.settings, 0.); in start_settings_timer()
|
| D | shrpx_client_handler.cc | 1025 auto &downstreamconf = *worker_->get_downstream_config(); in get_downstream_connection() local
1026 auto &routerconf = downstreamconf.router; in get_downstream_connection()
1028 auto catch_all = downstreamconf.addr_group_catch_all; in get_downstream_connection()
|
| D | shrpx_http2_upstream.cc | 1012 auto &downstreamconf = *worker->get_downstream_config(); in downstream_queue_size() local
1015 return downstreamconf.connections_per_host; in downstream_queue_size()
1018 return downstreamconf.connections_per_frontend; in downstream_queue_size()
|
| D | shrpx_http3_upstream.cc | 93 auto &downstreamconf = *worker->get_downstream_config(); in downstream_queue_size() local
96 return downstreamconf.connections_per_host; in downstream_queue_size()
99 return downstreamconf.connections_per_frontend; in downstream_queue_size()
|