nxt_port.h (347:e14011f5f005) nxt_port.h (352:47649fbbcb53)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_PORT_H_INCLUDED_
8#define _NXT_PORT_H_INCLUDED_

--- 92 unchanged lines hidden (view full) ---

101 nxt_pid_t pid;
102 nxt_port_id_t reply_port;
103
104 uint8_t type;
105 uint8_t last; /* 1 bit */
106
107 /* Message data send using mmap, next chunk is a nxt_port_mmap_msg_t. */
108 uint8_t mmap; /* 1 bit */
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_PORT_H_INCLUDED_
8#define _NXT_PORT_H_INCLUDED_

--- 92 unchanged lines hidden (view full) ---

101 nxt_pid_t pid;
102 nxt_port_id_t reply_port;
103
104 uint8_t type;
105 uint8_t last; /* 1 bit */
106
107 /* Message data send using mmap, next chunk is a nxt_port_mmap_msg_t. */
108 uint8_t mmap; /* 1 bit */
109
110 uint8_t nf;
111 uint8_t mf;
109} nxt_port_msg_t;
110
111
112typedef struct {
113 nxt_queue_link_t link;
114 nxt_buf_t *buf;
115 size_t share;
116 nxt_fd_t fd;

--- 49 unchanged lines hidden (view full) ---

166 nxt_socket_t pair[2];
167
168 nxt_port_id_t id;
169 nxt_pid_t pid;
170
171 nxt_lvlhsh_t rpc_streams; /* stream to nxt_port_rpc_reg_t */
172 nxt_lvlhsh_t rpc_peers; /* peer to queue of nxt_port_rpc_reg_t */
173
112} nxt_port_msg_t;
113
114
115typedef struct {
116 nxt_queue_link_t link;
117 nxt_buf_t *buf;
118 size_t share;
119 nxt_fd_t fd;

--- 49 unchanged lines hidden (view full) ---

169 nxt_socket_t pair[2];
170
171 nxt_port_id_t id;
172 nxt_pid_t pid;
173
174 nxt_lvlhsh_t rpc_streams; /* stream to nxt_port_rpc_reg_t */
175 nxt_lvlhsh_t rpc_peers; /* peer to queue of nxt_port_rpc_reg_t */
176
177 nxt_lvlhsh_t frags;
178
174 nxt_atomic_t use_count;
175
176 nxt_process_type_t type;
177
178 struct iovec *iov;
179 void *mmsg_buf;
180};
181

--- 65 unchanged lines hidden ---
179 nxt_atomic_t use_count;
180
181 nxt_process_type_t type;
182
183 struct iovec *iov;
184 void *mmsg_buf;
185};
186

--- 65 unchanged lines hidden ---