Deleted
Added
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_ */ |