nxt_router.h (163:e4d237f57e43) nxt_router.h (192:e8da77a2c293)
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_

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

15
16
17typedef struct {
18 nxt_thread_spinlock_t lock;
19 nxt_queue_t engines;
20
21 nxt_queue_t sockets; /* of nxt_socket_conf_t */
22 nxt_queue_t apps; /* of nxt_app_t */
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_

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

15
16
17typedef struct {
18 nxt_thread_spinlock_t lock;
19 nxt_queue_t engines;
20
21 nxt_queue_t sockets; /* of nxt_socket_conf_t */
22 nxt_queue_t apps; /* of nxt_app_t */
23
24 nxt_lvlhsh_t start_workers; /* stream to nxt_start_worker_t */
25} nxt_router_t;
26
27
28typedef struct {
29 uint32_t count;
30 uint32_t threads;
31 nxt_router_t *router;
32 nxt_mp_t *mem_pool;

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

119 nxt_socket_conf_t *socket_conf;
120
121 /* Modules configuraitons. */
122} nxt_socket_conf_joint_t;
123
124
125void nxt_router_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
126void nxt_router_conf_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
23} nxt_router_t;
24
25
26typedef struct {
27 uint32_t count;
28 uint32_t threads;
29 nxt_router_t *router;
30 nxt_mp_t *mem_pool;

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

117 nxt_socket_conf_t *socket_conf;
118
119 /* Modules configuraitons. */
120} nxt_socket_conf_joint_t;
121
122
123void nxt_router_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
124void nxt_router_conf_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
125void nxt_router_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
127
128nxt_bool_t nxt_router_app_remove_port(nxt_port_t *port);
129
130#endif /* _NXT_ROUTER_H_INCLUDED_ */
126
127nxt_bool_t nxt_router_app_remove_port(nxt_port_t *port);
128
129#endif /* _NXT_ROUTER_H_INCLUDED_ */