| /** @file |
| |
| A brief file description |
| |
| @section license License |
| |
| Licensed to the Apache Software Foundation (ASF) under one |
| or more contributor license agreements. See the NOTICE file |
| distributed with this work for additional information |
| regarding copyright ownership. The ASF licenses this file |
| to you under the Apache License, Version 2.0 (the |
| "License"); you may not use this file except in compliance |
| with the License. You may obtain a copy of the License at |
| |
| http://www.apache.org/licenses/LICENSE-2.0 |
| |
| Unless required by applicable law or agreed to in writing, software |
| distributed under the License is distributed on an "AS IS" BASIS, |
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| See the License for the specific language governing permissions and |
| limitations under the License. |
| */ |
| |
| #include "ink_config.h" |
| #include <ctype.h> |
| #include <string.h> |
| #include "HttpConfig.h" |
| #include "HTTP.h" |
| #include "ProcessManager.h" |
| #include "ProxyConfig.h" |
| #include "ICPProcessor.h" |
| #include "P_Net.h" |
| #include "P_RecUtils.h" |
| #include <records/I_RecHttp.h> |
| |
| #ifndef min |
| #define min(a,b) ((a) < (b) ? (a) : (b)) |
| #endif |
| #ifndef max |
| #define max(a,b) ((a) > (b) ? (a) : (b)) |
| #endif |
| |
| #define HttpEstablishStaticConfigStringAlloc(_ix,_n) \ |
| REC_EstablishStaticConfigStringAlloc(_ix,_n); \ |
| REC_RegisterConfigUpdateFunc(_n, http_config_cb, NULL) |
| |
| #define HttpEstablishStaticConfigLongLong(_ix,_n) \ |
| REC_EstablishStaticConfigInteger(_ix,_n); \ |
| REC_RegisterConfigUpdateFunc(_n, http_config_cb, NULL) |
| |
| #define HttpEstablishStaticConfigFloat(_ix,_n) \ |
| REC_EstablishStaticConfigFloat(_ix,_n); \ |
| REC_RegisterConfigUpdateFunc(_n, http_config_cb, NULL) |
| |
| #define HttpEstablishStaticConfigByte(_ix,_n) \ |
| REC_EstablishStaticConfigByte(_ix,_n); \ |
| REC_RegisterConfigUpdateFunc(_n, http_config_cb, NULL) |
| |
| |
| RecRawStatBlock *http_rsb; |
| #define HTTP_CLEAR_DYN_STAT(x) \ |
| do { \ |
| RecSetRawStatSum(http_rsb, x, 0); \ |
| RecSetRawStatCount(http_rsb, x, 0); \ |
| } while (0); |
| |
| |
| |
| class HttpConfigCont:public Continuation |
| { |
| public: |
| HttpConfigCont(); |
| int handle_event(int event, void *edata); |
| }; |
| |
| |
| //////////////////////////////////////////////////////////////// |
| // |
| // static variables |
| // |
| //////////////////////////////////////////////////////////////// |
| int HttpConfig::m_id = 0; |
| HttpConfigParams HttpConfig::m_master; |
| HttpUserAgent_RegxEntry *HttpConfig::user_agent_list = NULL; |
| |
| static volatile int http_config_changes = 1; |
| static HttpConfigCont *http_config_cont = NULL; |
| |
| |
| HttpConfigCont::HttpConfigCont() |
| : Continuation(new_ProxyMutex()) |
| { |
| SET_HANDLER(&HttpConfigCont::handle_event); |
| } |
| |
| int |
| HttpConfigCont::handle_event(int /* event ATS_UNUSED */, void * /* edata ATS_UNUSED */) |
| { |
| if (ink_atomic_increment((int *) &http_config_changes, -1) == 1) { |
| HttpConfig::reconfigure(); |
| } |
| return 0; |
| } |
| |
| |
| static int |
| http_config_cb(const char * /* name ATS_UNUSED */, RecDataT /* data_type ATS_UNUSED */, |
| RecData /* data ATS_UNUSED */, void * /* cookie ATS_UNUSED */) |
| { |
| ink_atomic_increment((int *) &http_config_changes, 1); |
| |
| INK_MEMORY_BARRIER; |
| |
| eventProcessor.schedule_in(http_config_cont, HRTIME_SECONDS(1), ET_CALL); |
| return 0; |
| } |
| |
| |
| void |
| register_configs() |
| { |
| } |
| |
| void |
| register_stat_callbacks() |
| { |
| |
| // Dynamic stats |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.background_fill_current_count", |
| RECD_INT, RECP_NON_PERSISTENT, (int) http_background_fill_current_count_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_background_fill_current_count_stat); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_client_connections", |
| RECD_INT, RECP_NON_PERSISTENT, (int) http_current_client_connections_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_client_connections_stat); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_active_client_connections", |
| RECD_INT, RECP_NON_PERSISTENT, |
| (int) http_current_active_client_connections_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_active_client_connections_stat); |
| // Current Transaction Stats |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_client_transactions", |
| RECD_INT, RECP_NON_PERSISTENT, (int) http_current_client_transactions_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_client_transactions_stat); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_parent_proxy_transactions", |
| RECD_INT, RECP_NON_PERSISTENT, |
| (int) http_current_parent_proxy_transactions_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_parent_proxy_transactions_stat); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_icp_transactions", |
| RECD_INT, RECP_NON_PERSISTENT, (int) http_current_icp_transactions_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_icp_transactions_stat); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_server_transactions", |
| RECD_INT, RECP_NON_PERSISTENT, (int) http_current_server_transactions_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_server_transactions_stat); |
| // Current Transaction (Raw) Stats |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_parent_proxy_raw_transactions", |
| RECD_INT, RECP_NON_PERSISTENT, |
| (int) http_current_parent_proxy_raw_transactions_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_parent_proxy_raw_transactions_stat); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_icp_raw_transactions", |
| RECD_INT, RECP_NON_PERSISTENT, (int) http_current_icp_raw_transactions_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_icp_raw_transactions_stat); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_server_raw_transactions", |
| RECD_INT, RECP_NON_PERSISTENT, (int) http_current_server_raw_transactions_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_server_raw_transactions_stat); |
| // Total connections stats |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.completed_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_completed_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.total_incoming_connections", |
| RECD_COUNTER, RECP_NULL, (int) http_total_incoming_connections_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.total_client_connections", |
| RECD_COUNTER, RECP_NULL, (int) http_total_client_connections_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.total_client_connections_ipv4", |
| RECD_COUNTER, RECP_NULL, (int) http_total_client_connections_ipv4_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.total_client_connections_ipv6", |
| RECD_COUNTER, RECP_NULL, (int) http_total_client_connections_ipv6_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.total_server_connections", |
| RECD_COUNTER, RECP_NULL, (int) http_total_server_connections_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.total_parent_proxy_connections", |
| RECD_COUNTER, RECP_NULL, (int) http_total_parent_proxy_connections_stat, RecRawStatSyncCount); |
| |
| // Upstream current connections stats |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_parent_proxy_connections", |
| RECD_INT, RECP_NON_PERSISTENT, |
| (int) http_current_parent_proxy_connections_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_parent_proxy_connections_stat); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_server_connections", |
| RECD_INT, RECP_NON_PERSISTENT, (int) http_current_server_connections_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_server_connections_stat); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.current_cache_connections", |
| RECD_INT, RECP_NON_PERSISTENT, (int) http_current_cache_connections_stat, RecRawStatSyncSum); |
| HTTP_CLEAR_DYN_STAT(http_current_cache_connections_stat); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.avg_transactions_per_client_connection", |
| RECD_FLOAT, RECP_NULL, (int) http_transactions_per_client_con, RecRawStatSyncAvg); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.avg_transactions_per_server_connection", |
| RECD_FLOAT, RECP_NULL, (int) http_transactions_per_server_con, RecRawStatSyncAvg); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.avg_transactions_per_parent_connection", |
| RECD_FLOAT, RECP_NULL, (int) http_transactions_per_parent_con, RecRawStatSyncAvg); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.client_connection_time", |
| RECD_INT, RECP_NULL, (int) http_client_connection_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.parent_proxy_connection_time", |
| RECD_INT, RECP_NULL, (int) http_parent_proxy_connection_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.server_connection_time", |
| RECD_INT, RECP_NULL, (int) http_server_connection_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_connection_time", |
| RECD_INT, RECP_NULL, (int) http_cache_connection_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.errors.pre_accept_hangups", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_ua_msecs_counts_errors_pre_accept_hangups_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.errors.pre_accept_hangups", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_errors_pre_accept_hangups_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.errors.empty_hangups", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_ua_msecs_counts_errors_empty_hangups_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.errors.empty_hangups", |
| RECD_FLOAT, RECP_NULL, (int) http_ua_msecs_counts_errors_empty_hangups_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.errors.early_hangups", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_ua_msecs_counts_errors_early_hangups_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.errors.early_hangups", |
| RECD_FLOAT, RECP_NULL, (int) http_ua_msecs_counts_errors_early_hangups_stat, RecRawStatSyncCount); |
| |
| |
| |
| // Transactional stats |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.incoming_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_incoming_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.outgoing_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_outgoing_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.incoming_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_incoming_responses_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.invalid_client_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_invalid_client_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.missing_host_hdr", |
| RECD_COUNTER, RECP_NULL, (int) http_missing_host_hdr_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.get_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_get_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.head_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_head_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.trace_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_trace_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.options_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_options_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.post_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_post_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.put_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_put_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.push_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_push_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.delete_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_delete_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.purge_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_purge_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.connect_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_connect_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.extension_method_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_extension_method_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.client_no_cache_requests", |
| RECD_COUNTER, RECP_NULL, (int) http_client_no_cache_requests_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.broken_server_connections", |
| RECD_COUNTER, RECP_NULL, (int) http_broken_server_connections_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_lookups", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_lookups_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_writes", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_writes_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_updates", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_updates_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_deletes", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_deletes_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tunnels", |
| RECD_COUNTER, RECP_NULL, (int) http_tunnels_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.throttled_proxy_only", |
| RECD_COUNTER, RECP_NULL, (int) http_throttled_proxy_only_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_taxonomy.i0_n0_m0", |
| RECD_COUNTER, RECP_NULL, (int) http_request_taxonomy_i0_n0_m0_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_taxonomy.i1_n0_m0", |
| RECD_COUNTER, RECP_NULL, (int) http_request_taxonomy_i1_n0_m0_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_taxonomy.i0_n1_m0", |
| RECD_COUNTER, RECP_NULL, (int) http_request_taxonomy_i0_n1_m0_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_taxonomy.i1_n1_m0", |
| RECD_COUNTER, RECP_NULL, (int) http_request_taxonomy_i1_n1_m0_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_taxonomy.i0_n0_m1", |
| RECD_COUNTER, RECP_NULL, (int) http_request_taxonomy_i0_n0_m1_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_taxonomy.i1_n0_m1", |
| RECD_COUNTER, RECP_NULL, (int) http_request_taxonomy_i1_n0_m1_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_taxonomy.i0_n1_m1", |
| RECD_COUNTER, RECP_NULL, (int) http_request_taxonomy_i0_n1_m1_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_taxonomy.i1_n1_m1", |
| RECD_COUNTER, RECP_NULL, (int) http_request_taxonomy_i1_n1_m1_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.icp_suggested_lookups", |
| RECD_COUNTER, RECP_NULL, (int) http_icp_suggested_lookups_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.client_transaction_time", |
| RECD_INT, RECP_NULL, (int) http_client_transaction_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.client_write_time", |
| RECD_INT, RECP_NULL, (int) http_client_write_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.server_read_time", |
| RECD_INT, RECP_NULL, (int) http_server_read_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.icp_transaction_time", |
| RECD_INT, RECP_NULL, (int) http_icp_transaction_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.icp_raw_transaction_time", |
| RECD_INT, RECP_NULL, (int) http_icp_raw_transaction_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.parent_proxy_transaction_time", |
| RECD_INT, RECP_NULL, (int) http_parent_proxy_transaction_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.parent_proxy_raw_transaction_time", |
| RECD_INT, RECP_NULL, (int) http_parent_proxy_raw_transaction_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.server_transaction_time", |
| RECD_INT, RECP_NULL, (int) http_server_transaction_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.server_raw_transaction_time", |
| RECD_INT, RECP_NULL, (int) http_server_raw_transaction_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_request_header_total_size", |
| RECD_INT, RECP_NULL, (int) http_user_agent_request_header_total_size_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_response_header_total_size", |
| RECD_INT, RECP_NULL, (int) http_user_agent_response_header_total_size_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_request_document_total_size", |
| RECD_INT, RECP_NULL, (int) http_user_agent_request_document_total_size_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_response_document_total_size", |
| RECD_INT, RECP_NULL, (int) http_user_agent_response_document_total_size_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_request_header_total_size", |
| RECD_INT, RECP_NULL, (int) http_origin_server_request_header_total_size_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_response_header_total_size", |
| RECD_INT, RECP_NULL, (int) http_origin_server_response_header_total_size_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_request_document_total_size", |
| RECD_INT, RECP_NULL, (int) http_origin_server_request_document_total_size_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_response_document_total_size", |
| RECD_INT, RECP_NULL, |
| (int) http_origin_server_response_document_total_size_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.parent_proxy_request_total_bytes", |
| RECD_INT, RECP_NULL, (int) http_parent_proxy_request_total_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.parent_proxy_response_total_bytes", |
| RECD_INT, RECP_NULL, (int) http_parent_proxy_response_total_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.pushed_response_header_total_size", |
| RECD_INT, RECP_NULL, (int) http_pushed_response_header_total_size_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.pushed_document_total_size", |
| RECD_INT, RECP_NULL, (int) http_pushed_document_total_size_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.response_document_size_100", |
| RECD_COUNTER, RECP_NULL, (int) http_response_document_size_100_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.response_document_size_1K", |
| RECD_COUNTER, RECP_NULL, (int) http_response_document_size_1K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.response_document_size_3K", |
| RECD_COUNTER, RECP_NULL, (int) http_response_document_size_3K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.response_document_size_5K", |
| RECD_COUNTER, RECP_NULL, (int) http_response_document_size_5K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.response_document_size_10K", |
| RECD_COUNTER, RECP_NULL, (int) http_response_document_size_10K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.response_document_size_1M", |
| RECD_COUNTER, RECP_NULL, (int) http_response_document_size_1M_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.response_document_size_inf", |
| RECD_COUNTER, RECP_NULL, (int) http_response_document_size_inf_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_document_size_100", |
| RECD_COUNTER, RECP_NULL, (int) http_request_document_size_100_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_document_size_1K", |
| RECD_COUNTER, RECP_NULL, (int) http_request_document_size_1K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_document_size_3K", |
| RECD_COUNTER, RECP_NULL, (int) http_request_document_size_3K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_document_size_5K", |
| RECD_COUNTER, RECP_NULL, (int) http_request_document_size_5K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_document_size_10K", |
| RECD_COUNTER, RECP_NULL, (int) http_request_document_size_10K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_document_size_1M", |
| RECD_COUNTER, RECP_NULL, (int) http_request_document_size_1M_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.request_document_size_inf", |
| RECD_COUNTER, RECP_NULL, (int) http_request_document_size_inf_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_speed_bytes_per_sec_100", |
| RECD_COUNTER, RECP_NULL, (int) http_user_agent_speed_bytes_per_sec_100_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_speed_bytes_per_sec_1K", |
| RECD_COUNTER, RECP_NULL, (int) http_user_agent_speed_bytes_per_sec_1K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_speed_bytes_per_sec_10K", |
| RECD_COUNTER, RECP_NULL, (int) http_user_agent_speed_bytes_per_sec_10K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_speed_bytes_per_sec_100K", |
| RECD_COUNTER, RECP_NULL, (int) http_user_agent_speed_bytes_per_sec_100K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_speed_bytes_per_sec_1M", |
| RECD_COUNTER, RECP_NULL, (int) http_user_agent_speed_bytes_per_sec_1M_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_speed_bytes_per_sec_10M", |
| RECD_COUNTER, RECP_NULL, (int) http_user_agent_speed_bytes_per_sec_10M_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.user_agent_speed_bytes_per_sec_100M", |
| RECD_COUNTER, RECP_NULL, (int) http_user_agent_speed_bytes_per_sec_100M_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_speed_bytes_per_sec_100", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_origin_server_speed_bytes_per_sec_100_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_speed_bytes_per_sec_1K", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_origin_server_speed_bytes_per_sec_1K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_speed_bytes_per_sec_10K", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_origin_server_speed_bytes_per_sec_10K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_speed_bytes_per_sec_100K", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_origin_server_speed_bytes_per_sec_100K_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_speed_bytes_per_sec_1M", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_origin_server_speed_bytes_per_sec_1M_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_speed_bytes_per_sec_10M", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_origin_server_speed_bytes_per_sec_10M_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.origin_server_speed_bytes_per_sec_100M", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_origin_server_speed_bytes_per_sec_100M_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.total_transactions_time", |
| RECD_INT, RECP_NULL, (int) http_total_transactions_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.total_transactions_think_time", |
| RECD_INT, RECP_NULL, (int) http_total_transactions_think_time_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_hit_fresh", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_hit_fresh_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_hit_mem_fresh", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_hit_mem_fresh_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_hit_revalidated", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_hit_reval_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_hit_ims", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_hit_ims_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_hit_stale_served", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_hit_stale_served_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_miss_cold", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_miss_cold_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_miss_changed", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_miss_changed_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_miss_client_no_cache", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_miss_client_no_cache_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_miss_client_not_cacheable", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_miss_uncacheable_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_miss_ims", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_miss_ims_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_read_error", |
| RECD_COUNTER, RECP_NULL, (int) http_cache_read_error_stat, RecRawStatSyncCount); |
| |
| ///////////////////////////////////////// |
| // Bandwidth Savings Transaction Stats // |
| ///////////////////////////////////////// |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_hit_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_tcp_hit_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_hit_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_hit_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_hit_origin_server_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_hit_origin_server_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_miss_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_tcp_miss_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_miss_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_miss_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_miss_origin_server_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_miss_origin_server_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_expired_miss_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_tcp_expired_miss_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_expired_miss_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_expired_miss_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_expired_miss_origin_server_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_expired_miss_origin_server_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_refresh_hit_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_tcp_refresh_hit_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_refresh_hit_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_refresh_hit_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_refresh_hit_origin_server_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_refresh_hit_origin_server_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_refresh_miss_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_tcp_refresh_miss_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_refresh_miss_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_refresh_miss_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_refresh_miss_origin_server_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_refresh_miss_origin_server_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_client_refresh_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_tcp_client_refresh_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_client_refresh_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_client_refresh_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_client_refresh_origin_server_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_client_refresh_origin_server_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_ims_hit_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_tcp_ims_hit_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_ims_hit_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_ims_hit_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_ims_hit_origin_server_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_ims_hit_origin_server_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_ims_miss_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_tcp_ims_miss_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_ims_miss_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_ims_miss_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.tcp_ims_miss_origin_server_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_tcp_ims_miss_origin_server_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.err_client_abort_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_err_client_abort_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.err_client_abort_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_err_client_abort_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.err_client_abort_origin_server_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_err_client_abort_origin_server_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.err_connect_fail_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_err_connect_fail_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.err_connect_fail_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_err_connect_fail_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.err_connect_fail_origin_server_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_err_connect_fail_origin_server_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.misc_count_stat", |
| RECD_COUNTER, RECP_NULL, (int) http_misc_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.misc_user_agent_bytes_stat", |
| RECD_INT, RECP_NULL, (int) http_misc_user_agent_bytes_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.background_fill_bytes_aborted_stat", |
| RECD_INT, RECP_NULL, (int) http_background_fill_bytes_aborted_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.background_fill_bytes_completed_stat", |
| RECD_INT, RECP_NULL, (int) http_background_fill_bytes_completed_stat, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_write_errors", |
| RECD_INT, RECP_NULL, (int) http_cache_write_errors, RecRawStatSyncSum); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.cache_read_errors", |
| RECD_INT, RECP_NULL, (int) http_cache_read_errors, RecRawStatSyncSum); |
| |
| //////////////////////////////////////////////////////////////////////////////// |
| // status code counts |
| //////////////////////////////////////////////////////////////////////////////// |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.100_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_100_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.101_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_101_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.1xx_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_1xx_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.200_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_200_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.201_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_201_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.202_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_202_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.203_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_203_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.204_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_204_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.205_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_205_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.206_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_206_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.2xx_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_2xx_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.300_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_300_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.301_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_301_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.302_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_302_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.303_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_303_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.304_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_304_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.305_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_305_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.307_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_307_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.3xx_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_3xx_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.400_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_400_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.401_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_401_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.402_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_402_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.403_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_403_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.404_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_404_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.405_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_405_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.406_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_406_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.407_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_407_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.408_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_408_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.409_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_409_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.410_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_410_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.411_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_411_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.412_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_412_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.413_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_413_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.414_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_414_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.415_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_415_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.416_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_416_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.4xx_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_4xx_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.500_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_500_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.501_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_501_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.502_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_502_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.503_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_503_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.504_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_504_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.505_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_505_count_stat, RecRawStatSyncCount); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.5xx_responses", |
| RECD_COUNTER, RECP_NULL, (int) http_response_status_5xx_count_stat, RecRawStatSyncCount); |
| |
| |
| //////////////////////////////////////////////////////////////////////////////// |
| // http - time and count of transactions classified by client's point of view // |
| // the internal stat is in msecs, the output time is float seconds // |
| //////////////////////////////////////////////////////////////////////////////// |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.hit_fresh", |
| RECD_COUNTER, RECP_NULL, (int) http_ua_msecs_counts_hit_fresh_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.hit_fresh", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_hit_fresh_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.hit_fresh.process", |
| RECD_COUNTER, RECP_NULL, (int) http_ua_msecs_counts_hit_fresh_process_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.hit_fresh.process", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_hit_fresh_process_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.hit_revalidated", |
| RECD_COUNTER, RECP_NULL, (int) http_ua_msecs_counts_hit_reval_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.hit_revalidated", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_hit_reval_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.miss_cold", |
| RECD_COUNTER, RECP_NULL, (int) http_ua_msecs_counts_miss_cold_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.miss_cold", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_miss_cold_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.miss_not_cacheable", |
| RECD_COUNTER, RECP_NULL, (int) http_ua_msecs_counts_miss_uncacheable_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.miss_not_cacheable", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_miss_uncacheable_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.miss_changed", |
| RECD_COUNTER, RECP_NULL, (int) http_ua_msecs_counts_miss_changed_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.miss_changed", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_miss_changed_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.miss_client_no_cache", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_ua_msecs_counts_miss_client_no_cache_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.miss_client_no_cache", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_miss_client_no_cache_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.errors.aborts", |
| RECD_COUNTER, RECP_NULL, (int) http_ua_msecs_counts_errors_aborts_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.errors.aborts", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_errors_aborts_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.errors.possible_aborts", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_ua_msecs_counts_errors_possible_aborts_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.errors.possible_aborts", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_errors_possible_aborts_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.errors.connect_failed", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_ua_msecs_counts_errors_connect_failed_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.errors.connect_failed", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_errors_connect_failed_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.errors.other", |
| RECD_COUNTER, RECP_NULL, (int) http_ua_msecs_counts_errors_other_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.errors.other", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_errors_other_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_counts.other.unclassified", |
| RECD_COUNTER, RECP_NULL, (int) http_ua_msecs_counts_other_unclassified_stat, RecRawStatSyncCount); |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.transaction_totaltime.other.unclassified", |
| RECD_FLOAT, RECP_NULL, |
| (int) http_ua_msecs_counts_other_unclassified_stat, RecRawStatSyncIntMsecsToFloatSeconds); |
| |
| RecRegisterRawStat(http_rsb, RECT_PROCESS, |
| "proxy.process.http.total_x_redirect_count", |
| RECD_COUNTER, RECP_NULL, |
| (int) http_total_x_redirect_stat, RecRawStatSyncCount); |
| |
| } |
| |
| |
| //////////////////////////////////////////////////////////////// |
| // |
| // HttpConfig::startup() |
| // |
| //////////////////////////////////////////////////////////////// |
| void |
| HttpConfig::startup() |
| { |
| |
| http_rsb = RecAllocateRawStatBlock((int) http_stat_count); |
| register_configs(); |
| register_stat_callbacks(); |
| |
| HttpConfigParams &c = m_master; |
| |
| http_config_cont = NEW(new HttpConfigCont); |
| |
| HttpEstablishStaticConfigStringAlloc(c.proxy_hostname, "proxy.config.proxy_name"); |
| c.proxy_hostname_len = -1; |
| |
| if (c.proxy_hostname == NULL) { |
| c.proxy_hostname = (char *)ats_malloc(sizeof(char)); |
| c.proxy_hostname[0] = '\0'; |
| } |
| |
| RecHttpLoadIp("proxy.local.incoming_ip_to_bind", c.inbound_ip4, c.inbound_ip6); |
| RecHttpLoadIp("proxy.local.outgoing_ip_to_bind", c.outbound_ip4, c.outbound_ip6); |
| |
| #if TS_USE_RECLAIMABLE_FREELIST |
| HttpEstablishStaticConfigLongLong(cfg_debug_filter, "proxy.config.allocator.debug_filter"); |
| HttpEstablishStaticConfigLongLong(cfg_enable_reclaim, "proxy.config.allocator.enable_reclaim"); |
| HttpEstablishStaticConfigLongLong(cfg_max_overage, "proxy.config.allocator.max_overage"); |
| HttpEstablishStaticConfigFloat(cfg_reclaim_factor, "proxy.config.allocator.reclaim_factor"); |
| #endif |
| |
| HttpEstablishStaticConfigLongLong(c.server_max_connections, "proxy.config.http.server_max_connections"); |
| HttpEstablishStaticConfigLongLong(c.oride.server_tcp_init_cwnd, "proxy.config.http.server_tcp_init_cwnd"); |
| HttpEstablishStaticConfigLongLong(c.oride.origin_max_connections, "proxy.config.http.origin_max_connections"); |
| HttpEstablishStaticConfigLongLong(c.origin_min_keep_alive_connections, "proxy.config.http.origin_min_keep_alive_connections"); |
| HttpEstablishStaticConfigLongLong(c.attach_server_session_to_client, "proxy.config.http.attach_server_session_to_client"); |
| |
| HttpEstablishStaticConfigByte(c.parent_proxy_routing_enable, "proxy.config.http.parent_proxy_routing_enable"); |
| |
| // Wank me. |
| HttpEstablishStaticConfigByte(c.disable_ssl_parenting, "proxy.local.http.parent_proxy.disable_connect_tunneling"); |
| HttpEstablishStaticConfigByte(c.no_dns_forward_to_parent, "proxy.config.http.no_dns_just_forward_to_parent"); |
| HttpEstablishStaticConfigByte(c.uncacheable_requests_bypass_parent, "proxy.config.http.uncacheable_requests_bypass_parent"); |
| HttpEstablishStaticConfigByte(c.oride.doc_in_cache_skip_dns, "proxy.config.http.doc_in_cache_skip_dns"); |
| |
| HttpEstablishStaticConfigByte(c.no_origin_server_dns, "proxy.config.http.no_origin_server_dns"); |
| HttpEstablishStaticConfigByte(c.use_client_target_addr, "proxy.config.http.use_client_target_addr"); |
| HttpEstablishStaticConfigByte(c.use_client_source_port, "proxy.config.http.use_client_source_port"); |
| HttpEstablishStaticConfigByte(c.oride.maintain_pristine_host_hdr, "proxy.config.url_remap.pristine_host_hdr"); |
| |
| HttpEstablishStaticConfigByte(c.enable_url_expandomatic, "proxy.config.http.enable_url_expandomatic"); |
| |
| HttpEstablishStaticConfigByte(c.oride.insert_request_via_string, "proxy.config.http.insert_request_via_str"); |
| HttpEstablishStaticConfigByte(c.oride.insert_response_via_string, "proxy.config.http.insert_response_via_str"); |
| |
| HttpEstablishStaticConfigStringAlloc(c.proxy_request_via_string, "proxy.config.http.request_via_str"); |
| c.proxy_request_via_string_len = -1; |
| HttpEstablishStaticConfigStringAlloc(c.proxy_response_via_string, "proxy.config.http.response_via_str"); |
| c.proxy_response_via_string_len = -1; |
| |
| HttpEstablishStaticConfigStringAlloc(c.url_expansions_string, "proxy.config.dns.url_expansions"); |
| HttpEstablishStaticConfigByte(c.oride.keep_alive_enabled_in, "proxy.config.http.keep_alive_enabled_in"); |
| HttpEstablishStaticConfigByte(c.oride.keep_alive_enabled_out, "proxy.config.http.keep_alive_enabled_out"); |
| HttpEstablishStaticConfigByte(c.oride.chunking_enabled, "proxy.config.http.chunking_enabled"); |
| HttpEstablishStaticConfigLongLong(c.oride.http_chunking_size, "proxy.config.http.chunking.size"); |
| HttpEstablishStaticConfigByte(c.oride.flow_control_enabled, "proxy.config.http.flow_control.enabled"); |
| HttpEstablishStaticConfigLongLong(c.oride.flow_high_water_mark, "proxy.config.http.flow_control.high_water"); |
| HttpEstablishStaticConfigLongLong(c.oride.flow_low_water_mark, "proxy.config.http.flow_control.low_water"); |
| HttpEstablishStaticConfigByte(c.oride.share_server_sessions, "proxy.config.http.share_server_sessions"); |
| HttpEstablishStaticConfigByte(c.oride.keep_alive_post_out, "proxy.config.http.keep_alive_post_out"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.keep_alive_no_activity_timeout_in, |
| "proxy.config.http.keep_alive_no_activity_timeout_in"); |
| HttpEstablishStaticConfigLongLong(c.oride.keep_alive_no_activity_timeout_out, |
| "proxy.config.http.keep_alive_no_activity_timeout_out"); |
| HttpEstablishStaticConfigLongLong(c.oride.transaction_no_activity_timeout_in, |
| "proxy.config.http.transaction_no_activity_timeout_in"); |
| HttpEstablishStaticConfigLongLong(c.oride.transaction_no_activity_timeout_out, |
| "proxy.config.http.transaction_no_activity_timeout_out"); |
| HttpEstablishStaticConfigLongLong(c.transaction_active_timeout_in, "proxy.config.http.transaction_active_timeout_in"); |
| HttpEstablishStaticConfigLongLong(c.oride.transaction_active_timeout_out, "proxy.config.http.transaction_active_timeout_out"); |
| HttpEstablishStaticConfigLongLong(c.accept_no_activity_timeout, "proxy.config.http.accept_no_activity_timeout"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.background_fill_active_timeout, "proxy.config.http.background_fill_active_timeout"); |
| HttpEstablishStaticConfigFloat(c.oride.background_fill_threshold, "proxy.config.http.background_fill_completed_threshold"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.connect_attempts_max_retries, "proxy.config.http.connect_attempts_max_retries"); |
| HttpEstablishStaticConfigLongLong(c.oride.connect_attempts_max_retries_dead_server, |
| "proxy.config.http.connect_attempts_max_retries_dead_server"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.connect_attempts_rr_retries, "proxy.config.http.connect_attempts_rr_retries"); |
| HttpEstablishStaticConfigLongLong(c.oride.connect_attempts_timeout, "proxy.config.http.connect_attempts_timeout"); |
| HttpEstablishStaticConfigLongLong(c.oride.post_connect_attempts_timeout, "proxy.config.http.post_connect_attempts_timeout"); |
| HttpEstablishStaticConfigLongLong(c.parent_connect_attempts, "proxy.config.http.parent_proxy.total_connect_attempts"); |
| HttpEstablishStaticConfigLongLong(c.per_parent_connect_attempts, "proxy.config.http.parent_proxy.per_parent_connect_attempts"); |
| HttpEstablishStaticConfigLongLong(c.parent_connect_timeout, "proxy.config.http.parent_proxy.connect_attempts_timeout"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.sock_recv_buffer_size_out, "proxy.config.net.sock_recv_buffer_size_out"); |
| HttpEstablishStaticConfigLongLong(c.oride.sock_send_buffer_size_out, "proxy.config.net.sock_send_buffer_size_out"); |
| HttpEstablishStaticConfigLongLong(c.oride.sock_option_flag_out, "proxy.config.net.sock_option_flag_out"); |
| HttpEstablishStaticConfigLongLong(c.oride.sock_packet_mark_out, "proxy.config.net.sock_packet_mark_out"); |
| HttpEstablishStaticConfigLongLong(c.oride.sock_packet_tos_out, "proxy.config.net.sock_packet_tos_out"); |
| |
| |
| HttpEstablishStaticConfigByte(c.oride.fwd_proxy_auth_to_parent, "proxy.config.http.forward.proxy_auth_to_parent"); |
| |
| HttpEstablishStaticConfigByte(c.oride.anonymize_remove_from, "proxy.config.http.anonymize_remove_from"); |
| HttpEstablishStaticConfigByte(c.oride.anonymize_remove_referer, "proxy.config.http.anonymize_remove_referer"); |
| HttpEstablishStaticConfigByte(c.oride.anonymize_remove_user_agent, "proxy.config.http.anonymize_remove_user_agent"); |
| HttpEstablishStaticConfigByte(c.oride.anonymize_remove_cookie, "proxy.config.http.anonymize_remove_cookie"); |
| HttpEstablishStaticConfigByte(c.oride.anonymize_remove_client_ip, "proxy.config.http.anonymize_remove_client_ip"); |
| HttpEstablishStaticConfigByte(c.oride.anonymize_insert_client_ip, "proxy.config.http.anonymize_insert_client_ip"); |
| HttpEstablishStaticConfigStringAlloc(c.anonymize_other_header_list, "proxy.config.http.anonymize_other_header_list"); |
| HttpEstablishStaticConfigStringAlloc(c.global_user_agent_header, "proxy.config.http.global_user_agent_header"); |
| c.global_user_agent_header_size = c.global_user_agent_header ? strlen(c.global_user_agent_header) : 0; |
| |
| HttpEstablishStaticConfigByte(c.oride.proxy_response_server_enabled, "proxy.config.http.response_server_enabled"); |
| HttpEstablishStaticConfigStringAlloc(c.oride.proxy_response_server_string, "proxy.config.http.response_server_str"); |
| c.oride.proxy_response_server_string_len = c.oride.proxy_response_server_string ? |
| strlen(c.oride.proxy_response_server_string) : 0; |
| |
| HttpEstablishStaticConfigByte(c.oride.insert_squid_x_forwarded_for, "proxy.config.http.insert_squid_x_forwarded_for"); |
| |
| |
| HttpEstablishStaticConfigByte(c.oride.insert_age_in_response, "proxy.config.http.insert_age_in_response"); |
| HttpEstablishStaticConfigByte(c.enable_http_stats, "proxy.config.http.enable_http_stats"); |
| HttpEstablishStaticConfigByte(c.oride.normalize_ae_gzip, "proxy.config.http.normalize_ae_gzip"); |
| |
| HttpEstablishStaticConfigByte(c.icp_enabled, "proxy.config.icp.enabled"); |
| HttpEstablishStaticConfigByte(c.stale_icp_enabled, "proxy.config.icp.stale_icp_enabled"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.cache_heuristic_min_lifetime, "proxy.config.http.cache.heuristic_min_lifetime"); |
| HttpEstablishStaticConfigLongLong(c.oride.cache_heuristic_max_lifetime, "proxy.config.http.cache.heuristic_max_lifetime"); |
| HttpEstablishStaticConfigFloat(c.oride.cache_heuristic_lm_factor, "proxy.config.http.cache.heuristic_lm_factor"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.cache_guaranteed_min_lifetime, "proxy.config.http.cache.guaranteed_min_lifetime"); |
| HttpEstablishStaticConfigLongLong(c.oride.cache_guaranteed_max_lifetime, "proxy.config.http.cache.guaranteed_max_lifetime"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.cache_max_stale_age, "proxy.config.http.cache.max_stale_age"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.freshness_fuzz_time, "proxy.config.http.cache.fuzz.time"); |
| HttpEstablishStaticConfigLongLong(c.oride.freshness_fuzz_min_time, "proxy.config.http.cache.fuzz.min_time"); |
| HttpEstablishStaticConfigFloat(c.oride.freshness_fuzz_prob, "proxy.config.http.cache.fuzz.probability"); |
| |
| HttpEstablishStaticConfigStringAlloc(c.cache_vary_default_text, "proxy.config.http.cache.vary_default_text"); |
| HttpEstablishStaticConfigStringAlloc(c.cache_vary_default_images, "proxy.config.http.cache.vary_default_images"); |
| HttpEstablishStaticConfigStringAlloc(c.cache_vary_default_other, "proxy.config.http.cache.vary_default_other"); |
| |
| // open read failure retries |
| HttpEstablishStaticConfigLongLong(c.oride.max_cache_open_read_retries, "proxy.config.http.cache.max_open_read_retries"); |
| HttpEstablishStaticConfigLongLong(c.oride.cache_open_read_retry_time, "proxy.config.http.cache.open_read_retry_time"); |
| |
| // open write failure retries |
| HttpEstablishStaticConfigLongLong(c.max_cache_open_write_retries, "proxy.config.http.cache.max_open_write_retries"); |
| |
| HttpEstablishStaticConfigByte(c.oride.cache_http, "proxy.config.http.cache.http"); |
| HttpEstablishStaticConfigByte(c.oride.cache_cluster_cache_local, "proxy.config.http.cache.cluster_cache_local"); |
| HttpEstablishStaticConfigByte(c.oride.cache_ignore_client_no_cache, "proxy.config.http.cache.ignore_client_no_cache"); |
| HttpEstablishStaticConfigByte(c.oride.cache_ignore_client_cc_max_age, "proxy.config.http.cache.ignore_client_cc_max_age"); |
| HttpEstablishStaticConfigByte(c.oride.cache_ims_on_client_no_cache, "proxy.config.http.cache.ims_on_client_no_cache"); |
| HttpEstablishStaticConfigByte(c.oride.cache_ignore_server_no_cache, "proxy.config.http.cache.ignore_server_no_cache"); |
| HttpEstablishStaticConfigByte(c.oride.cache_responses_to_cookies, "proxy.config.http.cache.cache_responses_to_cookies"); |
| |
| HttpEstablishStaticConfigByte(c.oride.cache_ignore_auth, "proxy.config.http.cache.ignore_authentication"); |
| HttpEstablishStaticConfigByte(c.oride.cache_urls_that_look_dynamic, "proxy.config.http.cache.cache_urls_that_look_dynamic"); |
| HttpEstablishStaticConfigByte(c.cache_enable_default_vary_headers, "proxy.config.http.cache.enable_default_vary_headers"); |
| |
| HttpEstablishStaticConfigByte(c.ignore_accept_mismatch, "proxy.config.http.cache.ignore_accept_mismatch"); |
| HttpEstablishStaticConfigByte(c.ignore_accept_language_mismatch, "proxy.config.http.cache.ignore_accept_language_mismatch"); |
| HttpEstablishStaticConfigByte(c.ignore_accept_encoding_mismatch, "proxy.config.http.cache.ignore_accept_encoding_mismatch"); |
| HttpEstablishStaticConfigByte(c.ignore_accept_charset_mismatch, "proxy.config.http.cache.ignore_accept_charset_mismatch"); |
| |
| HttpEstablishStaticConfigByte(c.oride.cache_when_to_revalidate, "proxy.config.http.cache.when_to_revalidate"); |
| HttpEstablishStaticConfigByte(c.cache_when_to_add_no_cache_to_msie_requests, |
| "proxy.config.http.cache.when_to_add_no_cache_to_msie_requests"); |
| HttpEstablishStaticConfigByte(c.oride.cache_required_headers, "proxy.config.http.cache.required_headers"); |
| HttpEstablishStaticConfigByte(c.oride.cache_range_lookup, "proxy.config.http.cache.range.lookup"); |
| |
| HttpEstablishStaticConfigStringAlloc(c.connect_ports_string, "proxy.config.http.connect_ports"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.request_hdr_max_size, "proxy.config.http.request_header_max_size"); |
| HttpEstablishStaticConfigLongLong(c.oride.response_hdr_max_size, "proxy.config.http.response_header_max_size"); |
| |
| HttpEstablishStaticConfigByte(c.push_method_enabled, "proxy.config.http.push_method_enabled"); |
| |
| HttpEstablishStaticConfigByte(c.reverse_proxy_enabled, "proxy.config.reverse_proxy.enabled"); |
| HttpEstablishStaticConfigByte(c.url_remap_required, "proxy.config.url_remap.remap_required"); |
| |
| HttpEstablishStaticConfigStringAlloc(c.reverse_proxy_no_host_redirect, "proxy.config.header.parse.no_host_url_redirect"); |
| c.reverse_proxy_no_host_redirect_len = -1; |
| |
| HttpEstablishStaticConfigByte(c.errors_log_error_pages, "proxy.config.http.errors.log_error_pages"); |
| |
| HttpEstablishStaticConfigLongLong(c.slow_log_threshold, "proxy.config.http.slow.log.threshold"); |
| |
| HttpEstablishStaticConfigByte(c.record_cop_page, "proxy.config.http.record_heartbeat"); |
| |
| HttpEstablishStaticConfigByte(c.record_tcp_mem_hit, "proxy.config.http.record_tcp_mem_hit"); |
| |
| HttpEstablishStaticConfigByte(c.oride.send_http11_requests, "proxy.config.http.send_http11_requests"); |
| |
| // HTTP Referer Filtering |
| HttpEstablishStaticConfigByte(c.referer_filter_enabled, "proxy.config.http.referer_filter"); |
| HttpEstablishStaticConfigByte(c.referer_format_redirect, "proxy.config.http.referer_format_redirect"); |
| |
| HttpEstablishStaticConfigLongLong(c.oride.down_server_timeout, "proxy.config.http.down_server.cache_time"); |
| HttpEstablishStaticConfigLongLong(c.oride.client_abort_threshold, "proxy.config.http.down_server.abort_threshold"); |
| |
| // Negative caching and revalidation |
| HttpEstablishStaticConfigByte(c.oride.negative_caching_enabled, "proxy.config.http.negative_caching_enabled"); |
| HttpEstablishStaticConfigLongLong(c.oride.negative_caching_lifetime, "proxy.config.http.negative_caching_lifetime"); |
| HttpEstablishStaticConfigByte(c.oride.negative_revalidating_enabled, "proxy.config.http.negative_revalidating_enabled"); |
| HttpEstablishStaticConfigLongLong(c.oride.negative_revalidating_lifetime, |
| "proxy.config.http.negative_revalidating_lifetime"); |
| |
| // Buffer size and watermark |
| HttpEstablishStaticConfigLongLong(c.oride.default_buffer_size_index, "proxy.config.http.default_buffer_size"); |
| HttpEstablishStaticConfigLongLong(c.oride.default_buffer_water_mark, "proxy.config.http.default_buffer_water_mark"); |
| |
| // Stat Page Info |
| HttpEstablishStaticConfigByte(c.enable_http_info, "proxy.config.http.enable_http_info"); |
| |
| //############################################################################## |
| //# |
| //# Redirection |
| //# |
| //# 1. redirection_enabled: if set to 1, redirection is enabled. |
| //# 2. number_of_redirections: The maximum number of redirections YTS permits |
| //# 3. post_copy_size: The maximum POST data size YTS permits to copy |
| //# |
| //############################################################################## |
| HttpEstablishStaticConfigByte(c.redirection_enabled, "proxy.config.http.redirection_enabled"); |
| HttpEstablishStaticConfigLongLong(c.number_of_redirections, "proxy.config.http.number_of_redirections"); |
| HttpEstablishStaticConfigLongLong(c.post_copy_size, "proxy.config.http.post_copy_size"); |
| |
| // Cluster time delta gets it own callback since it needs |
| // to use ink_atomic_swap |
| c.cluster_time_delta = 0; |
| RegisterMgmtCallback(MGMT_EVENT_HTTP_CLUSTER_DELTA, cluster_delta_cb, NULL); |
| |
| http_config_cont->handleEvent(EVENT_NONE, NULL); |
| |
| return; |
| } |
| |
| //////////////////////////////////////////////////////////////// |
| // |
| // HttpConfig::reconfigure() |
| // |
| //////////////////////////////////////////////////////////////// |
| void |
| HttpConfig::reconfigure() |
| { |
| #define INT_TO_BOOL(i) ((i) ? 1 : 0); |
| |
| HttpConfigParams *params; |
| |
| params = NEW(new HttpConfigParams); |
| |
| params->inbound_ip4 = m_master.inbound_ip4; |
| params->inbound_ip6 = m_master.inbound_ip6; |
| |
| params->outbound_ip4 = m_master.outbound_ip4; |
| params->outbound_ip6 = m_master.outbound_ip6; |
| |
| params->proxy_hostname = ats_strdup(m_master.proxy_hostname); |
| params->proxy_hostname_len = (params->proxy_hostname) ? strlen(params->proxy_hostname) : 0; |
| params->no_dns_forward_to_parent = INT_TO_BOOL(m_master.no_dns_forward_to_parent); |
| params->uncacheable_requests_bypass_parent = INT_TO_BOOL(m_master.uncacheable_requests_bypass_parent); |
| params->no_origin_server_dns = INT_TO_BOOL(m_master.no_origin_server_dns); |
| params->use_client_target_addr = INT_TO_BOOL(m_master.use_client_target_addr); |
| params->use_client_source_port = INT_TO_BOOL(m_master.use_client_source_port); |
| params->oride.maintain_pristine_host_hdr = INT_TO_BOOL(m_master.oride.maintain_pristine_host_hdr); |
| |
| params->disable_ssl_parenting = INT_TO_BOOL(m_master.disable_ssl_parenting); |
| |
| params->server_max_connections = m_master.server_max_connections; |
| params->oride.server_tcp_init_cwnd = m_master.oride.server_tcp_init_cwnd; |
| params->oride.origin_max_connections = m_master.oride.origin_max_connections; |
| params->origin_min_keep_alive_connections = m_master.origin_min_keep_alive_connections; |
| |
| if (params->oride.origin_max_connections && |
| params->oride.origin_max_connections < params->origin_min_keep_alive_connections ) { |
| Warning("origin_max_connections < origin_min_keep_alive_connections, setting min=max , please correct your records.config"); |
| params->origin_min_keep_alive_connections = params->oride.origin_max_connections; |
| } |
| |
| params->parent_proxy_routing_enable = INT_TO_BOOL(m_master.parent_proxy_routing_enable); |
| params->enable_url_expandomatic = INT_TO_BOOL(m_master.enable_url_expandomatic); |
| |
| params->oride.insert_request_via_string = m_master.oride.insert_request_via_string; |
| params->oride.insert_response_via_string = m_master.oride.insert_response_via_string; |
| params->proxy_request_via_string = ats_strdup(m_master.proxy_request_via_string); |
| params->proxy_request_via_string_len = (params->proxy_request_via_string) ? strlen(params->proxy_request_via_string) : 0; |
| params->proxy_response_via_string = ats_strdup(m_master.proxy_response_via_string); |
| params->proxy_response_via_string_len = (params->proxy_response_via_string) ? strlen(params->proxy_response_via_string) : 0; |
| |
| params->url_expansions_string = ats_strdup(m_master.url_expansions_string); |
| params->url_expansions = parse_url_expansions(params->url_expansions_string, ¶ms->num_url_expansions); |
| |
| params->oride.keep_alive_enabled_in = INT_TO_BOOL(m_master.oride.keep_alive_enabled_in); |
| params->oride.keep_alive_enabled_out = INT_TO_BOOL(m_master.oride.keep_alive_enabled_out); |
| params->oride.chunking_enabled = INT_TO_BOOL(m_master.oride.chunking_enabled); |
| params->oride.http_chunking_size = m_master.oride.http_chunking_size; |
| |
| params->oride.flow_control_enabled = INT_TO_BOOL(m_master.oride.flow_control_enabled); |
| params->oride.flow_high_water_mark = m_master.oride.flow_high_water_mark; |
| params->oride.flow_low_water_mark = m_master.oride.flow_low_water_mark; |
| // If not set (zero) then make values the same. |
| if (params->oride.flow_low_water_mark <= 0) |
| params->oride.flow_low_water_mark = params->oride.flow_high_water_mark; |
| if (params->oride.flow_high_water_mark <= 0) |
| params->oride.flow_high_water_mark = params->oride.flow_low_water_mark; |
| if (params->oride.flow_high_water_mark < params->oride.flow_low_water_mark) { |
| Warning("Flow control low water mark is greater than high water mark, flow control disabled"); |
| params->oride.flow_control_enabled = 0; |
| // zero means "hardwired default" when actually used. |
| params->oride.flow_high_water_mark = params->oride.flow_low_water_mark = 0; |
| } |
| |
| params->oride.share_server_sessions = m_master.oride.share_server_sessions; |
| params->oride.keep_alive_post_out = INT_TO_BOOL(m_master.oride.keep_alive_post_out); |
| |
| params->oride.keep_alive_no_activity_timeout_in = m_master.oride.keep_alive_no_activity_timeout_in; |
| params->oride.keep_alive_no_activity_timeout_out = m_master.oride.keep_alive_no_activity_timeout_out; |
| params->oride.transaction_no_activity_timeout_in = m_master.oride.transaction_no_activity_timeout_in; |
| params->oride.transaction_no_activity_timeout_out = m_master.oride.transaction_no_activity_timeout_out; |
| params->transaction_active_timeout_in = m_master.transaction_active_timeout_in; |
| params->oride.transaction_active_timeout_out = m_master.oride.transaction_active_timeout_out; |
| params->accept_no_activity_timeout = m_master.accept_no_activity_timeout; |
| params->oride.background_fill_active_timeout = m_master.oride.background_fill_active_timeout; |
| params->oride.background_fill_threshold = m_master.oride.background_fill_threshold; |
| |
| params->oride.connect_attempts_max_retries = m_master.oride.connect_attempts_max_retries; |
| params->oride.connect_attempts_max_retries_dead_server = m_master.oride.connect_attempts_max_retries_dead_server; |
| params->oride.connect_attempts_rr_retries = m_master.oride.connect_attempts_rr_retries; |
| params->oride.connect_attempts_timeout = m_master.oride.connect_attempts_timeout; |
| params->oride.post_connect_attempts_timeout = m_master.oride.post_connect_attempts_timeout; |
| params->parent_connect_attempts = m_master.parent_connect_attempts; |
| params->per_parent_connect_attempts = m_master.per_parent_connect_attempts; |
| params->parent_connect_timeout = m_master.parent_connect_timeout; |
| |
| params->oride.sock_recv_buffer_size_out = m_master.oride.sock_recv_buffer_size_out; |
| params->oride.sock_send_buffer_size_out = m_master.oride.sock_send_buffer_size_out; |
| params->oride.sock_option_flag_out = m_master.oride.sock_option_flag_out; |
| params->oride.sock_packet_mark_out = m_master.oride.sock_packet_mark_out; |
| params->oride.sock_packet_tos_out = m_master.oride.sock_packet_tos_out; |
| |
| |
| params->oride.fwd_proxy_auth_to_parent = INT_TO_BOOL(m_master.oride.fwd_proxy_auth_to_parent); |
| |
| params->oride.anonymize_remove_from = INT_TO_BOOL(m_master.oride.anonymize_remove_from); |
| params->oride.anonymize_remove_referer = INT_TO_BOOL(m_master.oride.anonymize_remove_referer); |
| params->oride.anonymize_remove_user_agent = INT_TO_BOOL(m_master.oride.anonymize_remove_user_agent); |
| params->oride.anonymize_remove_cookie = INT_TO_BOOL(m_master.oride.anonymize_remove_cookie); |
| params->oride.anonymize_remove_client_ip = INT_TO_BOOL(m_master.oride.anonymize_remove_client_ip); |
| params->oride.anonymize_insert_client_ip = INT_TO_BOOL(m_master.oride.anonymize_insert_client_ip); |
| params->anonymize_other_header_list = ats_strdup(m_master.anonymize_other_header_list); |
| |
| params->global_user_agent_header = ats_strdup(m_master.global_user_agent_header); |
| params->global_user_agent_header_size = params->global_user_agent_header ? |
| strlen(params->global_user_agent_header) : 0; |
| |
| params->oride.proxy_response_server_string = ats_strdup(m_master.oride.proxy_response_server_string); |
| params->oride.proxy_response_server_string_len = params->oride.proxy_response_server_string ? |
| strlen(params->oride.proxy_response_server_string) : 0; |
| params->oride.proxy_response_server_enabled = m_master.oride.proxy_response_server_enabled; |
| |
| params->oride.insert_squid_x_forwarded_for = INT_TO_BOOL(m_master.oride.insert_squid_x_forwarded_for); |
| params->oride.insert_age_in_response = INT_TO_BOOL(m_master.oride.insert_age_in_response); |
| params->enable_http_stats = INT_TO_BOOL(m_master.enable_http_stats); |
| params->oride.normalize_ae_gzip = INT_TO_BOOL(m_master.oride.normalize_ae_gzip); |
| |
| params->icp_enabled = (m_master.icp_enabled == ICP_MODE_SEND_RECEIVE ? 1 : 0); // INT_TO_BOOL |
| params->stale_icp_enabled = INT_TO_BOOL(m_master.stale_icp_enabled); |
| |
| params->oride.cache_heuristic_min_lifetime = m_master.oride.cache_heuristic_min_lifetime; |
| params->oride.cache_heuristic_max_lifetime = m_master.oride.cache_heuristic_max_lifetime; |
| params->oride.cache_heuristic_lm_factor = min(max(m_master.oride.cache_heuristic_lm_factor, 0), 1); |
| |
| params->oride.cache_guaranteed_min_lifetime = m_master.oride.cache_guaranteed_min_lifetime; |
| params->oride.cache_guaranteed_max_lifetime = m_master.oride.cache_guaranteed_max_lifetime; |
| |
| params->oride.cache_max_stale_age = m_master.oride.cache_max_stale_age; |
| params->oride.freshness_fuzz_time = m_master.oride.freshness_fuzz_time; |
| params->oride.freshness_fuzz_min_time = m_master.oride.freshness_fuzz_min_time; |
| params->oride.freshness_fuzz_prob = m_master.oride.freshness_fuzz_prob; |
| |
| params->cache_vary_default_text = ats_strdup(m_master.cache_vary_default_text); |
| params->cache_vary_default_images = ats_strdup(m_master.cache_vary_default_images); |
| params->cache_vary_default_other = ats_strdup(m_master.cache_vary_default_other); |
| |
| // open read failure retries |
| params->oride.max_cache_open_read_retries = m_master.oride.max_cache_open_read_retries; |
| params->oride.cache_open_read_retry_time = m_master.oride.cache_open_read_retry_time; |
| |
| // open write failure retries |
| params->max_cache_open_write_retries = m_master.max_cache_open_write_retries; |
| |
| params->oride.cache_http = INT_TO_BOOL(m_master.oride.cache_http); |
| params->oride.cache_cluster_cache_local = INT_TO_BOOL(m_master.oride.cache_cluster_cache_local); |
| params->oride.cache_ignore_client_no_cache = INT_TO_BOOL(m_master.oride.cache_ignore_client_no_cache); |
| params->oride.cache_ignore_client_cc_max_age = INT_TO_BOOL(m_master.oride.cache_ignore_client_cc_max_age); |
| params->oride.cache_ims_on_client_no_cache = INT_TO_BOOL(m_master.oride.cache_ims_on_client_no_cache); |
| params->oride.cache_ignore_server_no_cache = INT_TO_BOOL(m_master.oride.cache_ignore_server_no_cache); |
| params->oride.cache_responses_to_cookies = m_master.oride.cache_responses_to_cookies; |
| params->oride.cache_ignore_auth = INT_TO_BOOL(m_master.oride.cache_ignore_auth); |
| params->oride.cache_urls_that_look_dynamic = INT_TO_BOOL(m_master.oride.cache_urls_that_look_dynamic); |
| params->cache_enable_default_vary_headers = INT_TO_BOOL(m_master.cache_enable_default_vary_headers); |
| |
| params->ignore_accept_mismatch = m_master.ignore_accept_mismatch; |
| params->ignore_accept_language_mismatch = m_master.ignore_accept_language_mismatch; |
| params->ignore_accept_encoding_mismatch = m_master.ignore_accept_encoding_mismatch; |
| params->ignore_accept_charset_mismatch = m_master.ignore_accept_charset_mismatch; |
| |
| params->oride.cache_when_to_revalidate = m_master.oride.cache_when_to_revalidate; |
| params->cache_when_to_add_no_cache_to_msie_requests = m_master.cache_when_to_add_no_cache_to_msie_requests; |
| |
| params->oride.cache_required_headers = m_master.oride.cache_required_headers; |
| params->oride.cache_range_lookup = INT_TO_BOOL(m_master.oride.cache_range_lookup); |
| |
| params->connect_ports_string = ats_strdup(m_master.connect_ports_string); |
| params->connect_ports = parse_ports_list(params->connect_ports_string); |
| |
| params->oride.request_hdr_max_size = m_master.oride.request_hdr_max_size; |
| params->oride.response_hdr_max_size = m_master.oride.response_hdr_max_size; |
| |
| params->push_method_enabled = INT_TO_BOOL(m_master.push_method_enabled); |
| |
| params->reverse_proxy_enabled = INT_TO_BOOL(m_master.reverse_proxy_enabled); |
| params->url_remap_required = INT_TO_BOOL(m_master.url_remap_required); |
| params->errors_log_error_pages = INT_TO_BOOL(m_master.errors_log_error_pages); |
| params->slow_log_threshold = m_master.slow_log_threshold; |
| params->record_cop_page = INT_TO_BOOL(m_master.record_cop_page); |
| params->record_tcp_mem_hit = INT_TO_BOOL(m_master.record_tcp_mem_hit); |
| params->oride.send_http11_requests = m_master.oride.send_http11_requests; |
| params->oride.doc_in_cache_skip_dns = INT_TO_BOOL(m_master.oride.doc_in_cache_skip_dns); |
| params->oride.default_buffer_size_index = m_master.oride.default_buffer_size_index; |
| params->oride.default_buffer_water_mark = m_master.oride.default_buffer_water_mark; |
| params->enable_http_info = INT_TO_BOOL(m_master.enable_http_info); |
| params->reverse_proxy_no_host_redirect = ats_strdup(m_master.reverse_proxy_no_host_redirect); |
| params->reverse_proxy_no_host_redirect_len = |
| params->reverse_proxy_no_host_redirect ? strlen(params->reverse_proxy_no_host_redirect) : 0; |
| |
| params->referer_filter_enabled = INT_TO_BOOL(m_master.referer_filter_enabled); |
| params->referer_format_redirect = INT_TO_BOOL(m_master.referer_format_redirect); |
| |
| params->oride.accept_encoding_filter_enabled = INT_TO_BOOL(m_master.oride.accept_encoding_filter_enabled); |
| |
| params->oride.down_server_timeout = m_master.oride.down_server_timeout; |
| params->oride.client_abort_threshold = m_master.oride.client_abort_threshold; |
| |
| params->oride.negative_caching_enabled = INT_TO_BOOL(m_master.oride.negative_caching_enabled); |
| params->oride.negative_caching_lifetime = m_master.oride.negative_caching_lifetime; |
| params->oride.negative_revalidating_enabled = INT_TO_BOOL(m_master.oride.negative_revalidating_enabled); |
| params->oride.negative_revalidating_lifetime = m_master.oride.negative_revalidating_lifetime; |
| |
| //############################################################################## |
| //# |
| //# Redirection |
| //# |
| //# 1. redirection_enabled: if set to 1, redirection is enabled. |
| //# 2. number_of_redirections: The maximum number of redirections YTS permits |
| //# 3. post_copy_size: The maximum POST data size YTS permits to copy |
| //# |
| //############################################################################## |
| |
| params->redirection_enabled = INT_TO_BOOL(m_master.redirection_enabled); |
| params->number_of_redirections = m_master.number_of_redirections; |
| params->post_copy_size = m_master.post_copy_size; |
| |
| m_id = configProcessor.set(m_id, params); |
| |
| #undef INT_TO_BOOL |
| |
| // Redirection debug statements |
| Debug("http_init", "proxy.config.http.redirection_enabled = %d", params->redirection_enabled); |
| Debug("http_init", "proxy.config.http.number_of_redirections = %" PRId64"", params->number_of_redirections); |
| |
| Debug("http_init", "proxy.config.http.post_copy_size = %" PRId64"", params->post_copy_size); |
| } |
| |
| //////////////////////////////////////////////////////////////// |
| // |
| // HttpConfig::acquire() |
| // |
| //////////////////////////////////////////////////////////////// |
| HttpConfigParams * |
| HttpConfig::acquire() |
| { |
| if (m_id != 0) { |
| return (HttpConfigParams *) configProcessor.get(m_id); |
| } else { |
| return NULL; |
| } |
| } |
| |
| //////////////////////////////////////////////////////////////// |
| // |
| // HttpConfig::release() |
| // |
| //////////////////////////////////////////////////////////////// |
| void |
| HttpConfig::release(HttpConfigParams * params) |
| { |
| configProcessor.release(m_id, params); |
| } |
| |
| //////////////////////////////////////////////////////////////// |
| // |
| // HttpConfig::parse_ports_list() |
| // |
| //////////////////////////////////////////////////////////////// |
| HttpConfigPortRange * |
| HttpConfig::parse_ports_list(char *ports_string) |
| { |
| HttpConfigPortRange *ports_list = 0; |
| |
| if (!ports_string) |
| return (0); |
| |
| if (strchr(ports_string, '*')) { |
| ports_list = NEW(new HttpConfigPortRange); |
| ports_list->low = -1; |
| ports_list->high = -1; |
| ports_list->next = NULL; |
| } else { |
| HttpConfigPortRange *pr, *prev; |
| char *start; |
| char *end; |
| |
| pr = NULL; |
| prev = NULL; |
| |
| start = ports_string; |
| |
| while (1) { // eat whitespace |
| while ((start[0] != '\0') && ParseRules::is_space(start[0])) |
| start++; |
| |
| // locate the end of the next number |
| end = start; |
| while ((end[0] != '\0') && ParseRules::is_digit(end[0])) |
| end++; |
| |
| // if there is no next number we're done |
| if (start == end) |
| break; |
| |
| pr = NEW(new HttpConfigPortRange); |
| pr->low = atoi(start); |
| pr->high = pr->low; |
| pr->next = NULL; |
| |
| if (prev) |
| prev->next = pr; |
| else |
| ports_list = pr; |
| prev = pr; |
| |
| // if the next character after the current port |
| // number is a dash then we are parsing a range |
| if (end[0] == '-') { |
| start = end + 1; |
| while ((start[0] != '\0') && ParseRules::is_space(start[0])) |
| start++; |
| |
| end = start; |
| while ((end[0] != '\0') && ParseRules::is_digit(end[0])) |
| end++; |
| |
| if (start == end) |
| break; |
| |
| pr->high = atoi(start); |
| } |
| |
| start = end; |
| |
| ink_release_assert(pr->low <= pr->high); |
| } |
| } |
| return (ports_list); |
| } |
| |
| //////////////////////////////////////////////////////////////// |
| // |
| // HttpConfig::parse_url_expansions() |
| // |
| //////////////////////////////////////////////////////////////// |
| char ** |
| HttpConfig::parse_url_expansions(char *url_expansions_str, int *num_expansions) |
| { |
| char **expansions = NULL; |
| int count = 0, i; |
| |
| if (!url_expansions_str) { |
| *num_expansions = count; |
| return expansions; |
| } |
| // First count the number of URL expansions in the string |
| char *start = url_expansions_str, *end; |
| while (1) { |
| // Skip whitespace |
| while (isspace(*start)) |
| start++; |
| if (*start == '\0') |
| break; |
| count++; |
| end = start + 1; |
| |
| // Find end of expansion |
| while (!isspace(*end) && *end != '\0') |
| end++; |
| start = end; |
| } |
| |
| // Now extract the URL expansions |
| if (count) { |
| expansions = (char **)ats_malloc(count * sizeof(char *)); |
| start = url_expansions_str; |
| for (i = 0; i < count; i++) { |
| // Skip whitespace |
| while (isspace(*start)) |
| start++; |
| expansions[i] = start; |
| end = start + 1; |
| |
| // Find end of expansion |
| while (!isspace(*end) && *end != '\0') |
| end++; |
| *end = '\0'; |
| if (i < (count - 1)) |
| start = end + 1; |
| |
| } |
| } |
| |
| *num_expansions = count; |
| return expansions; |
| } |
| |
| |
| //////////////////////////////////////////////////////////////// |
| // |
| // HttpConfig::cluster_delta_cb |
| // |
| //////////////////////////////////////////////////////////////// |
| void * |
| HttpConfig::cluster_delta_cb(void * /* opaque_token ATS_UNUSED */, char *data_raw, int /* data_len ATS_UNUSED */) |
| { |
| int32_t delta32 = (int32_t) atoi(data_raw); |
| int32_t old; |
| |
| // Using ink_atomic_swap is mostly paranoia since a thirty bit write |
| // really ought to atomic. However, any risk of bogus time is |
| // too ugly for me to contemplate |
| old = ink_atomic_swap(&HttpConfig::m_master.cluster_time_delta, delta32); |
| Debug("http_trans", "Cluster time delta moving from %d to %d", old, delta32); |
| |
| return NULL; |
| |
| } |
| |
| volatile int32_t icp_dynamic_enabled; |