Lines Matching refs:nxt_task_t

10 static void nxt_stream_source_connected(nxt_task_t *task, void *obj,
12 static void nxt_stream_source_write_ready(nxt_task_t *task, void *obj,
14 static void nxt_stream_source_read_ready(nxt_task_t *task, void *obj,
18 static void nxt_stream_source_buf_completion(nxt_task_t *task, void *obj,
20 static void nxt_stream_source_read_done(nxt_task_t *task, void *obj,
22 static void nxt_stream_source_refused(nxt_task_t *task, void *obj, void *data);
23 static void nxt_stream_source_closed(nxt_task_t *task, void *obj, void *data);
24 static void nxt_stream_source_error(nxt_task_t *task, void *obj, void *data);
25 static void nxt_stream_source_close(nxt_task_t *task,
36 nxt_stream_source_connect(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_stream_source_connect()
92 nxt_stream_source_connected(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_connected()
153 nxt_stream_source_write_ready(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_write_ready()
166 nxt_stream_source_read_ready(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_read_ready()
241 nxt_stream_source_read_done(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_read_done()
342 nxt_stream_source_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_buf_completion()
396 nxt_stream_source_refused(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_refused()
417 nxt_stream_source_closed(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_closed()
443 nxt_stream_source_error(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_error()
464 nxt_stream_source_close(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_stream_source_close()
473 nxt_source_filter_handler(nxt_task_t *task, void *obj, void *data) in nxt_source_filter_handler()