Home
last modified time | relevance | path

Searched refs:limit (Results 1 – 25 of 31) sorted by path

12

/unit/
H A DCHANGES304 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 Dunit-openapi.yaml3433 Unit's [request body size limit]
/unit/pkg/deb/debian.module/
H A Dcopyright.unit-jsc-common692 limit or alter the recipient's rights in the Source Code form from
/unit/pkg/rpm/rpmbuild/SOURCES/
H A DCOPYRIGHT.unit-jsc-common692 limit or alter the recipient's rights in the Source Code form from
/unit/src/java/nginx/unit/
H A DRequest.java1287 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 DAsyncChannelWrapperSecure.java361 socketReadBuffer.position(socketReadBuffer.limit()); in run()
H A DLocalStrings.properties68 wsFrame.messageTooBig=The message was [{0}] bytes long but the MessageHandler has a limit of [{1}] …
H A DPerMessageDeflate.java322 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 DWsFrameBase.java94 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 DWsFrameClient.java80 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 DWsPongMessage.java29 byte[] dst = new byte[applicationData.limit()]; in WsPongMessage()
H A DWsRemoteEndpointImplBase.java718 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 DWsWebSocketContainer.java528 int toWrite = request.limit(); in writeRequest()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeBinary.java98 byte[] array = new byte[message.limit() - message.position()]; in decode()
/unit/src/
H A Dnxt_aix_send_file.c13 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 Dnxt_conn.h32 size_t limit; member
73 size_t limit);
H A Dnxt_conn_write.c53 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 Dnxt_cyassl.c33 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 Dnxt_event_conn_job_sendfile.c14 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 Dnxt_freebsd_sendfile.c19 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 Dnxt_gnutls.c48 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 Dnxt_hpux_sendfile.c13 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 Dnxt_linux_sendfile.c26 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 Dnxt_log_moderation.c34 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 Dnxt_log_moderation.h13 uint32_t limit; member

12