[BACK]Return to mod_compress.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / lighttpd / src

Diff for /embedaddon/lighttpd/src/mod_compress.c between versions 1.1 and 1.1.1.3

version 1.1, 2013/10/14 10:32:47 version 1.1.1.3, 2016/11/02 10:35:00
Line 1 Line 1
   #include "first.h"
   
 #include "base.h"  #include "base.h"
 #include "log.h"  #include "log.h"
 #include "buffer.h"  #include "buffer.h"
Line 12 Line 14
 #include <sys/types.h>  #include <sys/types.h>
 #include <sys/stat.h>  #include <sys/stat.h>
   
   #include <assert.h>
 #include <fcntl.h>  #include <fcntl.h>
 #include <unistd.h>  #include <unistd.h>
 #include <ctype.h>  #include <ctype.h>
 #include <stdlib.h>  #include <stdlib.h>
 #include <string.h>  #include <string.h>
   #include <strings.h>
 #include <errno.h>  #include <errno.h>
 #include <time.h>  #include <time.h>
   
Line 32 Line 36
 # include <bzlib.h>  # include <bzlib.h>
 #endif  #endif
   
   #if defined HAVE_SYS_MMAN_H && defined HAVE_MMAP && defined ENABLE_MMAP
   #define USE_MMAP
   
 #include "sys-mmap.h"  #include "sys-mmap.h"
   #include <setjmp.h>
   #include <signal.h>
   
   static volatile int sigbus_jmp_valid;
   static sigjmp_buf sigbus_jmp;
   
   static void sigbus_handler(int sig) {
           UNUSED(sig);
           if (sigbus_jmp_valid) siglongjmp(sigbus_jmp, 1);
           log_failed_assert(__FILE__, __LINE__, "SIGBUS");
   }
   #endif
   
 /* request: accept-encoding */  /* request: accept-encoding */
 #define HTTP_ACCEPT_ENCODING_IDENTITY BV(0)  #define HTTP_ACCEPT_ENCODING_IDENTITY BV(0)
 #define HTTP_ACCEPT_ENCODING_GZIP     BV(1)  #define HTTP_ACCEPT_ENCODING_GZIP     BV(1)
Line 89  FREE_FUNC(mod_compress_free) { Line 108  FREE_FUNC(mod_compress_free) {
                 for (i = 0; i < srv->config_context->used; i++) {                  for (i = 0; i < srv->config_context->used; i++) {
                         plugin_config *s = p->config_storage[i];                          plugin_config *s = p->config_storage[i];
   
                        if (!s) continue;                        if (NULL == s) continue;
   
                         array_free(s->compress);                          array_free(s->compress);
                         buffer_free(s->compress_cache_dir);                          buffer_free(s->compress_cache_dir);
Line 161  SETDEFAULTS_FUNC(mod_compress_setdefaults) { Line 180  SETDEFAULTS_FUNC(mod_compress_setdefaults) {
                 { NULL,                             NULL, T_CONFIG_UNSET, T_CONFIG_SCOPE_UNSET }                  { NULL,                             NULL, T_CONFIG_UNSET, T_CONFIG_SCOPE_UNSET }
         };          };
   
        p->config_storage = calloc(1, srv->config_context->used * sizeof(specific_config *));        p->config_storage = calloc(1, srv->config_context->used * sizeof(plugin_config *));
   
         for (i = 0; i < srv->config_context->used; i++) {          for (i = 0; i < srv->config_context->used; i++) {
                   data_config const* config = (data_config const*)srv->config_context->data[i];
                 plugin_config *s;                  plugin_config *s;
                 array  *encodings_arr = array_init();                  array  *encodings_arr = array_init();
   
Line 180  SETDEFAULTS_FUNC(mod_compress_setdefaults) { Line 200  SETDEFAULTS_FUNC(mod_compress_setdefaults) {
   
                 p->config_storage[i] = s;                  p->config_storage[i] = s;
   
                if (0 != config_insert_values_global(srv, ((data_config *)srv->config_context->data[i])->value, cv)) {                if (0 != config_insert_values_global(srv, config->value, cv, i == 0 ? T_CONFIG_SCOPE_SERVER : T_CONFIG_SCOPE_CONNECTION)) {
                         return HANDLER_ERROR;                          return HANDLER_ERROR;
                 }                  }
   
Line 221  SETDEFAULTS_FUNC(mod_compress_setdefaults) { Line 241  SETDEFAULTS_FUNC(mod_compress_setdefaults) {
   
                 array_free(encodings_arr);                  array_free(encodings_arr);
   
                if (!buffer_is_empty(s->compress_cache_dir)) {                if (!buffer_string_is_empty(s->compress_cache_dir)) {
                         struct stat st;                          struct stat st;
                         mkdir_recursive(s->compress_cache_dir->ptr);                          mkdir_recursive(s->compress_cache_dir->ptr);
   
Line 243  static int deflate_file_to_buffer_gzip(server *srv, co Line 263  static int deflate_file_to_buffer_gzip(server *srv, co
         unsigned char *c;          unsigned char *c;
         unsigned long crc;          unsigned long crc;
         z_stream z;          z_stream z;
           size_t outlen;
   
         UNUSED(srv);          UNUSED(srv);
         UNUSED(con);          UNUSED(con);
Line 265  static int deflate_file_to_buffer_gzip(server *srv, co Line 286  static int deflate_file_to_buffer_gzip(server *srv, co
         z.total_in = 0;          z.total_in = 0;
   
   
        buffer_prepare_copy(p->b, (z.avail_in * 1.1) + 12 + 18);        buffer_string_prepare_copy(p->b, (z.avail_in * 1.1) + 12 + 18);
   
         /* write gzip header */          /* write gzip header */
   
Line 281  static int deflate_file_to_buffer_gzip(server *srv, co Line 302  static int deflate_file_to_buffer_gzip(server *srv, co
         c[8] = 0x00; /* extra flags */          c[8] = 0x00; /* extra flags */
         c[9] = 0x03; /* UNIX */          c[9] = 0x03; /* UNIX */
   
        p->b->used = 10;        outlen = 10;
        z.next_out = (unsigned char *)p->b->ptr + p->b->used;        z.next_out = (unsigned char *)p->b->ptr + outlen;
        z.avail_out = p->b->size - p->b->used - 8;        z.avail_out = p->b->size - outlen - 9;
         z.total_out = 0;          z.total_out = 0;
   
         if (Z_STREAM_END != deflate(&z, Z_FINISH)) {          if (Z_STREAM_END != deflate(&z, Z_FINISH)) {
Line 292  static int deflate_file_to_buffer_gzip(server *srv, co Line 313  static int deflate_file_to_buffer_gzip(server *srv, co
         }          }
   
         /* trailer */          /* trailer */
        p->b->used += z.total_out;        outlen += z.total_out;
   
         crc = generate_crc32c(start, st_size);          crc = generate_crc32c(start, st_size);
   
        c = (unsigned char *)p->b->ptr + p->b->used;        c = (unsigned char *)p->b->ptr + outlen;
   
         c[0] = (crc >>  0) & 0xff;          c[0] = (crc >>  0) & 0xff;
         c[1] = (crc >>  8) & 0xff;          c[1] = (crc >>  8) & 0xff;
Line 306  static int deflate_file_to_buffer_gzip(server *srv, co Line 327  static int deflate_file_to_buffer_gzip(server *srv, co
         c[5] = (z.total_in >>  8) & 0xff;          c[5] = (z.total_in >>  8) & 0xff;
         c[6] = (z.total_in >> 16) & 0xff;          c[6] = (z.total_in >> 16) & 0xff;
         c[7] = (z.total_in >> 24) & 0xff;          c[7] = (z.total_in >> 24) & 0xff;
        p->b->used += 8;        outlen += 8;
         buffer_commit(p->b, outlen);
   
         if (Z_OK != deflateEnd(&z)) {          if (Z_OK != deflateEnd(&z)) {
                 return -1;                  return -1;
Line 338  static int deflate_file_to_buffer_deflate(server *srv, Line 360  static int deflate_file_to_buffer_deflate(server *srv,
         z.avail_in = st_size;          z.avail_in = st_size;
         z.total_in = 0;          z.total_in = 0;
   
        buffer_prepare_copy(p->b, (z.avail_in * 1.1) + 12);        buffer_string_prepare_copy(p->b, (z.avail_in * 1.1) + 12);
   
         z.next_out = (unsigned char *)p->b->ptr;          z.next_out = (unsigned char *)p->b->ptr;
        z.avail_out = p->b->size;        z.avail_out = p->b->size - 1;
         z.total_out = 0;          z.total_out = 0;
   
         if (Z_STREAM_END != deflate(&z, Z_FINISH)) {          if (Z_STREAM_END != deflate(&z, Z_FINISH)) {
Line 349  static int deflate_file_to_buffer_deflate(server *srv, Line 371  static int deflate_file_to_buffer_deflate(server *srv,
                 return -1;                  return -1;
         }          }
   
         /* trailer */  
         p->b->used += z.total_out;  
   
         if (Z_OK != deflateEnd(&z)) {          if (Z_OK != deflateEnd(&z)) {
                 return -1;                  return -1;
         }          }
   
           /* trailer */
           buffer_commit(p->b, z.total_out);
   
         return 0;          return 0;
 }  }
   
Line 384  static int deflate_file_to_buffer_bzip2(server *srv, c Line 406  static int deflate_file_to_buffer_bzip2(server *srv, c
         bz.total_in_lo32 = 0;          bz.total_in_lo32 = 0;
         bz.total_in_hi32 = 0;          bz.total_in_hi32 = 0;
   
        buffer_prepare_copy(p->b, (bz.avail_in * 1.1) + 12);        buffer_string_prepare_copy(p->b, (bz.avail_in * 1.1) + 12);
   
         bz.next_out = p->b->ptr;          bz.next_out = p->b->ptr;
        bz.avail_out = p->b->size;        bz.avail_out = p->b->size - 1;
         bz.total_out_lo32 = 0;          bz.total_out_lo32 = 0;
         bz.total_out_hi32 = 0;          bz.total_out_hi32 = 0;
   
Line 396  static int deflate_file_to_buffer_bzip2(server *srv, c Line 418  static int deflate_file_to_buffer_bzip2(server *srv, c
                 return -1;                  return -1;
         }          }
   
           if (BZ_OK != BZ2_bzCompressEnd(&bz)) {
                   return -1;
           }
   
         /* file is too large for now */          /* file is too large for now */
         if (bz.total_out_hi32) return -1;          if (bz.total_out_hi32) return -1;
   
         /* trailer */          /* trailer */
        p->b->used = bz.total_out_lo32;        buffer_commit(p->b, bz.total_out_lo32);
   
         if (BZ_OK != BZ2_bzCompressEnd(&bz)) {  
                 return -1;  
         }  
   
         return 0;          return 0;
 }  }
 #endif  #endif
   
 static int deflate_file_to_file(server *srv, connection *con, plugin_data *p, buffer *fn, stat_cache_entry *sce, int type) {  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 ifd, ofd;
        int ret = -1;        int ret;
 #ifdef USE_MMAP
         volatile int mapped = 0;/* quiet warning: might be clobbered by 'longjmp' */
 #endif
         void *start;          void *start;
         const char *filename = fn->ptr;          const char *filename = fn->ptr;
         ssize_t r;          ssize_t r;
Line 428  static int deflate_file_to_file(server *srv, connectio Line 453  static int deflate_file_to_file(server *srv, connectio
         if (sce->st.st_size > 128 * 1024 * 1024) return -1;          if (sce->st.st_size > 128 * 1024 * 1024) return -1;
   
         buffer_reset(p->ofn);          buffer_reset(p->ofn);
        buffer_copy_string_buffer(p->ofn, p->conf.compress_cache_dir);        buffer_copy_buffer(p->ofn, p->conf.compress_cache_dir);
        BUFFER_APPEND_SLASH(p->ofn);        buffer_append_slash(p->ofn);
   
        if (0 == strncmp(con->physical.path->ptr, con->physical.doc_root->ptr, con->physical.doc_root->used-1)) {        if (0 == strncmp(con->physical.path->ptr, con->physical.doc_root->ptr, buffer_string_length(con->physical.doc_root))) {
                buffer_append_string(p->ofn, con->physical.path->ptr + con->physical.doc_root->used - 1);                buffer_append_string(p->ofn, con->physical.path->ptr + buffer_string_length(con->physical.doc_root));
                buffer_copy_string_buffer(p->b, p->ofn); 
         } else {          } else {
                 buffer_append_string_buffer(p->ofn, con->uri.path);                  buffer_append_string_buffer(p->ofn, con->uri.path);
         }          }
Line 468  static int deflate_file_to_file(server *srv, connectio Line 492  static int deflate_file_to_file(server *srv, connectio
 #if 0  #if 0
                         log_error_write(srv, __FILE__, __LINE__, "bs", p->ofn, "compress-cache hit");                          log_error_write(srv, __FILE__, __LINE__, "bs", p->ofn, "compress-cache hit");
 #endif  #endif
                        buffer_copy_string_buffer(con->physical.path, p->ofn);                        buffer_copy_buffer(con->physical.path, p->ofn);
   
                         return 0;                          return 0;
                 }                  }
Line 494  static int deflate_file_to_file(server *srv, connectio Line 518  static int deflate_file_to_file(server *srv, connectio
         }          }
   
 #ifdef USE_MMAP  #ifdef USE_MMAP
        if (MAP_FAILED == (start = mmap(NULL, sce->st.st_size, PROT_READ, MAP_SHARED, ifd, 0))) {        if (MAP_FAILED != (start = mmap(NULL, sce->st.st_size, PROT_READ, MAP_SHARED, ifd, 0))) {
                log_error_write(srv, __FILE__, __LINE__, "sbss", "mmaping", fn, "failed", strerror(errno));                mapped = 1;
                 signal(SIGBUS, sigbus_handler);
                 sigbus_jmp_valid = 1;
                 if (0 != sigsetjmp(sigbus_jmp, 1)) {
                         sigbus_jmp_valid = 0;
   
                close(ofd);                        log_error_write(srv, __FILE__, __LINE__, "sbd", "SIGBUS in mmap:",
                close(ifd);                                fn, ifd);
   
                /* Remove the incomplete cache file, so that later hits aren't served from it */                        munmap(start, sce->st.st_size);
                if (-1 == unlink(p->ofn->ptr)) {                        close(ofd);
                        log_error_write(srv, __FILE__, __LINE__, "sbss", "unlinking incomplete cachefile", p->ofn, "failed:", strerror(errno));                        close(ifd);
                } 
   
                return -1;                        /* Remove the incomplete cache file, so that later hits aren't served from it */
        }                        if (-1 == unlink(p->ofn->ptr)) {
#else                                log_error_write(srv, __FILE__, __LINE__, "sbss", "unlinking incomplete cachefile", p->ofn, "failed:", strerror(errno));
        start = malloc(sce->st.st_size);                        }
        if (NULL == start || sce->st.st_size != read(ifd, start, sce->st.st_size)) {
                         return -1;
                 }
         } else
 #endif  /* FIXME: might attempt to read very large file completely into memory; see compress.max-filesize config option */
         if (NULL == (start = malloc(sce->st.st_size)) || sce->st.st_size != read(ifd, start, sce->st.st_size)) {
                 log_error_write(srv, __FILE__, __LINE__, "sbss", "reading", fn, "failed", strerror(errno));                  log_error_write(srv, __FILE__, __LINE__, "sbss", "reading", fn, "failed", strerror(errno));
   
                 close(ofd);                  close(ofd);
Line 523  static int deflate_file_to_file(server *srv, connectio Line 555  static int deflate_file_to_file(server *srv, connectio
   
                 return -1;                  return -1;
         }          }
 #endif  
   
           ret = -1;
         switch(type) {          switch(type) {
 #ifdef USE_ZLIB  #ifdef USE_ZLIB
         case HTTP_ACCEPT_ENCODING_GZIP:          case HTTP_ACCEPT_ENCODING_GZIP:
Line 541  static int deflate_file_to_file(server *srv, connectio Line 573  static int deflate_file_to_file(server *srv, connectio
                 ret = deflate_file_to_buffer_bzip2(srv, con, p, start, sce->st.st_size);                  ret = deflate_file_to_buffer_bzip2(srv, con, p, start, sce->st.st_size);
                 break;                  break;
 #endif  #endif
         default:  
                 ret = -1;  
                 break;  
         }          }
   
         if (ret == 0) {          if (ret == 0) {
                r = write(ofd, p->b->ptr, p->b->used);                r = write(ofd, CONST_BUF_LEN(p->b));
                 if (-1 == r) {                  if (-1 == r) {
                         log_error_write(srv, __FILE__, __LINE__, "sbss", "writing cachefile", p->ofn, "failed:", strerror(errno));                          log_error_write(srv, __FILE__, __LINE__, "sbss", "writing cachefile", p->ofn, "failed:", strerror(errno));
                         ret = -1;                          ret = -1;
                } else if ((size_t)r != p->b->used) {                } else if ((size_t)r != buffer_string_length(p->b)) {
                         log_error_write(srv, __FILE__, __LINE__, "sbs", "writing cachefile", p->ofn, "failed: not enough bytes written");                          log_error_write(srv, __FILE__, __LINE__, "sbs", "writing cachefile", p->ofn, "failed: not enough bytes written");
                         ret = -1;                          ret = -1;
                 }                  }
         }          }
   
 #ifdef USE_MMAP  #ifdef USE_MMAP
        munmap(start, sce->st.st_size);        if (mapped) {
#else                sigbus_jmp_valid = 0;
        free(start);                munmap(start, sce->st.st_size);
         } else
 #endif  #endif
                   free(start);
   
         close(ofd);  
         close(ifd);          close(ifd);
   
        if (ret != 0) {        if (0 != close(ofd) || ret != 0) {
                 if (0 == ret) {
                         log_error_write(srv, __FILE__, __LINE__, "sbss", "writing cachefile", p->ofn, "failed:", strerror(errno));
                 }
 
                 /* Remove the incomplete cache file, so that later hits aren't served from it */                  /* Remove the incomplete cache file, so that later hits aren't served from it */
                 if (-1 == unlink(p->ofn->ptr)) {                  if (-1 == unlink(p->ofn->ptr)) {
                         log_error_write(srv, __FILE__, __LINE__, "sbss", "unlinking incomplete cachefile", p->ofn, "failed:", strerror(errno));                          log_error_write(srv, __FILE__, __LINE__, "sbss", "unlinking incomplete cachefile", p->ofn, "failed:", strerror(errno));
Line 575  static int deflate_file_to_file(server *srv, connectio Line 609  static int deflate_file_to_file(server *srv, connectio
                 return -1;                  return -1;
         }          }
   
        buffer_copy_string_buffer(con->physical.path, p->ofn);        buffer_copy_buffer(con->physical.path, p->ofn);
   
         return 0;          return 0;
 }  }
Line 583  static int deflate_file_to_file(server *srv, connectio Line 617  static int deflate_file_to_file(server *srv, connectio
 static int deflate_file_to_buffer(server *srv, connection *con, plugin_data *p, buffer *fn, stat_cache_entry *sce, int type) {  static int deflate_file_to_buffer(server *srv, connection *con, plugin_data *p, buffer *fn, stat_cache_entry *sce, int type) {
         int ifd;          int ifd;
         int ret = -1;          int ret = -1;
   #ifdef USE_MMAP
           volatile int mapped = 0;/* quiet warning: might be clobbered by 'longjmp' */
   #endif
         void *start;          void *start;
         buffer *b;  
   
         /* overflow */          /* overflow */
         if ((off_t)(sce->st.st_size * 1.1) < sce->st.st_size) return -1;          if ((off_t)(sce->st.st_size * 1.1) < sce->st.st_size) return -1;
Line 604  static int deflate_file_to_buffer(server *srv, connect Line 640  static int deflate_file_to_buffer(server *srv, connect
         }          }
   
 #ifdef USE_MMAP  #ifdef USE_MMAP
        if (MAP_FAILED == (start = mmap(NULL, sce->st.st_size, PROT_READ, MAP_SHARED, ifd, 0))) {        if (MAP_FAILED != (start = mmap(NULL, sce->st.st_size, PROT_READ, MAP_SHARED, ifd, 0))) {
                log_error_write(srv, __FILE__, __LINE__, "sbss", "mmaping", fn, "failed", strerror(errno));                mapped = 1;
                 signal(SIGBUS, sigbus_handler);
                 sigbus_jmp_valid = 1;
                 if (0 != sigsetjmp(sigbus_jmp, 1)) {
                         sigbus_jmp_valid = 0;
   
                close(ifd);                        log_error_write(srv, __FILE__, __LINE__, "sbd", "SIGBUS in mmap:",
                return -1;                                fn, ifd);
        }
#else                        munmap(start, sce->st.st_size);
        start = malloc(sce->st.st_size);                        close(ifd);
        if (NULL == start || sce->st.st_size != read(ifd, start, sce->st.st_size)) {                        return -1;
                 }
         } else
 #endif  /* FIXME: might attempt to read very large file completely into memory; see compress.max-filesize config option */
         if (NULL == (start = malloc(sce->st.st_size)) || sce->st.st_size != read(ifd, start, sce->st.st_size)) {
                 log_error_write(srv, __FILE__, __LINE__, "sbss", "reading", fn, "failed", strerror(errno));                  log_error_write(srv, __FILE__, __LINE__, "sbss", "reading", fn, "failed", strerror(errno));
   
                 close(ifd);                  close(ifd);
                 free(start);                  free(start);
                 return -1;                  return -1;
         }          }
 #endif  
   
         switch(type) {          switch(type) {
 #ifdef USE_ZLIB  #ifdef USE_ZLIB
Line 643  static int deflate_file_to_buffer(server *srv, connect Line 686  static int deflate_file_to_buffer(server *srv, connect
         }          }
   
 #ifdef USE_MMAP  #ifdef USE_MMAP
        munmap(start, sce->st.st_size);        if (mapped) {
#else                sigbus_jmp_valid = 0;
        free(start);                munmap(start, sce->st.st_size);
         } else
 #endif  #endif
                   free(start);
   
         close(ifd);          close(ifd);
   
         if (ret != 0) return -1;          if (ret != 0) return -1;
   
         chunkqueue_reset(con->write_queue);          chunkqueue_reset(con->write_queue);
        b = chunkqueue_get_append_buffer(con->write_queue);        chunkqueue_append_buffer(con->write_queue, p->b);
        buffer_copy_memory(b, p->b->ptr, p->b->used + 1); 
   
         buffer_reset(con->physical.path);          buffer_reset(con->physical.path);
   
Line 703  static int mod_compress_patch_connection(server *srv,  Line 748  static int mod_compress_patch_connection(server *srv, 
 }  }
 #undef PATCH  #undef PATCH
   
static int mod_compress_contains_encoding(const char *headervalue, const char *encoding) {static int mod_compress_contains_encoding(const char *headervalue, const char *encoding, size_t len) {
        const char *m;        const char *m = headervalue;
        for ( ;; ) {        do {
                m = strstr(headervalue, encoding);                while (*m == ',' || *m == ' ' || *m == '\t') {
                if (NULL == m) return 0;                        ++m;
                if (m == headervalue || m[-1] == ' ' || m[-1] == ',') return 1;                }
                if (0 == strncasecmp(m, encoding, len)) {
                /* only partial match, search for next value */                        /*(not a full HTTP field parse: not parsing for q-values and not handling q=0)*/
                m = strchr(m, ',');                        m += len;
                if (NULL == m) return 0;                        if (*m == '\0' || *m == ',' || *m == ';' || *m == ' ' || *m == '\t')
                headervalue = m + 1;                                return 1;
        }                } else if (*m != '\0') {
                         ++m;
                 }
         } while ((m = strchr(m, ',')));
         return 0;
 }  }
   
 PHYSICALPATH_FUNC(mod_compress_physical) {  PHYSICALPATH_FUNC(mod_compress_physical) {
Line 733  PHYSICALPATH_FUNC(mod_compress_physical) { Line 782  PHYSICALPATH_FUNC(mod_compress_physical) {
                 return HANDLER_GO_ON;                  return HANDLER_GO_ON;
         }          }
   
        if (buffer_is_empty(con->physical.path)) {        if (buffer_string_is_empty(con->physical.path)) {
                 return HANDLER_GO_ON;                  return HANDLER_GO_ON;
         }          }
   
Line 810  PHYSICALPATH_FUNC(mod_compress_physical) { Line 859  PHYSICALPATH_FUNC(mod_compress_physical) {
   
                                 /* get client side support encodings */                                  /* get client side support encodings */
 #ifdef USE_ZLIB  #ifdef USE_ZLIB
                                if (mod_compress_contains_encoding(value, "gzip")) accept_encoding |= HTTP_ACCEPT_ENCODING_GZIP;                                if (mod_compress_contains_encoding(value, CONST_STR_LEN("gzip"))) accept_encoding |= HTTP_ACCEPT_ENCODING_GZIP;
                                if (mod_compress_contains_encoding(value, "x-gzip")) accept_encoding |= HTTP_ACCEPT_ENCODING_X_GZIP;                                if (mod_compress_contains_encoding(value, CONST_STR_LEN("x-gzip"))) accept_encoding |= HTTP_ACCEPT_ENCODING_X_GZIP;
                                if (mod_compress_contains_encoding(value, "deflate")) accept_encoding |= HTTP_ACCEPT_ENCODING_DEFLATE;                                if (mod_compress_contains_encoding(value, CONST_STR_LEN("deflate"))) accept_encoding |= HTTP_ACCEPT_ENCODING_DEFLATE;
                                if (mod_compress_contains_encoding(value, "compress")) accept_encoding |= HTTP_ACCEPT_ENCODING_COMPRESS;                                if (mod_compress_contains_encoding(value, CONST_STR_LEN("compress"))) accept_encoding |= HTTP_ACCEPT_ENCODING_COMPRESS;
 #endif  #endif
 #ifdef USE_BZ2LIB  #ifdef USE_BZ2LIB
                                if (mod_compress_contains_encoding(value, "bzip2")) accept_encoding |= HTTP_ACCEPT_ENCODING_BZIP2;                                if (mod_compress_contains_encoding(value, CONST_STR_LEN("bzip2"))) accept_encoding |= HTTP_ACCEPT_ENCODING_BZIP2;
                                if (mod_compress_contains_encoding(value, "x-bzip2")) accept_encoding |= HTTP_ACCEPT_ENCODING_X_BZIP2;                                if (mod_compress_contains_encoding(value, CONST_STR_LEN("x-bzip2"))) accept_encoding |= HTTP_ACCEPT_ENCODING_X_BZIP2;
 #endif  #endif
                                if (mod_compress_contains_encoding(value, "identity")) accept_encoding |= HTTP_ACCEPT_ENCODING_IDENTITY;                                if (mod_compress_contains_encoding(value, CONST_STR_LEN("identity"))) accept_encoding |= HTTP_ACCEPT_ENCODING_IDENTITY;
   
                                 /* find matching entries */                                  /* find matching entries */
                                 matched_encodings = accept_encoding & p->conf.allowed_encodings;                                  matched_encodings = accept_encoding & p->conf.allowed_encodings;
Line 860  PHYSICALPATH_FUNC(mod_compress_physical) { Line 909  PHYSICALPATH_FUNC(mod_compress_physical) {
                                         } else if (matched_encodings & HTTP_ACCEPT_ENCODING_X_GZIP) {                                          } else if (matched_encodings & HTTP_ACCEPT_ENCODING_X_GZIP) {
                                                 compression_type = HTTP_ACCEPT_ENCODING_X_GZIP;                                                  compression_type = HTTP_ACCEPT_ENCODING_X_GZIP;
                                                 compression_name = dflt_x_gzip;                                                  compression_name = dflt_x_gzip;
                                        } else if (matched_encodings & HTTP_ACCEPT_ENCODING_DEFLATE) {                                        } else {
                                                 force_assert(matched_encodings & HTTP_ACCEPT_ENCODING_DEFLATE);
                                                 compression_type = HTTP_ACCEPT_ENCODING_DEFLATE;                                                  compression_type = HTTP_ACCEPT_ENCODING_DEFLATE;
                                                 compression_name = dflt_deflate;                                                  compression_name = dflt_deflate;
                                         }                                          }
   
                                         if (use_etag) {                                          if (use_etag) {
                                                 /* try matching etag of compressed version */                                                  /* try matching etag of compressed version */
                                                buffer_copy_string_buffer(srv->tmp_buf, sce->etag);                                                buffer_copy_buffer(srv->tmp_buf, sce->etag);
                                                 buffer_append_string_len(srv->tmp_buf, CONST_STR_LEN("-"));                                                  buffer_append_string_len(srv->tmp_buf, CONST_STR_LEN("-"));
                                                 buffer_append_string(srv->tmp_buf, compression_name);                                                  buffer_append_string(srv->tmp_buf, compression_name);
                                                 etag_mutate(con->physical.etag, srv->tmp_buf);                                                  etag_mutate(con->physical.etag, srv->tmp_buf);
Line 884  PHYSICALPATH_FUNC(mod_compress_physical) { Line 934  PHYSICALPATH_FUNC(mod_compress_physical) {
                                         }                                          }
   
                                         /* deflate it */                                          /* deflate it */
                                        if (use_etag && p->conf.compress_cache_dir->used) {                                        if (use_etag && !buffer_string_is_empty(p->conf.compress_cache_dir)) {
                                                 if (0 != deflate_file_to_file(srv, con, p, con->physical.path, sce, compression_type))                                                  if (0 != deflate_file_to_file(srv, con, p, con->physical.path, sce, compression_type))
                                                         return HANDLER_GO_ON;                                                          return HANDLER_GO_ON;
                                         } else {                                          } else {
Line 898  PHYSICALPATH_FUNC(mod_compress_physical) { Line 948  PHYSICALPATH_FUNC(mod_compress_physical) {
                                         }                                          }
                                         response_header_overwrite(srv, con, CONST_STR_LEN("Content-Type"), CONST_BUF_LEN(sce->content_type));                                          response_header_overwrite(srv, con, CONST_STR_LEN("Content-Type"), CONST_BUF_LEN(sce->content_type));
                                         /* let mod_staticfile handle the cached compressed files, physical path was modified */                                          /* let mod_staticfile handle the cached compressed files, physical path was modified */
                                        return (use_etag && p->conf.compress_cache_dir->used) ? HANDLER_GO_ON : HANDLER_FINISHED;                                        return (use_etag && !buffer_string_is_empty(p->conf.compress_cache_dir)) ? HANDLER_GO_ON : HANDLER_FINISHED;
                                 }                                  }
                         }                          }
                 }                  }
Removed from v.1.1  
changed lines
  Added in v.1.1.1.3

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>