| /mOS-networking-stack/samples/lighttpd-1.4.32/src/ |
| H A D | server.c | 209 server *srv = calloc(1, sizeof(*srv)); in server_init() local 265 srv->startup_ts = srv->cur_ts; in server_init() 327 fdevent_unregister(srv->ev, srv->fd); in server_free() 369 joblist_free(srv, srv->joblist); in server_free() 370 fdwaitqueue_free(srv, srv->fdwaitqueue); in server_free() 411 srv->max_conns = srv->max_fds/2; in set_max_conns() 417 srv->max_conns = srv->max_fds/3; in set_max_conns() 420 srv->max_conns = srv->srvconf.max_conns; in set_max_conns() 430 if (NULL == (srv->ev = fdevent_init(srv, srv->max_fds + 1, srv->event_handler))) { in initialize_fd_framework() 639 srv->max_fds = srv->max_conns * 3; in start_server() [all …]
|
| H A D | log.c | 161 if (-1 == (srv->errorlog_fd = open_logfile_or_pipe(srv, logfile))) { in log_error_open() 169 if (srv->errorlog_mode == ERRORLOG_FD && !srv->srvconf.dont_daemonize) { in log_error_open() 173 srv->errorlog_fd = -1; in log_error_open() 227 srv->errorlog_fd = -1; in log_error_cycle() 254 srv->errorlog_fd = -1; in log_error_close() 276 if (srv->cur_ts != srv->last_generated_debug_ts) { in log_error_write() 278 …strftime(srv->ts_debug_str->ptr, srv->ts_debug_str->size - 1, "%Y-%m-%d %H:%M:%S", localtime(&(srv… in log_error_write() 279 srv->ts_debug_str->used = strlen(srv->ts_debug_str->ptr) + 1; in log_error_write() 281 srv->last_generated_debug_ts = srv->cur_ts; in log_error_write() 284 buffer_copy_string_buffer(srv->errorlog_buf, srv->ts_debug_str); in log_error_write() [all …]
|
| H A D | network.c | 165 if (srv == srv->first_entry) { 481 …srv->srv_sockets.ptr = realloc(srv->srv_sockets.ptr, srv->srv_sockets.size * sizeof(server_socket)… 484 srv->srv_sockets.ptr[srv->srv_sockets.used++] = srv_socket; 496 srv->cur_fds = srv->first_entry->srv_sockets.ptr[srv->first_entry->srv_sockets.used - 1]->fd; 506 …srv->srv_sockets.ptr = realloc(srv->srv_sockets.ptr, srv->srv_sockets.size * sizeof(server_socket)… 510 if (NULL == srv->srv_sockets.ptr[srv->srv_sockets.used]) { 516 memcpy((srv->srv_sockets.ptr[srv->srv_sockets.used]), 520 srv->srv_sockets.ptr[srv->srv_sockets.used]->fd = 523 srv->srv_sockets.ptr[srv->srv_sockets.used]->addr = 525 srv->srv_sockets.ptr[srv->srv_sockets.used]->use_ipv6 = [all …]
|
| H A D | joblist.c | 13 srv->joblist->ptr = malloc(sizeof(*srv->joblist->ptr) * srv->joblist->size); in joblist_append() 14 } else if (srv->joblist->used == srv->joblist->size) { in joblist_append() 16 srv->joblist->ptr = realloc(srv->joblist->ptr, sizeof(*srv->joblist->ptr) * srv->joblist->size); in joblist_append() 19 srv->joblist->ptr[srv->joblist->used++] = con; in joblist_append() 25 UNUSED(srv); in joblist_free() 33 UNUSED(srv); in fdwaitqueue_unshift() 48 srv->fdwaitqueue->ptr = malloc(sizeof(*(srv->fdwaitqueue->ptr)) * srv->fdwaitqueue->size); in fdwaitqueue_append() 49 } else if (srv->fdwaitqueue->used == srv->fdwaitqueue->size) { in fdwaitqueue_append() 51 …srv->fdwaitqueue->ptr = realloc(srv->fdwaitqueue->ptr, sizeof(*(srv->fdwaitqueue->ptr)) * srv->f… in fdwaitqueue_append() 54 srv->fdwaitqueue->ptr[srv->fdwaitqueue->used++] = con; in fdwaitqueue_append() [all …]
|
| H A D | plugin.c | 82 srv->plugins.size = 4; in plugins_register() 83 srv->plugins.ptr = malloc(srv->plugins.size * sizeof(*ps)); in plugins_register() 84 srv->plugins.used = 0; in plugins_register() 85 } else if (srv->plugins.used == srv->plugins.size) { in plugins_register() 86 srv->plugins.size += 4; in plugins_register() 87 srv->plugins.ptr = realloc(srv->plugins.ptr, srv->plugins.size * sizeof(*ps)); in plugins_register() 90 ps = srv->plugins.ptr; in plugins_register() 112 plugins_register(srv, p); in plugins_load() 136 buffer_copy_string_buffer(srv->tmp_buf, srv->srvconf.modules_dir); in plugins_load() 331 ps = srv->plugins.ptr; [all …]
|
| H A D | plugin.h | 8 static handler_t x(server *srv, void *p_d) 11 static handler_t x(server *srv, connection *con, void *p_d) 35 handler_t (* set_defaults) (server *srv, void *p_d); 64 int plugins_load(server *srv); 65 void plugins_free(server *srv); 78 handler_t plugins_call_handle_trigger(server *srv); 79 handler_t plugins_call_handle_sighup(server *srv); 81 handler_t plugins_call_init(server *srv); 82 handler_t plugins_call_set_defaults(server *srv); 83 handler_t plugins_call_cleanup(server *srv); [all …]
|
| H A D | connections.c | 146 srv->cur_fds--; 152 connection_del(srv, con); 329 UNUSED(srv); 677 UNUSED(srv); 1318 if (srv->conns->used >= srv->max_conns) { 1348 srv->cur_fds++; 1355 srv->con_opened++; 1523 srv->want_fds++; 1577 srv->con_written++; 1627 srv->con_closed++; [all …]
|
| H A D | response.c | 101 if (srv->cur_ts != srv->last_generated_date_ts) { in http_response_write_header() 102 buffer_prepare_copy(srv->ts_date_str, 255); in http_response_write_header() 104 strftime(srv->ts_date_str->ptr, srv->ts_date_str->size - 1, in http_response_write_header() 107 srv->ts_date_str->used = strlen(srv->ts_date_str->ptr) + 1; in http_response_write_header() 109 srv->last_generated_date_ts = srv->cur_ts; in http_response_write_header() 239 config_cond_cache_reset(srv, con); in http_response_prepare() 346 buffer_urldecode_path(srv->tmp_buf); in http_response_prepare() 386 log_error_write(srv, __FILE__, __LINE__, ""); in http_response_prepare() 489 log_error_write(srv, __FILE__, __LINE__, ""); in http_response_prepare() 650 buffer_copy_string_len(con->physical.path, srv->tmp_buf->ptr, slash - srv->tmp_buf->ptr); in http_response_prepare() [all …]
|
| H A D | mod_proxy.c | 160 UNUSED(srv); in FREE_FUNC() 349 srv->cur_fds--; in proxy_connection_close() 558 UNUSED(srv); in proxy_response_parse() 733 joblist_append(srv, con); in proxy_demux_response() 742 joblist_append(srv, con); in proxy_demux_response() 789 srv->cur_fds++; in proxy_write_request() 828 ret = srv->network_backend_write(srv, con, hctx->fd, hctx->wb, MAX_WRITE_LIMIT); in proxy_write_request() 934 joblist_append(srv, con); in SUBREQUEST_FUNC() 978 joblist_append(srv, con); in proxy_handle_fdevent() 1098 joblist_append(srv, con); in proxy_handle_fdevent() [all …]
|
| H A D | configfile-glue.c | 173 srv->config_unsupported = 1; in config_insert_values_internal() 179 srv->config_deprecated = 1; in config_insert_values_internal() 307 l = srv->cond_check_buf; in config_check_cond_nocache() 311 l = srv->cond_check_buf; in config_check_cond_nocache() 322 l = srv->empty_string; in config_check_cond_nocache() 364 … log_error_write(srv, __FILE__, __LINE__, "sb", "ERROR: ip addr is invalid:", srv->cond_check_buf); in config_check_cond_nocache() 412 l = srv->empty_string; in config_check_cond_nocache() 421 l = srv->empty_string; in config_check_cond_nocache() 430 l = srv->empty_string; in config_check_cond_nocache() 441 l = srv->tmp_buf; in config_check_cond_nocache() [all …]
|
| H A D | request.c | 22 UNUSED(srv); in request_check_hostname() 555 if (srv->srvconf.log_request_header_on_error) { in http_request_parse() 557 log_error_write(srv, __FILE__, __LINE__, "Sb", in http_request_parse() 826 vals = srv->split_vals; in http_request_parse() 1112 if (srv->srvconf.log_request_header_on_error) { in http_request_parse() 1113 log_error_write(srv, __FILE__, __LINE__, "s", in http_request_parse() 1115 log_error_write(srv, __FILE__, __LINE__, "Sb", in http_request_parse() 1133 log_error_write(srv, __FILE__, __LINE__, "s", in http_request_parse() 1145 log_error_write(srv, __FILE__, __LINE__, "s", in http_request_parse() 1173 if (srv->srvconf.max_request_size != 0 && in http_request_parse() [all …]
|
| H A D | mod_scgi.c | 551 UNUSED(srv); in FREE_FUNC() 1259 srv->cur_fds--; in scgi_reconnect() 1417 srv->tmp_buf->ptr[srv->tmp_buf->used++] = in scgi_env_add_request_headers() 1421 srv->tmp_buf->ptr[srv->tmp_buf->used++] = '\0'; in scgi_env_add_request_headers() 1438 srv->tmp_buf->ptr[srv->tmp_buf->used++] = in scgi_env_add_request_headers() 1442 srv->tmp_buf->ptr[srv->tmp_buf->used++] = '\0'; in scgi_env_add_request_headers() 1693 UNUSED(srv); in scgi_response_parse() 1936 UNUSED(srv); in scgi_proclist_sort_up() 1988 UNUSED(srv); in scgi_proclist_sort_up() 1997 UNUSED(srv); in scgi_proclist_sort_down() [all …]
|
| H A D | inet_ntop_cache.c | 9 const char * inet_ntop_cache_get_ip(server *srv, sock_addr *addr) { in inet_ntop_cache_get_ip() argument 13 if (srv->inet_ntop_cache[i].ts != 0 && srv->inet_ntop_cache[i].family == addr->plain.sa_family) { in inet_ntop_cache_get_ip() 14 if (srv->inet_ntop_cache[i].family == AF_INET6 && in inet_ntop_cache_get_ip() 18 } else if (srv->inet_ntop_cache[i].family == AF_INET && in inet_ntop_cache_get_ip() 35 srv->inet_ntop_cache[i].b2, INET6_ADDRSTRLEN); in inet_ntop_cache_get_ip() 37 srv->inet_ntop_cache[i].ts = srv->cur_ts; in inet_ntop_cache_get_ip() 38 srv->inet_ntop_cache[i].family = addr->plain.sa_family; in inet_ntop_cache_get_ip() 40 if (srv->inet_ntop_cache[i].family == AF_INET) { in inet_ntop_cache_get_ip() 42 } else if (srv->inet_ntop_cache[i].family == AF_INET6) { in inet_ntop_cache_get_ip() 47 return srv->inet_ntop_cache[i].b2; in inet_ntop_cache_get_ip() [all …]
|
| H A D | mod_fastcgi.c | 693 UNUSED(srv); in FREE_FUNC() 1481 srv->cur_fds--; in fcgi_connection_close() 1530 srv->cur_fds--; in fcgi_reconnect() 1777 srv->tmp_buf->ptr[srv->tmp_buf->used++] = c; in fcgi_env_add_request_headers() 1779 srv->tmp_buf->ptr[srv->tmp_buf->used++] = '\0'; in fcgi_env_add_request_headers() 1804 srv->tmp_buf->ptr[srv->tmp_buf->used++] = c; in fcgi_env_add_request_headers() 1806 srv->tmp_buf->ptr[srv->tmp_buf->used++] = '\0'; in fcgi_env_add_request_headers() 2184 UNUSED(srv); in fcgi_response_parse() 2286 srv->tmp_buf); in fcgi_response_parse() 2943 "socket failed:", strerror(errno), srv->cur_fds, srv->max_fds); in fcgi_write_request() [all …]
|
| H A D | configfile.c | 23 static int config_insert(server *srv) { in config_insert() argument 162 srv->config_storage = calloc(1, srv->config_context->used * sizeof(specific_config *)); in config_insert() 164 assert(srv->config_storage); in config_insert() 279 srv->config_storage[i] = s; in config_insert() 548 UNUSED(srv); 1082 context->srv = srv; in context_init() 1103 context_init(srv, &context); in config_read() 1125 srv->config = dc->value; in config_read() 1150 srv->config = dc->value; in config_read() 1276 buffer_copy_string_buffer(srv->tmp_buf, srv->srvconf.changeroot); in config_set_defaults() [all …]
|
| H A D | http-header-glue.c | 78 UNUSED(srv); in response_header_insert() 94 UNUSED(srv); in response_header_overwrite() 109 UNUSED(srv); in response_header_append() 189 log_error_write(srv, __FILE__, __LINE__, in http_response_redirect_to_directory() 225 if (srv->mtime_cache[i].mtime == last_mod) return srv->mtime_cache[i].str; in strftime_cache_get() 235 srv->mtime_cache[i].mtime = last_mod; in strftime_cache_get() 237 tm = gmtime(&(srv->mtime_cache[i].mtime)); in strftime_cache_get() 238 srv->mtime_cache[i].str->used = strftime(srv->mtime_cache[i].str->ptr, in strftime_cache_get() 239 srv->mtime_cache[i].str->size - 1, in strftime_cache_get() 241 srv->mtime_cache[i].str->used++; in strftime_cache_get() [all …]
|
| H A D | mod_compress.c | 80 UNUSED(srv); in FREE_FUNC() 89 for (i = 0; i < srv->config_context->used; i++) { in FREE_FUNC() 166 for (i = 0; i < srv->config_context->used; i++) { in SETDEFAULTS_FUNC() 183 …if (0 != config_insert_values_global(srv, ((data_config *)srv->config_context->data[i])->value, cv… in SETDEFAULTS_FUNC() 247 UNUSED(srv); in deflate_file_to_buffer_gzip() 321 UNUSED(srv); in deflate_file_to_buffer_deflate() 368 UNUSED(srv); in deflate_file_to_buffer_bzip2() 679 for (i = 1; i < srv->config_context->used; i++) { in mod_compress_patch_connection() 684 if (!config_check_cond(srv, con, dc)) continue; in mod_compress_patch_connection() 740 mod_compress_patch_connection(srv, con, p); in PHYSICALPATH_FUNC() [all …]
|
| H A D | mod_ssi.c | 63 UNUSED(srv); in FREE_FUNC() 125 …if (0 != config_insert_values_global(srv, ((data_config *)srv->config_context->data[i])->value, cv… in SETDEFAULTS_FUNC() 177 buffer_reset(srv->tmp_buf); in ssi_env_add_request_headers() 186 srv->tmp_buf->used--; in ssi_env_add_request_headers() 199 srv->tmp_buf->ptr[srv->tmp_buf->used++] = c; in ssi_env_add_request_headers() 201 srv->tmp_buf->ptr[srv->tmp_buf->used] = '\0'; in ssi_env_add_request_headers() 215 buffer_reset(srv->tmp_buf); in ssi_env_add_request_headers() 227 srv->tmp_buf->ptr[srv->tmp_buf->used++] = c; in ssi_env_add_request_headers() 229 srv->tmp_buf->ptr[srv->tmp_buf->used] = '\0'; in ssi_env_add_request_headers() 567 buffer_path_simplify(srv->tmp_buf, srv->tmp_buf); in process_ssi_stmt() [all …]
|
| H A D | mod_expire.c | 55 UNUSED(srv); in FREE_FUNC() 63 for (i = 0; i < srv->config_context->used; i++) { in FREE_FUNC() 94 log_error_write(srv, __FILE__, __LINE__, "s", in mod_expire_get_offset() 112 log_error_write(srv, __FILE__, __LINE__, "ss", in mod_expire_get_offset() 128 log_error_write(srv, __FILE__, __LINE__, "ss", in mod_expire_get_offset() 135 log_error_write(srv, __FILE__, __LINE__, "ss", in mod_expire_get_offset() 170 log_error_write(srv, __FILE__, __LINE__, "ss", in mod_expire_get_offset() 236 …if (0 != config_insert_values_global(srv, ((data_config *)srv->config_context->data[i])->value, cv… in SETDEFAULTS_FUNC() 293 mod_expire_patch_connection(srv, con, p); in URIHANDLER_FUNC() 314 expires = (ts + srv->cur_ts); in URIHANDLER_FUNC() [all …]
|
| H A D | mod_cgi.c | 123 UNUSED(srv); in FREE_FUNC() 190 UNUSED(srv); in cgi_pid_add() 213 UNUSED(srv); in cgi_pid_del() 236 UNUSED(srv); in cgi_response_parse() 374 joblist_append(srv, con); in cgi_demux_response() 462 joblist_append(srv, con); in cgi_demux_response() 505 joblist_append(srv, con); in cgi_demux_response() 610 cgi_pid_add(srv, p, pid); in cgi_connection_close() 627 joblist_append(srv, con); in cgi_handle_fdevent() 675 joblist_append(srv, con); in cgi_handle_fdevent() [all …]
|
| H A D | mod_trigger_b4_dl.c | 83 UNUSED(srv); in FREE_FUNC() 89 for (i = 0; i < srv->config_context->used; i++) { in FREE_FUNC() 174 …if (0 != config_insert_values_global(srv, ((data_config *)srv->config_context->data[i])->value, cv… in SETDEFAULTS_FUNC() 239 log_error_write(srv, __FILE__, __LINE__, "s", in SETDEFAULTS_FUNC() 377 val.dptr = (char *)&(srv->cur_ts); in URIHANDLER_FUNC() 378 val.dsize = sizeof(srv->cur_ts); in URIHANDLER_FUNC() 402 (char *)&(srv->cur_ts), sizeof(srv->cur_ts), in URIHANDLER_FUNC() 461 val.dptr = (char *)&(srv->cur_ts); in URIHANDLER_FUNC() 462 val.dsize = sizeof(srv->cur_ts); in URIHANDLER_FUNC() 510 (char *)&(srv->cur_ts), sizeof(srv->cur_ts), in URIHANDLER_FUNC() [all …]
|
| H A D | mod_status.c | 78 UNUSED(srv); in FREE_FUNC() 312 ts = srv->cur_ts - srv->startup_ts; in mod_status_handle_server_status_html() 346 ts = srv->startup_ts; in mod_status_handle_server_status_html() 381 avg = p->abs_requests / (srv->cur_ts - srv->startup_ts); in mod_status_handle_server_status_html() 391 avg = p->abs_traffic_out / (srv->cur_ts - srv->startup_ts); in mod_status_handle_server_status_html() 591 ts = srv->cur_ts - srv->startup_ts; in mod_status_handle_server_status_text() 601 buffer_append_long(b, srv->conns->size - srv->conns->used); in mod_status_handle_server_status_text() 611 for (l = 0; l < srv->conns->size - srv->conns->used; l++) { in mod_status_handle_server_status_text() 626 array *st = srv->status; in mod_status_handle_server_statistics() 741 plugin **ps = srv->plugins.ptr; in mod_status_handle_server_config() [all …]
|
| H A D | mod_magnet.c | 64 UNUSED(srv); in FREE_FUNC() 238 server *srv; in magnet_print() local 253 server *srv; in magnet_stat() local 347 server *srv; in magnet_atpanic() local 396 server *srv; in magnet_status_get() local 415 server *srv; in magnet_status_set() local 431 server *srv; in magnet_status_pairs() local 489 UNUSED(srv); in magnet_env_get_buffer_by_id() 537 server *srv; in magnet_env_get() local 565 server *srv; in magnet_env_set() local [all …]
|
| H A D | http_auth.c | 367 log_error_write(srv, __FILE__, __LINE__, "sb", in http_auth_match_rules() 375 log_error_write(srv, __FILE__, __LINE__, "sb", in http_auth_match_rules() 611 UNUSED(srv); in http_auth_basic_password_compare() 877 …log_error_write(srv, __FILE__, __LINE__, "ss", "get_password failed, IP:", inet_ntop_cache_get_ip(… in http_auth_basic_check() 976 log_error_write(srv, __FILE__, __LINE__, "s", in http_auth_digest_check() 1035 log_error_write(srv, __FILE__, __LINE__, "s", in http_auth_digest_check() 1048 log_error_write(srv, __FILE__, __LINE__, "s", in http_auth_digest_check() 1159 log_error_write(srv, __FILE__, __LINE__, "s", in http_auth_digest_check() 1171 log_error_write(srv, __FILE__, __LINE__, "s", in http_auth_digest_check() 1191 LI_ltostr(hh, srv->cur_ts); in http_auth_digest_generate_nonce() [all …]
|
| H A D | network_write.c | 66 log_error_write(srv, __FILE__, __LINE__, "ssd", in network_write_chunkqueue_write() 94 if (HANDLER_ERROR == stat_cache_get_entry(srv, con, c->file.name, &sce)) { in network_write_chunkqueue_write() 95 log_error_write(srv, __FILE__, __LINE__, "sb", in network_write_chunkqueue_write() 138 log_error_write(srv, __FILE__, __LINE__, "ssd", in network_write_chunkqueue_write() 148 buffer_prepare_copy(srv->tmp_buf, toSend); in network_write_chunkqueue_write() 151 if (-1 == (toSend = read(ifd, srv->tmp_buf->ptr, toSend))) { in network_write_chunkqueue_write() 152 log_error_write(srv, __FILE__, __LINE__, "ss", "read: ", strerror(errno)); in network_write_chunkqueue_write() 160 if ((r = send(fd, srv->tmp_buf->ptr, toSend, 0)) < 0) { in network_write_chunkqueue_write() 167 if ((r = write(fd, srv->tmp_buf->ptr, toSend)) < 0) { in network_write_chunkqueue_write() 177 log_error_write(srv, __FILE__, __LINE__, "ssd", in network_write_chunkqueue_write() [all …]
|