nxt_runtime.h (697:b73f6d3709c2) nxt_runtime.h (743:e0f0cd7d244a)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#ifndef _NXT_RUNTIME_H_INCLUDED_

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

101#define nxt_runtime_process_next(rt, lhe) \
102 nxt_lvlhsh_each(&rt->processes, lhe)
103
104
105void nxt_runtime_port_add(nxt_task_t *task, nxt_port_t *port);
106
107void nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port);
108
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#ifndef _NXT_RUNTIME_H_INCLUDED_

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

101#define nxt_runtime_process_next(rt, lhe) \
102 nxt_lvlhsh_each(&rt->processes, lhe)
103
104
105void nxt_runtime_port_add(nxt_task_t *task, nxt_port_t *port);
106
107void nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port);
108
109nxt_port_t *nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid,
109NXT_EXPORT nxt_port_t *nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid,
110 nxt_port_id_t port_id);
111
112
113/* STUB */
114nxt_int_t nxt_runtime_controller_socket(nxt_task_t *task, nxt_runtime_t *rt);
115
116nxt_str_t *nxt_current_directory(nxt_mp_t *mp);
117

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

124nxt_file_t *nxt_runtime_log_file_add(nxt_runtime_t *rt, nxt_str_t *name);
125
126/* STUB */
127void nxt_cdecl nxt_log_time_handler(nxt_uint_t level, nxt_log_t *log,
128 const char *fmt, ...);
129
130void nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data);
131
110 nxt_port_id_t port_id);
111
112
113/* STUB */
114nxt_int_t nxt_runtime_controller_socket(nxt_task_t *task, nxt_runtime_t *rt);
115
116nxt_str_t *nxt_current_directory(nxt_mp_t *mp);
117

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

124nxt_file_t *nxt_runtime_log_file_add(nxt_runtime_t *rt, nxt_str_t *name);
125
126/* STUB */
127void nxt_cdecl nxt_log_time_handler(nxt_uint_t level, nxt_log_t *log,
128 const char *fmt, ...);
129
130void nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data);
131
132void nxt_app_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
133void nxt_app_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
134
132
135
136#define nxt_runtime_process_each(rt, process) \
137 do { \
138 nxt_lvlhsh_each_t _lhe; \
139 nxt_process_t *_nxt; \
140 \
141 for (process = nxt_runtime_process_first(rt, &_lhe); \
142 process != NULL; \
143 process = _nxt) { \

--- 13 unchanged lines hidden --- 		133#define nxt_runtime_process_each(rt, process) \
134 do { \
135 nxt_lvlhsh_each_t _lhe; \
136 nxt_process_t *_nxt; \
137 \
138 for (process = nxt_runtime_process_first(rt, &_lhe); \
139 process != NULL; \
140 process = _nxt) { \

--- 13 unchanged lines hidden ---