Merged with the default branch.1.14.0-1

1 files changed, 10 insertions, 1 deletions

diff --git a/src/nxt_port.h b/src/nxt_port.h
index eeb6caa5..c6f15238 100644
--- a/src/nxt_port.h
+++ b/src/nxt_port.h
@@ -44,6 +44,9 @@ struct nxt_port_handlers_s {
 
     /* Various data. */
     nxt_port_handler_t  data;
+
+    nxt_port_handler_t  oosm;
+    nxt_port_handler_t  shm_ack;
 };
 
 
@@ -82,6 +85,9 @@ typedef enum {
 
     _NXT_PORT_MSG_DATA          = nxt_port_handler_idx(data),
 
+    _NXT_PORT_MSG_OOSM          = nxt_port_handler_idx(oosm),
+    _NXT_PORT_MSG_SHM_ACK       = nxt_port_handler_idx(shm_ack),
+
     NXT_PORT_MSG_MAX            = sizeof(nxt_port_handlers_t)
                                   / sizeof(nxt_port_handler_t),
 
@@ -114,6 +120,9 @@ typedef enum {
 
     NXT_PORT_MSG_DATA           = _NXT_PORT_MSG_DATA,
     NXT_PORT_MSG_DATA_LAST      = _NXT_PORT_MSG_DATA | NXT_PORT_MSG_LAST,
+
+    NXT_PORT_MSG_OOSM           = _NXT_PORT_MSG_OOSM | NXT_PORT_MSG_LAST,
+    NXT_PORT_MSG_SHM_ACK        = _NXT_PORT_MSG_SHM_ACK | NXT_PORT_MSG_LAST,
 } nxt_port_msg_type_t;
 
 
@@ -269,7 +278,7 @@ nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port,
 }
 
 void nxt_port_enable(nxt_task_t *task, nxt_port_t *port,
-    nxt_port_handlers_t *handlers);
+    const nxt_port_handlers_t *handlers);
 nxt_int_t nxt_port_send_port(nxt_task_t *task, nxt_port_t *port,
     nxt_port_t *new_port, uint32_t stream);
 void nxt_port_change_log_file(nxt_task_t *task, nxt_runtime_t *rt,