mod_reqtimeout.c with more debug logs

mod_reqtimeout.c.debug (text/plain), 22.89 KB, created by Frank Meier on 2014-03-06 10:04:51 UTC

(hide)

Description: mod_reqtimeout.c with more debug logs

Filename:

MIME Type:

Creator: Frank Meier

Created: 2014-03-06 10:04:51 UTC

Size: 22.89 KB

patch

obsolete

>/* 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 "httpd.h" >#include "http_config.h" >#include "http_request.h" >#include "http_connection.h" >#include "http_protocol.h" >#include "http_log.h" >#include "http_core.h" >#include "util_filter.h" >#define APR_WANT_STRFUNC >#include "apr_strings.h" >#include "apr_version.h" > >module AP_MODULE_DECLARE_DATA reqtimeout_module; > >#define UNSET -1 >#define MRT_DEFAULT_HEADER_TIMEOUT 20 >#define MRT_DEFAULT_HEADER_MAX_TIMEOUT 40 >#define MRT_DEFAULT_HEADER_MIN_RATE 500 >#define MRT_DEFAULT_BODY_TIMEOUT 20 >#define MRT_DEFAULT_BODY_MAX_TIMEOUT 0 >#define MRT_DEFAULT_BODY_MIN_RATE 500 > >typedef struct >{ > int header_timeout; /* timeout for reading the req hdrs in secs */ > int header_max_timeout; /* max timeout for req hdrs in secs */ > int header_min_rate; /* min rate for reading req hdrs in bytes/s */ > apr_time_t header_rate_factor; > int body_timeout; /* timeout for reading the req body in secs */ > int body_max_timeout; /* max timeout for req body in secs */ > int body_min_rate; /* min rate for reading req body in bytes/s */ > apr_time_t body_rate_factor; >} reqtimeout_srv_cfg; > >/* this struct is used both as conn_config and as filter context */ >typedef struct >{ > apr_time_t timeout_at; > apr_time_t max_timeout_at; > int min_rate; > int new_timeout; > int new_max_timeout; > int in_keep_alive; > char *type; > apr_socket_t *socket; > apr_time_t rate_factor; > apr_bucket_brigade *tmpbb; >} reqtimeout_con_cfg; > >static const char *const reqtimeout_filter_name = "reqtimeout"; >static int default_header_rate_factor; >static int default_body_rate_factor; > >static void extend_timeout(reqtimeout_con_cfg *ccfg, apr_bucket_brigade *bb) >{ > apr_off_t len; > apr_time_t new_timeout_at; > > if (apr_brigade_length(bb, 0, &len) != APR_SUCCESS || len <= 0) > return; > > new_timeout_at = ccfg->timeout_at + len * ccfg->rate_factor; > if (ccfg->max_timeout_at > 0 && new_timeout_at > ccfg->max_timeout_at) { > ccfg->timeout_at = ccfg->max_timeout_at; > } > else { > ccfg->timeout_at = new_timeout_at; > } >} > >static apr_status_t check_time_left(reqtimeout_con_cfg *ccfg, > apr_time_t *time_left_p, > apr_time_t now) >{ > if (!now) > now = apr_time_now(); > *time_left_p = ccfg->timeout_at - now; > if (*time_left_p <= 0) > return APR_TIMEUP; > > if (*time_left_p < apr_time_from_sec(1)) { > *time_left_p = apr_time_from_sec(1); > } > return APR_SUCCESS; >} > >static apr_status_t have_lf_or_eos(apr_bucket_brigade *bb) >{ > apr_bucket *b = APR_BRIGADE_LAST(bb); > > for ( ; b != APR_BRIGADE_SENTINEL(bb) ; b = APR_BUCKET_PREV(b) ) { > const char *str; > apr_size_t len; > apr_status_t rv; > > if (APR_BUCKET_IS_EOS(b)) > return APR_SUCCESS; > > if (APR_BUCKET_IS_METADATA(b)) > continue; > > rv = apr_bucket_read(b, &str, &len, APR_BLOCK_READ); > if (rv != APR_SUCCESS) > return rv; > > if (len == 0) > continue; > > if (str[len-1] == APR_ASCII_LF) > return APR_SUCCESS; > } > return APR_INCOMPLETE; >} > >/* > * Append bbIn to bbOut and merge small buckets, to avoid DoS by high memory > * usage > */ >static apr_status_t brigade_append(apr_bucket_brigade *bbOut, apr_bucket_brigade *bbIn) >{ > while (!APR_BRIGADE_EMPTY(bbIn)) { > apr_bucket *e = APR_BRIGADE_FIRST(bbIn); > const char *str; > apr_size_t len; > apr_status_t rv; > > rv = apr_bucket_read(e, &str, &len, APR_BLOCK_READ); > if (rv != APR_SUCCESS) { > return rv; > } > > APR_BUCKET_REMOVE(e); > if (APR_BUCKET_IS_METADATA(e) || len > APR_BUCKET_BUFF_SIZE/4) { > APR_BRIGADE_INSERT_TAIL(bbOut, e); > } > else { > if (len > 0) { > rv = apr_brigade_write(bbOut, NULL, NULL, str, len); > if (rv != APR_SUCCESS) { > apr_bucket_destroy(e); > return rv; > } > } > apr_bucket_destroy(e); > } > } > return APR_SUCCESS; >} > > >#define MIN(x,y) ((x) < (y) ? (x) : (y)) >static apr_status_t reqtimeout_filter(ap_filter_t *f, > apr_bucket_brigade *bb, > ap_input_mode_t mode, > apr_read_type_e block, > apr_off_t readbytes) >{ > apr_time_t time_left; > apr_time_t now = 0; > apr_status_t rv; > apr_interval_time_t saved_sock_timeout = UNSET; > reqtimeout_con_cfg *ccfg = f->ctx; > > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: ctx:%x", ccfg); > > if (ccfg->in_keep_alive) { > /* For this read, the normal keep-alive timeout must be used */ > ccfg->in_keep_alive = 0; > return ap_get_brigade(f->next, bb, mode, block, readbytes); > } > > if (ccfg->new_timeout > 0) { > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: new_timeout == %d", ccfg->new_timeout ); > /* set new timeout */ > now = apr_time_now(); > ccfg->timeout_at = now + apr_time_from_sec(ccfg->new_timeout); > ccfg->new_timeout = 0; > if (ccfg->new_max_timeout > 0) { > ccfg->max_timeout_at = now + apr_time_from_sec(ccfg->new_max_timeout); > ccfg->new_max_timeout = 0; > } > } > else if (ccfg->timeout_at == 0) { > /* no timeout set */ > return ap_get_brigade(f->next, bb, mode, block, readbytes); > } > > if (!ccfg->socket) { > ccfg->socket = ap_get_conn_socket(f->c); > } > > rv = check_time_left(ccfg, &time_left, now); > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: 1) check_time_left %d -> %d", time_left, rv ); > > if (rv != APR_SUCCESS) > goto out; > > if (block == APR_NONBLOCK_READ || mode == AP_MODE_INIT > || mode == AP_MODE_EATCRLF) { > rv = ap_get_brigade(f->next, bb, mode, block, readbytes); > if (ccfg->min_rate > 0 && rv == APR_SUCCESS) { > extend_timeout(ccfg, bb); > } > return rv; > } > > rv = apr_socket_timeout_get(ccfg->socket, &saved_sock_timeout); > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: apr_socket_timeout_get:%d rv:%d", saved_sock_timeout, rv ); > AP_DEBUG_ASSERT(rv == APR_SUCCESS); > > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: apr_socket_timeout_set:%d", MIN(time_left, saved_sock_timeout) ); > rv = apr_socket_timeout_set(ccfg->socket, MIN(time_left, saved_sock_timeout)); > //ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: rv debug:%d", rv ); > AP_DEBUG_ASSERT(rv == APR_SUCCESS); > > if (mode == AP_MODE_GETLINE) { > /* > * For a blocking AP_MODE_GETLINE read, apr_brigade_split_line() > * would loop until a whole line has been read. As this would make it > * impossible to enforce a total timeout, we only do non-blocking > * reads. > */ > apr_off_t remaining = HUGE_STRING_LEN; > do { > apr_off_t bblen; >#if APR_MAJOR_VERSION < 2 > apr_int32_t nsds; > apr_interval_time_t poll_timeout; > apr_pollfd_t pollset; >#endif > > rv = ap_get_brigade(f->next, bb, AP_MODE_GETLINE, APR_NONBLOCK_READ, remaining); > //ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: rv debug:%d", rv ); > if (rv != APR_SUCCESS && !APR_STATUS_IS_EAGAIN(rv)) { > break; > } > > if (!APR_BRIGADE_EMPTY(bb)) { > if (ccfg->min_rate > 0) { > extend_timeout(ccfg, bb); > } > > rv = have_lf_or_eos(bb); > //ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: rv debug:%d", rv ); > if (rv != APR_INCOMPLETE) { > break; > } > > rv = apr_brigade_length(bb, 1, &bblen); > //ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: rv debug:%d", rv ); > if (rv != APR_SUCCESS) { > break; > } > remaining -= bblen; > if (remaining <= 0) { > break; > } > > /* Haven't got a whole line yet, save what we have ... */ > if (!ccfg->tmpbb) { > ccfg->tmpbb = apr_brigade_create(f->c->pool, f->c->bucket_alloc); > } > rv = brigade_append(ccfg->tmpbb, bb); > //ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: rv debug:%d", rv ); > if (rv != APR_SUCCESS) > break; > } > > /* ... and wait for more */ >#if APR_MAJOR_VERSION < 2 > pollset.p = f->c->pool; > pollset.desc_type = APR_POLL_SOCKET; > pollset.reqevents = APR_POLLIN|APR_POLLHUP; > pollset.desc.s = ccfg->socket; > apr_socket_timeout_get(ccfg->socket, &poll_timeout); > rv = apr_poll(&pollset, 1, &nsds, poll_timeout); >#else > rv = apr_socket_wait(ccfg->socket, APR_WAIT_READ); >#endif > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: after apr_socket_wait rv:%d", rv ); > if (rv != APR_SUCCESS) > break; > > rv = check_time_left(ccfg, &time_left, 0); > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: 2) check_time_left:%d saved_sock_timeout:%d -> %d", time_left, saved_sock_timeout, rv ); > > if (rv != APR_SUCCESS) > break; > > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: apr_socket_timeout_set:%d", MIN(time_left, saved_sock_timeout) ); > rv = apr_socket_timeout_set(ccfg->socket, MIN(time_left, saved_sock_timeout)); > //ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: rv debug:%d", rv ); > AP_DEBUG_ASSERT(rv == APR_SUCCESS); > > } while (1); > > if (ccfg->tmpbb) > APR_BRIGADE_PREPEND(bb, ccfg->tmpbb); > > } > else { > /* mode != AP_MODE_GETLINE */ > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: mode == %d -> ap_get_brigate(f->next...", mode ); > rv = ap_get_brigade(f->next, bb, mode, block, readbytes); > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: rv debug:%d", rv ); > if (ccfg->min_rate > 0 && rv == APR_SUCCESS) { > extend_timeout(ccfg, bb); > } > } > > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, f->c, "reqtimeout_filter: restore socket_timeout:%d", saved_sock_timeout ); > apr_socket_timeout_set(ccfg->socket, saved_sock_timeout); > >out: > if (APR_STATUS_IS_TIMEUP(rv)) { > ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, f->c, APLOGNO(01382) > "Request %s read timeout", ccfg->type); > /* > * If we allow a normal lingering close, the client may keep this > * process/thread busy for another 30s (MAX_SECS_TO_LINGER). > * Therefore we tell ap_lingering_close() to shorten this period to > * 2s (SECONDS_TO_LINGER). > */ > apr_table_setn(f->c->notes, "short-lingering-close", "1"); > > /* > * Also, we must not allow keep-alive requests, as > * ap_finalize_protocol() may ignore our error status (if the timeout > * happened on a request body that is discarded). > */ > f->c->keepalive = AP_CONN_CLOSE; > } > return rv; >} > >static int reqtimeout_init(conn_rec *c) >{ > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, c, "reqtimeout_init: con_rec:%x", c ); > > reqtimeout_con_cfg *ccfg; > reqtimeout_srv_cfg *cfg; > > cfg = ap_get_module_config(c->base_server->module_config, > &reqtimeout_module); > AP_DEBUG_ASSERT(cfg != NULL); > if (cfg->header_timeout == 0 && cfg->body_timeout == 0) { > /* disabled for this vhost */ > return DECLINED; > } > > ccfg = ap_get_module_config(c->conn_config, &reqtimeout_module); > if ( NULL == ccfg ) > { > ccfg = apr_pcalloc(c->pool, sizeof(reqtimeout_con_cfg)); > ap_set_module_config(c->conn_config, &reqtimeout_module, ccfg); > ap_add_input_filter("reqtimeout", ccfg, NULL, c); > } > ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, c, "reqtimeout_init: reqtimeout ctx:%x con_rec:%x", ccfg, c ); > >// ccfg = apr_pcalloc(c->pool, sizeof(reqtimeout_con_cfg)); > ccfg->type = "header"; > if (cfg->header_timeout != UNSET) { > ccfg->new_timeout = cfg->header_timeout; > ccfg->new_max_timeout = cfg->header_max_timeout; > ccfg->min_rate = cfg->header_min_rate; > ccfg->rate_factor = cfg->header_rate_factor; > } > else { > ccfg->new_timeout = MRT_DEFAULT_HEADER_TIMEOUT; > ccfg->new_max_timeout = MRT_DEFAULT_HEADER_MAX_TIMEOUT; > ccfg->min_rate = MRT_DEFAULT_HEADER_MIN_RATE; > ccfg->rate_factor = default_header_rate_factor; > } >// ap_set_module_config(c->conn_config, &reqtimeout_module, ccfg); > >// ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, c, "reqtimeout_init: reqtimeout ctx:%x con_rec:%x", ccfg, c ); >// ap_add_input_filter("reqtimeout", ccfg, NULL, c); > /* we are not handling the connection, we just do initialization */ > return DECLINED; >} > >static int reqtimeout_after_headers(request_rec *r) >{ > reqtimeout_srv_cfg *cfg; > reqtimeout_con_cfg *ccfg = > ap_get_module_config(r->connection->conn_config, &reqtimeout_module); > > ap_log_rerror(APLOG_MARK, APLOG_DEBUG, 0, r, "reqtimeout_after_headers: reqtimeout ctx:%x", ccfg); > > if (ccfg == NULL || r->method_number == M_CONNECT) { > /* either disabled for this connection or a CONNECT request */ > return OK; > } > cfg = ap_get_module_config(r->connection->base_server->module_config, > &reqtimeout_module); > AP_DEBUG_ASSERT(cfg != NULL); > > ccfg->timeout_at = 0; > ccfg->max_timeout_at = 0; > ccfg->type = "body"; > if (cfg->body_timeout != UNSET) { > ccfg->new_timeout = cfg->body_timeout; > ccfg->new_max_timeout = cfg->body_max_timeout; > ccfg->min_rate = cfg->body_min_rate; > ccfg->rate_factor = cfg->body_rate_factor; > } > else { > ccfg->new_timeout = MRT_DEFAULT_BODY_TIMEOUT; > ccfg->new_max_timeout = MRT_DEFAULT_BODY_MAX_TIMEOUT; > ccfg->min_rate = MRT_DEFAULT_BODY_MIN_RATE; > ccfg->rate_factor = default_body_rate_factor; > } > ap_log_rerror(APLOG_MARK, APLOG_DEBUG, 0, r, "reqtimeout_after_headers: new->timeout:%d", ccfg->new_timeout); > > return OK; >} > >static int reqtimeout_after_body(request_rec *r) >{ > reqtimeout_srv_cfg *cfg; > reqtimeout_con_cfg *ccfg = > ap_get_module_config(r->connection->conn_config, &reqtimeout_module); > > ap_log_rerror(APLOG_MARK, APLOG_DEBUG, 0, r, "reqtimeout_after_body: reqtimeout ctx:%x", ccfg); > > if (ccfg == NULL) { > /* not configured for this connection */ > return OK; > } > > cfg = ap_get_module_config(r->connection->base_server->module_config, > &reqtimeout_module); > AP_DEBUG_ASSERT(cfg != NULL); > > ccfg->timeout_at = 0; > ccfg->max_timeout_at = 0; > ccfg->in_keep_alive = 1; > ccfg->type = "header"; > if (ccfg->new_timeout != UNSET) { > ccfg->new_timeout = cfg->header_timeout; > ccfg->new_max_timeout = cfg->header_max_timeout; > ccfg->min_rate = cfg->header_min_rate; > ccfg->rate_factor = cfg->header_rate_factor; > } > else { > ccfg->new_timeout = MRT_DEFAULT_HEADER_TIMEOUT; > ccfg->new_max_timeout = MRT_DEFAULT_HEADER_MAX_TIMEOUT; > ccfg->min_rate = MRT_DEFAULT_HEADER_MIN_RATE; > ccfg->rate_factor = default_header_rate_factor; > } > > return OK; >} > >static void *reqtimeout_create_srv_config(apr_pool_t *p, server_rec *s) >{ > reqtimeout_srv_cfg *cfg = apr_pcalloc(p, sizeof(reqtimeout_srv_cfg)); > > cfg->header_timeout = UNSET; > cfg->header_max_timeout = UNSET; > cfg->header_min_rate = UNSET; > cfg->body_timeout = UNSET; > cfg->body_max_timeout = UNSET; > cfg->body_min_rate = UNSET; > > return cfg; >} > >#define MERGE_INT(cfg, b, a, val) cfg->val = (a->val == UNSET) ? b->val : a->val; >static void *reqtimeout_merge_srv_config(apr_pool_t *p, void *base_, void *add_) >{ > reqtimeout_srv_cfg *base = base_; > reqtimeout_srv_cfg *add = add_; > reqtimeout_srv_cfg *cfg = apr_pcalloc(p, sizeof(reqtimeout_srv_cfg)); > > MERGE_INT(cfg, base, add, header_timeout); > MERGE_INT(cfg, base, add, header_max_timeout); > MERGE_INT(cfg, base, add, header_min_rate); > MERGE_INT(cfg, base, add, body_timeout); > MERGE_INT(cfg, base, add, body_max_timeout); > MERGE_INT(cfg, base, add, body_min_rate); > > cfg->header_rate_factor = (cfg->header_min_rate == UNSET) ? > base->header_rate_factor : add->header_rate_factor; > cfg->body_rate_factor = (cfg->body_min_rate == UNSET) ? > base->body_rate_factor : add->body_rate_factor; > return cfg; >} > >static const char *parse_int(apr_pool_t *p, const char *arg, int *val) { > char *endptr; > *val = strtol(arg, &endptr, 10); > > if (arg == endptr) { > return apr_psprintf(p, "Value '%s' not numerical", endptr); > } > if (*endptr != '\0') { > return apr_psprintf(p, "Cannot parse '%s'", endptr); > } > if (*val < 0) { > return "Value must be non-negative"; > } > return NULL; >} > >static const char *set_reqtimeout_param(reqtimeout_srv_cfg *conf, > apr_pool_t *p, > const char *key, > const char *val) >{ > const char *ret = NULL; > char *rate_str = NULL, *initial_str, *max_str = NULL; > int rate = 0, initial = 0, max = 0; > enum { PARAM_HEADER, PARAM_BODY } type; > > if (!strcasecmp(key, "header")) { > type = PARAM_HEADER; > } > else if (!strcasecmp(key, "body")) { > type = PARAM_BODY; > } > else { > return "Unknown RequestReadTimeout parameter"; > } > > if ((rate_str = ap_strcasestr(val, ",minrate="))) { > initial_str = apr_pstrndup(p, val, rate_str - val); > rate_str += strlen(",minrate="); > ret = parse_int(p, rate_str, &rate); > if (ret) > return ret; > > if (rate == 0) > return "Minimum data rate must be larger than 0"; > > if ((max_str = strchr(initial_str, '-'))) { > *max_str++ = '\0'; > ret = parse_int(p, max_str, &max); > if (ret) > return ret; > } > > ret = parse_int(p, initial_str, &initial); > } > else { > if (ap_strchr_c(val, '-')) > return "Must set MinRate option if using timeout range"; > ret = parse_int(p, val, &initial); > } > > if (ret) > return ret; > > if (max && initial >= max) { > return "Maximum timeout must be larger than initial timeout"; > } > > if (type == PARAM_HEADER) { > conf->header_timeout = initial; > conf->header_max_timeout = max; > conf->header_min_rate = rate; > if (rate) > conf->header_rate_factor = apr_time_from_sec(1) / rate; > } > else { > conf->body_timeout = initial; > conf->body_max_timeout = max; > conf->body_min_rate = rate; > if (rate) > conf->body_rate_factor = apr_time_from_sec(1) / rate; > } > return ret; >} > >static const char *set_reqtimeouts(cmd_parms *cmd, void *mconfig, > const char *arg) >{ > reqtimeout_srv_cfg *conf = > ap_get_module_config(cmd->server->module_config, > &reqtimeout_module); > > while (*arg) { > char *word, *val; > const char *err; > > word = ap_getword_conf(cmd->temp_pool, &arg); > val = strchr(word, '='); > if (!val) { > return "Invalid RequestReadTimeout parameter. Parameter must be " > "in the form 'key=value'"; > } > else > *val++ = '\0'; > > err = set_reqtimeout_param(conf, cmd->pool, word, val); > > if (err) > return apr_psprintf(cmd->temp_pool, "RequestReadTimeout: %s=%s: %s", > word, val, err); > } > > return NULL; > >} > >static void reqtimeout_hooks(apr_pool_t *pool) >{ > /* > * mod_ssl is AP_FTYPE_CONNECTION + 5 and mod_reqtimeout needs to > * be called before mod_ssl. Otherwise repeated reads during the ssl > * handshake can prevent the timeout from triggering. > */ > ap_register_input_filter(reqtimeout_filter_name, reqtimeout_filter, NULL, > AP_FTYPE_CONNECTION + 8); > > /* > * mod_reqtimeout needs to be called before ap_process_http_request (which > * is run at APR_HOOK_REALLY_LAST) but after all other protocol modules. > * This ensures that it only influences normal http connections and not > * e.g. mod_ftp. Also, if mod_reqtimeout used the pre_connection hook, it > * would be inserted on mod_proxy's backend connections. > */ > ap_hook_process_connection(reqtimeout_init, NULL, NULL, APR_HOOK_LAST); > > ap_hook_post_read_request(reqtimeout_after_headers, NULL, NULL, > APR_HOOK_MIDDLE); > ap_hook_log_transaction(reqtimeout_after_body, NULL, NULL, > APR_HOOK_MIDDLE); > >#if MRT_DEFAULT_HEADER_MIN_RATE > 0 > default_header_rate_factor = apr_time_from_sec(1) / MRT_DEFAULT_HEADER_MIN_RATE; >#endif >#if MRT_DEFAULT_BODY_MIN_RATE > 0 > default_body_rate_factor = apr_time_from_sec(1) / MRT_DEFAULT_BODY_MIN_RATE; >#endif >} > >static const command_rec reqtimeout_cmds[] = { > AP_INIT_RAW_ARGS("RequestReadTimeout", set_reqtimeouts, NULL, RSRC_CONF, > "Set various timeout parameters for reading request " > "headers and body"), > {NULL} >}; > >AP_DECLARE_MODULE(reqtimeout) = { > STANDARD20_MODULE_STUFF, > NULL, /* create per-dir config structures */ > NULL, /* merge per-dir config structures */ > reqtimeout_create_srv_config, /* create per-server config structures */ > reqtimeout_merge_srv_config, /* merge per-server config structures */ > reqtimeout_cmds, /* table of config file commands */ > reqtimeout_hooks >}; View Attachment As Raw

This is ASF Bugzilla: the Apache Software Foundation bug system. In case of problems with the functioning of ASF Bugzilla, please contact bugzilla-admin@apache.org. Please Note: this e-mail address is only for reporting problems with ASF Bugzilla. Mail about any other subject will be silently ignored.

• • Home
  • | New
  • | Browse
  • | Search
  • |
    [?]
  • | Reports
  • | Help
  • | New Account
  • | Log In
    Remember [x]
  • | Forgot Password
    Login: [x]