nxt_port.h (424:38b478d79178) nxt_port.h (425:1da949cf0a34)
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_

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

163
164 /* Maximum size of message part. */
165 uint32_t max_size;
166 /* Maximum interleave of message parts. */
167 uint32_t max_share;
168
169 uint32_t app_pending_responses;
170 uint32_t app_responses;
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_

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

163
164 /* Maximum size of message part. */
165 uint32_t max_size;
166 /* Maximum interleave of message parts. */
167 uint32_t max_share;
168
169 uint32_t app_pending_responses;
170 uint32_t app_responses;
171 nxt_queue_t pending_requests;
171
172 nxt_port_handler_t handler;
173 nxt_port_handler_t *data;
174
175 nxt_mp_t *mem_pool;
176 nxt_event_engine_t *engine;
177
178 nxt_buf_t *free_bufs;

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

260void nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
261void nxt_port_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
262void nxt_port_empty_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
263
264nxt_int_t nxt_port_post(nxt_task_t *task, nxt_port_t *port,
265 nxt_port_post_handler_t handler, void *data);
266void nxt_port_use(nxt_task_t *task, nxt_port_t *port, int i);
267
172
173 nxt_port_handler_t handler;
174 nxt_port_handler_t *data;
175
176 nxt_mp_t *mem_pool;
177 nxt_event_engine_t *engine;
178
179 nxt_buf_t *free_bufs;

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

261void nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
262void nxt_port_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
263void nxt_port_empty_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
264
265nxt_int_t nxt_port_post(nxt_task_t *task, nxt_port_t *port,
266 nxt_port_post_handler_t handler, void *data);
267void nxt_port_use(nxt_task_t *task, nxt_port_t *port, int i);
268
269nxt_inline void nxt_port_inc_use(nxt_port_t *port)
270{
271 nxt_atomic_fetch_add(&port->use_count, 1);
272}
273
268#endif /* _NXT_PORT_H_INCLUDED_ */
274#endif /* _NXT_PORT_H_INCLUDED_ */