summaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorMax Romanov <max.romanov@nginx.com>2017-08-30 11:50:29 -0700
committerMax Romanov <max.romanov@nginx.com>2017-08-30 11:50:29 -0700
commit9537821f3f486f5176affc7d4f51328c23efd48f (patch)
tree6001f9529a7ba65941bc98e6b4662725e79c23ff
parent9791b09ce35ca982cb04152847938124bb293cac (diff)
downloadunit-9537821f3f486f5176affc7d4f51328c23efd48f.tar.gz
unit-9537821f3f486f5176affc7d4f51328c23efd48f.tar.bz2
Send remote address to go application.
-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);