cache patch

[Igor Sysoev <is@xxxxxxxxxxxxx>]

Прилагаемый патч

1) кэширует только GET
2) понимает X-Accel-Expires.

   X-Accel-Expires: 0               # запрет кэширования
   X-Accel-Expires: 5               # кэшировать на 5 секунд
   X-Accel-Expires: @1238763266     # кэшировать до "Apr 3 16:54:26 MSD 2009"


-- 
Игорь Сысоев
http://sysoev.ru

Index: src/http/ngx_http_upstream.c
===================================================================
--- src/http/ngx_http_upstream.c        (revision 1981)
+++ src/http/ngx_http_upstream.c        (working copy)
@@ -74,6 +74,8 @@
     ngx_table_elt_t *h, ngx_uint_t offset);
 static ngx_int_t ngx_http_upstream_ignore_header_line(ngx_http_request_t *r,
     ngx_table_elt_t *h, ngx_uint_t offset);
+static ngx_int_t ngx_http_upstream_process_accel_expires(ngx_http_request_t *r,
+    ngx_table_elt_t *h, ngx_uint_t offset);
 static ngx_int_t ngx_http_upstream_process_limit_rate(ngx_http_request_t *r,
     ngx_table_elt_t *h, ngx_uint_t offset);
 static ngx_int_t ngx_http_upstream_process_buffering(ngx_http_request_t *r,
@@ -214,7 +216,7 @@
                  ngx_http_upstream_copy_header_line, 0, 0 },
 
     { ngx_string("X-Accel-Expires"),
-                 ngx_http_upstream_process_header_line,
+                 ngx_http_upstream_process_accel_expires,
                  offsetof(ngx_http_upstream_headers_in_t, x_accel_expires),
                  ngx_http_upstream_copy_header_line, 0, 0 },
 
@@ -531,6 +533,10 @@
     ngx_int_t          rc;
     ngx_http_cache_t  *c;
 
+    if (!(r->method & NGX_HTTP_GET)) {
+        return NGX_DECLINED;
+    }
+
     c = ngx_pcalloc(r->pool, sizeof(ngx_http_cache_t));
     if (c == NULL) {
         return NGX_ERROR;
@@ -1910,14 +1916,19 @@
     if (u->cacheable) {
         time_t  now, valid;
 
-        valid = ngx_http_file_cache_valid(u->conf->cache_valid,
-                                          u->headers_in.status_n);
-        if (valid) {
+        now = ngx_time();
 
-            now = ngx_time();
+        valid = r->cache->valid_sec;
 
-            r->cache->valid_sec = now + valid;
+        if (valid == 0) {
+            valid = ngx_http_file_cache_valid(u->conf->cache_valid,
+                                              u->headers_in.status_n);
+            if (valid) {
+                r->cache->valid_sec = now + valid;
+            }
+        }
 
+        if (valid) {
             r->cache->last_modified = r->headers_out.last_modified_time;
             r->cache->date = now;
             r->cache->body_start = (u_short) (u->buffer.pos - u->buffer.start);
@@ -2828,6 +2839,54 @@
 
 
 static ngx_int_t
+ngx_http_upstream_process_accel_expires(ngx_http_request_t *r,
+    ngx_table_elt_t *h, ngx_uint_t offset)
+{
+    u_char     *p;
+    size_t      len;
+    ngx_int_t   n;
+
+    r->upstream->headers_in.x_accel_expires = h;
+
+    if (r->cache == NULL) {
+        return NGX_OK;
+    }
+
+    len = h->value.len;
+    p = h->value.data;
+
+    if (p[0] != '@') {
+        n = ngx_atoi(p, len);
+
+        switch (n) {
+        case 0:
+            r->upstream->cacheable = 0;
+            break;
+
+        case NGX_ERROR:
+            break;
+
+        default:
+            r->cache->valid_sec = ngx_time() + n;
+            break;
+        }
+
+    } else {
+        p++;
+        len--;
+
+        n = ngx_atoi(p, len);
+
+        if (n != NGX_ERROR) {
+            r->cache->valid_sec = n;
+        }
+    }
+
+    return NGX_OK;
+}
+
+
+static ngx_int_t
 ngx_http_upstream_process_limit_rate(ngx_http_request_t *r, ngx_table_elt_t *h,
     ngx_uint_t offset)
 {