Home
last modified time | relevance | path

Searched refs:read (Results 1 – 25 of 83) sorted by relevance

1234

/unit/src/java/nginx/unit/
H A DInputStream.java52 public int read() throws IOException in read() method in InputStream
54 return read(req_info_ptr); in read()
57 private static native int read(long req_info_ptr); in read() method in InputStream
61 public int read(byte b[], int off, int len) throws IOException { in read() method in InputStream
70 return read(req_info_ptr, b, off, len); in read()
73 private static native int read(long req_info_ptr, byte b[], int off, int len); in read() method in InputStream
/unit/test/python/upload/
H A Dwsgi.py5 def read(environ): function
9 body.write(bytes(environ['wsgi.input'].read(length)))
17 file = read(environ)
22 data = filename.encode() + form['file'].file.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/test/unit/
H A Dlog.py29 log = Log.read()
57 return re.findall(pattern, Log.read(name), flags)
79 log = Log.read()
88 def read(*args, **kwargs): member in Log
90 return file.read()
106 found = re.search(pattern, file.read(), flags)
/unit/src/
H A Dnxt_eventport_engine.c155 ev->read = NXT_EVENT_ACTIVE; in nxt_eventport_enable()
167 ev->read = NXT_EVENT_INACTIVE; in nxt_eventport_disable()
184 ev->read = NXT_EVENT_INACTIVE; in nxt_eventport_close()
196 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_eventport_enable_read()
202 ev->read = NXT_EVENT_ACTIVE; in nxt_eventport_enable_read()
251 ev->read = NXT_EVENT_INACTIVE; in nxt_eventport_disable_read()
267 if (ev->read == NXT_EVENT_INACTIVE) { in nxt_eventport_disable_write()
369 ev->read = NXT_EVENT_INACTIVE; in nxt_eventport_error_handler()
380 ev->read = NXT_EVENT_BLOCKED; in nxt_eventport_block_read()
398 ev->read = NXT_EVENT_ACTIVE; in nxt_eventport_oneshot_read()
[all …]
H A Dnxt_epoll_engine.c103 .read = nxt_conn_io_read,
357 ev->read = NXT_EVENT_ACTIVE; in nxt_epoll_enable()
370 ev->read = NXT_EVENT_INACTIVE; in nxt_epoll_disable()
383 ev->read = NXT_EVENT_INACTIVE; in nxt_epoll_delete()
430 ev->read = NXT_EVENT_ACTIVE; in nxt_epoll_enable_read()
465 ev->read = NXT_EVENT_INACTIVE; in nxt_epoll_disable_read()
507 ev->read = NXT_EVENT_BLOCKED; in nxt_epoll_block_read()
542 ev->read = NXT_EVENT_ONESHOT; in nxt_epoll_oneshot_read()
557 ev->read = NXT_EVENT_INACTIVE; in nxt_epoll_oneshot_write()
569 ev->read = NXT_EVENT_ACTIVE; in nxt_epoll_enable_accept()
[all …]
H A Dnxt_devpoll_engine.c172 ev->read = NXT_EVENT_ACTIVE; in nxt_devpoll_enable()
184 ev->read = NXT_EVENT_INACTIVE; in nxt_devpoll_disable()
242 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_devpoll_enable_read()
261 ev->read = NXT_EVENT_ACTIVE; in nxt_devpoll_enable_read()
298 ev->read = NXT_EVENT_INACTIVE; in nxt_devpoll_disable_read()
321 if (ev->read <= NXT_EVENT_BLOCKED) { in nxt_devpoll_disable_write()
322 ev->read = NXT_EVENT_INACTIVE; in nxt_devpoll_disable_write()
338 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_devpoll_block_read()
339 ev->read = NXT_EVENT_BLOCKED; in nxt_devpoll_block_read()
358 ev->read = NXT_EVENT_ONESHOT; in nxt_devpoll_oneshot_read()
[all …]
H A Dnxt_pollset_engine.c167 ev->read = NXT_EVENT_ACTIVE; in nxt_pollset_enable()
179 ev->read = NXT_EVENT_INACTIVE; in nxt_pollset_disable()
216 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_pollset_enable_read()
235 ev->read = NXT_EVENT_ACTIVE; in nxt_pollset_enable_read()
272 ev->read = NXT_EVENT_INACTIVE; in nxt_pollset_disable_read()
295 if (ev->read <= NXT_EVENT_BLOCKED) { in nxt_pollset_disable_write()
296 ev->read = NXT_EVENT_INACTIVE; in nxt_pollset_disable_write()
312 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_pollset_block_read()
313 ev->read = NXT_EVENT_BLOCKED; in nxt_pollset_block_read()
332 ev->read = NXT_EVENT_ONESHOT; in nxt_pollset_oneshot_read()
[all …]
H A Dnxt_select_engine.c108 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_select_disable()
142 ev->read = NXT_EVENT_ACTIVE; in nxt_select_enable_read()
188 ev->read = NXT_EVENT_INACTIVE; in nxt_select_error_handler()
210 ev->read = NXT_EVENT_INACTIVE; in nxt_select_disable_read()
236 if (ev->read == NXT_EVENT_INACTIVE) { in nxt_select_disable_write()
246 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_select_block_read()
266 ev->read = NXT_EVENT_ONESHOT; in nxt_select_oneshot_read()
338 fd, ev->read, ev->write); in nxt_select_poll()
342 if (ev->read == NXT_EVENT_ONESHOT) { in nxt_select_poll()
355 fd, ev->read, ev->write); in nxt_select_poll()
H A Dnxt_poll_engine.c139 ev->read = NXT_EVENT_ACTIVE; in nxt_poll_enable()
150 ev->read = NXT_EVENT_INACTIVE; in nxt_poll_disable()
172 ev->read = NXT_EVENT_ACTIVE; in nxt_poll_enable_read()
194 if (ev->read == NXT_EVENT_INACTIVE) { in nxt_poll_enable_write()
212 ev->read = NXT_EVENT_INACTIVE; in nxt_poll_disable_read()
234 if (ev->read == NXT_EVENT_INACTIVE) { in nxt_poll_disable_write()
250 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_poll_block_read()
273 ev->read = NXT_EVENT_ONESHOT; in nxt_poll_oneshot_read()
288 ev->read = NXT_EVENT_INACTIVE; in nxt_poll_oneshot_write()
608 if (ev->read == NXT_EVENT_ONESHOT) { in nxt_poll()
[all …]
H A Dnxt_h1proto_websocket.c134 c->read = ws_frame; in nxt_h1p_websocket_frame_start()
138 in = c->read; in nxt_h1p_websocket_frame_start()
232 size = nxt_buf_mem_used_size(&c->read->mem); in nxt_h1p_conn_ws_frame_header_read()
263 r->ws_frame = c->read; in nxt_h1p_conn_ws_frame_header_read()
343 c->read->mem.end = c->read->mem.start + frame_size; in nxt_h1p_conn_ws_frame_header_read()
348 c->read->next = b; in nxt_h1p_conn_ws_frame_header_read()
349 c->read = b; in nxt_h1p_conn_ws_frame_header_read()
409 c->read = NULL; in nxt_h1p_conn_ws_frame_process()
468 b = c->read; in nxt_h1p_ws_io_read_handler()
484 c->read = b; in nxt_h1p_ws_io_read_handler()
[all …]
H A Dnxt_fd_event.h65 nxt_fd_event_state_t read:8; /* 3 bits. */ member
82 nxt_fd_event_state_t read:3; member
H A Dnxt_kqueue_engine.c117 .read = nxt_kqueue_conn_io_read,
260 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_kqueue_disable()
261 ev->read = NXT_EVENT_INACTIVE; in nxt_kqueue_disable()
275 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_kqueue_delete()
276 ev->read = NXT_EVENT_INACTIVE; in nxt_kqueue_delete()
301 ev->read = NXT_EVENT_INACTIVE; in nxt_kqueue_close()
331 ev->read = NXT_EVENT_ACTIVE; in nxt_kqueue_enable_read()
350 ev->read = NXT_EVENT_INACTIVE; in nxt_kqueue_disable_read()
369 ev->read = NXT_EVENT_BLOCKED; in nxt_kqueue_block_read()
406 ev->read = NXT_EVENT_ACTIVE; in nxt_kqueue_enable_accept()
[all …]
/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelWrapperNonSecure.java45 public Future<Integer> read(ByteBuffer dst) { in read() method in AsyncChannelWrapperNonSecure
46 return socketChannel.read(dst); in read()
50 public <B,A extends B> void read(ByteBuffer dst, A attachment, in read() method in AsyncChannelWrapperNonSecure
52 socketChannel.read(dst, attachment, handler); in read()
H A DAsyncChannelWrapper.java33 Future<Integer> read(ByteBuffer dst); in read() method
35 <B,A extends B> void read(ByteBuffer dst, A attachment, in read() method
H A DAsyncChannelWrapperSecure.java78 public Future<Integer> read(ByteBuffer dst) { in read() method in AsyncChannelWrapperSecure
94 public <B,A extends B> void read(ByteBuffer dst, A attachment, in read() method in AsyncChannelWrapperSecure
258 int read = 0; in run() local
263 while (read == 0) { in run()
268 Future<Integer> f = socketChannel.read(socketReadBuffer); in run()
280 read += r.bytesProduced(); in run()
290 if (read == 0) { in run()
331 future.complete(Integer.valueOf(read)); in run()
386 socketChannel.read(socketReadBuffer); in run()
/unit/test/java/multipart/
H A Dapp.java52 int read = 0; in doPost() local
55 while ((read = filecontent.read(bytes)) != -1) { in doPost()
56 out.write(bytes, 0, read); in doPost()
/unit/test/ruby/header_custom/
H A Dconfig.ru4 'Custom-Header' => env['rack.input'].read
/unit/test/python/input_read_length/
H A Dwsgi.py4 body = bytes(environ['wsgi.input'].read(input_length))
/unit/test/python/mirror/
H A Dwsgi.py4 body = bytes(environ['wsgi.input'].read(content_length))
/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/python/log_body/
H A Dwsgi.py3 body = bytes(environ['wsgi.input'].read(content_length))
/unit/test/unit/applications/
H A Dtls.py47 return self.conf(k.read() + c.read(), f'/certificates/{crt}')
/unit/test/ruby/input_read_buffer/
H A Dconfig.ru3 env['rack.input'].read(nil, body)

1234