Home
last modified time | relevance | path

Searched refs:Integer (Results 1 – 24 of 24) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelWrapperSecure.java78 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 DAsyncChannelWrapper.java33 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 DAsyncChannelWrapperNonSecure.java45 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 DConstants.java44 static final int DEFAULT_BUFFER_SIZE = Integer.getInteger(
118 static final int DEFAULT_PROCESS_PERIOD = Integer.getInteger(
H A DWsFrameClient.java37 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 DPerMessageDeflate.java94 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 DWsWebSocketContainer.java355 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 DWsFrameBase.java156 … 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 DDigestAuthenticator.java91 challenge.append("nc=" + String.format("%08X", Integer.valueOf(nonceCount))); in getAuthorization()
124 preDigest.append(String.format("%08X", Integer.valueOf(nonceCount))); in calculateRequestDigest()
H A DAsyncChannelGroupUtil.java88 Integer.MAX_VALUE, in createAsynchronousChannelGroup()
H A DUtil.java298 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 DLocalStrings.properties29 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 DWsServerContainer.java75 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 Dapp.java20 response.addHeader("X-Get-Int", Integer.toString(request.getIntHeader("X-Header"))); in doGet()
/unit/test/java/get_header_names/
H A Dapp.java23 response.addHeader("X-Reply-" + Integer.toString(i), in doGet()
/unit/test/java/get_headers/
H A Dapp.java23 response.addHeader("X-Reply-" + Integer.toString(i), in doGet()
/unit/test/java/threads/
H A Dapp.java21 delay = Integer.parseInt(x_delay); in doGet()
/unit/test/java/session_inactive/
H A Dapp.java25 s.setMaxInactiveInterval(Integer.parseInt(interval)); in doGet()
/unit/test/java/mirror/
H A Dapp.java28 String dataLength = Integer.toString(data.length()); in doPost()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeBinary.java58 if (maxMessageSize > Integer.MAX_VALUE) { in PojoMessageHandlerWholeBinary()
H A DPojoMessageHandlerWholeText.java58 if (maxMessageSize > Integer.MAX_VALUE) { in PojoMessageHandlerWholeText()
H A DPojoMethodMapping.java379 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 DLocalStrings.properties40 …Whole.maxBufferSize=The maximum supported message size for this implementation is Integer.MAX_VALUE
/unit/src/java/nginx/unit/
H A DContext.java160 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()