summaryrefslogtreecommitdiff
path: root/src/mod_compress.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/mod_compress.c')
-rw-r--r--src/mod_compress.c848
1 files changed, 0 insertions, 848 deletions
diff --git a/src/mod_compress.c b/src/mod_compress.c
deleted file mode 100644
index 7e72fb4a..00000000
--- a/src/mod_compress.c
+++ /dev/null
@@ -1,848 +0,0 @@
-#include <sys/types.h>
-#include <sys/stat.h>
-
-#include <fcntl.h>
-#include <ctype.h>
-#include <stdlib.h>
-#include <string.h>
-#include <errno.h>
-#include <time.h>
-
-#include "base.h"
-#include "log.h"
-#include "buffer.h"
-#include "response.h"
-#include "stat_cache.h"
-
-#include "plugin.h"
-
-#include "crc32.h"
-#include "etag.h"
-
-#if defined HAVE_ZLIB_H && defined HAVE_LIBZ
-# define USE_ZLIB
-# include <zlib.h>
-#endif
-
-#if defined HAVE_BZLIB_H && defined HAVE_LIBBZ2
-# define USE_BZ2LIB
-/* we don't need stdio interface */
-# define BZ_NO_STDIO
-# include <bzlib.h>
-#endif
-
-#include "sys-mmap.h"
-#include "sys-files.h"
-
-/* request: accept-encoding */
-#define HTTP_ACCEPT_ENCODING_IDENTITY BV(0)
-#define HTTP_ACCEPT_ENCODING_GZIP BV(1)
-#define HTTP_ACCEPT_ENCODING_DEFLATE BV(2)
-#define HTTP_ACCEPT_ENCODING_COMPRESS BV(3)
-#define HTTP_ACCEPT_ENCODING_BZIP2 BV(4)
-
-#ifdef __WIN32
-#define mkdir(x,y) mkdir(x)
-#endif
-
-typedef struct {
- buffer *compress_cache_dir;
- array *compress;
- off_t compress_max_filesize; /** max filesize in kb */
- int allowed_encodings;
-} plugin_config;
-
-typedef struct {
- PLUGIN_DATA;
- buffer *ofn;
- buffer *b;
-
- plugin_config **config_storage;
- plugin_config conf;
-} plugin_data;
-
-INIT_FUNC(mod_compress_init) {
- plugin_data *p;
-
- UNUSED(srv);
-
- p = calloc(1, sizeof(*p));
-
- p->ofn = buffer_init();
- p->b = buffer_init();
-
- return p;
-}
-
-FREE_FUNC(mod_compress_free) {
- plugin_data *p = p_d;
-
- UNUSED(srv);
-
- if (!p) return HANDLER_GO_ON;
-
- buffer_free(p->ofn);
- buffer_free(p->b);
-
- if (p->config_storage) {
- size_t i;
- for (i = 0; i < srv->config_context->used; i++) {
- plugin_config *s = p->config_storage[i];
-
- if (!s) continue;
-
- array_free(s->compress);
- buffer_free(s->compress_cache_dir);
-
- free(s);
- }
- free(p->config_storage);
- }
-
-
- free(p);
-
- return HANDLER_GO_ON;
-}
-
-/* 0 on success, -1 for error */
-static int mkdir_recursive(char *dir) {
- char *p = dir;
-
- if (!dir || !dir[0])
- return 0;
-
- while ((p = strchr(p + 1, '/')) != NULL) {
-
- *p = '\0';
- if ((mkdir(dir, 0700) != 0) && (errno != EEXIST)) {
- *p = '/';
- return -1;
- }
-
- *p++ = '/';
- if (!*p) return 0; /* Ignore trailing slash */
- }
-
- return (mkdir(dir, 0700) != 0) && (errno != EEXIST) ? -1 : 0;
-}
-
-/* 0 on success, -1 for error */
-static int mkdir_for_file(char *filename) {
- char *p = filename;
-
- if (!filename || !filename[0])
- return -1;
-
- while ((p = strchr(p + 1, '/')) != NULL) {
-
- *p = '\0';
- if ((mkdir(filename, 0700) != 0) && (errno != EEXIST)) {
- ERROR("creating cache-directory \"%s\" failed: %s", filename, strerror(errno));
- *p = '/';
- return -1;
- }
-
- *p++ = '/';
- if (!*p) {
- ERROR("unexpected trailing slash for filename \"%s\"", filename);
- return -1;
- }
- }
-
- return 0;
-}
-
-SETDEFAULTS_FUNC(mod_compress_setdefaults) {
- plugin_data *p = p_d;
- size_t i = 0;
-
- config_values_t cv[] = {
- { "compress.cache-dir", NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION },
- { "compress.filetype", NULL, T_CONFIG_ARRAY, T_CONFIG_SCOPE_CONNECTION },
- { "compress.max-filesize", NULL, T_CONFIG_SHORT, T_CONFIG_SCOPE_CONNECTION },
- { "compress.allowed-encodings", NULL, T_CONFIG_ARRAY, T_CONFIG_SCOPE_CONNECTION },
- { NULL, NULL, T_CONFIG_UNSET, T_CONFIG_SCOPE_UNSET }
- };
-
- p->config_storage = calloc(1, srv->config_context->used * sizeof(specific_config *));
-
- for (i = 0; i < srv->config_context->used; i++) {
- plugin_config *s;
- array *encodings_arr = array_init();
-
- s = calloc(1, sizeof(plugin_config));
- s->compress_cache_dir = buffer_init();
- s->compress = array_init();
- s->compress_max_filesize = 0;
- s->allowed_encodings = 0;
-
- cv[0].destination = s->compress_cache_dir;
- cv[1].destination = s->compress;
- cv[2].destination = &(s->compress_max_filesize);
- cv[3].destination = encodings_arr; /* temp array for allowed encodings list */
-
- p->config_storage[i] = s;
-
- if (0 != config_insert_values_global(srv, ((data_config *)srv->config_context->data[i])->value, cv)) {
- return HANDLER_ERROR;
- }
-
- if (encodings_arr->used) {
- size_t j = 0;
- for (j = 0; j < encodings_arr->used; j++) {
- data_string *ds = (data_string *)encodings_arr->data[j];
-#ifdef USE_ZLIB
- if (NULL != strstr(ds->value->ptr, "gzip"))
- s->allowed_encodings |= HTTP_ACCEPT_ENCODING_GZIP;
- if (NULL != strstr(ds->value->ptr, "deflate"))
- s->allowed_encodings |= HTTP_ACCEPT_ENCODING_DEFLATE;
- /*
- if (NULL != strstr(ds->value->ptr, "compress"))
- s->allowed_encodings |= HTTP_ACCEPT_ENCODING_COMPRESS;
- */
-#endif
-#ifdef USE_BZ2LIB
- if (NULL != strstr(ds->value->ptr, "bzip2"))
- s->allowed_encodings |= HTTP_ACCEPT_ENCODING_BZIP2;
-#endif
- }
- } else {
- /* default encodings */
- s->allowed_encodings = 0
-#ifdef USE_ZLIB
- | HTTP_ACCEPT_ENCODING_GZIP | HTTP_ACCEPT_ENCODING_DEFLATE
-#endif
-#ifdef USE_BZ2LIB
- | HTTP_ACCEPT_ENCODING_BZIP2
-#endif
- ;
- }
-
- array_free(encodings_arr);
-
- if (!buffer_is_empty(s->compress_cache_dir)) {
- struct stat st;
- if (0 != stat(s->compress_cache_dir->ptr, &st)) {
-
- ERROR("can't stat compress.cache-dir (%s), attempting to create '%s'", strerror(errno),SAFE_BUF_STR(s->compress_cache_dir));
- mkdir_recursive(s->compress_cache_dir->ptr);
-
- if (0 != stat(s->compress_cache_dir->ptr, &st)) {
- ERROR("can't stat compress.cache-dir (%s), failed to create '%s'", strerror(errno),SAFE_BUF_STR(s->compress_cache_dir));
- return HANDLER_ERROR;
- }
- }
- }
- }
-
- return HANDLER_GO_ON;
-
-}
-
-#ifdef USE_ZLIB
-static int deflate_file_to_buffer_gzip(server *srv, connection *con, plugin_data *p, char *start, off_t st_size, time_t mtime) {
- unsigned char *c;
- unsigned long crc;
- z_stream z;
-
- UNUSED(srv);
- UNUSED(con);
-
- z.zalloc = Z_NULL;
- z.zfree = Z_NULL;
- z.opaque = Z_NULL;
-
- if (Z_OK != deflateInit2(&z,
- Z_DEFAULT_COMPRESSION,
- Z_DEFLATED,
- -MAX_WBITS, /* supress zlib-header */
- 8,
- Z_DEFAULT_STRATEGY)) {
- return -1;
- }
-
- z.next_in = (unsigned char *)start;
- z.avail_in = st_size;
- z.total_in = 0;
-
-
- buffer_prepare_copy(p->b, (z.avail_in * 1.1) + 12 + 18);
-
- /* write gzip header */
-
- c = (unsigned char *)p->b->ptr;
- c[0] = 0x1f;
- c[1] = 0x8b;
- c[2] = Z_DEFLATED;
- c[3] = 0; /* options */
- c[4] = (mtime >> 0) & 0xff;
- c[5] = (mtime >> 8) & 0xff;
- c[6] = (mtime >> 16) & 0xff;
- c[7] = (mtime >> 24) & 0xff;
- c[8] = 0x00; /* extra flags */
- c[9] = 0x03; /* UNIX */
-
- p->b->used = 10;
- z.next_out = (unsigned char *)p->b->ptr + p->b->used;
- z.avail_out = p->b->size - p->b->used - 8;
- z.total_out = 0;
-
- if (Z_STREAM_END != deflate(&z, Z_FINISH)) {
- deflateEnd(&z);
- return -1;
- }
-
- /* trailer */
- p->b->used += z.total_out;
-
- crc = generate_crc32c(start, st_size);
-
- c = (unsigned char *)p->b->ptr + p->b->used;
-
- c[0] = (crc >> 0) & 0xff;
- c[1] = (crc >> 8) & 0xff;
- c[2] = (crc >> 16) & 0xff;
- c[3] = (crc >> 24) & 0xff;
- c[4] = (z.total_in >> 0) & 0xff;
- c[5] = (z.total_in >> 8) & 0xff;
- c[6] = (z.total_in >> 16) & 0xff;
- c[7] = (z.total_in >> 24) & 0xff;
- p->b->used += 8;
-
- if (Z_OK != deflateEnd(&z)) {
- return -1;
- }
-
- return 0;
-}
-
-static int deflate_file_to_buffer_deflate(server *srv, connection *con, plugin_data *p, unsigned char *start, off_t st_size) {
- z_stream z;
-
- UNUSED(srv);
- UNUSED(con);
-
- z.zalloc = Z_NULL;
- z.zfree = Z_NULL;
- z.opaque = Z_NULL;
-
- if (Z_OK != deflateInit2(&z,
- Z_DEFAULT_COMPRESSION,
- Z_DEFLATED,
- -MAX_WBITS, /* supress zlib-header */
- 8,
- Z_DEFAULT_STRATEGY)) {
- return -1;
- }
-
- z.next_in = start;
- z.avail_in = st_size;
- z.total_in = 0;
-
- buffer_prepare_copy(p->b, (z.avail_in * 1.1) + 12);
-
- z.next_out = (unsigned char *)p->b->ptr;
- z.avail_out = p->b->size;
- z.total_out = 0;
-
- if (Z_STREAM_END != deflate(&z, Z_FINISH)) {
- deflateEnd(&z);
- return -1;
- }
-
- /* trailer */
- p->b->used += z.total_out;
-
- if (Z_OK != deflateEnd(&z)) {
- return -1;
- }
-
- return 0;
-}
-
-#endif
-
-#ifdef USE_BZ2LIB
-static int deflate_file_to_buffer_bzip2(server *srv, connection *con, plugin_data *p, unsigned char *start, off_t st_size) {
- bz_stream bz;
-
- UNUSED(srv);
- UNUSED(con);
-
- bz.bzalloc = NULL;
- bz.bzfree = NULL;
- bz.opaque = NULL;
-
- if (BZ_OK != BZ2_bzCompressInit(&bz,
- 9, /* blocksize = 900k */
- 0, /* no output */
- 0)) { /* workFactor: default */
- return -1;
- }
-
- bz.next_in = (char *)start;
- bz.avail_in = st_size;
- bz.total_in_lo32 = 0;
- bz.total_in_hi32 = 0;
-
- buffer_prepare_copy(p->b, (bz.avail_in * 1.1) + 12);
-
- bz.next_out = p->b->ptr;
- bz.avail_out = p->b->size;
- bz.total_out_lo32 = 0;
- bz.total_out_hi32 = 0;
-
- if (BZ_STREAM_END != BZ2_bzCompress(&bz, BZ_FINISH)) {
- BZ2_bzCompressEnd(&bz);
- return -1;
- }
-
- /* file is too large for now */
- if (bz.total_out_hi32) return -1;
-
- /* trailer */
- p->b->used = bz.total_out_lo32;
-
- if (BZ_OK != BZ2_bzCompressEnd(&bz)) {
- return -1;
- }
-
- return 0;
-}
-#endif
-
-static int deflate_file_to_file(server *srv, connection *con, plugin_data *p, buffer *fn, stat_cache_entry *sce, int type) {
- int ifd, ofd;
- int ret = -1;
- void *start;
- const char *filename = fn->ptr;
- ssize_t r;
- stat_cache_entry *compressed_sce = NULL;
-
- if (buffer_is_empty(p->conf.compress_cache_dir)) return -1;
-
- /* overflow */
- if ((off_t)(sce->st.st_size * 1.1) < sce->st.st_size) return -1;
-
- /* don't mmap files > 128Mb
- *
- * we could use a sliding window, but currently there is no need for it
- */
-
- if (sce->st.st_size > 128 * 1024 * 1024) return -1;
-
- buffer_reset(p->ofn);
- buffer_copy_string_buffer(p->ofn, p->conf.compress_cache_dir);
- PATHNAME_APPEND_SLASH(p->ofn);
-
- if (0 == strncmp(con->physical.path->ptr, con->physical.doc_root->ptr, con->physical.doc_root->used-1)) {
- buffer_append_string(p->ofn, con->physical.path->ptr + con->physical.doc_root->used - 1);
- buffer_copy_string_buffer(p->b, p->ofn);
- } else {
- buffer_append_string_buffer(p->ofn, con->uri.path);
- }
-
- switch(type) {
- case HTTP_ACCEPT_ENCODING_GZIP:
- buffer_append_string_len(p->ofn, CONST_STR_LEN("-gzip-"));
- break;
- case HTTP_ACCEPT_ENCODING_DEFLATE:
- buffer_append_string_len(p->ofn, CONST_STR_LEN("-deflate-"));
- break;
- case HTTP_ACCEPT_ENCODING_BZIP2:
- buffer_append_string_len(p->ofn, CONST_STR_LEN("-bzip2-"));
- break;
- default:
- ERROR("unknown compression type %d", type);
- return -1;
- }
-
- buffer_append_string_buffer(p->ofn, sce->etag);
-
-
- if (HANDLER_ERROR != stat_cache_get_entry(srv, con, p->ofn, &compressed_sce)) {
- /* file exists */
- if (con->conf.log_request_handling) TRACE("file exists in the cache (%s), sending it", SAFE_BUF_STR(p->ofn));
-
- chunkqueue_reset(con->send);
- chunkqueue_append_file(con->send, p->ofn, 0, compressed_sce->st.st_size);
- con->send->is_closed = 1;
-
- return 0;
- }
-
- if (-1 == (ofd = open(p->ofn->ptr, O_WRONLY | O_CREAT | O_EXCL | O_BINARY, 0600))) {
- if (-1 == mkdir_for_file(p->ofn->ptr)) {
- return -1; // error message in mkdir_for_file
- } else if (-1 == (ofd = open(p->ofn->ptr, O_WRONLY | O_CREAT | O_EXCL | O_BINARY, 0600))) {
- ERROR("creating cachefile '%s' failed: %s", SAFE_BUF_STR(p->ofn), strerror(errno));
- return -1;
- }
- }
-
- if (-1 == (ifd = open(filename, O_RDONLY | O_BINARY))) {
- ERROR("opening plain-file '%s' failed: %s", SAFE_BUF_STR(fn), strerror(errno));
- close(ofd);
- return -1;
- }
-
-
- if (MAP_FAILED == (start = mmap(NULL, sce->st.st_size, PROT_READ, MAP_SHARED, ifd, 0))) {
- ERROR("mmaping '%s' failed: %s", SAFE_BUF_STR(fn), strerror(errno));
- close(ofd);
- close(ifd);
- return -1;
- }
-
- switch(type) {
-#ifdef USE_ZLIB
- case HTTP_ACCEPT_ENCODING_GZIP:
- ret = deflate_file_to_buffer_gzip(srv, con, p, start, sce->st.st_size, sce->st.st_mtime);
- break;
- case HTTP_ACCEPT_ENCODING_DEFLATE:
- ret = deflate_file_to_buffer_deflate(srv, con, p, start, sce->st.st_size);
- break;
-#endif
-#ifdef USE_BZ2LIB
- case HTTP_ACCEPT_ENCODING_BZIP2:
- ret = deflate_file_to_buffer_bzip2(srv, con, p, start, sce->st.st_size);
- break;
-#endif
- default:
- ret = -1;
- break;
- }
-
- if (-1 == (r = write(ofd, p->b->ptr, p->b->used))) {
- munmap(start, sce->st.st_size);
- close(ofd);
- close(ifd);
- return -1;
- }
-
- if ((size_t)r != p->b->used) {
-
- }
-
- munmap(start, sce->st.st_size);
- close(ofd);
- close(ifd);
-
- if (ret != 0) return -1;
-
- chunkqueue_reset(con->send);
- chunkqueue_append_file(con->send, p->ofn, 0, r);
- con->send->is_closed = 1;
-
- return 0;
-}
-
-static int deflate_file_to_buffer(server *srv, connection *con, plugin_data *p, buffer *fn, stat_cache_entry *sce, int type) {
- int ifd;
- int ret = -1;
- void *start;
- buffer *b;
-
- /* overflow */
- if ((off_t)(sce->st.st_size * 1.1) < sce->st.st_size) return -1;
-
- /* don't mmap files > 128M
- *
- * we could use a sliding window, but currently there is no need for it
- */
-
- if (sce->st.st_size > 128 * 1024 * 1024) return -1;
-
- if (-1 == (ifd = open(fn->ptr, O_RDONLY | O_BINARY))) {
- ERROR("opening plain-file '%s' failed: %s", SAFE_BUF_STR(fn), strerror(errno));
-
- return -1;
- }
-
- start = mmap(NULL, sce->st.st_size, PROT_READ, MAP_SHARED, ifd, 0);
-
- close(ifd);
-
- if (MAP_FAILED == start) {
- ERROR("mmaping '%s' failed: %s", SAFE_BUF_STR(fn), strerror(errno));
-
- return -1;
- }
-
- switch(type) {
-#ifdef USE_ZLIB
- case HTTP_ACCEPT_ENCODING_GZIP:
- ret = deflate_file_to_buffer_gzip(srv, con, p, start, sce->st.st_size, sce->st.st_mtime);
- break;
- case HTTP_ACCEPT_ENCODING_DEFLATE:
- ret = deflate_file_to_buffer_deflate(srv, con, p, start, sce->st.st_size);
- break;
-#endif
-#ifdef USE_BZ2LIB
- case HTTP_ACCEPT_ENCODING_BZIP2:
- ret = deflate_file_to_buffer_bzip2(srv, con, p, start, sce->st.st_size);
- break;
-#endif
- default:
- ret = -1;
- break;
- }
-
- munmap(start, sce->st.st_size);
-
- if (ret != 0) return -1;
-
- chunkqueue_reset(con->send);
- b = chunkqueue_get_append_buffer(con->send);
- buffer_copy_memory(b, p->b->ptr, p->b->used + 1);
- con->send->bytes_in += b->used-1;
-
- buffer_reset(con->physical.path);
-
- con->send->is_closed = 1;
- con->file_started = 1;
-
- return 0;
-}
-
-static int mod_compress_patch_connection(server *srv, connection *con, plugin_data *p) {
- size_t i, j;
- plugin_config *s = p->config_storage[0];
-
- PATCH_OPTION(compress_cache_dir);
- PATCH_OPTION(compress);
- PATCH_OPTION(compress_max_filesize);
- PATCH_OPTION(allowed_encodings);
-
- /* skip the first, the global context */
- for (i = 1; i < srv->config_context->used; i++) {
- data_config *dc = (data_config *)srv->config_context->data[i];
- s = p->config_storage[i];
-
- /* condition didn't match */
- if (!config_check_cond(srv, con, dc)) continue;
-
- /* merge config */
- for (j = 0; j < dc->value->used; j++) {
- data_unset *du = dc->value->data[j];
-
- if (buffer_is_equal_string(du->key, CONST_STR_LEN("compress.cache-dir"))) {
- PATCH_OPTION(compress_cache_dir);
- } else if (buffer_is_equal_string(du->key, CONST_STR_LEN("compress.filetype"))) {
- PATCH_OPTION(compress);
- } else if (buffer_is_equal_string(du->key, CONST_STR_LEN("compress.max-filesize"))) {
- PATCH_OPTION(compress_max_filesize);
- } else if (buffer_is_equal_string(du->key, CONST_STR_LEN("compress.allowed-encodings"))) {
- PATCH_OPTION(allowed_encodings);
- }
- }
- }
-
- return 0;
-}
-
-PHYSICALPATH_FUNC(mod_compress_physical) {
- plugin_data *p = p_d;
- size_t m;
- off_t max_fsize;
- stat_cache_entry *sce = NULL;
- data_string *ds;
- int accept_encoding = 0;
- char *value;
- int matched_encodings = 0;
- const char *dflt_gzip = "gzip";
- const char *dflt_deflate = "deflate";
- const char *dflt_bzip2 = "bzip2";
-
- const char *compression_name = NULL;
- int compression_type = 0;
- buffer *mtime, *content_type;
-
- if (con->mode != DIRECT) return HANDLER_GO_ON;
-
- if (con->conf.log_request_handling) TRACE("-- %s", "handling in mod_compress");
-
- /* only GET and POST can get compressed */
- if (con->request.http_method != HTTP_METHOD_GET &&
- con->request.http_method != HTTP_METHOD_POST) {
- return HANDLER_GO_ON;
- }
-
- if (buffer_is_empty(con->physical.path)) {
- return HANDLER_GO_ON;
- }
-
- mod_compress_patch_connection(srv, con, p);
-
- max_fsize = p->conf.compress_max_filesize;
-
- if (HANDLER_GO_ON != stat_cache_get_entry(srv, con, con->physical.path, &sce)) {
- if (con->conf.log_request_handling) TRACE("file '%s' not found", SAFE_BUF_STR(con->physical.path));
- return HANDLER_GO_ON;
- }
-
- /* don't compress files that are too large as we need to much time to handle them */
- if (max_fsize && (sce->st.st_size >> 10) > max_fsize) {
- if (con->conf.log_request_handling) TRACE("file '%s' is too large: %jd",
- SAFE_BUF_STR(con->physical.path),
- (intmax_t) sce->st.st_size);
-
- return HANDLER_GO_ON;
- }
-
- /* compressing the file might lead to larger files instead */
- if (sce->st.st_size < 128) {
- if (con->conf.log_request_handling) TRACE("file '%s' is too small: %jd",
- SAFE_BUF_STR(con->physical.path),
- (intmax_t) sce->st.st_size);
-
- return HANDLER_GO_ON;
- }
-
- /* check if mimetype is in compress-config */
- content_type = 0;
- if (sce->content_type->ptr) {
- char *c;
- if ( (c = strchr(BUF_STR(sce->content_type), ';')) != 0) {
- content_type = buffer_init();
- buffer_copy_string_len(content_type, BUF_STR(sce->content_type), c - BUF_STR(sce->content_type));
- }
- }
- for (m = 0; m < p->conf.compress->used; m++) {
- data_string *compress_ds = (data_string *)p->conf.compress->data[m];
-
- if (!compress_ds) {
- ERROR("evil: %s .. %s", SAFE_BUF_STR(con->physical.path), SAFE_BUF_STR(con->uri.path));
-
- return HANDLER_GO_ON;
- }
-
- if (buffer_is_equal(compress_ds->value, sce->content_type)
- || (content_type && buffer_is_equal(compress_ds->value, content_type))) {
- break;
- }
- }
- buffer_free(content_type);
-
- if (m == p->conf.compress->used) {
- return HANDLER_GO_ON;
- }
- /* mimetype found */
-
-
- if (con->send->is_closed == 0) {
- if (con->conf.log_request_handling) TRACE("we can't compress streams: is_closed = %d", con->send->is_closed);
- return HANDLER_GO_ON;
- }
-
- if (con->send->first == NULL) {
- if (con->conf.log_request_handling) TRACE("we can't compress streams: ->first = %p", NULL);
- return HANDLER_GO_ON;
- }
-
- if (con->send->first->next != NULL) {
- if (con->conf.log_request_handling) TRACE("we can't compress streams: ->first->next = %p", NULL);
- return HANDLER_GO_ON;
- }
-
- if (con->send->first->type != FILE_CHUNK) {
- if (con->conf.log_request_handling) TRACE("we can compress file-chunks: ->type = %d", con->send->first->type);
- return HANDLER_GO_ON;
- }
-
- /* the response might change according to Accept-Encoding */
- response_header_insert(srv, con, CONST_STR_LEN("Vary"), CONST_STR_LEN("Accept-Encoding"));
-
- if (NULL == (ds = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("Accept-Encoding")))) {
- if (con->conf.log_request_handling) TRACE("couldn't find a Accept-Encoding header: %s", "");
- return HANDLER_GO_ON;
- }
-
- value = ds->value->ptr;
-
- /* get client side support encodings */
-#ifdef USE_ZLIB
- if (NULL != strstr(value, "gzip")) accept_encoding |= HTTP_ACCEPT_ENCODING_GZIP;
- if (NULL != strstr(value, "deflate")) accept_encoding |= HTTP_ACCEPT_ENCODING_DEFLATE;
- if (NULL != strstr(value, "compress")) accept_encoding |= HTTP_ACCEPT_ENCODING_COMPRESS;
-#endif
-#ifdef USE_BZ2LIB
- if (NULL != strstr(value, "bzip2")) accept_encoding |= HTTP_ACCEPT_ENCODING_BZIP2;
-#endif
- if (NULL != strstr(value, "identity")) accept_encoding |= HTTP_ACCEPT_ENCODING_IDENTITY;
-
- /* find matching entries */
- matched_encodings = accept_encoding & p->conf.allowed_encodings;
- if (0 == matched_encodings) {
- if (con->conf.log_request_handling) TRACE("we don't support the requested encoding: %s", value);
- return HANDLER_GO_ON;
- }
-
- mtime = strftime_cache_get(srv, sce->st.st_mtime);
- etag_mutate(con->physical.etag, sce->etag);
-
- response_header_overwrite(srv, con, CONST_STR_LEN("Last-Modified"), CONST_BUF_LEN(mtime));
- response_header_overwrite(srv, con, CONST_STR_LEN("ETag"), CONST_BUF_LEN(con->physical.etag));
-
- /* perhaps we don't even have to compress the file as the browser still has the
- * current version */
- if (HANDLER_FINISHED == http_response_handle_cachable(srv, con, mtime)) {
- if (con->conf.log_request_handling) TRACE("%s is still the same, caching", SAFE_BUF_STR(con->physical.path));
- return HANDLER_FINISHED;
- }
-
- /* select best matching encoding */
- if (matched_encodings & HTTP_ACCEPT_ENCODING_BZIP2) {
- compression_type = HTTP_ACCEPT_ENCODING_BZIP2;
- compression_name = dflt_bzip2;
- } else if (matched_encodings & HTTP_ACCEPT_ENCODING_GZIP) {
- compression_type = HTTP_ACCEPT_ENCODING_GZIP;
- compression_name = dflt_gzip;
- } else if (matched_encodings & HTTP_ACCEPT_ENCODING_DEFLATE) {
- compression_type = HTTP_ACCEPT_ENCODING_DEFLATE;
- compression_name = dflt_deflate;
- }
-
- if (con->conf.log_request_handling) TRACE("we are fine, let's compress: %s", "");
-
- /* deflate it to file (cached) or to memory */
- if (0 == deflate_file_to_file(srv, con, p,
- con->physical.path, sce, compression_type) ||
- 0 == deflate_file_to_buffer(srv, con, p,
- con->physical.path, sce, compression_type)) {
-
- response_header_overwrite(srv, con,
- CONST_STR_LEN("Content-Encoding"),
- compression_name, strlen(compression_name));
-
- response_header_overwrite(srv, con,
- CONST_STR_LEN("Content-Type"),
- CONST_BUF_LEN(sce->content_type));
-
- con->response.content_length = chunkqueue_length(con->send);
-
- if (con->conf.log_request_handling) TRACE("looks like %s could be compressed", SAFE_BUF_STR(con->physical.path));
- return HANDLER_FINISHED;
- }
-
- return HANDLER_GO_ON;
-}
-
-LI_EXPORT int mod_compress_plugin_init(plugin *p);
-LI_EXPORT int mod_compress_plugin_init(plugin *p) {
- p->version = LIGHTTPD_VERSION_ID;
- p->name = buffer_init_string("compress");
-
- p->init = mod_compress_init;
- p->set_defaults = mod_compress_setdefaults;
-
- /* we have to hook into the response-header settings */
- p->handle_response_header = mod_compress_physical;
-
- p->cleanup = mod_compress_free;
-
- p->data = NULL;
-
- return 0;
-}
View Lorry Controller Status