Proxy: fixed do_write handling in previous commit.

As rightfully complained by MSVC, do_write variable was used uninitialized.
Correct fix is to set it's initial value based on event happened.

diff --git a/src/http/ngx_http_upstream.c b/src/http/ngx_http_upstream.c
index 8c6367397761844b89c257203755b45c29074b3c..6a77f7f0369ee97784ac4573399cddb75d7bf4f9 100644 (file)
--- a/src/http/ngx_http_upstream.c
+++ b/src/http/ngx_http_upstream.c
@@ -55,7 +55,7 @@ static void ngx_http_upstream_upgraded_read_upstream(ngx_http_request_t *r,
 static void ngx_http_upstream_upgraded_write_upstream(ngx_http_request_t *r,
     ngx_http_upstream_t *u);
 static void ngx_http_upstream_process_upgraded(ngx_http_request_t *r,
-    ngx_uint_t from_upstream);
+    ngx_uint_t from_upstream, ngx_uint_t do_write);
 static void
     ngx_http_upstream_process_non_buffered_downstream(ngx_http_request_t *r);
 static void
@@ -2432,13 +2432,13 @@ ngx_http_upstream_upgrade(ngx_http_request_t *r, ngx_http_upstream_t *u)
     if (u->peer.connection->read->ready
         || u->buffer.pos != u->buffer.last)
     {
-        ngx_http_upstream_process_upgraded(r, 1);
+        ngx_http_upstream_process_upgraded(r, 1, 1);
     }
 
     if (c->read->ready
         || r->header_in->pos != r->header_in->last)
     {
-        ngx_http_upstream_process_upgraded(r, 0);
+        ngx_http_upstream_process_upgraded(r, 0, 1);
     }
 }
 
@@ -2446,14 +2446,14 @@ ngx_http_upstream_upgrade(ngx_http_request_t *r, ngx_http_upstream_t *u)
 static void
 ngx_http_upstream_upgraded_read_downstream(ngx_http_request_t *r)
 {
-    ngx_http_upstream_process_upgraded(r, 0);
+    ngx_http_upstream_process_upgraded(r, 0, 0);
 }
 
 
 static void
 ngx_http_upstream_upgraded_write_downstream(ngx_http_request_t *r)
 {
-    ngx_http_upstream_process_upgraded(r, 1);
+    ngx_http_upstream_process_upgraded(r, 1, 1);
 }
 
 
@@ -2461,7 +2461,7 @@ static void
 ngx_http_upstream_upgraded_read_upstream(ngx_http_request_t *r,
     ngx_http_upstream_t *u)
 {
-    ngx_http_upstream_process_upgraded(r, 1);
+    ngx_http_upstream_process_upgraded(r, 1, 0);
 }
 
 
@@ -2469,18 +2469,17 @@ static void
 ngx_http_upstream_upgraded_write_upstream(ngx_http_request_t *r,
     ngx_http_upstream_t *u)
 {
-    ngx_http_upstream_process_upgraded(r, 0);
+    ngx_http_upstream_process_upgraded(r, 0, 1);
 }
 
 
 static void
 ngx_http_upstream_process_upgraded(ngx_http_request_t *r,
-    ngx_uint_t from_upstream)
+    ngx_uint_t from_upstream, ngx_uint_t do_write)
 {
     size_t                     size;
     ssize_t                    n;
     ngx_buf_t                 *b;
-    ngx_uint_t                 do_write;
     ngx_connection_t          *c, *downstream, *upstream, *dst, *src;
     ngx_http_upstream_t       *u;
     ngx_http_core_loc_conf_t  *clcf;