Home
last modified time | relevance | path

Searched refs:result (Results 1 – 25 of 40) sorted by path

12

/unit/
H A DCODE_OF_CONDUCT.md59 complaints will be reviewed and investigated and will result in a response that
H A DLICENSE160 result of this License or out of the use or inability to use the
/unit/auto/cc/
H A Dtest111 #NXT_CFLAGS="$NXT_CFLAGS -Wunused-result"
148 #NXT_CFLAGS="$NXT_CFLAGS -Wunused-result"
/unit/auto/
H A Dtypes9 # to use "%zu" format to printf() result of sizeof(). But "%zu" may
/unit/pkg/deb/debian.module/
H A Dcopyright.unit-jsc-common208 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 DCOPYRIGHT.unit-jsc-common208 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 DContainerProvider.java37 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 DSendHandler.java21 void onResult(SendResult result); in onResult() argument
/unit/src/java/javax/websocket/server/
H A DServerEndpointConfig.java167 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 DAsyncChannelWrapperSecure.java425 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 DFutureToSendHandler.java41 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 DLocalStrings.properties29 asyncChannelWrapperSecure.tooBig=The result [{0}] is too big to be expressed as an Integer
H A DPerMessageDeflate.java270 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 DUtil.java160 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 DWsFrameBase.java286 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 DWsFrameClient.java151 public void completed(Integer result, Void attachment) { in completed() argument
152 if (result.intValue() == -1) { in completed()
H A DWsRemoteEndpointImplBase.java386 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 DWsSession.java311 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 DWsWebSocketContainer.java628 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 DPojoMessageHandlerBase.java70 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 DPojoMessageHandlerPartialBase.java69 Object result = null; in onMessage() local
71 result = method.invoke(pojo, parameters); in onMessage()
75 processResult(result); in onMessage()
H A DPojoMessageHandlerWholeBase.java78 Object result = null; in onMessage() local
80 result = method.invoke(pojo, parameters); in onMessage()
84 processResult(result); in onMessage()
H A DPojoMethodMapping.java267 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 DDefaultServerEndpointConfigurator.java67 List<Extension> result = new ArrayList<>(); in getNegotiatedExtensions() local
70 result.add(request); in getNegotiatedExtensions()
73 return result; in getNegotiatedExtensions()
H A DUpgradeUtil.java198 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()

12