diff options
Diffstat (limited to 'src/nxt_process_chan.h')
-rw-r--r-- | src/nxt_process_chan.h | 68 |
1 files changed, 0 insertions, 68 deletions
diff --git a/src/nxt_process_chan.h b/src/nxt_process_chan.h deleted file mode 100644 index 18ff7be3..00000000 --- a/src/nxt_process_chan.h +++ /dev/null @@ -1,68 +0,0 @@ - -/* - * Copyright (C) Igor Sysoev - * Copyright (C) NGINX, Inc. - */ - -#ifndef _NXT_PROCESS_CHAN_H_INCLUDED_ -#define _NXT_PROCESS_CHAN_H_INCLUDED_ - - -#define NXT_CHAN_MSG_MAX NXT_CHAN_MSG_DATA - -typedef enum { - NXT_CHAN_MSG_QUIT = 0, - NXT_CHAN_MSG_NEW_CHAN, - NXT_CHAN_MSG_CHANGE_FILE, - NXT_CHAN_MSG_DATA, -} nxt_chan_msg_type_e; - - -typedef struct { - nxt_pid_t pid; - uint32_t engine; - uint32_t generation; - nxt_chan_t *chan; -} nxt_process_chan_t; - - -typedef struct { - nxt_pid_t pid; - uint32_t engine; - size_t max_size; - size_t max_share; -} nxt_proc_msg_new_chan_t; - - -/* - * nxt_process_chan_data_t is allocaiton size - * enabling effective reuse of memory pool cache. - */ -typedef union { - nxt_buf_t buf; - nxt_proc_msg_new_chan_t new_chan; -} nxt_process_chan_data_t; - - -typedef void (*nxt_process_chan_handler_t)(nxt_task_t *task, - nxt_chan_recv_msg_t *msg); - - -void nxt_process_chan_create(nxt_thread_t *thr, nxt_process_chan_t *proc, - nxt_process_chan_handler_t *handlers); -void nxt_process_chan_write(nxt_task_t *task, nxt_cycle_t *cycle, - nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_buf_t *b); -void nxt_process_new_chan(nxt_task_t *task, nxt_cycle_t *cycle, - nxt_process_chan_t *proc); -void nxt_process_chan_change_log_file(nxt_task_t *task, nxt_cycle_t *cycle, - nxt_uint_t slot, nxt_fd_t fd); - -void nxt_process_chan_quit_handler(nxt_task_t *task, nxt_chan_recv_msg_t *msg); -void nxt_process_chan_new_handler(nxt_task_t *task, nxt_chan_recv_msg_t *msg); -void nxt_process_chan_change_log_file_handler(nxt_task_t *task, - nxt_chan_recv_msg_t *msg); -void nxt_process_chan_data_handler(nxt_task_t *task, nxt_chan_recv_msg_t *msg); -void nxt_process_chan_empty_handler(nxt_task_t *task, nxt_chan_recv_msg_t *msg); - - -#endif /* _NXT_PROCESS_CHAN_H_INCLUDED_ */ |