summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_process_chan.h
diff options
context:
space:
mode:
authorIgor Sysoev <igor@sysoev.ru>2017-01-23 19:56:03 +0300
committerIgor Sysoev <igor@sysoev.ru>2017-01-23 19:56:03 +0300
commitde532922d9ab42aa15b40d47c8db53ac2af38500 (patch)
treed6b7c6b21c7a6e0e3620a3e0c7198e63454d05e3 /src/nxt_process_chan.h
parent16cbf3c076a0aca6d47adaf3f719493674cf2363 (diff)
downloadunit-de532922d9ab42aa15b40d47c8db53ac2af38500.tar.gz
unit-de532922d9ab42aa15b40d47c8db53ac2af38500.tar.bz2
Introducing tasks.
Diffstat (limited to '')
-rw-r--r--src/nxt_process_chan.h26
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_ */