diff options
author | Igor Sysoev <igor@sysoev.ru> | 2017-01-23 19:56:03 +0300 |
---|---|---|
committer | Igor Sysoev <igor@sysoev.ru> | 2017-01-23 19:56:03 +0300 |
commit | de532922d9ab42aa15b40d47c8db53ac2af38500 (patch) | |
tree | d6b7c6b21c7a6e0e3620a3e0c7198e63454d05e3 /src/nxt_process_chan.h | |
parent | 16cbf3c076a0aca6d47adaf3f719493674cf2363 (diff) | |
download | unit-de532922d9ab42aa15b40d47c8db53ac2af38500.tar.gz unit-de532922d9ab42aa15b40d47c8db53ac2af38500.tar.bz2 |
Introducing tasks.
Diffstat (limited to '')
-rw-r--r-- | src/nxt_process_chan.h | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/src/nxt_process_chan.h b/src/nxt_process_chan.h index a073e3dd..18ff7be3 100644 --- a/src/nxt_process_chan.h +++ b/src/nxt_process_chan.h @@ -44,25 +44,25 @@ typedef union { } nxt_process_chan_data_t; -typedef void (*nxt_process_chan_handler_t)(nxt_thread_t *thr, +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_cycle_t *cycle, nxt_uint_t type, - nxt_fd_t fd, uint32_t stream, nxt_buf_t *b); -void nxt_process_new_chan(nxt_cycle_t *cycle, nxt_process_chan_t *proc); -void nxt_process_chan_change_log_file(nxt_cycle_t *cycle, nxt_uint_t slot, - nxt_fd_t fd); - -void nxt_process_chan_quit_handler(nxt_thread_t *thr, nxt_chan_recv_msg_t *msg); -void nxt_process_chan_new_handler(nxt_thread_t *thr, nxt_chan_recv_msg_t *msg); -void nxt_process_chan_change_log_file_handler(nxt_thread_t *thr, - nxt_chan_recv_msg_t *msg); -void nxt_process_chan_data_handler(nxt_thread_t *thr, nxt_chan_recv_msg_t *msg); -void nxt_process_chan_empty_handler(nxt_thread_t *thr, +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_ */ |