Deleted
Added
nxt_process.h (163:e4d237f57e43) | nxt_process.h (164:7449e4954471) |
---|---|
1 2/* 3 * Copyright (C) Igor Sysoev 4 * Copyright (C) NGINX, Inc. 5 */ 6 7#ifndef _NXT_PROCESS_H_INCLUDED_ 8#define _NXT_PROCESS_H_INCLUDED_ --- 43 unchanged lines hidden (view full) --- 52 nxt_bool_t restart; 53}; 54 55 56typedef struct { 57 nxt_pid_t pid; 58 nxt_queue_t ports; /* of nxt_port_t */ 59 nxt_bool_t ready; | 1 2/* 3 * Copyright (C) Igor Sysoev 4 * Copyright (C) NGINX, Inc. 5 */ 6 7#ifndef _NXT_PROCESS_H_INCLUDED_ 8#define _NXT_PROCESS_H_INCLUDED_ --- 43 unchanged lines hidden (view full) --- 52 nxt_bool_t restart; 53}; 54 55 56typedef struct { 57 nxt_pid_t pid; 58 nxt_queue_t ports; /* of nxt_port_t */ 59 nxt_bool_t ready; |
60 nxt_uint_t port_cleanups; |
|
60 61 nxt_process_init_t *init; 62 63 nxt_thread_mutex_t incoming_mutex; 64 nxt_array_t *incoming; /* of nxt_port_mmap_t */ 65 66 nxt_thread_mutex_t outgoing_mutex; 67 nxt_array_t *outgoing; /* of nxt_port_mmap_t */ --- 15 unchanged lines hidden (view full) --- 83 char ***orig_envp); 84 85#define nxt_process_port_remove(port) \ 86 nxt_queue_remove(&port->link) 87 88#define nxt_process_port_first(process) \ 89 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link) 90 | 61 62 nxt_process_init_t *init; 63 64 nxt_thread_mutex_t incoming_mutex; 65 nxt_array_t *incoming; /* of nxt_port_mmap_t */ 66 67 nxt_thread_mutex_t outgoing_mutex; 68 nxt_array_t *outgoing; /* of nxt_port_mmap_t */ --- 15 unchanged lines hidden (view full) --- 84 char ***orig_envp); 85 86#define nxt_process_port_remove(port) \ 87 nxt_queue_remove(&port->link) 88 89#define nxt_process_port_first(process) \ 90 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link) 91 |
91NXT_EXPORT void nxt_process_port_add(nxt_process_t *process, nxt_port_t *port); | 92NXT_EXPORT void nxt_process_port_add(nxt_task_t *task, nxt_process_t *process, 93 nxt_port_t *port); |
92 93#define nxt_process_port_each(process, port) \ 94 nxt_queue_each(port, &process->ports, nxt_port_t, link) 95 96#define nxt_process_port_loop \ 97 nxt_queue_loop 98 99 --- 44 unchanged lines hidden --- | 94 95#define nxt_process_port_each(process, port) \ 96 nxt_queue_each(port, &process->ports, nxt_port_t, link) 97 98#define nxt_process_port_loop \ 99 nxt_queue_loop 100 101 --- 44 unchanged lines hidden --- |