Lines Matching refs:task

12 static void nxt_buf_filter_file_read_start(nxt_task_t *task,
14 static void nxt_buf_filter_file_read(nxt_task_t *task, nxt_buf_filter_t *f);
15 static void nxt_buf_filter_file_job_completion(nxt_task_t *task, void *obj,
17 static void nxt_buf_filter_buf_completion(nxt_task_t *task, void *obj,
19 static void nxt_buf_filter_file_read_error(nxt_task_t *task, void *obj,
24 nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f, nxt_buf_t *b) in nxt_buf_filter_add() argument
28 nxt_buf_filter(task, f, NULL); in nxt_buf_filter_add()
33 nxt_buf_filter(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter() argument
41 nxt_debug(task, "buf filter"); in nxt_buf_filter()
62 nxt_debug(task, "buf filter current: %p", b); in nxt_buf_filter()
72 nxt_debug(task, "buf filter input: %p", b); in nxt_buf_filter()
96 nxt_buf_filter_file_read_start(task, f); in nxt_buf_filter()
142 nxt_thread_work_queue_add(task->thread, f->work_queue, in nxt_buf_filter()
144 task, b, b->parent); in nxt_buf_filter()
168 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter()
169 task, f, f->data); in nxt_buf_filter()
211 nxt_buf_filter_enqueue(nxt_task_t *task, nxt_buf_filter_t *f) in nxt_buf_filter_enqueue() argument
213 nxt_debug(task, "buf filter enqueue: %d", f->queued); in nxt_buf_filter_enqueue()
217 nxt_thread_work_queue_add(task->thread, f->work_queue, nxt_buf_filter, in nxt_buf_filter_enqueue()
218 task, f, NULL); in nxt_buf_filter_enqueue()
224 nxt_buf_filter_file_read_start(nxt_task_t *task, nxt_buf_filter_t *f) in nxt_buf_filter_file_read_start() argument
232 nxt_thread_work_queue_add(task->thread, f->work_queue, in nxt_buf_filter_file_read_start()
234 task, f, f->data); in nxt_buf_filter_file_read_start()
250 nxt_buf_filter_file_read(task, f); in nxt_buf_filter_file_read_start()
255 nxt_buf_filter_file_read(nxt_task_t *task, nxt_buf_filter_t *f) in nxt_buf_filter_file_read() argument
300 nxt_job_file_read(task, &ff->job_file.job); in nxt_buf_filter_file_read()
320 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter_file_read()
321 task, f, f->data); in nxt_buf_filter_file_read()
332 nxt_buf_filter_file_job_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_file_job_completion() argument
345 nxt_debug(task, "buf filter file completion: \"%FN\" %O-%O", in nxt_buf_filter_file_job_completion()
374 nxt_buf_filter(task, f, NULL); in nxt_buf_filter_file_job_completion()
387 nxt_buf_filter_file_read(task, f); in nxt_buf_filter_file_job_completion()
394 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter_file_job_completion()
395 task, f, f->data); in nxt_buf_filter_file_job_completion()
400 nxt_buf_filter_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_buf_completion() argument
410 nxt_debug(task, "buf filter completion: %p \"%FN\" %O-%O", in nxt_buf_filter_buf_completion()
422 nxt_buf_filter_file_read(task, f); in nxt_buf_filter_buf_completion()
431 nxt_thread_work_queue_add(task->thread, f->work_queue, in nxt_buf_filter_buf_completion()
433 task, fb, fb->parent); in nxt_buf_filter_buf_completion()
436 nxt_buf_filter(task, f, NULL); in nxt_buf_filter_buf_completion()
441 nxt_buf_filter_file_read_error(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_file_read_error() argument
447 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter_file_read_error()
448 task, f, f->data); in nxt_buf_filter_file_read_error()