Home
last modified time | relevance | path

Searched refs:write (Results 1 – 25 of 85) sorted by relevance

1234

/unit/src/java/nginx/unit/
H A DOutputStream.java17 public void write(int b) throws IOException in write() method in OutputStream
19 write(req_info_ptr, b); in write()
22 private static native void write(long req_info_ptr, int b); in write() method in OutputStream
26 public void write(byte b[], int off, int len) throws IOException in write() method in OutputStream
37 write(req_info_ptr, b, off, len); in write()
40 private static native void write(long req_info_ptr, byte b[], int off, int len); in write() method in OutputStream
/unit/test/python/write/
H A Dwsgi.py2 write = start_response('200', [('Content-Length', '10')])
3 write(b'012')
4 write(b'345')
/unit/src/
H A Dnxt_devpoll_engine.c173 ev->write = NXT_EVENT_ACTIVE; in nxt_devpoll_enable()
185 ev->write = NXT_EVENT_INACTIVE; in nxt_devpoll_disable()
270 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_devpoll_enable_write()
289 ev->write = NXT_EVENT_ACTIVE; in nxt_devpoll_enable_write()
300 if (ev->write <= NXT_EVENT_BLOCKED) { in nxt_devpoll_disable_read()
301 ev->write = NXT_EVENT_INACTIVE; in nxt_devpoll_disable_read()
319 ev->write = NXT_EVENT_INACTIVE; in nxt_devpoll_disable_write()
347 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_devpoll_block_write()
348 ev->write = NXT_EVENT_BLOCKED; in nxt_devpoll_block_write()
367 ev->write = NXT_EVENT_ONESHOT; in nxt_devpoll_oneshot_write()
[all …]
H A Dnxt_eventport_engine.c156 ev->write = NXT_EVENT_ACTIVE; in nxt_eventport_enable()
168 ev->write = NXT_EVENT_INACTIVE; in nxt_eventport_disable()
185 ev->write = NXT_EVENT_INACTIVE; in nxt_eventport_close()
211 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_eventport_enable_write()
217 ev->write = NXT_EVENT_ACTIVE; in nxt_eventport_enable_write()
253 if (ev->write == NXT_EVENT_INACTIVE) { in nxt_eventport_disable_read()
265 ev->write = NXT_EVENT_INACTIVE; in nxt_eventport_disable_write()
370 ev->write = NXT_EVENT_INACTIVE; in nxt_eventport_error_handler()
388 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_eventport_block_write()
389 ev->write = NXT_EVENT_BLOCKED; in nxt_eventport_block_write()
[all …]
H A Dnxt_pollset_engine.c168 ev->write = NXT_EVENT_ACTIVE; in nxt_pollset_enable()
180 ev->write = NXT_EVENT_INACTIVE; in nxt_pollset_disable()
244 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_pollset_enable_write()
263 ev->write = NXT_EVENT_ACTIVE; in nxt_pollset_enable_write()
274 if (ev->write <= NXT_EVENT_BLOCKED) { in nxt_pollset_disable_read()
275 ev->write = NXT_EVENT_INACTIVE; in nxt_pollset_disable_read()
293 ev->write = NXT_EVENT_INACTIVE; in nxt_pollset_disable_write()
321 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_pollset_block_write()
322 ev->write = NXT_EVENT_BLOCKED; in nxt_pollset_block_write()
341 ev->write = NXT_EVENT_ONESHOT; in nxt_pollset_oneshot_write()
[all …]
H A Dnxt_epoll_engine.c107 .write = nxt_conn_io_write,
358 ev->write = NXT_EVENT_ACTIVE; in nxt_epoll_enable()
371 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_disable()
384 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_delete()
455 ev->write = NXT_EVENT_ACTIVE; in nxt_epoll_enable_write()
468 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_disable_read()
487 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_disable_write()
516 ev->write = NXT_EVENT_BLOCKED; in nxt_epoll_block_write()
543 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_oneshot_read()
558 ev->write = NXT_EVENT_ONESHOT; in nxt_epoll_oneshot_write()
[all …]
H A Dnxt_select_engine.c112 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_select_disable()
169 ev->write = NXT_EVENT_ACTIVE; in nxt_select_enable_write()
189 ev->write = NXT_EVENT_INACTIVE; in nxt_select_error_handler()
212 if (ev->write == NXT_EVENT_INACTIVE) { in nxt_select_disable_read()
234 ev->write = NXT_EVENT_INACTIVE; in nxt_select_disable_write()
255 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_select_block_write()
275 ev->write = NXT_EVENT_ONESHOT; in nxt_select_oneshot_write()
338 fd, ev->read, ev->write); in nxt_select_poll()
355 fd, ev->read, ev->write); in nxt_select_poll()
359 if (ev->write == NXT_EVENT_ONESHOT) { in nxt_select_poll()
H A Dnxt_poll_engine.c140 ev->write = NXT_EVENT_ACTIVE; in nxt_poll_enable()
151 ev->write = NXT_EVENT_INACTIVE; in nxt_poll_disable()
174 if (ev->write == NXT_EVENT_INACTIVE) { in nxt_poll_enable_read()
192 ev->write = NXT_EVENT_ACTIVE; in nxt_poll_enable_write()
214 if (ev->write == NXT_EVENT_INACTIVE) { in nxt_poll_disable_read()
232 ev->write = NXT_EVENT_INACTIVE; in nxt_poll_disable_write()
259 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_poll_block_write()
274 ev->write = NXT_EVENT_INACTIVE; in nxt_poll_oneshot_read()
289 ev->write = NXT_EVENT_ONESHOT; in nxt_poll_oneshot_write()
620 if (ev->write == NXT_EVENT_ONESHOT) { in nxt_poll()
[all …]
H A Dnxt_fd_event.h66 nxt_fd_event_state_t write:8; /* 3 bits. */ member
83 nxt_fd_event_state_t write:3; member
H A Dnxt_event_conn_job_sendfile.c68 sb.buf = c->write; in nxt_event_conn_job_sendfile_start()
79 jbs->out = c->write; in nxt_event_conn_job_sendfile_start()
80 c->write = NULL; in nxt_event_conn_job_sendfile_start()
193 nxt_buf_chain_add(&b, c->write); in nxt_event_conn_job_sendfile_return()
194 c->write = b; in nxt_event_conn_job_sendfile_return()
H A Dnxt_kqueue_engine.c121 .write = nxt_conn_io_write,
266 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_disable()
281 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_delete()
302 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_close()
343 ev->write = NXT_EVENT_ACTIVE; in nxt_kqueue_enable_write()
359 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_disable_write()
378 ev->write = NXT_EVENT_BLOCKED; in nxt_kqueue_block_write()
386 ev->write = NXT_EVENT_ACTIVE; in nxt_kqueue_oneshot_read()
396 ev->write = NXT_EVENT_ACTIVE; in nxt_kqueue_oneshot_write()
541 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_fd_error_handler()
[all …]
/unit/test/node/write_multiple/
H A Dapp.js4 res.write('write');
5 res.write('write2');
/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelWrapperNonSecure.java56 public Future<Integer> write(ByteBuffer src) { in write() method in AsyncChannelWrapperNonSecure
57 return socketChannel.write(src); in write()
61 public <B,A extends B> void write(ByteBuffer[] srcs, int offset, int length, in write() method in AsyncChannelWrapperNonSecure
64 socketChannel.write( in write()
H A DAsyncChannelWrapper.java38 Future<Integer> write(ByteBuffer src); in write() method
40 <B,A extends B> void write(ByteBuffer[] srcs, int offset, int length, in write() method
/unit/test/python/delayed/
H A Dwsgi.py11 write = start_response('200', [('Content-Length', str(len(body)))])
20 write(body[i : i + step])
/unit/test/
H A Dtest_static.py22 index.write('0123456789')
23 readme.write('readme')
24 log.write('[debug]')
25 file.write('blah')
91 f.write(b'\0')
107 f.write('blah')
H A Dtest_usr1.py84 unit_log.write(unit_log_new.read())
85 unit_log.write(log)
/unit/test/python/iter_exception/
H A Dwsgi.py23 write = self.start('200', headers)
28 write(b'XXXXX')
/unit/test/python/errors_write/
H A Dwsgi.py2 environ['wsgi.errors'].write('Error in application.')
/unit/src/java/
H A DREADME.JSR-3407 write to this code. You should instead deploy and write production
/unit/test/node/write_before_write_head/
H A Dapp.js3 res.write('blah');
/unit/test/node/write_return/
H A Dapp.js4 .end(res.write('body').toString());
/unit/test/python/unicode/
H A Dwsgi.py5 f.write('\u26a0\ufe0f')
/unit/src/nodejs/unit-http/
H A Dsocket.js100 Socket.prototype.write = function write(data, encoding, callback) { method in Socket
/unit/test/python/atexit/
H A Dwsgi.py6 environ['wsgi.errors'].write('At exit called.\n')

1234