Request body read state implemented.

With specific timeout and buffer size settings.

1 files changed, 4 insertions, 3 deletions

diff --git a/src/nginext/nxt_go_port.c b/src/nginext/nxt_go_port.c
index af50b860..fca3cf9a 100644
--- a/src/nginext/nxt_go_port.c
+++ b/src/nginext/nxt_go_port.c
@@ -83,22 +83,23 @@ nxt_go_data_handler(nxt_port_msg_t *port_msg, size_t size)
 
     do {
         rc = nxt_go_ctx_read_str(ctx, &n);
-        rc = nxt_go_ctx_read_str(ctx, &v);
 
         if (n.length == 0) {
             break;
         }
 
+        rc = nxt_go_ctx_read_str(ctx, &v);
         nxt_go_request_add_header(r, nxt_go_str(&n), nxt_go_str(&v));
     } while(1);
 
-    ctx->r.body.preread = v;
+    nxt_go_ctx_read_size(ctx, &s);
+    ctx->r.body.preread_size = s;
 
     if (h->parsed_content_length > 0) {
         nxt_go_request_set_content_length(r, h->parsed_content_length);
     }
 
-    if (v.length < h->parsed_content_length) {
+    if (ctx->r.body.preread_size < h->parsed_content_length) {
         nxt_go_request_create_channel(r);
     }