diff options
Diffstat (limited to 'src/go/unit')
| -rw-r--r-- | src/go/unit/nxt_go_port_memory.c | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/go/unit/nxt_go_port_memory.c b/src/go/unit/nxt_go_port_memory.c index d2c0a0aa..310e17cb 100644 --- a/src/go/unit/nxt_go_port_memory.c +++ b/src/go/unit/nxt_go_port_memory.c @@ -105,7 +105,8 @@ nxt_go_new_port_mmap(nxt_go_process_t *process, nxt_port_id_t id) memset(hdr->free_map, 0xFFU, sizeof(hdr->free_map)); hdr->id = process->outgoing.nelts - 1; - hdr->pid = process->pid; + hdr->src_pid = getpid(); + hdr->dst_pid = process->pid; hdr->sent_over = id; /* Mark first chunk as busy */ @@ -136,7 +137,7 @@ nxt_go_new_port_mmap(nxt_go_process_t *process, nxt_port_id_t id) */ memcpy(CMSG_DATA(&cmsg.cm), &fd, sizeof(int)); - rc = nxt_go_port_send(hdr->pid, id, &port_msg, sizeof(port_msg), + rc = nxt_go_port_send(hdr->dst_pid, id, &port_msg, sizeof(port_msg), &cmsg, sizeof(cmsg)); nxt_go_debug("new mmap #%d created for %d -> %d", |