Mercurial > hg > nginx-quic
view src/http/ngx_http_core_module.c @ 136:da00cde00e8a
nginx-0.0.1-2003-10-02-09:39:37 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Thu, 02 Oct 2003 05:39:37 +0000 |
parents | cd54bcbaf3b5 |
children | 5526213be452 |
line wrap: on
line source
#include <ngx_config.h> #include <ngx_core.h> #include <ngx_http.h> #include <nginx.h> /* STUB */ int ngx_http_static_handler(ngx_http_request_t *r); static int ngx_http_core_index_handler(ngx_http_request_t *r); static void *ngx_http_core_create_main_conf(ngx_conf_t *cf); static char *ngx_http_core_init_main_conf(ngx_conf_t *cf, void *conf); static void *ngx_http_core_create_srv_conf(ngx_conf_t *cf); static char *ngx_http_core_merge_srv_conf(ngx_conf_t *cf, void *parent, void *child); static void *ngx_http_core_create_loc_conf(ngx_conf_t *cf); static char *ngx_http_core_merge_loc_conf(ngx_conf_t *cf, void *parent, void *child); static int ngx_http_core_init(ngx_cycle_t *cycle); static char *ngx_server_block(ngx_conf_t *cf, ngx_command_t *cmd, void *dummy); static int ngx_cmp_locations(const void *first, const void *second); static char *ngx_location_block(ngx_conf_t *cf, ngx_command_t *cmd, void *dummy); static char *ngx_types_block(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); static char *ngx_set_type(ngx_conf_t *cf, ngx_command_t *dummy, void *conf); static char *ngx_set_listen(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); static char *ngx_set_server_name(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); static char *ngx_set_error_log(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); static ngx_command_t ngx_http_core_commands[] = { {ngx_string("server"), NGX_HTTP_MAIN_CONF|NGX_CONF_BLOCK|NGX_CONF_NOARGS, ngx_server_block, 0, 0, NULL}, {ngx_string("connection_pool_size"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_CONF_TAKE1, ngx_conf_set_size_slot, NGX_HTTP_SRV_CONF_OFFSET, offsetof(ngx_http_core_srv_conf_t, connection_pool_size), NULL}, {ngx_string("post_accept_timeout"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_CONF_TAKE1, ngx_conf_set_msec_slot, NGX_HTTP_SRV_CONF_OFFSET, offsetof(ngx_http_core_srv_conf_t, post_accept_timeout), NULL}, {ngx_string("request_pool_size"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_CONF_TAKE1, ngx_conf_set_size_slot, NGX_HTTP_SRV_CONF_OFFSET, offsetof(ngx_http_core_srv_conf_t, request_pool_size), NULL}, {ngx_string("client_header_timeout"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_CONF_TAKE1, ngx_conf_set_msec_slot, NGX_HTTP_SRV_CONF_OFFSET, offsetof(ngx_http_core_srv_conf_t, client_header_timeout), NULL}, {ngx_string("client_header_buffer_size"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_CONF_TAKE1, ngx_conf_set_size_slot, NGX_HTTP_SRV_CONF_OFFSET, offsetof(ngx_http_core_srv_conf_t, client_header_buffer_size), NULL}, {ngx_string("large_client_header"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_CONF_FLAG, ngx_conf_set_flag_slot, NGX_HTTP_SRV_CONF_OFFSET, offsetof(ngx_http_core_srv_conf_t, large_client_header), NULL}, {ngx_string("location"), NGX_HTTP_SRV_CONF|NGX_CONF_BLOCK|NGX_CONF_TAKE1, ngx_location_block, NGX_HTTP_SRV_CONF_OFFSET, 0, NULL}, {ngx_string("listen"), #if 0 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_CONF_TAKE1, #else NGX_HTTP_SRV_CONF|NGX_CONF_TAKE1, #endif ngx_set_listen, NGX_HTTP_SRV_CONF_OFFSET, 0, NULL}, {ngx_string("server_name"), NGX_HTTP_SRV_CONF|NGX_CONF_1MORE, ngx_set_server_name, NGX_HTTP_SRV_CONF_OFFSET, 0, NULL}, {ngx_string("types"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF |NGX_CONF_BLOCK|NGX_CONF_NOARGS, ngx_types_block, NGX_HTTP_LOC_CONF_OFFSET, 0, NULL}, {ngx_string("default_type"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_str_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_core_loc_conf_t, default_type), NULL}, {ngx_string("root"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_str_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_core_loc_conf_t, doc_root), NULL}, {ngx_string("sendfile"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_flag_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_core_loc_conf_t, sendfile), NULL}, {ngx_string("send_timeout"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_msec_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_core_loc_conf_t, send_timeout), NULL}, {ngx_string("keepalive_timeout"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_msec_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_core_loc_conf_t, keepalive_timeout), NULL}, {ngx_string("lingering_time"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_msec_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_core_loc_conf_t, lingering_time), NULL}, {ngx_string("lingering_timeout"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_msec_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_core_loc_conf_t, lingering_timeout), NULL}, {ngx_string("error_log"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_set_error_log, NGX_HTTP_LOC_CONF_OFFSET, 0, NULL}, ngx_null_command }; ngx_http_module_t ngx_http_core_module_ctx = { ngx_http_core_create_main_conf, /* create main configuration */ ngx_http_core_init_main_conf, /* init main configuration */ ngx_http_core_create_srv_conf, /* create server configuration */ ngx_http_core_merge_srv_conf, /* merge server configuration */ ngx_http_core_create_loc_conf, /* create location configuration */ ngx_http_core_merge_loc_conf /* merge location configuration */ }; ngx_module_t ngx_http_core_module = { NGX_MODULE, &ngx_http_core_module_ctx, /* module context */ ngx_http_core_commands, /* module directives */ NGX_HTTP_MODULE, /* module type */ ngx_http_core_init, /* init module */ NULL /* init child */ }; void ngx_http_handler(ngx_http_request_t *r) { int rc, i; ngx_http_log_ctx_t *lcx; ngx_http_handler_pt *h; ngx_http_core_loc_conf_t *clcf, **clcfp; ngx_http_core_srv_conf_t *cscf; ngx_http_core_main_conf_t *cmcf; r->connection->unexpected_eof = 0; lcx = r->connection->log->data; lcx->action = NULL; r->keepalive = 1; if (r->headers_in.content_length_n > 0) { r->lingering_close = 1; } /* TEST STUB */ r->lingering_close = 1; /* TODO: run rewrite url phase */ /* find location config */ cscf = ngx_http_get_module_srv_conf(r, ngx_http_core_module); clcfp = cscf->locations.elts; for (i = 0; i < cscf->locations.nelts; i++) { #if 0 ngx_log_debug(r->connection->log, "trans: %s" _ clcfp[i]->name.data); #endif if (r->uri.len < clcfp[i]->name.len) { continue; } rc = ngx_strncmp(r->uri.data, clcfp[i]->name.data, clcfp[i]->name.len); ngx_log_debug(r->connection->log, "rc: %d" _ rc); if (rc < 0) { break; } if (rc == 0) { r->loc_conf = clcfp[i]->loc_conf; clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module); r->connection->log->file = clcf->err_log->file; r->connection->log->log_level = clcf->err_log->log_level; } } clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module); if ((ngx_io.flags & NGX_IO_SENDFILE) == 0 || clcf->sendfile == 0) { r->filter = NGX_HTTP_FILTER_NEED_IN_MEMORY; } cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module); /* run translation phase */ h = cmcf->translate_handlers.elts; for (i = cmcf->translate_handlers.nelts - 1; i >= 0; i--) { rc = h[i](r); if (rc == NGX_DECLINED) { continue; } if (rc >= NGX_HTTP_SPECIAL_RESPONSE) { ngx_http_finalize_request(r, rc); return; } if (rc == NGX_OK) { rc = r->handler(r); if (rc >= NGX_HTTP_SPECIAL_RESPONSE) { ngx_http_finalize_request(r, rc); } return; } } /* TODO: no handlers found ? */ ngx_http_finalize_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR); return; } int ngx_http_core_translate_handler(ngx_http_request_t *r) { char *location, *last; ngx_err_t err; ngx_table_elt_t *h; ngx_http_core_srv_conf_t *cscf; ngx_http_core_loc_conf_t *clcf; clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module); if (clcf->handler) { r->handler = clcf->handler; return NGX_OK; } cscf = ngx_http_get_module_srv_conf(r, ngx_http_core_module); if (r->uri.data[r->uri.len - 1] == '/') { r->handler = ngx_http_core_index_handler; return NGX_OK; } /* "+ 2" is for trailing '/' in redirect and '\0' */ ngx_test_null(r->file.name.data, ngx_palloc(r->pool, clcf->doc_root.len + r->uri.len + 2), NGX_HTTP_INTERNAL_SERVER_ERROR); location = ngx_cpymem(r->file.name.data, clcf->doc_root.data, clcf->doc_root.len), last = ngx_cpystrn(location, r->uri.data, r->uri.len + 1); ngx_log_debug(r->connection->log, "HTTP filename: '%s'" _ r->file.name.data); #if (WIN9X) /* There is no way to open a file or a directory in Win9X with one syscall: Win9X has no FILE_FLAG_BACKUP_SEMANTICS flag. so we need to check its type before the opening */ r->file.info.dwFileAttributes = GetFileAttributes(r->file.name.data); if (r->file.info.dwFileAttributes == INVALID_FILE_ATTRIBUTES) { err = ngx_errno; ngx_log_error(NGX_LOG_ERR, r->connection->log, err, ngx_file_type_n " \"%s\" failed", r->file.name.data); if (err == NGX_ENOENT || err == NGX_ENOTDIR) { return NGX_HTTP_NOT_FOUND; } else if (err == NGX_EACCES) { return NGX_HTTP_FORBIDDEN; } else { return NGX_HTTP_INTERNAL_SERVER_ERROR; } } #else if (r->file.fd == NGX_INVALID_FILE) { r->file.fd = ngx_open_file(r->file.name.data, NGX_FILE_RDONLY, NGX_FILE_OPEN); } if (r->file.fd == NGX_INVALID_FILE) { err = ngx_errno; ngx_log_error(NGX_LOG_ERR, r->connection->log, ngx_errno, ngx_open_file_n " \"%s\" failed", r->file.name.data); if (err == NGX_ENOENT || err == NGX_ENOTDIR) { return NGX_HTTP_NOT_FOUND; } else if (err == NGX_EACCES) { return NGX_HTTP_FORBIDDEN; } else { return NGX_HTTP_INTERNAL_SERVER_ERROR; } } ngx_log_debug(r->connection->log, "FILE: %d" _ r->file.fd); if (!r->file.info_valid) { if (ngx_stat_fd(r->file.fd, &r->file.info) == NGX_FILE_ERROR) { ngx_log_error(NGX_LOG_CRIT, r->connection->log, ngx_errno, ngx_stat_fd_n " \"%s\" failed", r->file.name.data); if (ngx_close_file(r->file.fd) == NGX_FILE_ERROR) { ngx_log_error(NGX_LOG_ALERT, r->connection->log, ngx_errno, ngx_close_file_n " \"%s\" failed", r->file.name.data); } r->file.fd = NGX_INVALID_FILE; return NGX_HTTP_INTERNAL_SERVER_ERROR; } r->file.info_valid = 1; } #endif if (ngx_is_dir(r->file.info)) { ngx_log_debug(r->connection->log, "HTTP DIR: '%s'" _ r->file.name.data); #if !(WIN9X) if (ngx_close_file(r->file.fd) == NGX_FILE_ERROR) { ngx_log_error(NGX_LOG_ALERT, r->connection->log, ngx_errno, ngx_close_file_n " \"%s\" failed", r->file.name.data); } r->file.fd = NGX_INVALID_FILE; #endif /* BROKEN: need to include server name */ ngx_test_null(h, ngx_push_table(r->headers_out.headers), NGX_HTTP_INTERNAL_SERVER_ERROR); *last++ = '/'; *last = '\0'; h->key.len = 8; h->key.data = "Location" ; h->value.len = last - location; h->value.data = location; r->headers_out.location = h; return NGX_HTTP_MOVED_PERMANENTLY; } r->handler = ngx_http_static_handler; return NGX_OK; } static int ngx_http_core_index_handler(ngx_http_request_t *r) { int i, rc; ngx_http_handler_pt *h; ngx_http_core_main_conf_t *cmcf; cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module); h = cmcf->index_handlers.elts; for (i = cmcf->index_handlers.nelts; i > 0; /* void */) { rc = h[--i](r); if (rc != NGX_DECLINED) { if (rc == NGX_HTTP_NOT_FOUND) { ngx_log_error(NGX_LOG_ERR, r->connection->log, r->path_err, "\"%s\" is not found", r->path.data); } if (rc == NGX_HTTP_FORBIDDEN) { ngx_log_error(NGX_LOG_ERR, r->connection->log, r->path_err, "\"%s\" is forbidden", r->path.data); } return rc; } } r->path.data[r->path.len] = '\0'; ngx_log_error(NGX_LOG_ERR, r->connection->log, 0, "directory index of \"%s\" is forbidden", r->path.data); return NGX_HTTP_FORBIDDEN; } int ngx_http_send_header(ngx_http_request_t *r) { return (*ngx_http_top_header_filter)(r); } int ngx_http_redirect(ngx_http_request_t *r, int redirect) { /* STUB */ /* log request */ ngx_http_close_request(r, 0); return NGX_OK; } int ngx_http_error(ngx_http_request_t *r, int error) { /* STUB */ ngx_log_debug(r->connection->log, "http error: %d" _ error); /* log request */ ngx_http_special_response_handler(r, error); ngx_http_close_request(r, 0); return NGX_OK; } int ngx_http_internal_redirect(ngx_http_request_t *r, ngx_str_t *uri, ngx_str_t *args) { int i; ngx_log_debug(r->connection->log, "internal redirect: '%s'" _ uri->data); r->uri.len = uri->len; r->uri.data = uri->data; if (args) { r->args.len = args->len; r->args.data = args->data; } r->exten.len = 0; r->exten.data = NULL; for (i = uri->len - 1; i > 1; i--) { if (uri->data[i] == '.' && uri->data[i - 1] != '/') { r->exten.len = uri->len - i - 1; if (r->exten.len > 0) { ngx_test_null(r->exten.data, ngx_palloc(r->pool, r->exten.len + 1), NGX_HTTP_INTERNAL_SERVER_ERROR); ngx_cpystrn(r->exten.data, &uri->data[i + 1], r->exten.len + 1); } break; } else if (uri->data[i] == '/') { break; } } ngx_http_handler(r); return NGX_OK; } static int ngx_http_core_init(ngx_cycle_t *cycle) { ngx_http_handler_pt *h; ngx_http_conf_ctx_t *ctx; ngx_http_core_main_conf_t *cmcf; ctx = (ngx_http_conf_ctx_t *) cycle->conf_ctx[ngx_http_module.index]; cmcf = ctx->main_conf[ngx_http_core_module.ctx_index]; ngx_test_null(h, ngx_push_array(&cmcf->translate_handlers), NGX_ERROR); *h = ngx_http_core_translate_handler; return NGX_OK; } static char *ngx_server_block(ngx_conf_t *cf, ngx_command_t *cmd, void *dummy) { int m; char *rv; ngx_http_module_t *module; ngx_conf_t pcf; ngx_http_conf_ctx_t *ctx, *hctx, *pctx; ngx_http_core_main_conf_t *cmcf; ngx_http_core_srv_conf_t *cscf, **cscfp; ngx_test_null(ctx, ngx_pcalloc(cf->pool, sizeof(ngx_http_conf_ctx_t)), NGX_CONF_ERROR); hctx = (ngx_http_conf_ctx_t *) cf->ctx; ctx->main_conf = hctx->main_conf; /* the server{}'s srv_conf */ ngx_test_null(ctx->srv_conf, ngx_pcalloc(cf->pool, sizeof(void *) * ngx_http_max_module), NGX_CONF_ERROR); /* the server{}'s loc_conf */ ngx_test_null(ctx->loc_conf, ngx_pcalloc(cf->pool, sizeof(void *) * ngx_http_max_module), NGX_CONF_ERROR); for (m = 0; ngx_modules[m]; m++) { if (ngx_modules[m]->type != NGX_HTTP_MODULE) { continue; } module = ngx_modules[m]->ctx; if (module->create_srv_conf) { ngx_test_null(ctx->srv_conf[ngx_modules[m]->ctx_index], module->create_srv_conf(cf), NGX_CONF_ERROR); } if (module->create_loc_conf) { ngx_test_null(ctx->loc_conf[ngx_modules[m]->ctx_index], module->create_loc_conf(cf), NGX_CONF_ERROR); } } /* create links of the srv_conf's */ cscf = ctx->srv_conf[ngx_http_core_module.ctx_index]; cscf->ctx = ctx; cmcf = ctx->main_conf[ngx_http_core_module.ctx_index]; ngx_test_null(cscfp, ngx_push_array(&cmcf->servers), NGX_CONF_ERROR); *cscfp = cscf; /* parse inside server{} */ pcf = *cf; pctx = cf->ctx; cf->ctx = ctx; cf->cmd_type = NGX_HTTP_SRV_CONF; rv = ngx_conf_parse(cf, NULL); *cf = pcf; if (rv != NGX_CONF_OK) { return rv; } ngx_qsort(cscf->locations.elts, cscf->locations.nelts, sizeof(void *), ngx_cmp_locations); return rv; } static int ngx_cmp_locations(const void *first, const void *second) { ngx_http_core_loc_conf_t *one = *(ngx_http_core_loc_conf_t **) first; ngx_http_core_loc_conf_t *two = *(ngx_http_core_loc_conf_t **) second; return ngx_strcmp(one->name.data, two->name.data); } static char *ngx_location_block(ngx_conf_t *cf, ngx_command_t *cmd, void *dummy) { int m; char *rv; ngx_str_t *location; ngx_http_module_t *module; ngx_conf_t pcf; ngx_http_conf_ctx_t *ctx, *pctx; ngx_http_core_srv_conf_t *cscf; ngx_http_core_loc_conf_t *clcf, **clcfp; ngx_test_null(ctx, ngx_pcalloc(cf->pool, sizeof(ngx_http_conf_ctx_t)), NGX_CONF_ERROR); pctx = (ngx_http_conf_ctx_t *) cf->ctx; ctx->main_conf = pctx->main_conf; ctx->srv_conf = pctx->srv_conf; ngx_test_null(ctx->loc_conf, ngx_pcalloc(cf->pool, sizeof(void *) * ngx_http_max_module), NGX_CONF_ERROR); for (m = 0; ngx_modules[m]; m++) { if (ngx_modules[m]->type != NGX_HTTP_MODULE) { continue; } module = ngx_modules[m]->ctx; if (module->create_loc_conf) { ngx_test_null(ctx->loc_conf[ngx_modules[m]->ctx_index], module->create_loc_conf(cf), NGX_CONF_ERROR); } } clcf = ctx->loc_conf[ngx_http_core_module.ctx_index]; location = (ngx_str_t *) cf->args->elts; clcf->name.len = location[1].len; clcf->name.data = location[1].data; clcf->loc_conf = ctx->loc_conf; cscf = ctx->srv_conf[ngx_http_core_module.ctx_index]; ngx_test_null(clcfp, ngx_push_array(&cscf->locations), NGX_CONF_ERROR); *clcfp = clcf; pcf = *cf; cf->ctx = ctx; cf->cmd_type = NGX_HTTP_LOC_CONF; rv = ngx_conf_parse(cf, NULL); *cf = pcf; return rv; } static char *ngx_types_block(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) { char *rv; ngx_conf_t pcf; pcf = *cf; cf->handler = ngx_set_type; cf->handler_conf = conf; rv = ngx_conf_parse(cf, NULL); *cf = pcf; return rv; } static char *ngx_set_type(ngx_conf_t *cf, ngx_command_t *dummy, void *conf) { ngx_http_core_loc_conf_t *lcf = conf; int i, key; ngx_str_t *args; ngx_http_type_t *t; if (lcf->types == NULL) { ngx_test_null(lcf->types, ngx_palloc(cf->pool, NGX_HTTP_TYPES_HASH_PRIME * sizeof(ngx_array_t)), NGX_CONF_ERROR); for (i = 0; i < NGX_HTTP_TYPES_HASH_PRIME; i++) { ngx_init_array(lcf->types[i], cf->pool, 5, sizeof(ngx_http_type_t), NGX_CONF_ERROR); } } args = (ngx_str_t *) cf->args->elts; for (i = 1; i < cf->args->nelts; i++) { ngx_http_types_hash_key(key, args[i]); ngx_test_null(t, ngx_push_array(&lcf->types[key]), NGX_CONF_ERROR); t->exten.len = args[i].len; t->exten.data = args[i].data; t->type.len = args[0].len; t->type.data = args[0].data; } return NGX_CONF_OK; } static void *ngx_http_core_create_main_conf(ngx_conf_t *cf) { ngx_http_core_main_conf_t *cmcf; ngx_test_null(cmcf, ngx_palloc(cf->pool, sizeof(ngx_http_core_main_conf_t)), NGX_CONF_ERROR); ngx_init_array(cmcf->servers, cf->pool, 5, sizeof(ngx_http_core_srv_conf_t *), NGX_CONF_ERROR); return cmcf; } static char *ngx_http_core_init_main_conf(ngx_conf_t *cf, void *conf) { ngx_http_core_main_conf_t *cmcf = conf; /* TODO: remove it if no directives */ return NGX_CONF_OK; } static void *ngx_http_core_create_srv_conf(ngx_conf_t *cf) { ngx_http_core_srv_conf_t *cscf; ngx_test_null(cscf, ngx_pcalloc(cf->pool, sizeof(ngx_http_core_srv_conf_t)), NGX_CONF_ERROR); ngx_init_array(cscf->locations, cf->pool, 5, sizeof(void *), NGX_CONF_ERROR); ngx_init_array(cscf->listen, cf->pool, 5, sizeof(ngx_http_listen_t), NGX_CONF_ERROR); ngx_init_array(cscf->server_names, cf->pool, 5, sizeof(ngx_http_server_name_t), NGX_CONF_ERROR); cscf->connection_pool_size = NGX_CONF_UNSET; cscf->post_accept_timeout = NGX_CONF_UNSET; cscf->request_pool_size = NGX_CONF_UNSET; cscf->client_header_timeout = NGX_CONF_UNSET; cscf->client_header_buffer_size = NGX_CONF_UNSET; cscf->large_client_header = NGX_CONF_UNSET; return cscf; } static char *ngx_http_core_merge_srv_conf(ngx_conf_t *cf, void *parent, void *child) { ngx_http_core_srv_conf_t *prev = parent; ngx_http_core_srv_conf_t *conf = child; ngx_http_listen_t *l; ngx_http_server_name_t *n; /* TODO: it does not merge, it inits only */ if (conf->listen.nelts == 0) { ngx_test_null(l, ngx_push_array(&conf->listen), NGX_CONF_ERROR); l->addr = INADDR_ANY; #if (WIN32) l->port = 80; #else /* STUB: getuid() should be cached */ l->port = (getuid() == 0) ? 80 : 8000; #endif l->family = AF_INET; } if (conf->server_names.nelts == 0) { ngx_test_null(n, ngx_push_array(&conf->server_names), NGX_CONF_ERROR); ngx_test_null(n->name.data, ngx_palloc(cf->pool, NGX_MAXHOSTNAMELEN), NGX_CONF_ERROR); if (gethostname(n->name.data, NGX_MAXHOSTNAMELEN) == -1) { ngx_conf_log_error(NGX_LOG_EMERG, cf, ngx_errno, "gethostname() failed"); return NGX_CONF_ERROR; } n->name.len = ngx_strlen(n->name.data); n->core_srv_conf = conf; } ngx_conf_merge_size_value(conf->connection_pool_size, prev->connection_pool_size, 16384); ngx_conf_merge_msec_value(conf->post_accept_timeout, prev->post_accept_timeout, 30000); ngx_conf_merge_size_value(conf->request_pool_size, prev->request_pool_size, 16384); ngx_conf_merge_msec_value(conf->client_header_timeout, prev->client_header_timeout, 60000); ngx_conf_merge_size_value(conf->client_header_buffer_size, prev->client_header_buffer_size, 1024); ngx_conf_merge_value(conf->large_client_header, prev->large_client_header, 1); return NGX_CONF_OK; } static void *ngx_http_core_create_loc_conf(ngx_conf_t *cf) { ngx_http_core_loc_conf_t *lcf; ngx_test_null(lcf, ngx_pcalloc(cf->pool, sizeof(ngx_http_core_loc_conf_t)), NGX_CONF_ERROR); /* set by ngx_pcalloc(): lcf->doc_root.len = 0; lcf->doc_root.data = NULL; lcf->types = NULL; lcf->default_type.len = 0; lcf->default_type.data = NULL; lcf->err_log = NULL; */ lcf->sendfile = NGX_CONF_UNSET; lcf->send_timeout = NGX_CONF_UNSET; lcf->discarded_buffer_size = NGX_CONF_UNSET; lcf->keepalive_timeout = NGX_CONF_UNSET; lcf->lingering_time = NGX_CONF_UNSET; lcf->lingering_timeout = NGX_CONF_UNSET; return lcf; } static ngx_http_type_t default_types[] = { { ngx_string("html"), ngx_string("text/html") }, { ngx_string("gif"), ngx_string("image/gif") }, { ngx_string("jpg"), ngx_string("image/jpeg") }, { ngx_null_string, ngx_null_string } }; static char *ngx_http_core_merge_loc_conf(ngx_conf_t *cf, void *parent, void *child) { ngx_http_core_loc_conf_t *prev = parent; ngx_http_core_loc_conf_t *conf = child; int i, key; ngx_http_type_t *t; ngx_conf_merge_str_value(conf->doc_root, prev->doc_root, "html"); if (conf->types == NULL) { if (prev->types) { conf->types = prev->types; } else { ngx_test_null(conf->types, ngx_palloc(cf->pool, NGX_HTTP_TYPES_HASH_PRIME * sizeof(ngx_array_t)), NGX_CONF_ERROR); for (i = 0; i < NGX_HTTP_TYPES_HASH_PRIME; i++) { ngx_init_array(conf->types[i], cf->pool, 5, sizeof(ngx_http_type_t), NGX_CONF_ERROR); } for (i = 0; default_types[i].exten.len; i++) { ngx_http_types_hash_key(key, default_types[i].exten); ngx_test_null(t, ngx_push_array(&conf->types[key]), NGX_CONF_ERROR); t->exten.len = default_types[i].exten.len; t->exten.data = default_types[i].exten.data; t->type.len = default_types[i].type.len; t->type.data = default_types[i].type.data; } } } if (conf->err_log == NULL) { if (prev->err_log) { conf->err_log = prev->err_log; } else { conf->err_log = cf->cycle->log; } } ngx_conf_merge_str_value(conf->default_type, prev->default_type, "text/plain"); ngx_conf_merge_value(conf->sendfile, prev->sendfile, 0); ngx_conf_merge_msec_value(conf->send_timeout, prev->send_timeout, 10000); ngx_conf_merge_size_value(conf->discarded_buffer_size, prev->discarded_buffer_size, 1500); ngx_conf_merge_msec_value(conf->keepalive_timeout, prev->keepalive_timeout, 70000); ngx_conf_merge_msec_value(conf->lingering_time, prev->lingering_time, 30000); ngx_conf_merge_msec_value(conf->lingering_timeout, prev->lingering_timeout, 5000); return NGX_CONF_OK; } static char *ngx_set_listen(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) { ngx_http_core_srv_conf_t *scf = conf; char *addr; u_int p; struct hostent *h; ngx_str_t *args; ngx_http_listen_t *ls; /* TODO: check duplicate 'listen' directives, add resolved name to server names ??? */ ngx_test_null(ls, ngx_push_array(&scf->listen), NGX_CONF_ERROR); /* AF_INET only */ ls->family = AF_INET; ls->flags = 0; ls->file_name = cf->conf_file->file.name; ls->line = cf->conf_file->line; args = cf->args->elts; addr = args[1].data; for (p = 0; p < args[1].len; p++) { if (addr[p] == ':') { addr[p++] = '\0'; break; } } if (p == args[1].len) { /* no ":" in the "listen" */ p = 0; } ls->port = ngx_atoi(&addr[p], args[1].len - p); if (ls->port == NGX_ERROR && p == 0) { /* "listen host" */ ls->port = 80; } else if ((ls->port == NGX_ERROR && p != 0) /* "listen host:NONNUMBER" */ || (ls->port < 1 || ls->port > 65536)) { /* "listen 99999" */ ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "invalid port \"%s\" in \"%s\" directive, " "it must be a number between 1 and 65535", &addr[p], cmd->name.data); return NGX_CONF_ERROR; } else if (p == 0) { ls->addr = INADDR_ANY; return NGX_CONF_OK; } ls->addr = inet_addr(addr); if (ls->addr == INADDR_NONE) { h = gethostbyname(addr); if (h == NULL || h->h_addr_list[0] == NULL) { ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "can not resolve host \"%s\" " "in \"%s\" directive", addr, cmd->name.data); return NGX_CONF_ERROR; } ls->addr = *(u_int32_t *)(h->h_addr_list[0]); } return NGX_CONF_OK; } static char *ngx_set_server_name(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) { ngx_http_core_srv_conf_t *scf = conf; int i; ngx_str_t *value; ngx_http_server_name_t *sn; /* TODO: several names */ /* TODO: warn about duplicate 'server_name' directives */ value = cf->args->elts; for (i = 1; i < cf->args->nelts; i++) { if (value[i].len == 0) { ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "server name \"%s\" is invalid " "in \"%s\" directive", value[i].data, cmd->name.data); return NGX_CONF_ERROR; } ngx_test_null(sn, ngx_push_array(&scf->server_names), NGX_CONF_ERROR); sn->name.len = value[i].len; sn->name.data = value[i].data; sn->core_srv_conf = scf; } return NGX_CONF_OK; } static char *ngx_set_error_log(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) { ngx_http_core_loc_conf_t *lcf = conf; ngx_str_t *value; value = cf->args->elts; ngx_test_null(lcf->err_log, ngx_log_create_errlog(cf->cycle, &value[1]), NGX_CONF_ERROR); return NGX_CONF_OK; }