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 ---