lighttpd
/
lighttpd1.4
2
0
Fork 0
Code Issues Releases Wiki Activity

[multiple] use http_chunk_append_file_ref() 

use http_chunk_append_file_ref() and http_chunk_append_file_ref_range()

reduce resource usage (number of fds open) by reference counting open
fds to files served, and sharing the fd among FILE_CHUNKs in responses
This commit is contained in:
Glenn Strauss 2020-10-19 23:31:02 -04:00
parent 9078cc4ce8
commit 019c513819
3 changed files with 8 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/http-header-glue.c
View File

@ -365,7 +365,7 @@ static int http_response_coalesce_ranges (off_t * const ranges, int n)
}
static int http_response_parse_range(request_st * const r, const buffer * const path, const int fd, const stat_cache_entry * const sce, const char * const range) {
static int http_response_parse_range(request_st * const r, stat_cache_entry * const sce, const char * const range) {
int n = 0;
int error;
off_t start, end;
@ -531,7 +531,7 @@ static int http_response_parse_range(request_st * const r, const buffer * const
http_chunk_append_mem(r, CONST_BUF_LEN(b));
}
http_chunk_append_file_fd_range(r, path, i < 8 ? fdevent_dup_cloexec(fd) : -1, start, end - start + 1);
http_chunk_append_file_ref_range(r, sce, start, end - start + 1);
}
buffer * const tb = r->tmp_buf;
@ -728,7 +728,7 @@ void http_response_send_file (request_st * const r, buffer * const path) {
/* content prepared, I'm done */
r->resp_body_finished = 1;
if (0 == http_response_parse_range(r, path, sce->fd, sce, range->ptr+6)) {
if (0 == http_response_parse_range(r, sce, range->ptr+6)) {
r->http_status = 206;
}
return;
@ -741,8 +741,7 @@ void http_response_send_file (request_st * const r, buffer * const path) {
* the HEAD request will drop it afterwards again
*/
int fd = sce->fd >= 0 ? fdevent_dup_cloexec(sce->fd) : -1;
if (0 == http_chunk_append_file_fd(r, path, fd, sce->st.st_size)) {
if (0 == http_chunk_append_file_ref(r, sce)) {
r->http_status = 200;
r->resp_body_finished = 1;
/*(Transfer-Encoding should not have been set at this point)*/
@ -942,12 +941,7 @@ range_success: ;
break;
}
if (range_len != 0) {
int fd = sce->fd >= 0 ? fdevent_dup_cloexec(sce->fd) : -1;
if (fd < 0) {
r->http_status = 502;
break;
}
http_chunk_append_file_fd_range(r, b, fd, begin_range, range_len);
http_chunk_append_file_ref_range(r, sce, begin_range, range_len);
}
if (*pos == ',') pos++;

4
src/mod_deflate.c
View File

@ -1533,9 +1533,7 @@ REQUEST_FUNC(mod_deflate_handle_response_start) {
stat_cache_entry *sce = stat_cache_get_entry_open(tb, 1);
if (NULL != sce) {
chunkqueue_reset(&r->write_queue);
int fd = sce->fd >= 0 ? fdevent_dup_cloexec(sce->fd) : -1;
if (fd < 0
|| 0 != http_chunk_append_file_fd(r, tb, fd, sce->st.st_size))
if (sce->fd < 0 || 0 != http_chunk_append_file_ref(r, sce))
return HANDLER_ERROR;
if (light_btst(r->resp_htags, HTTP_HEADER_CONTENT_LENGTH))
http_header_response_unset(r, HTTP_HEADER_CONTENT_LENGTH,

8
src/response.c
View File

@ -727,12 +727,8 @@ http_response_static_errdoc (request_st * const r)
buffer_append_string_len(&r->physical.path, CONST_STR_LEN(".html"));
stat_cache_entry *sce =
stat_cache_get_entry_open(&r->physical.path, r->conf.follow_symlink);
int fd = sce && sce->fd >= 0 ? fdevent_dup_cloexec(sce->fd) : -1;
if (fd >= 0 && 0 == http_chunk_append_file_fd(r, &r->physical.path,
fd, sce->st.st_size)) {
const buffer *content_type = (NULL != sce)
? stat_cache_content_type_get(sce, r)
: NULL;
if (sce && 0 == http_chunk_append_file_ref(r, sce)) {
const buffer *content_type = stat_cache_content_type_get(sce, r);
if (content_type)
http_header_response_set(r, HTTP_HEADER_CONTENT_TYPE,
CONST_STR_LEN("Content-Type"),