Home
last modified time | relevance | path

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

/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,
980 nxt_unit_read_info_t read_info; in nxt_perl_psgi_result_body_fh() local
992 read_info.read = nxt_perl_psgi_io_read; in nxt_perl_psgi_result_body_fh()
993 read_info.eof = PerlIO_eof(io_ctx.fp); in nxt_perl_psgi_result_body_fh()
994 read_info.buf_size = 8192; in nxt_perl_psgi_result_body_fh()
995 read_info.data = &io_ctx; in nxt_perl_psgi_result_body_fh()
997 return nxt_unit_response_write_cb(req, &read_info); in nxt_perl_psgi_result_body_fh()
1002 nxt_perl_psgi_io_read(nxt_unit_read_info_t *read_info, void *dst, size_t size) in nxt_perl_psgi_io_read() argument
1007 ctx = read_info->data; in nxt_perl_psgi_io_read()
1013 read_info->eof = PerlIO_eof(ctx->fp); in nxt_perl_psgi_io_read()
/unit/src/ruby/
H A Dnxt_ruby.c71 static void *nxt_ruby_response_write_cb(void *read_info);
1068 nxt_ruby_rack_file_read(nxt_unit_read_info_t *read_info, void *dst, size_t size) in nxt_ruby_rack_file_read() argument
1073 file = read_info->data; in nxt_ruby_rack_file_read()
1088 read_info->eof = file->rest == 0; in nxt_ruby_rack_file_read()
1095 nxt_unit_read_info_t read_info; member
1133 ri.read_info.read = nxt_ruby_rack_file_read; in nxt_ruby_rack_result_body_file_write()
1134 ri.read_info.eof = ruby_file.rest == 0; in nxt_ruby_rack_result_body_file_write()
1135 ri.read_info.buf_size = ruby_file.rest; in nxt_ruby_rack_result_body_file_write()
1136 ri.read_info.data = &ruby_file; in nxt_ruby_rack_result_body_file_write()
1158 rc = nxt_unit_response_write_cb(ri->req, &ri->read_info); in nxt_ruby_response_write_cb()
/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.c2956 nxt_unit_read_info_t *read_info) in nxt_unit_response_write_cb() argument
2988 n = read_info->read(read_info, buf->free, buf->end - buf->free); in nxt_unit_response_write_cb()
2999 if (read_info->eof) { in nxt_unit_response_write_cb()
3011 if (read_info->eof) { in nxt_unit_response_write_cb()
3016 while (!read_info->eof) { in nxt_unit_response_write_cb()
3018 read_info->buf_size); in nxt_unit_response_write_cb()
3020 buf_size = nxt_min(read_info->buf_size, PORT_MMAP_DATA_SIZE); in nxt_unit_response_write_cb()
3031 while (!read_info->eof && buf->end > buf->free) { in nxt_unit_response_write_cb()
3032 n = read_info->read(read_info, buf->free, buf->end - buf->free); in nxt_unit_response_write_cb()