From 83088a0f4bdbe321c42e7cf0b18e2a9cc897b068 Mon Sep 17 00:00:00 2001 From: Max Romanov Date: Fri, 23 Jun 2017 19:20:08 +0300 Subject: Incoming and outgoing port_mmap arrays are protected with mutexes. --- src/nxt_process.h | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'src/nxt_process.h') diff --git a/src/nxt_process.h b/src/nxt_process.h index 32a8d8dc..d0ed7343 100644 --- a/src/nxt_process.h +++ b/src/nxt_process.h @@ -56,8 +56,10 @@ typedef struct { nxt_port_id_t last_port_id; nxt_process_init_t *init; - nxt_array_t *incoming; /* of nxt_mmap_t */ - nxt_array_t *outgoing; /* of nxt_mmap_t */ + nxt_thread_mutex_t incoming_mutex; + nxt_array_t *incoming; /* of nxt_port_mmap_t */ + nxt_thread_mutex_t outgoing_mutex; + nxt_array_t *outgoing; /* of nxt_port_mmap_t */ nxt_lvlhsh_t connected_ports; /* of nxt_port_t */ } nxt_process_t; -- cgit