http_core.c revision 01034377c5f9c37762abb03c94ab0847e9f870e9
3802a3d3d7af51ddff31943d5514382f01265770Lennart Poettering/* Copyright 1999-2005 The Apache Software Foundation or its licensors, as
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * applicable.
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek *
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * Licensed under the Apache License, Version 2.0 (the "License");
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * you may not use this file except in compliance with the License.
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * You may obtain a copy of the License at
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek *
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * http://www.apache.org/licenses/LICENSE-2.0
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek *
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * Unless required by applicable law or agreed to in writing, software
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * distributed under the License is distributed on an "AS IS" BASIS,
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * See the License for the specific language governing permissions and
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * limitations under the License.
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek */
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "apr_strings.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "apr_thread_proc.h" /* for RLIMIT stuff */
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#define APR_WANT_STRFUNC
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "apr_want.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#define CORE_PRIVATE
301af7e4853ad0281402f8d86f5a77c6cb7ce9f4Josh Triplett#include "httpd.h"
301af7e4853ad0281402f8d86f5a77c6cb7ce9f4Josh Triplett#include "http_config.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "http_connection.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "http_core.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "http_protocol.h" /* For index_of_response(). Grump. */
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "http_request.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "util_filter.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "util_ebcdic.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "ap_mpm.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "scoreboard.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek#include "mod_core.h"
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek/* Handles for core filters */
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-SzmekAP_DECLARE_DATA ap_filter_rec_t *ap_http_input_filter_handle;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-SzmekAP_DECLARE_DATA ap_filter_rec_t *ap_http_header_filter_handle;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-SzmekAP_DECLARE_DATA ap_filter_rec_t *ap_chunk_filter_handle;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-SzmekAP_DECLARE_DATA ap_filter_rec_t *ap_byterange_filter_handle;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmekstatic const char *set_keep_alive_timeout(cmd_parms *cmd, void *dummy,
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek const char *arg)
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek{
301af7e4853ad0281402f8d86f5a77c6cb7ce9f4Josh Triplett const char *err = ap_check_cmd_context(cmd, NOT_IN_DIR_LOC_FILE|NOT_IN_LIMIT);
301af7e4853ad0281402f8d86f5a77c6cb7ce9f4Josh Triplett if (err != NULL) {
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek return err;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek }
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek cmd->server->keep_alive_timeout = apr_time_from_sec(atoi(arg));
301af7e4853ad0281402f8d86f5a77c6cb7ce9f4Josh Triplett return NULL;
301af7e4853ad0281402f8d86f5a77c6cb7ce9f4Josh Triplett}
301af7e4853ad0281402f8d86f5a77c6cb7ce9f4Josh Triplett
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmekstatic const char *set_keep_alive(cmd_parms *cmd, void *dummy,
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek const char *arg)
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek{
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek const char *err = ap_check_cmd_context(cmd, NOT_IN_DIR_LOC_FILE|NOT_IN_LIMIT);
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek if (err != NULL) {
18ead1b00dff180a97507d014325cb46198e6657Chris Mayo return err;
18ead1b00dff180a97507d014325cb46198e6657Chris Mayo }
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek /* We've changed it to On/Off, but used to use numbers
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek * so we accept anything but "Off" or "0" as "On"
e93549ef29c4123d9ee45acb5815048390201e49Zbigniew Jędrzejewski-Szmek */
301af7e4853ad0281402f8d86f5a77c6cb7ce9f4Josh Triplett if (!strcasecmp(arg, "off") || !strcmp(arg, "0")) {
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek cmd->server->keep_alive = 0;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek }
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek else {
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek cmd->server->keep_alive = 1;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek }
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek return NULL;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek}
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmekstatic const char *set_keep_alive_max(cmd_parms *cmd, void *dummy,
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek const char *arg)
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek{
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek const char *err = ap_check_cmd_context(cmd, NOT_IN_DIR_LOC_FILE|NOT_IN_LIMIT);
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek if (err != NULL) {
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek return err;
8d0e0ddda6501479eb69164687c83c1a7667b33aJan Engelhardt }
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek cmd->server->keep_alive_max = atoi(arg);
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek return NULL;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek}
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmekstatic const command_rec http_cmds[] = {
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek AP_INIT_TAKE1("KeepAliveTimeout", set_keep_alive_timeout, NULL, RSRC_CONF,
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek "Keep-Alive timeout duration (sec)"),
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek AP_INIT_TAKE1("MaxKeepAliveRequests", set_keep_alive_max, NULL, RSRC_CONF,
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek "Maximum number of Keep-Alive requests per connection, "
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek "or 0 for infinite"),
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek AP_INIT_TAKE1("KeepAlive", set_keep_alive, NULL, RSRC_CONF,
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek "Whether persistent connections should be On or Off"),
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek { NULL }
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek};
8c9571d0ae50656f730a5e37378d5c3dcf3b9789Lennart Poettering
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmekstatic const char *http_scheme(const request_rec *r)
442f7f155358a7396a350d3c47ea42e86bee4024Chris Atkinson{
8c9571d0ae50656f730a5e37378d5c3dcf3b9789Lennart Poettering return "http";
8c9571d0ae50656f730a5e37378d5c3dcf3b9789Lennart Poettering}
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmekstatic apr_port_t http_port(const request_rec *r)
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek{
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek return DEFAULT_HTTP_PORT;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek}
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmekstatic int ap_process_http_async_connection(conn_rec *c)
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek{
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek request_rec *r;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek conn_state_t *cs = c->cs;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek AP_DEBUG_ASSERT(cs->state == CONN_STATE_READ_REQUEST_LINE);
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek while (cs->state == CONN_STATE_READ_REQUEST_LINE) {
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek ap_update_child_status(c->sbh, SERVER_BUSY_READ, NULL);
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek if ((r = ap_read_request(c))) {
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek c->keepalive = AP_CONN_UNKNOWN;
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering /* process the request if it was read without error */
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering ap_update_child_status(c->sbh, SERVER_BUSY_WRITE, r);
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering if (r->status == HTTP_OK)
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering ap_process_request(r);
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering if (ap_extended_status)
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering ap_increment_counts(c->sbh, r);
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering if (c->keepalive != AP_CONN_KEEPALIVE || c->aborted
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering || ap_graceful_stop_signalled()) {
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering cs->state = CONN_STATE_LINGER;
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering }
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering else if (!c->data_in_input_filters) {
cbfaff65cb086e3eb3709cf86dcf63b46622389bKarel Zak cs->state = CONN_STATE_CHECK_REQUEST_LINE_READABLE;
5470c03b37d8421a903564c2c8028c8b8d67d403Lennart Poettering }
5470c03b37d8421a903564c2c8028c8b8d67d403Lennart Poettering
5470c03b37d8421a903564c2c8028c8b8d67d403Lennart Poettering /* else we are pipelining. Stay in READ_REQUEST_LINE state
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering * and stay in the loop
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek */
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek apr_pool_destroy(r->pool);
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek }
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek else { /* ap_read_request failed - client may have closed */
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek cs->state = CONN_STATE_LINGER;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek }
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek }
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering
0dc5d23c85db85f96b141d4d32deee8018e56a6aLennart Poettering return OK;
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek}
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmekstatic int ap_process_http_connection(conn_rec *c)
3cc765d2718ac9b4ff978044ceabf5ad59d73edfZbigniew Jędrzejewski-Szmek{
request_rec *r;
apr_socket_t *csd = NULL;
/*
* Read and process each request found on our connection
* until no requests are left or we decide to close.
*/
ap_update_child_status(c->sbh, SERVER_BUSY_READ, NULL);
while ((r = ap_read_request(c)) != NULL) {
c->keepalive = AP_CONN_UNKNOWN;
/* process the request if it was read without error */
ap_update_child_status(c->sbh, SERVER_BUSY_WRITE, r);
if (r->status == HTTP_OK)
ap_process_request(r);
if (ap_extended_status)
ap_increment_counts(c->sbh, r);
if (c->keepalive != AP_CONN_KEEPALIVE || c->aborted)
break;
ap_update_child_status(c->sbh, SERVER_BUSY_KEEPALIVE, r);
apr_pool_destroy(r->pool);
if (ap_graceful_stop_signalled())
break;
if (!csd) {
csd = ap_get_module_config(c->conn_config, &core_module);
}
apr_socket_opt_set(csd, APR_INCOMPLETE_READ, 1);
apr_socket_timeout_set(csd, c->base_server->keep_alive_timeout);
/* Go straight to select() to wait for the next request */
}
return OK;
}
static int http_create_request(request_rec *r)
{
if (!r->main && !r->prev) {
ap_add_output_filter_handle(ap_byterange_filter_handle,
NULL, r, r->connection);
ap_add_output_filter_handle(ap_content_length_filter_handle,
NULL, r, r->connection);
ap_add_output_filter_handle(ap_http_header_filter_handle,
NULL, r, r->connection);
}
return OK;
}
static void register_hooks(apr_pool_t *p)
{
/**
* If we ae using an MPM That Supports Async Connections,
* use a different processing function
*/
int async_mpm = 0;
if (ap_mpm_query(AP_MPMQ_IS_ASYNC, &async_mpm) == APR_SUCCESS
&& async_mpm == 1) {
ap_hook_process_connection(ap_process_http_async_connection, NULL,
NULL, APR_HOOK_REALLY_LAST);
}
else {
ap_hook_process_connection(ap_process_http_connection, NULL, NULL,
APR_HOOK_REALLY_LAST);
}
ap_hook_map_to_storage(ap_send_http_trace,NULL,NULL,APR_HOOK_MIDDLE);
ap_hook_http_scheme(http_scheme,NULL,NULL,APR_HOOK_REALLY_LAST);
ap_hook_default_port(http_port,NULL,NULL,APR_HOOK_REALLY_LAST);
ap_hook_create_request(http_create_request, NULL, NULL, APR_HOOK_REALLY_LAST);
ap_http_input_filter_handle =
ap_register_input_filter("HTTP_IN", ap_http_filter,
NULL, AP_FTYPE_PROTOCOL);
ap_http_header_filter_handle =
ap_register_output_filter("HTTP_HEADER", ap_http_header_filter,
NULL, AP_FTYPE_PROTOCOL);
ap_chunk_filter_handle =
ap_register_output_filter("CHUNK", ap_http_chunk_filter,
NULL, AP_FTYPE_TRANSCODE);
ap_byterange_filter_handle =
ap_register_output_filter("BYTERANGE", ap_byterange_filter,
NULL, AP_FTYPE_PROTOCOL);
ap_method_registry_init(p);
}
module AP_MODULE_DECLARE_DATA http_module = {
STANDARD20_MODULE_STUFF,
NULL, /* create per-directory config structure */
NULL, /* merge per-directory config structures */
NULL, /* create per-server config structure */
NULL, /* merge per-server config structures */
http_cmds, /* command apr_table_t */
register_hooks /* register hooks */
};