Home
last modified time | relevance | path

Searched refs:jbf (Results 1 – 4 of 4) sorted by relevance

/unit/src/
H A Dnxt_job_file.c22 nxt_job_file_t *jbf; in nxt_job_file_create() local
32 return jbf; in nxt_job_file_create()
69 jbf = obj; in nxt_job_file_open_and_read()
70 file = &jbf->file; in nxt_job_file_open_and_read()
109 nxt_file_read_ahead(&jbf->file, jbf->offset, size); in nxt_job_file_open_and_read()
137 nxt_job_return(task, &jbf->job, jbf->ready_handler); in nxt_job_file_open_and_read()
167 if (jbf->read_required(jbf) != NXT_OK) { in nxt_job_file_open()
183 return jbf->read_required(jbf); in nxt_job_file_open()
196 jbf->file.name[jbf->directory_end] = '\0'; in nxt_job_file_open()
243 jbf->file.fd, jbf->offset); in nxt_job_file_mmap()
[all …]
H A Dnxt_job_file_cache.c18 nxt_job_file_cache_read(nxt_cache_t *cache, nxt_job_file_t *jbf) in nxt_job_file_cache_read() argument
27 nxt_job_return(&jbf->job, jbf->ready_handler); in nxt_job_file_cache_read()
32 nxt_job_return(&jbf->job, jbf->error_handler); in nxt_job_file_cache_read()
37 jbf->job.thread_pool = NULL; in nxt_job_file_cache_read()
41 nxt_job_file_read(jbf); in nxt_job_file_cache_read()
H A Dnxt_buf_filter.c226 nxt_job_file_t *jbf; in nxt_buf_filter_file_read_start() local
240 jbf = &ff->job_file; in nxt_buf_filter_file_read_start()
241 jbf->file = *f->input->file; in nxt_buf_filter_file_read_start()
243 jbf->ready_handler = nxt_buf_filter_file_job_completion; in nxt_buf_filter_file_read_start()
244 jbf->error_handler = nxt_buf_filter_file_read_error; in nxt_buf_filter_file_read_start()
246 nxt_job_set_name(&jbf->job, "buf filter job file"); in nxt_buf_filter_file_read_start()
336 nxt_job_file_t *jbf; in nxt_buf_filter_file_job_completion() local
340 jbf = obj; in nxt_buf_filter_file_job_completion()
342 b = jbf->buffer; in nxt_buf_filter_file_job_completion()
343 jbf->buffer = NULL; in nxt_buf_filter_file_job_completion()
[all …]
H A Dnxt_job_file.h57 nxt_int_t (*read_required)(nxt_job_file_t *jbf);
70 NXT_EXPORT void nxt_job_file_init(nxt_job_file_t *jbf);