36d35
< nxt_request_app_link_t *req_app_link;
40a40
> req_rpc_data = r->req_rpc_data;
42,44c42
< if (nxt_slow_path((req_rpc_data = r->req_rpc_data) == NULL
< || (req_app_link = req_rpc_data->req_app_link) == NULL))
< {
---
> if (nxt_slow_path(req_rpc_data == NULL)) {
72,73c70
< buf = nxt_port_mmap_get_buf(task,
< &req_app_link->app_port->process->outgoing,
---
> buf = nxt_port_mmap_get_buf(task, &req_rpc_data->app->outgoing,
104c101
< res = nxt_port_socket_twrite(task, req_app_link->app_port,
---
> res = nxt_port_socket_twrite(task, req_rpc_data->app_port,
106,107c103,104
< req_app_link->stream,
< req_app_link->reply_port->id, out, NULL);
---
> req_rpc_data->stream,
> task->thread->engine->port->id, out, NULL);
133d129
< nxt_request_app_link_t *req_app_link;
138a135
> req_rpc_data = r->req_rpc_data;
140c137
< if ((req_rpc_data = r->req_rpc_data) == NULL) {
---
> if (req_rpc_data == NULL) {
145,150c142
< if ((req_app_link = req_rpc_data->req_app_link) == NULL) {
< nxt_debug(task, " req_app_link is NULL");
< goto close_handler;
< }
<
< if (req_app_link->app_port == NULL) {
---
> if (req_rpc_data->app_port == NULL) {
155c147
< (void) nxt_port_socket_twrite(task, req_app_link->app_port,
---
> (void) nxt_port_socket_twrite(task, req_rpc_data->app_port,
157,158c149,150
< -1, req_app_link->stream,
< req_app_link->reply_port->id, NULL, NULL);
---
> -1, req_rpc_data->stream,
> task->thread->engine->port->id, NULL, NULL);