/unit/docs/ |
H A D | change_log_conf.dtd | 3 <!ELEMENT generic (length, start, indent?) > 4 <!ELEMENT rpm (length, start, indent?) > 5 <!ELEMENT deb (length, start, indent?) > 7 <!ELEMENT length (#PCDATA) > element 11 <!ELEMENT changes (title, length,
|
H A D | changes.xsls | 44 !{$conf/rpm/length} 47 !{$conf/deb/length} 50 !{$conf/generic/length} 163 X:var length = { 166 length = "$max") 181 X:template length(text, prefix, length) { 183 $length - $prefix + string-length($br)), 191 X:when "string-length($text) + $prefix <= $length" { 192 !{$length - $prefix} 196 !{$length - $prefix + 1} [all …]
|
/unit/src/java/nginx/unit/ |
H A D | Context.java | 215 url.length() == pattern.length() in match() 216 || url.charAt(pattern.length()) == '/'); in match() 222 return p.pattern.length() - pattern.length(); in compareTo() 587 trace(0, s, s.length()); in getResource() 779 if (p.pattern.length() == path.length()) { in findServlet() 945 || (path.length() > context_path_.length() in service() 1470 int max_len = varr1.length > varr2.length ? varr1.length : varr2.length; in compareVersion() 2270 pattern_ = p.substring(1, p.length()); 2315 url.length() == pattern_.length() 3003 log(0, msg, msg.length()); [all …]
|
H A D | InputStream.java | 64 } else if (off < 0 || len < 0 || len > b.length - off) { in read()
|
H A D | OutputStream.java | 30 } else if ((off < 0) || (off > b.length) || (len < 0) || in write() 31 ((off + len) > b.length) || ((off + len) < 0)) { in write()
|
H A D | Request.java | 179 if (cookies == null || cookies.getCookies().length == 0) { in getCookies() 220 for (int i = 0; (date == null) && (i < formats.length); i++) { in parseDate() 236 String res = getHeader(req_ptr, name, name.length()); in getHeader() 262 return getHeaders(req_ptr, name, name.length()); in getHeaders() 273 return getIntHeader(req_ptr, name, name.length()); in getIntHeader() 1262 log(req_info_ptr, msg, msg.length()); in log() 1271 trace(req_info_ptr, msg, msg.length()); in trace()
|
H A D | Response.java | 101 if (name == null || name.length() == 0) { in addSetRFC6265Cookie() 116 if (path != null && path.length() > 0) { in addSetRFC6265Cookie() 121 if (domain != null && domain.length() > 0) { in addSetRFC6265Cookie()
|
/unit/src/java/nginx/unit/websocket/ |
H A D | AsyncChannelWrapper.java | 40 <B,A extends B> void write(ByteBuffer[] srcs, int offset, int length, in write() argument
|
H A D | AsyncChannelWrapperNonSecure.java | 61 public <B,A extends B> void write(ByteBuffer[] srcs, int offset, int length, in write() argument 65 srcs, offset, length, timeout, unit, attachment, handler); in write()
|
H A D | AsyncChannelWrapperSecure.java | 130 public <B,A extends B> void write(ByteBuffer[] srcs, int offset, int length, in write() argument 142 WriteTask writeTask = new WriteTask(srcs, offset, length, future); in write() 173 private final int length; field in AsyncChannelWrapperSecure.WriteTask 176 public WriteTask(ByteBuffer[] srcs, int offset, int length, in WriteTask() argument 181 this.length = length; in WriteTask() 189 for (int i = offset; i < offset + length; i++) { in run()
|
H A D | LocalStrings.properties | 52 # frames and therefore must be 123 bytes (not characters) or less in length. 72 …alHeaderComplete=WebSocket frame received. fin [{0}], rsv [{1}], OpCode [{2}], payload length [{3}] 100 # frame and therefore must be 123 bytes (not characters) or less in length. 122 # frame and therefore must be 123 bytes (not characters) or less in length.
|
H A D | PerMessageDeflate.java | 55 private final byte[] EOM_BUFFER = new byte[EOM_BYTES.length + 1]; 377 compressedPayload.limit(compressedPayload.limit() - EOM_BYTES.length); in sendMessagePart() 404 … int eomBufferWritten = deflater.deflate(EOM_BUFFER, 0, EOM_BUFFER.length, Deflater.SYNC_FLUSH); in sendMessagePart() 405 if (eomBufferWritten < EOM_BUFFER.length) { in sendMessagePart() 407 … compressedPayload.limit(compressedPayload.limit() - EOM_BYTES.length + eomBufferWritten); in sendMessagePart()
|
H A D | Util.java | 280 for (int i = 0; i < tvs.length; i++) { in getTypeParameter() 500 for (int i = 1; i < unparsedParameters.length; i++) { in parseExtensionHeader() 510 int len = value.length(); in parseExtensionHeader() 513 value = value.substring(1, value.length() - 1); in parseExtensionHeader() 536 if (input == null || input.length() == 0) { in containsDelims()
|
H A D | WsRemoteEndpointImplBase.java | 960 if ((off < 0) || (off > b.length) || (len < 0) || in write() 961 ((off + len) > b.length) || ((off + len) < 0)) { in write() 1039 if ((off < 0) || (off > cbuf.length) || (len < 0) || in write() 1040 ((off + len) > cbuf.length) || ((off + len) < 0)) { in write()
|
H A D | WsSession.java | 70 private static final int ELLIPSIS_BYTES_LEN = ELLIPSIS_BYTES.length; 638 if (reason != null && reason.length() > 0) { in sendCloseMessage() 676 if (reasonBytes.length <= 123) { in appendCloseReasonWithTruncation() 684 while (remaining >= bytesNext.length) { in appendCloseReasonWithTruncation() 686 remaining -= bytesNext.length; in appendCloseReasonWithTruncation()
|
H A D | WsWebSocketContainer.java | 699 if (value != null && value.length() > 0) { in generateExtensionHeaders() 763 if (bytes.length > input.remaining()) { in putWithExpand() 765 if (bytes.length > input.capacity()) { in putWithExpand() 766 newSize = 2 * bytes.length; in putWithExpand() 837 if (parts.length < 2 || !("HTTP/1.0".equals(parts[0]) || "HTTP/1.1".equals(parts[0]))) { in parseStatus()
|
/unit/src/java/nginx/unit/websocket/pojo/ |
H A D | PojoMessageHandlerPartialBase.java | 52 if (params.length == 1 && params[0] instanceof DecodeException) { in onMessage()
|
H A D | PojoMessageHandlerWholeBase.java | 48 if (params.length == 1 && params[0] instanceof DecodeException) { in onMessage()
|
H A D | PojoMethodMapping.java | 284 PojoPathParam[] result = new PojoPathParam[types.length]; in getPathParams() 285 for (int i = 0; i < types.length; i++) { in getPathParams() 339 Object[] result = new Object[pathParams.length]; in buildArgs() 340 for (int i = 0; i < pathParams.length; i++) { in buildArgs() 390 for (int i = 0; i < types.length; i++) { in MessageHandlerInfo() 633 Object[] params = new Object[m.getParameterTypes().length]; in getMessageHandlers()
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | UpgradeUtil.java | 224 if (extension == null || extension.getName() == null || extension.getName().length() == 0) { in append()
|
H A D | UriTemplate.java | 46 if (path == null || path.length() ==0 || !path.startsWith("/")) { in UriTemplate() 51 StringBuilder normalized = new StringBuilder(path.length()); in UriTemplate() 59 for (int i = 0; i < segments.length; i++) { in UriTemplate() 61 if (segment.length() == 0) { in UriTemplate() 62 if (i == 0 || (i == segments.length - 1 && paramCount == 0)) { in UriTemplate() 79 segment = segment.substring(1, segment.length() - 1); in UriTemplate()
|
/unit/src/nodejs/unit-http/ |
H A D | http_server.js | 75 count = value.length; 115 for (var i = 0; i < keys.length; i++) { 153 this.headers_count -= value.length; 154 this.headers_len -= value.length * name_len; 210 for (var i = 0; i < keys.length; i++) { 272 contentLength = chunk.length; 276 contentLength = chunk.length; 470 if (typeof args[args.length - 1] === 'function') { 510 if (this._output.length <= 0) { 514 while (this._output.length > 0) { [all …]
|
H A D | utils.js | 11 function(emitter, type) { return emitter.listeners(type).length; };
|
H A D | websocket_connection.js | 352 this.fragmentationSize = frame.length; 370 this.fragmentationSize = frame.length; 377 if (this.frameQueue.length === 0) { 383 this.fragmentationSize += frame.length; 493 if (frame.binaryPayload.length > 1) { 502 this.closeDescription, frame.length 531 this._debug('sendUTF: %d bytes', data.length); 564 if (data.length > 125) { 581 if (Buffer.isBuffer(binaryPayload) && binaryPayload.length > 125) { 598 var length = frame.binaryPayload.length; [all …]
|
H A D | websocket_request.js | 185 if (!extensionsString || extensionsString.length === 0) { 232 var val = pair.substr(++eq_idx, pair.length).trim(); 271 for (var i=0; i < protocolFullCase.length; i++) {
|