Home
last modified time | relevance | path

Searched refs:input (Results 1 – 18 of 18) sorted by relevance

/unit/test/ruby/input_rewind/
H A Dconfig.ru2 env['rack.input'].read
3 env['rack.input'].rewind
4 body = env['rack.input'].read
/unit/test/ruby/input_read_parts/
H A Dconfig.ru2 body = env['rack.input'].read(4)
3 body += env['rack.input'].read(4)
4 body += env['rack.input'].read(1)
/unit/src/
H A Dnxt_buf_filter.c26 nxt_buf_chain_add(&f->input, b); in nxt_buf_filter_add()
70 b = f->input; in nxt_buf_filter()
87 f->input = b->next; in nxt_buf_filter()
105 f->input = b->next; in nxt_buf_filter()
241 jbf->file = *f->input->file; in nxt_buf_filter_file_read_start()
269 size = f->input->file_end - f->input->file_pos; in nxt_buf_filter_file_read()
293 b->file = f->input->file; in nxt_buf_filter_file_read()
356 ctx->buf = f->input; in nxt_buf_filter_file_job_completion()
358 f->input->file_pos = b->file_end; in nxt_buf_filter_file_job_completion()
360 done = (f->input->file_pos == f->input->file_end); in nxt_buf_filter_file_job_completion()
[all …]
H A Dnxt_buf_filter.h90 nxt_buf_t *input; member
/unit/test/ruby/input_gets/
H A Dconfig.ru2 body = env['rack.input'].gets
3 env['rack.input'].close
/unit/test/ruby/empty/
H A Dconfig.ru2 body = env['rack.input'].gets
3 #body += env['rack.input'].gets
/unit/test/ruby/header_custom/
H A Dconfig.ru4 'Custom-Header' => env['rack.input'].read
/unit/test/ruby/input_read_empty/
H A Dconfig.ru2 body = env['rack.input'].read
/unit/test/ruby/mirror/
H A Dconfig.ru2 body = env['rack.input'].read
/unit/test/ruby/input_read_buffer/
H A Dconfig.ru3 env['rack.input'].read(nil, body)
/unit/test/ruby/input_read_buffer_not_empty/
H A Dconfig.ru3 env['rack.input'].read(nil, body)
/unit/test/ruby/input_each/
H A Dconfig.ru3 env['rack.input'].each do |value|
/unit/test/ruby/input_gets_all/
H A Dconfig.ru5 buf = env['rack.input'].gets
/unit/test/ruby/variables/
H A Dconfig.ru2 body = env['rack.input'].read
/unit/src/java/nginx/unit/websocket/
H A DWsWebSocketContainer.java762 private static ByteBuffer putWithExpand(ByteBuffer input, byte[] bytes) { in putWithExpand() argument
763 if (bytes.length > input.remaining()) { in putWithExpand()
765 if (bytes.length > input.capacity()) { in putWithExpand()
768 newSize = input.capacity() * 2; in putWithExpand()
771 input.flip(); in putWithExpand()
772 expanded.put(input); in putWithExpand()
773 input = expanded; in putWithExpand()
775 return input.put(bytes); in putWithExpand()
H A DUtil.java535 private static boolean containsDelims(String input) { in containsDelims() argument
536 if (input == null || input.length() == 0) { in containsDelims()
539 for (char c : input.toCharArray()) { in containsDelims()
H A DLocalStrings.properties21 asyncChannelWrapperSecure.check.wrap=Bytes were consumed from the input during a write
/unit/src/java/nginx/unit/websocket/server/
H A DLocalStrings.properties34 wsFrameServer.bytesRead=Read [{0}] bytes into input buffer ready for processing