nxt_router.h (318:c2442f5e054d) nxt_router.h (343:9fa845db60fb)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_ROUTER_H_INCLUDED_
8#define _NXT_ROUTER_H_INCLUDED_

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

82 nxt_queue_t ports; /* of nxt_port_t.app_link */
83
84 nxt_queue_t requests; /* of nxt_req_conn_link_t */
85 nxt_str_t name;
86
87 uint32_t pending_workers;
88 uint32_t workers;
89 uint32_t max_workers;
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_ROUTER_H_INCLUDED_
8#define _NXT_ROUTER_H_INCLUDED_

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

82 nxt_queue_t ports; /* of nxt_port_t.app_link */
83
84 nxt_queue_t requests; /* of nxt_req_conn_link_t */
85 nxt_str_t name;
86
87 uint32_t pending_workers;
88 uint32_t workers;
89 uint32_t max_workers;
90 uint32_t max_pending_responses;
90
91 nxt_msec_t timeout;
92
93 nxt_app_type_t type:8;
94 uint8_t live; /* 1 bit */
95
96 nxt_queue_link_t link;
97
98 nxt_str_t conf;
99 nxt_app_prepare_msg_t prepare_msg;
91
92 nxt_msec_t timeout;
93
94 nxt_app_type_t type:8;
95 uint8_t live; /* 1 bit */
96
97 nxt_queue_link_t link;
98
99 nxt_str_t conf;
100 nxt_app_prepare_msg_t prepare_msg;
101
102 nxt_atomic_t use_count;
100};
101
102
103typedef struct {
104 uint32_t count;
105 nxt_socket_t fd;
106} nxt_router_socket_t;
107

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

136 /* Modules configuraitons. */
137} nxt_socket_conf_joint_t;
138
139
140void nxt_router_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
141void nxt_router_conf_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
142void nxt_router_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
143
103};
104
105
106typedef struct {
107 uint32_t count;
108 nxt_socket_t fd;
109} nxt_router_socket_t;
110

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

139 /* Modules configuraitons. */
140} nxt_socket_conf_joint_t;
141
142
143void nxt_router_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
144void nxt_router_conf_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
145void nxt_router_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
146
144nxt_bool_t nxt_router_app_remove_port(nxt_port_t *port);
147void nxt_router_app_port_close(nxt_task_t *task, nxt_port_t *port);
148void nxt_router_app_use(nxt_task_t *task, nxt_app_t *app, int i);
145
146#endif /* _NXT_ROUTER_H_INCLUDED_ */
149
150#endif /* _NXT_ROUTER_H_INCLUDED_ */