summaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/nginext/nxt_go_port.c5
-rw-r--r--src/nxt_router.c1
2 files changed, 6 insertions, 0 deletions
diff --git a/src/nginext/nxt_go_port.c b/src/nginext/nxt_go_port.c
index fca3cf9a..033dd5be 100644
--- a/src/nginext/nxt_go_port.c
+++ b/src/nginext/nxt_go_port.c
@@ -69,6 +69,11 @@ nxt_go_data_handler(nxt_port_msg_t *port_msg, size_t size)
h->version.start[5] - '0',
h->version.start[7] - '0');
+ nxt_go_ctx_read_str(ctx, &ctx->r.remote);
+ if (ctx->r.remote.start != NULL) {
+ nxt_go_request_set_remote_addr(r, nxt_go_str(&ctx->r.remote));
+ }
+
nxt_go_ctx_read_str(ctx, &h->host);
nxt_go_ctx_read_str(ctx, &h->cookie);
nxt_go_ctx_read_str(ctx, &h->content_type);
diff --git a/src/nxt_router.c b/src/nxt_router.c
index 62e1f3a9..97d6dada 100644
--- a/src/nxt_router.c
+++ b/src/nxt_router.c
@@ -2934,6 +2934,7 @@ nxt_go_prepare_msg(nxt_task_t *task, nxt_app_request_t *r, nxt_app_wmsg_t *wmsg)
}
NXT_WRITE(&h->version);
+ NXT_WRITE(&r->remote);
NXT_WRITE(&h->host);
NXT_WRITE(&h->cookie);