/unit/src/java/nginx/unit/websocket/ |
H A D | AsyncChannelWrapperSecure.java | 78 public Future<Integer> read(ByteBuffer dst) { in read() 95 CompletionHandler<Integer,B> handler) { in read() argument 97 WrapperFuture<Integer,B> future = in read() 111 public Future<Integer> write(ByteBuffer src) { in write() 223 Future<Integer> f = in run() 249 private final WrapperFuture<Integer,?> future; 269 Integer socketRead = f.get(); in run() 376 Future<Integer> fWrite = in run() 385 Future<Integer> fRead = in run() 547 return Integer.valueOf(result.intValue()); in get() [all …]
|
H A D | AsyncChannelWrapper.java | 33 Future<Integer> read(ByteBuffer dst); in read() 36 CompletionHandler<Integer,B> handler); in read() argument 38 Future<Integer> write(ByteBuffer src); in write()
|
H A D | AsyncChannelWrapperNonSecure.java | 45 public Future<Integer> read(ByteBuffer dst) { in read() 51 CompletionHandler<Integer,B> handler) { in read() argument 56 public Future<Integer> write(ByteBuffer src) { in write()
|
H A D | Constants.java | 44 static final int DEFAULT_BUFFER_SIZE = Integer.getInteger( 118 static final int DEFAULT_PROCESS_PERIOD = Integer.getInteger(
|
H A D | WsFrameClient.java | 37 private final CompletionHandler<Integer, Void> handler; 148 private class WsFrameClientCompletionHandler implements CompletionHandler<Integer, Void> { 151 public void completed(Integer result, Void attachment) { in completed()
|
H A D | PerMessageDeflate.java | 94 serverMaxWindowBits = Integer.parseInt(param.getValue()); in negotiate() 99 Integer.valueOf(serverMaxWindowBits))); in negotiate() 127 clientMaxWindowBits = Integer.parseInt(param.getValue()); in negotiate() 132 Integer.valueOf(clientMaxWindowBits))); in negotiate() 279 Integer.toString(serverMaxWindowBits))); in getExtensionResponse() 286 Integer.toString(clientMaxWindowBits))); in getExtensionResponse()
|
H A D | WsWebSocketContainer.java | 355 maxRedirects = Integer.parseInt(maxRedirectsValue); in connectToServerRecursive() 368 Integer.toString(httpResponse.status))); in connectToServerRecursive() 389 Integer.toString(redirectSet.size()), in connectToServerRecursive() 390 Integer.toString(maxRedirects))); in connectToServerRecursive() 402 Integer.valueOf(httpResponse.status))); in connectToServerRecursive() 412 Integer.toString(httpResponse.status))); in connectToServerRecursive() 436 Integer.toString(httpResponse.status))); in connectToServerRecursive() 530 Future<Integer> fWrite = channel.write(request); in writeRequest() 531 Integer thisWrite = fWrite.get(timeout, TimeUnit.MILLISECONDS); in writeRequest() 802 Future<Integer> read = channel.read(response); in processResponse() [all …]
|
H A D | WsFrameBase.java | 156 … sm.getString("wsFrame.wrongRsv", Integer.valueOf(rsv), Integer.valueOf(opCode)))); in processInitialHeader() 170 sm.getString("wsFrame.invalidOpCode", Integer.valueOf(opCode)))); in processInitialHeader() 202 sm.getString("wsFrame.invalidOpCode", Integer.valueOf(opCode)))); in processInitialHeader() 224 Integer.toString(rsv), Integer.toString(opCode), Long.toString(payloadLength))); in processInitialHeader() 367 sm.getString("wsFrame.invalidOpCode", Integer.valueOf(opCode)))); in processDataControl() 517 Integer.valueOf(messageBufferBinary.capacity()), in processDataBinary()
|
H A D | DigestAuthenticator.java | 91 challenge.append("nc=" + String.format("%08X", Integer.valueOf(nonceCount))); in getAuthorization() 124 preDigest.append(String.format("%08X", Integer.valueOf(nonceCount))); in calculateRequestDigest()
|
H A D | AsyncChannelGroupUtil.java | 88 Integer.MAX_VALUE, in createAsynchronousChannelGroup()
|
H A D | Util.java | 298 clazz.equals(Integer.class) || in isPrimitive() 320 } else if (type.equals(int.class) || type.equals(Integer.class)) { in coerceToType() 321 return Integer.valueOf(value); in coerceToType()
|
H A D | LocalStrings.properties | 29 asyncChannelWrapperSecure.tooBig=The result [{0}] is too big to be expressed as an Integer 129 wsWebSocketContainer.maxBuffer=This implementation limits the maximum size of a buffer to Integer.M…
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | WsServerContainer.java | 75 private final Map<Integer,SortedSet<TemplatePathMatch>> configTemplateMatchMap = 92 setDefaultMaxBinaryMessageBufferSize(Integer.parseInt(value)); in WsServerContainer() 98 setDefaultMaxTextMessageBufferSize(Integer.parseInt(value)); in WsServerContainer() 153 Integer key = Integer.valueOf(uriTemplate.getSegmentCount()); in addEndpoint() 292 Integer key = Integer.valueOf(pathUriTemplate.getSegmentCount()); in findMapping()
|
/unit/test/java/header_int/ |
H A D | app.java | 20 response.addHeader("X-Get-Int", Integer.toString(request.getIntHeader("X-Header"))); in doGet()
|
/unit/test/java/get_header_names/ |
H A D | app.java | 23 response.addHeader("X-Reply-" + Integer.toString(i), in doGet()
|
/unit/test/java/get_headers/ |
H A D | app.java | 23 response.addHeader("X-Reply-" + Integer.toString(i), in doGet()
|
/unit/test/java/threads/ |
H A D | app.java | 21 delay = Integer.parseInt(x_delay); in doGet()
|
/unit/test/java/session_inactive/ |
H A D | app.java | 25 s.setMaxInactiveInterval(Integer.parseInt(interval)); in doGet()
|
/unit/test/java/mirror/ |
H A D | app.java | 28 String dataLength = Integer.toString(data.length()); in doPost()
|
/unit/src/java/nginx/unit/websocket/pojo/ |
H A D | PojoMessageHandlerWholeBinary.java | 58 if (maxMessageSize > Integer.MAX_VALUE) { in PojoMessageHandlerWholeBinary()
|
H A D | PojoMessageHandlerWholeText.java | 58 if (maxMessageSize > Integer.MAX_VALUE) { in PojoMessageHandlerWholeText()
|
H A D | PojoMethodMapping.java | 379 private Map<Integer,PojoPathParam> indexPathParams = new HashMap<>(); 397 Integer.valueOf(i), new PojoPathParam(types[i], in MessageHandlerInfo() 635 for (Map.Entry<Integer,PojoPathParam> entry : in getMessageHandlers()
|
H A D | LocalStrings.properties | 40 …Whole.maxBufferSize=The maximum supported message size for this implementation is Integer.MAX_VALUE
|
/unit/src/java/nginx/unit/ |
H A D | Context.java | 160 private final Map<Integer, String> error2location_ = new HashMap<>(); 974 if (code != null && code instanceof Integer) { in service() 975 handleStatusCode((Integer) code, req, resp); in service() 1316 reg.setLoadOnStartup(Integer.parseInt(child_node.getTextContent().trim())); in processWebXml() 1408 Integer code = Integer.parseInt(child_node.getTextContent().trim()); in processWebXml() 1426 session_timeout_ = Integer.parseInt(timeout); in processWebXml() 1472 int l = i < varr1.length ? Integer.parseInt(varr1[i]) : 0; in compareVersion() 1473 int r = i < varr2.length ? Integer.parseInt(varr2[i]) : 0; in compareVersion()
|