nxt_port.h (65:10688b89aa16) nxt_port.h (77:585861a3a152)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_PORT_H_INCLUDED_
8#define _NXT_PORT_H_INCLUDED_

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

105void nxt_port_write_enable(nxt_task_t *task, nxt_port_t *port);
106void nxt_port_write_close(nxt_port_t *port);
107void nxt_port_read_enable(nxt_task_t *task, nxt_port_t *port);
108void nxt_port_read_close(nxt_port_t *port);
109nxt_int_t nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port,
110 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port,
111 nxt_buf_t *b);
112
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_PORT_H_INCLUDED_
8#define _NXT_PORT_H_INCLUDED_

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

105void nxt_port_write_enable(nxt_task_t *task, nxt_port_t *port);
106void nxt_port_write_close(nxt_port_t *port);
107void nxt_port_read_enable(nxt_task_t *task, nxt_port_t *port);
108void nxt_port_read_close(nxt_port_t *port);
109nxt_int_t nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port,
110 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port,
111 nxt_buf_t *b);
112
113void nxt_port_create(nxt_thread_t *thread, nxt_port_t *port,
113void nxt_port_create(nxt_task_t *task, nxt_port_t *port,
114 nxt_port_handler_t *handlers);
115void nxt_port_write(nxt_task_t *task, nxt_runtime_t *rt, nxt_uint_t type,
116 nxt_fd_t fd, uint32_t stream, nxt_buf_t *b);
117void nxt_port_send_new_port(nxt_task_t *task, nxt_runtime_t *rt,
118 nxt_port_t *port);
119void nxt_port_change_log_file(nxt_task_t *task, nxt_runtime_t *rt,
120 nxt_uint_t slot, nxt_fd_t fd);
121
122void nxt_port_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
123void nxt_port_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
124void nxt_port_change_log_file_handler(nxt_task_t *task,
125 nxt_port_recv_msg_t *msg);
126void nxt_port_mmap_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
127void nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
128void nxt_port_empty_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
129
130
131#endif /* _NXT_PORT_H_INCLUDED_ */
114 nxt_port_handler_t *handlers);
115void nxt_port_write(nxt_task_t *task, nxt_runtime_t *rt, nxt_uint_t type,
116 nxt_fd_t fd, uint32_t stream, nxt_buf_t *b);
117void nxt_port_send_new_port(nxt_task_t *task, nxt_runtime_t *rt,
118 nxt_port_t *port);
119void nxt_port_change_log_file(nxt_task_t *task, nxt_runtime_t *rt,
120 nxt_uint_t slot, nxt_fd_t fd);
121
122void nxt_port_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
123void nxt_port_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
124void nxt_port_change_log_file_handler(nxt_task_t *task,
125 nxt_port_recv_msg_t *msg);
126void nxt_port_mmap_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
127void nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
128void nxt_port_empty_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
129
130
131#endif /* _NXT_PORT_H_INCLUDED_ */