diff options
author | Igor Sysoev <igor@sysoev.ru> | 2017-03-09 18:03:27 +0300 |
---|---|---|
committer | Igor Sysoev <igor@sysoev.ru> | 2017-03-09 18:03:27 +0300 |
commit | 6f2c9acd1841ca20a1388b34aef64e9f00459090 (patch) | |
tree | c0b9c1063ec464027d1ca29a793f6c0b7a6878d5 /src/nxt_port.h | |
parent | 5745e4826427155e29c1d520fe77811a0f570689 (diff) | |
download | unit-6f2c9acd1841ca20a1388b34aef64e9f00459090.tar.gz unit-6f2c9acd1841ca20a1388b34aef64e9f00459090.tar.bz2 |
Processes refactoring.
The cycle has been renamed to the runtime.
Diffstat (limited to '')
-rw-r--r-- | src/nxt_port.h | 17 |
1 files changed, 5 insertions, 12 deletions
diff --git a/src/nxt_port.h b/src/nxt_port.h index c27b1bc4..8a9b8926 100644 --- a/src/nxt_port.h +++ b/src/nxt_port.h @@ -8,9 +8,6 @@ #define _NXT_PORT_H_INCLUDED_ -typedef struct nxt_port_s nxt_port_t; - - typedef struct { uint32_t stream; @@ -28,17 +25,14 @@ typedef struct { } nxt_port_send_msg_t; -typedef struct nxt_port_recv_msg_s { +struct nxt_port_recv_msg_s { uint32_t stream; uint16_t type; nxt_fd_t fd; nxt_buf_t *buf; nxt_port_t *port; -} nxt_port_recv_msg_t; - - -typedef void (*nxt_port_handler_t)(nxt_task_t *task, nxt_port_recv_msg_t *msg); +}; struct nxt_port_s { @@ -61,7 +55,6 @@ struct nxt_port_s { nxt_pid_t pid; uint32_t engine; - uint32_t generation; }; @@ -105,11 +98,11 @@ nxt_int_t nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, void nxt_port_create(nxt_thread_t *thread, nxt_port_t *port, nxt_port_handler_t *handlers); -void nxt_port_write(nxt_task_t *task, nxt_cycle_t *cycle, nxt_uint_t type, +void nxt_port_write(nxt_task_t *task, nxt_runtime_t *rt, nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_buf_t *b); -void nxt_port_send_new_port(nxt_task_t *task, nxt_cycle_t *cycle, +void nxt_port_send_new_port(nxt_task_t *task, nxt_runtime_t *rt, nxt_port_t *port); -void nxt_port_change_log_file(nxt_task_t *task, nxt_cycle_t *cycle, +void nxt_port_change_log_file(nxt_task_t *task, nxt_runtime_t *rt, nxt_uint_t slot, nxt_fd_t fd); void nxt_port_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg); |