/unit/ |
H A D | CODE_OF_CONDUCT.md | 59 complaints will be reviewed and investigated and will result in a response that
|
H A D | LICENSE | 160 result of this License or out of the use or inability to use the
|
/unit/auto/cc/ |
H A D | test | 111 #NXT_CFLAGS="$NXT_CFLAGS -Wunused-result" 148 #NXT_CFLAGS="$NXT_CFLAGS -Wunused-result"
|
/unit/auto/ |
H A D | types | 9 # to use "%zu" format to printf() result of sizeof(). But "%zu" may
|
/unit/pkg/deb/debian.module/ |
H A D | copyright.unit-jsc-common | 208 court requires any other Contributor to pay any damages as a result, the 445 result of this License or out of the use or inability to use the 682 such Contributor as a result of warranty, support, indemnity or 699 by the Initial Developer or such Contributor as a result of any
|
/unit/pkg/rpm/rpmbuild/SOURCES/ |
H A D | COPYRIGHT.unit-jsc-common | 208 court requires any other Contributor to pay any damages as a result, the 445 result of this License or out of the use or inability to use the 682 such Contributor as a result of warranty, support, indemnity or 699 by the Initial Developer or such Contributor as a result of any
|
/unit/src/java/javax/websocket/ |
H A D | ContainerProvider.java | 37 WebSocketContainer result = null; in getWebSocketContainer() local 42 while (result == null && iter.hasNext()) { in getWebSocketContainer() 43 result = iter.next().getContainer(); in getWebSocketContainer() 47 if (result == null) { in getWebSocketContainer() 53 result = clazz.getConstructor().newInstance(); in getWebSocketContainer() 59 return result; in getWebSocketContainer()
|
H A D | SendHandler.java | 21 void onResult(SendResult result); in onResult() argument
|
/unit/src/java/javax/websocket/server/ |
H A D | ServerEndpointConfig.java | 167 Configurator result = null; in loadDefault() local 173 while (result == null && iter.hasNext()) { in loadDefault() 174 result = iter.next(); in loadDefault() 178 if (result == null) { in loadDefault() 184 result = clazz.getConstructor().newInstance(); in loadDefault() 190 return result; in loadDefault()
|
/unit/src/java/nginx/unit/websocket/ |
H A D | AsyncChannelWrapperSecure.java | 425 resultStatus = result.getStatus(); in checkResult() 432 if (wrap && result.bytesConsumed() != 0) { in checkResult() 447 private volatile T result = null; field in AsyncChannelWrapperSecure.WrapperFuture 460 public void complete(T result) { in complete() argument 461 this.result = result; in complete() 464 handler.completed(result, attachment); in complete() 499 return result; in get() 513 return result; in get() 542 Long result = wrapped.get(); in get() local 547 return Integer.valueOf(result.intValue()); in get() [all …]
|
H A D | FutureToSendHandler.java | 41 private volatile AtomicReference<SendResult> result = new AtomicReference<>(null); field in FutureToSendHandler 51 public void onResult(SendResult result) { in onResult() argument 52 this.result.compareAndSet(null, result); in onResult() 85 if (result.get().getException() != null) { in get() 86 throw new ExecutionException(result.get().getException()); in get() 107 if (result.get().getException() != null) { in get() 108 throw new ExecutionException(result.get().getException()); in get()
|
H A D | LocalStrings.properties | 29 asyncChannelWrapperSecure.tooBig=The result [{0}] is too big to be expressed as an Integer
|
H A D | PerMessageDeflate.java | 270 Extension result = new WsExtension(NAME); in getExtensionResponse() local 272 List<Extension.Parameter> params = result.getParameters(); in getExtensionResponse() 289 return result; in getExtensionResponse() 460 int result = uncompressedMessagePart.getRsv(); in getRsv() local 462 result += RSV_BITMASK; in getRsv() 465 return result; in getRsv()
|
H A D | Util.java | 160 sr.nextBytes(result); in generateMask() 165 return result; in generateMask() 233 if (result.getClazz() != null && result.getDimension() > 0) { in getGenericType() 236 return result; in getGenericType() 277 return result; in getTypeParameter() 357 return result; in getDecoders() 374 results.add(result); in getMessageHandlers() 379 results.add(result); in getMessageHandlers() 384 results.add(result); in getMessageHandlers() 398 results.add(result); in getMessageHandlers() [all …]
|
H A D | WsFrameBase.java | 286 boolean result; in processData() 288 result = processDataControl(); in processData() 291 result = swallowInput(); in processData() 293 result = processDataText(); in processData() 297 result = swallowInput(); in processData() 299 result = processDataBinary(); in processData() 303 return result; in processData() 671 long result = 0; in byteArrayToLong() local 673 result = result + ((b[i] & 0xFF) << shift); in byteArrayToLong() 676 return result; in byteArrayToLong()
|
H A D | WsFrameClient.java | 151 public void completed(Integer result, Void attachment) { in completed() argument 152 if (result.intValue() == -1) { in completed()
|
H A D | WsRemoteEndpointImplBase.java | 386 handler.onResult(result); in endMessage() 782 handler.onResult(result); in onResult() 783 } else if(!result.isOK()) { in onResult() 784 handler.onResult(result); in onResult() 888 if (result.isOK()) { in onResult() 896 handler.onResult(result); in onResult() 917 if (result.isOK()) { in onResult() 920 handler.onResult(result); in onResult() 1213 if (result.isOK()) { in onResult() 1216 handler.onResult(result); in onResult() [all …]
|
H A D | WsSession.java | 311 Set<MessageHandler> result = new HashSet<>(); in getMessageHandlers() local 313 result.add(binaryMessageHandler); in getMessageHandlers() 316 result.add(textMessageHandler); in getMessageHandlers() 319 result.add(pongMessageHandler); in getMessageHandlers() 321 return result; in getMessageHandlers()
|
H A D | WsWebSocketContainer.java | 628 return result; in getOpenSessions() 706 return result; in generateExtensionHeaders() 736 result = addHeader(result, entry.getKey(), entry.getValue()); in createRequest() 740 result.put(CRLF); in createRequest() 742 result.flip(); in createRequest() 744 return result; in createRequest() 750 return result; in addHeader() 753 result = putWithExpand(result, key.getBytes(StandardCharsets.ISO_8859_1)); in addHeader() 756 result = putWithExpand(result, CRLF); in addHeader() 758 return result; in addHeader() [all …]
|
/unit/src/java/nginx/unit/websocket/pojo/ |
H A D | PojoMessageHandlerBase.java | 70 protected final void processResult(Object result) { in processResult() argument 71 if (result == null) { in processResult() 77 if (result instanceof String) { in processResult() 78 remoteEndpoint.sendText((String) result); in processResult() 79 } else if (result instanceof ByteBuffer) { in processResult() 80 remoteEndpoint.sendBinary((ByteBuffer) result); in processResult() 81 } else if (result instanceof byte[]) { in processResult() 82 remoteEndpoint.sendBinary(ByteBuffer.wrap((byte[]) result)); in processResult() 84 remoteEndpoint.sendObject(result); in processResult()
|
H A D | PojoMessageHandlerPartialBase.java | 69 Object result = null; in onMessage() local 71 result = method.invoke(pojo, parameters); in onMessage() 75 processResult(result); in onMessage()
|
H A D | PojoMessageHandlerWholeBase.java | 78 Object result = null; in onMessage() local 80 result = method.invoke(pojo, parameters); in onMessage() 84 processResult(result); in onMessage()
|
H A D | PojoMethodMapping.java | 267 Set<MessageHandler> result = new HashSet<>(); in getMessageHandlers() local 272 return result; in getMessageHandlers() 288 result[i] = new PojoPathParam(type, null); in getPathParams() 319 if (result[i] == null) { in getPathParams() 331 return result; in getPathParams() 339 Object[] result = new Object[pathParams.length]; in buildArgs() local 343 result[i] = session; in buildArgs() 345 result[i] = config; in buildArgs() 347 result[i] = throwable; in buildArgs() 349 result[i] = closeReason; in buildArgs() [all …]
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | DefaultServerEndpointConfigurator.java | 67 List<Extension> result = new ArrayList<>(); in getNegotiatedExtensions() local 70 result.add(request); in getNegotiatedExtensions() 73 return result; in getNegotiatedExtensions()
|
H A D | UpgradeUtil.java | 198 List<Transformation> result = new ArrayList<>(negotiatedExtensions.size()); in createTransformations() local 216 result.add(transformation); in createTransformations() 219 return result; in createTransformations() 267 List<String> result = new ArrayList<>(); in getTokensFromHeader() local 273 result.add(token.trim()); in getTokensFromHeader() 276 return result; in getTokensFromHeader()
|