diff options
| -rw-r--r-- | src/nginext/nxt_go_port.c | 5 | ||||
| -rw-r--r-- | src/nxt_router.c | 1 |
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); |