now we always set Content-Length for the cached responses. thanks Andre Pascha.

agentzh · agentzh · commit 2a5858b4a400 · 2011-02-07T18:35:14.000+08:00
diff --git a/src/ngx_http_srcache_filter_module.c b/src/ngx_http_srcache_filter_module.c
@@ -551,6 +551,7 @@ ngx_http_srcache_access_handler(ngx_http_request_t *r)
     ngx_http_srcache_main_conf_t   *smcf;
     ngx_http_srcache_ctx_t         *ctx;
     ngx_chain_t                    *cl;
+    size_t                          len;
 
     if (r != r->main) {
         return NGX_DECLINED;
@@ -601,29 +602,44 @@ ngx_http_srcache_access_handler(ngx_http_request_t *r)
 
             dd("sending header");
 
-            rc = ngx_http_next_header_filter(r);
-
-            if (rc == NGX_ERROR || rc >= NGX_HTTP_SPECIAL_RESPONSE) {
-                return rc;
-            }
-
-            dd("sent header from cache: %d", (int) rc);
-
             if (ctx->body_from_cache) {
+                len = 0;
+
                 for (cl = ctx->body_from_cache; cl->next; cl = cl->next) {
-                    /* do nothing */
+                    len += ngx_buf_size(cl->buf);
                 }
 
+                len += ngx_buf_size(cl->buf);
+
                 cl->buf->last_buf = 1;
 
+                r->headers_out.content_length_n = len;
+
+                rc = ngx_http_next_header_filter(r);
+
+                if (rc == NGX_ERROR || rc >= NGX_HTTP_SPECIAL_RESPONSE) {
+                    return rc;
+                }
+
                 rc = ngx_http_next_body_filter(r, ctx->body_from_cache);
 
                 if (rc == NGX_ERROR || rc >= NGX_HTTP_SPECIAL_RESPONSE) {
                     return rc;
                 }
 
                 dd("sent body from cache: %d", (int) rc);
+
             } else {
+                r->headers_out.content_length_n = 0;
+
+                rc = ngx_http_next_header_filter(r);
+
+                if (rc == NGX_ERROR || rc >= NGX_HTTP_SPECIAL_RESPONSE) {
+                    return rc;
+                }
+
+                dd("sent header from cache: %d", (int) rc);
+
                 dd("send last buf for the main request");
 
                 cl = ngx_alloc_chain_link(r->pool);
diff --git a/t/err-page.t b/t/err-page.t
@@ -55,6 +55,7 @@ GET /flush
 GET /foo
 --- response_body
 err
+--- LAST
 
 
 
diff --git a/t/main-req.t b/t/main-req.t
@@ -5,7 +5,7 @@ use Test::Nginx::Socket;
 
 #repeat_each(2);
 
-plan tests => repeat_each() * 3 * blocks();
+plan tests => repeat_each() * 4 * blocks();
 
 $ENV{TEST_NGINX_MEMCACHED_PORT} ||= 11211;
 
@@ -23,6 +23,7 @@ __DATA__
     }
 --- response_headers
 Content-Type: text/plain
+Content-Length: 4
 --- request
 GET /flush
 --- response_body eval: "OK\r\n"
@@ -50,6 +51,7 @@ GET /flush
 GET /foo
 --- response_headers
 Content-Type: text/css
+Content-Length:
 --- response_body
 hello
 
@@ -76,6 +78,7 @@ hello
 GET /foo
 --- response_headers
 Content-Type: text/css
+Content-Length: 6
 --- response_body
 hello
 
@@ -104,6 +107,7 @@ hello
 GET /foo
 --- response_headers
 Content-Type: text/css
+Content-Length: 6
 --- response_body
 hello
 
