Stop publisher on shutdown or terminate.

Author: arut

src/ngx_http_ts_module.c

@@ -185,6 +185,11 @@ ngx_http_ts_read_event_handler(ngx_http_request_t *r)
     ngx_http_ts_ctx_t        *ctx;
     ngx_http_request_body_t  *rb;
 
+    if (ngx_exiting || ngx_terminate) {
+        ngx_http_finalize_request(r, NGX_HTTP_CLOSE);
+        return;
+    }
+
     ctx = ngx_http_get_module_ctx(r, ngx_http_ts_module);
 
     rb = r->request_body;

src/ngx_stream_ts_module.c

@@ -154,6 +154,11 @@ ngx_stream_ts_read_handler(ngx_event_t *rev)
     c = rev->data;
     s = c->data;
 
+    if (ngx_exiting || ngx_terminate) {
+        ngx_stream_finalize_request(s, NGX_STREAM_OK);
+        return;
+    }
+
     if (rev->timedout) {
         ngx_stream_finalize_session(s, NGX_STREAM_OK);
         return;