/unit/src/java/nginx/unit/ |
H A D | InputStream.java | 52 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 D | wsgi.py | 5 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 D | config.ru | 2 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 D | log.py | 29 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 D | nxt_eventport_engine.c | 155 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 D | nxt_epoll_engine.c | 103 .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 D | nxt_devpoll_engine.c | 172 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 D | nxt_pollset_engine.c | 167 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 D | nxt_select_engine.c | 108 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 D | nxt_poll_engine.c | 139 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 D | nxt_h1proto_websocket.c | 134 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 D | nxt_fd_event.h | 65 nxt_fd_event_state_t read:8; /* 3 bits. */ member 82 nxt_fd_event_state_t read:3; member
|
H A D | nxt_kqueue_engine.c | 117 .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 D | AsyncChannelWrapperNonSecure.java | 45 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 D | AsyncChannelWrapper.java | 33 Future<Integer> read(ByteBuffer dst); in read() method 35 <B,A extends B> void read(ByteBuffer dst, A attachment, in read() method
|
H A D | AsyncChannelWrapperSecure.java | 78 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 D | app.java | 52 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 D | config.ru | 4 'Custom-Header' => env['rack.input'].read
|
/unit/test/python/input_read_length/ |
H A D | wsgi.py | 4 body = bytes(environ['wsgi.input'].read(input_length))
|
/unit/test/python/mirror/ |
H A D | wsgi.py | 4 body = bytes(environ['wsgi.input'].read(content_length))
|
/unit/test/ruby/input_read_empty/ |
H A D | config.ru | 2 body = env['rack.input'].read
|
/unit/test/ruby/mirror/ |
H A D | config.ru | 2 body = env['rack.input'].read
|
/unit/test/python/log_body/ |
H A D | wsgi.py | 3 body = bytes(environ['wsgi.input'].read(content_length))
|
/unit/test/unit/applications/ |
H A D | tls.py | 47 return self.conf(k.read() + c.read(), f'/certificates/{crt}')
|
/unit/test/ruby/input_read_buffer/ |
H A D | config.ru | 3 env['rack.input'].read(nil, body)
|