Home
last modified time | relevance | path

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

12

/unit/src/
H A Dnxt_sendbuf.h45 size_t limit; member
66 size_t limit; member
73 size_t limit);
79 size_t limit);
85 size_t limit);
91 size_t limit);
97 size_t limit);
103 size_t limit);
107 size_t limit);
123 nxt_buf_t *b, size_t limit);
H A Dnxt_solaris_sendfilev.c19 size_t limit);
21 int32_t *nsfv, nxt_bool_t *sync, size_t limit);
26 size_t limit) in nxt_solaris_event_conn_io_sendfilev() argument
38 return nxt_event_conn_io_sendbuf(c, b, limit); in nxt_solaris_event_conn_io_sendfilev()
43 size = nxt_solaris_buf_coalesce(b, sfv, &nsfv, &sync, limit); in nxt_solaris_event_conn_io_sendfilev()
91 nxt_bool_t *sync, size_t limit) in nxt_solaris_buf_coalesce() argument
103 for (total = 0; b != NULL && total < limit; b = b->next) { in nxt_solaris_buf_coalesce()
115 if (total + size > limit) { in nxt_solaris_buf_coalesce()
116 size = limit - total; in nxt_solaris_buf_coalesce()
129 if (total + size > limit) { in nxt_solaris_buf_coalesce()
[all …]
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_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_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_sendbuf.c29 for (b = sb->buf; b != NULL && total < sb->limit; b = b->next) { in nxt_sendbuf_mem_coalesce0()
43 if (total + size > sb->limit) { in nxt_sendbuf_mem_coalesce0()
44 size = sb->limit - total; in nxt_sendbuf_mem_coalesce0()
99 for (b = sb->buf; b != NULL && total < sb->limit; b = b->next) { in nxt_sendbuf_mem_coalesce()
113 if (total + size > sb->limit) { in nxt_sendbuf_mem_coalesce()
114 size = sb->limit - total; in nxt_sendbuf_mem_coalesce()
182 if (total + size >= sb->limit) { in nxt_sendbuf_file_coalesce()
183 total = sb->limit; in nxt_sendbuf_file_coalesce()
212 size_t limit) in nxt_sendbuf_copy_coalesce() argument
258 n = c->io->send(c, bm->pos, nxt_min(size, limit)); in nxt_sendbuf_copy_coalesce()
[all …]
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_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_macosx_sendfile.c15 size_t limit);
29 nxt_macosx_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_macosx_event_conn_io_sendfile() argument
46 sb.limit = limit; in nxt_macosx_event_conn_io_sendfile()
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_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.h13 uint32_t limit; member
H A Dnxt_conn.h32 size_t limit; member
73 size_t limit);
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_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_port_socket.c413 sb.limit = port->max_size; in nxt_port_write_handler()
421 sb.limit = (1ULL << 31) - 1; in nxt_port_write_handler()
426 sb.limit -= iov[0].iov_len; in nxt_port_write_handler()
/unit/src/java/nginx/unit/websocket/
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 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 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 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 DAsyncChannelWrapperSecure.java361 socketReadBuffer.position(socketReadBuffer.limit()); in run()
/unit/test/unit/
H A Dhttp.py148 def log_truncate(self, log, limit=1024): argument
150 if len_log > limit:
151 log = log[:limit]
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeBinary.java98 byte[] array = new byte[message.limit() - message.position()]; in decode()
/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()

12