Home
last modified time | relevance | path

Searched refs:read_info (Results 1 – 4 of 4) sorted by last modified time

/unit/src/
H A Dnxt_unit.h185 typedef ssize_t (*nxt_unit_read_func_t)(nxt_unit_read_info_t *read_info,
311 nxt_unit_read_info_t *read_info);
H A Dnxt_unit.c2970 nxt_unit_read_info_t *read_info) in nxt_unit_response_write_cb() argument
3002 n = read_info->read(read_info, buf->free, buf->end - buf->free); in nxt_unit_response_write_cb()
3013 if (read_info->eof) { in nxt_unit_response_write_cb()
3025 if (read_info->eof) { in nxt_unit_response_write_cb()
3030 while (!read_info->eof) { in nxt_unit_response_write_cb()
3032 read_info->buf_size); in nxt_unit_response_write_cb()
3034 buf_size = nxt_min(read_info->buf_size, PORT_MMAP_DATA_SIZE); in nxt_unit_response_write_cb()
3045 while (!read_info->eof && buf->end > buf->free) { in nxt_unit_response_write_cb()
3046 n = read_info->read(read_info, buf->free, buf->end - buf->free); in nxt_unit_response_write_cb()
/unit/src/perl/
H A Dnxt_perl_psgi.c84 static ssize_t nxt_perl_psgi_io_read(nxt_unit_read_info_t *read_info, void *dst,
981 nxt_unit_read_info_t read_info; in nxt_perl_psgi_result_body_fh() local
993 read_info.read = nxt_perl_psgi_io_read; in nxt_perl_psgi_result_body_fh()
994 read_info.eof = PerlIO_eof(io_ctx.fp); in nxt_perl_psgi_result_body_fh()
995 read_info.buf_size = 8192; in nxt_perl_psgi_result_body_fh()
996 read_info.data = &io_ctx; in nxt_perl_psgi_result_body_fh()
998 return nxt_unit_response_write_cb(req, &read_info); in nxt_perl_psgi_result_body_fh()
1003 nxt_perl_psgi_io_read(nxt_unit_read_info_t *read_info, void *dst, size_t size) in nxt_perl_psgi_io_read() argument
1008 ctx = read_info->data; in nxt_perl_psgi_io_read()
1014 read_info->eof = PerlIO_eof(ctx->fp); in nxt_perl_psgi_io_read()
/unit/src/ruby/
H A Dnxt_ruby.c70 static void *nxt_ruby_response_write_cb(void *read_info);
1040 nxt_ruby_rack_file_read(nxt_unit_read_info_t *read_info, void *dst, size_t size) in nxt_ruby_rack_file_read() argument
1045 file = read_info->data; in nxt_ruby_rack_file_read()
1060 read_info->eof = file->rest == 0; in nxt_ruby_rack_file_read()
1067 nxt_unit_read_info_t read_info; member
1105 ri.read_info.read = nxt_ruby_rack_file_read; in nxt_ruby_rack_result_body_file_write()
1106 ri.read_info.eof = ruby_file.rest == 0; in nxt_ruby_rack_result_body_file_write()
1107 ri.read_info.buf_size = ruby_file.rest; in nxt_ruby_rack_result_body_file_write()
1108 ri.read_info.data = &ruby_file; in nxt_ruby_rack_result_body_file_write()
1130 rc = nxt_unit_response_write_cb(ri->req, &ri->read_info); in nxt_ruby_response_write_cb()