Lines Matching refs:task

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() argument
47 nxt_log(task, NXT_LOG_ERR, in nxt_stream_source_connect()
66 nxt_event_conn_connect(task, c); in nxt_stream_source_connect()
71 stream->error_handler(task, stream); in nxt_stream_source_connect()
92 nxt_stream_source_connected(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_connected() argument
100 nxt_debug(task, "stream source connected fd:%d", c->socket.fd); in nxt_stream_source_connected()
106 if (task->thread->engine->batch != 0) { in nxt_stream_source_connected()
107 nxt_event_conn_write(task, c); in nxt_stream_source_connected()
111 nxt_thread_work_queue_add(task->thread, in nxt_stream_source_connected()
112 &task->thread->engine->read_work_queue, in nxt_stream_source_connected()
113 c->io->read, task, c, stream); in nxt_stream_source_connected()
115 c->io->write(task, c, stream); 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() argument
159 nxt_debug(task, "stream source write ready fd:%d", c->socket.fd); in nxt_stream_source_write_ready()
161 nxt_conn_read(task, c); 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() argument
178 nxt_debug(task, "stream source read ready fd:%d", c->socket.fd); in nxt_stream_source_read_ready()
194 nxt_debug(task, "stream source flush"); in nxt_stream_source_read_ready()
202 nxt_event_fd_block_read(task->thread->engine, &c->socket); in nxt_stream_source_read_ready()
204 nxt_source_filter(task->thread, c->write_work_queue, task, in nxt_stream_source_read_ready()
215 nxt_conn_read(task, c); in nxt_stream_source_read_ready()
220 nxt_stream_source_close(task, stream); 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() argument
251 nxt_debug(task, "stream source read done fd:%d", c->socket.fd); in nxt_stream_source_read_done()
257 nxt_stream_source_close(task, stream); in nxt_stream_source_read_done()
261 batch = (task->thread->engine->batch != 0); in nxt_stream_source_read_done()
264 nxt_thread_work_queue_add(task->thread, in nxt_stream_source_read_done()
267 task, stream->next, b); in nxt_stream_source_read_done()
272 nxt_thread_work_queue_add(task->thread, in nxt_stream_source_read_done()
275 task, c, stream); in nxt_stream_source_read_done()
279 stream->next->filter(task, stream->next->context, b); 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() argument
382 nxt_thread_work_queue_add(task->thread, in nxt_stream_source_buf_completion()
385 task, stream->conn, in nxt_stream_source_buf_completion()
396 nxt_stream_source_refused(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_refused() argument
408 nxt_debug(task, "stream source refused fd:%d", c->socket.fd); in nxt_stream_source_refused()
412 nxt_stream_source_close(task, stream); in nxt_stream_source_refused()
417 nxt_stream_source_closed(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_closed() argument
426 nxt_debug(task, "stream source closed fd:%d", c->socket.fd); in nxt_stream_source_closed()
428 nxt_conn_close(task, c); in nxt_stream_source_closed()
434 stream->error_handler(task, stream); in nxt_stream_source_closed()
438 nxt_source_filter(task->thread, c->write_work_queue, task, stream->next, b); in nxt_stream_source_closed()
443 nxt_stream_source_error(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_error() argument
455 nxt_debug(task, "stream source error fd:%d", ev->fd); in nxt_stream_source_error()
459 nxt_stream_source_close(task, stream); in nxt_stream_source_error()
464 nxt_stream_source_close(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_stream_source_close() argument
466 nxt_conn_close(task, stream->conn); in nxt_stream_source_close()
468 stream->error_handler(task, stream); in nxt_stream_source_close()
473 nxt_source_filter_handler(nxt_task_t *task, void *obj, void *data) in nxt_source_filter_handler() argument
479 next->filter(task, next->context, data); in nxt_source_filter_handler()