/unit/ |
H A D | CHANGES | 304 limit was reached by asynchronous or multithreaded apps. 360 *) Feature: the ability to limit static file serving by MIME types. 615 when reaching open connections limit. 947 *) Feature: configuration of the request body size limit.
|
/unit/docs/ |
H A D | unit-openapi.yaml | 3433 Unit's [request body size limit]
|
/unit/pkg/deb/debian.module/ |
H A D | copyright.unit-jsc-common | 692 limit or alter the recipient's rights in the Source Code form from
|
/unit/pkg/rpm/rpmbuild/SOURCES/ |
H A D | COPYRIGHT.unit-jsc-common | 692 limit or alter the recipient's rights in the Source Code form from
|
/unit/src/java/nginx/unit/ |
H A D | Request.java | 1287 trace("processWsFrame: " + opCode + ", [" + buf.position() + ", " + buf.limit() + "]"); in processWsFrame() 1307 ", " + payload.limit() + "]"); in sendWsFrame() 1311 payload.limit() - payload.position(), opCode, last); in sendWsFrame() 1314 payload.limit() - payload.position(), opCode, last); in sendWsFrame()
|
/unit/src/java/nginx/unit/websocket/ |
H A D | AsyncChannelWrapperSecure.java | 361 socketReadBuffer.position(socketReadBuffer.limit()); in run()
|
H A D | LocalStrings.properties | 68 wsFrame.messageTooBig=The message was [{0}] bytes long but the MessageHandler has a limit of [{1}] …
|
H A D | PerMessageDeflate.java | 322 boolean emptyPart = uncompressedPart.getPayload().limit() == 0; in sendMessagePart() 371 boolean full = compressedPayload.limit() == compressedPayload.capacity(); in sendMessagePart() 377 compressedPayload.limit(compressedPayload.limit() - EOM_BYTES.length); in sendMessagePart() 407 … compressedPayload.limit(compressedPayload.limit() - EOM_BYTES.length + eomBufferWritten); in sendMessagePart()
|
H A D | WsFrameBase.java | 94 inputBuffer.position(0).limit(0); in WsFrameBase() 522 ByteBuffer copy = ByteBuffer.allocate(messageBufferBinary.limit()); in processDataBinary() 537 ByteBuffer copy = ByteBuffer.allocate(messageBufferBinary.limit()); in processDataBinary() 600 inputBuffer.position(0).limit(0); in newFrame() 946 int orgLimit = inputBuffer.limit(); in getMoreData() 947 inputBuffer.limit(inputBuffer.position() + (int) toWrite); in getMoreData() 949 inputBuffer.limit(orgLimit); in getMoreData()
|
H A D | WsFrameClient.java | 80 inputBuffer.position(inputBuffer.limit()).limit(inputBuffer.capacity()); in processSocketRead() 87 int orgLimit = response.limit(); in processSocketRead() 88 response.limit(response.position() + toCopy); in processSocketRead() 90 response.limit(orgLimit); in processSocketRead() 92 inputBuffer.limit(inputBuffer.position()).reset(); in processSocketRead()
|
H A D | WsPongMessage.java | 29 byte[] dst = new byte[applicationData.limit()]; in WsPongMessage()
|
H A D | WsRemoteEndpointImplBase.java | 718 if (payload.limit() < 126) { in writeHeader() 719 headerBuffer.put((byte) (payload.limit() | b)); in writeHeader() 720 } else if (payload.limit() < 65536) { in writeHeader() 722 headerBuffer.put((byte) (payload.limit() >>> 8)); in writeHeader() 723 headerBuffer.put((byte) (payload.limit() & 0xFF)); in writeHeader() 731 headerBuffer.put((byte) (payload.limit() >>> 24)); in writeHeader() 732 headerBuffer.put((byte) (payload.limit() >>> 16)); in writeHeader() 733 headerBuffer.put((byte) (payload.limit() >>> 8)); in writeHeader() 841 int payloadLimit = payload.limit(); in write() 848 payload.limit(payload.position() + toWrite); in write() [all …]
|
H A D | WsWebSocketContainer.java | 528 int toWrite = request.limit(); in writeRequest()
|
/unit/src/java/nginx/unit/websocket/pojo/ |
H A D | PojoMessageHandlerWholeBinary.java | 98 byte[] array = new byte[message.limit() - message.position()]; in decode()
|
/unit/src/ |
H A D | nxt_aix_send_file.c | 13 size_t limit); 17 nxt_aix_event_conn_io_send_file(nxt_event_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_aix_event_conn_io_send_file() argument 33 sb.limit = limit; in nxt_aix_event_conn_io_send_file()
|
H A D | nxt_conn.h | 32 size_t limit; member 73 size_t limit);
|
H A D | nxt_conn_write.c | 53 sb.limit = 10 * 1024 * 1024; in nxt_conn_io_write() 69 sb.limit -= ret; in nxt_conn_io_write() 85 } while (sb.limit != 0); in nxt_conn_io_write() 97 if (sb.limit == 0) { in nxt_conn_io_write() 398 ssize_t limit, correction; in nxt_event_conn_write_limit() local 407 limit = rate->limit; in nxt_event_conn_write_limit() 413 limit += correction; in nxt_event_conn_write_limit() 415 if (limit <= 0) { in nxt_event_conn_write_limit() 420 limit += rate->limit_after; in nxt_event_conn_write_limit() 421 limit = nxt_min((size_t) limit, rate->max_limit); in nxt_event_conn_write_limit() [all …]
|
H A D | nxt_cyassl.c | 33 nxt_event_conn_t *c, nxt_buf_t *b, size_t limit); 396 nxt_buf_t *b, size_t limit) in nxt_cyassl_conn_io_write_chunk() argument 404 return nxt_sendbuf_copy_coalesce(c, &ssltls->buffer, b, limit); in nxt_cyassl_conn_io_write_chunk()
|
H A D | nxt_event_conn_job_sendfile.c | 14 size_t limit; member 64 jbs->limit = nxt_event_conn_write_limit(c); in nxt_event_conn_job_sendfile_start() 66 if (jbs->limit != 0) { in nxt_event_conn_job_sendfile_start() 73 sb.limit = jbs->limit; in nxt_event_conn_job_sendfile_start() 113 ret = c->io->old_sendbuf(c, b, jbs->limit); in nxt_event_conn_job_sendfile_handler() 124 jbs->limit -= ret; in nxt_event_conn_job_sendfile_handler() 132 if (jbs->limit == 0) { in nxt_event_conn_job_sendfile_handler() 135 jbs->limit = c->max_chunk; in nxt_event_conn_job_sendfile_handler()
|
H A D | nxt_freebsd_sendfile.c | 19 size_t limit); 34 size_t limit) in nxt_freebsd_event_conn_io_sendfile() argument 51 sb.limit = limit; in nxt_freebsd_event_conn_io_sendfile()
|
H A D | nxt_gnutls.c | 48 nxt_event_conn_t *c, nxt_buf_t *b, size_t limit); 527 nxt_buf_t *b, size_t limit) in nxt_gnutls_conn_io_write_chunk() argument 535 return nxt_sendbuf_copy_coalesce(c, &ssltls->buffer, b, limit); in nxt_gnutls_conn_io_write_chunk()
|
H A D | nxt_hpux_sendfile.c | 13 size_t limit); 34 nxt_hpux_event_conn_io_sendfile(nxt_event_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_hpux_event_conn_io_sendfile() argument 49 sb.limit = limit; in nxt_hpux_event_conn_io_sendfile()
|
H A D | nxt_linux_sendfile.c | 26 size_t limit); 47 size_t limit) in nxt_linux_event_conn_io_sendfile() argument 63 sb.limit = limit; in nxt_linux_event_conn_io_sendfile()
|
H A D | nxt_log_moderation.c | 34 if (n <= mod->limit) { in nxt_log_moderate_allow() 44 if (n < mod->limit) { in nxt_log_moderate_allow() 47 } else if (n == mod->limit) { in nxt_log_moderate_allow() 95 mod->msg, n - mod->limit); in nxt_log_moderate_timer_handler()
|
H A D | nxt_log_moderation.h | 13 uint32_t limit; member
|