Stream: marking incoming chain as processed.

Previously, the buffers of proxy module were not reclaimed.
This resulted in stopping the processing of new data chunks from
a client after proxy_buffer_size bytes were received.

diff --git a/nginx/ngx_stream_js_module.c b/nginx/ngx_stream_js_module.c
index 3981c7b3c4b78dfd3e745b3ce403018092de2a82..7526bc18187d674bc7b1c803c3f74ccb3ee583ed 100644 (file)
--- a/nginx/ngx_stream_js_module.c
+++ b/nginx/ngx_stream_js_module.c
@@ -570,6 +570,8 @@ ngx_stream_js_body_filter(ngx_stream_session_t *s, ngx_chain_t *in,
                 goto exception;
             }
 
+            ctx->buf->pos = ctx->buf->last;
+
         } else {
             cl = ngx_alloc_chain_link(c->pool);
             if (cl == NULL) {