/unit/src/java/nginx/unit/websocket/ |
H A D | AsyncChannelGroupUtil.java | 42 private static AsynchronousChannelGroup group = null; 68 group = null; in unregister()
|
H A D | AsyncChannelWrapperNonSecure.java | 102 return null; in get() 109 return null; in get()
|
H A D | AsyncChannelWrapperSecure.java | 212 while (runnable != null) { in run() 319 while (runnable != null) { in run() 396 Runnable r = null; in run() 418 hFuture.complete(null); in run() 447 private volatile T result = null; 448 private volatile Throwable throwable = null; 452 this(null, null); in WrapperFuture() 463 if (handler != null) { in complete() 471 if (handler != null) { in fail() 496 if (throwable != null) { in get() [all …]
|
H A D | Authenticator.java | 63 challenge.put(key, qtedValue != null ? qtedValue : value); in parseWWWAuthenticateHeader()
|
H A D | AuthenticatorFactory.java | 35 Authenticator auth = null; in getAuthenticator() 65 return null; in loadAuthenticators()
|
H A D | BackgroundProcessManager.java | 52 private WsBackgroundThread wsBackgroundThread = null; 76 if (wsBackgroundThread != null && processes.size() == 0) { in unregister() 78 wsBackgroundThread = null; in unregister() 114 if (wsBackgroundThread != null) { in shutdown() 116 wsBackgroundThread = null; in shutdown()
|
H A D | BasicAuthenticator.java | 39 if (userName == null || password == null) { in getAuthorization() 49 if (wwwAuthenticate.get(charsetparam) != null in getAuthorization()
|
H A D | DigestAuthenticator.java | 44 if (userName == null || password == null) { in getAuthorization() 54 String algorithm = wwwAuthenticate.get("algorithm") == null ? "MD5" in getAuthorization() 61 if (cnonceGenerator == null) { in getAuthorization()
|
H A D | FutureToSendHandler.java | 41 private volatile AtomicReference<SendResult> result = new AtomicReference<>(null); 52 this.result.compareAndSet(null, result); in onResult() 85 if (result.get().getException() != null) { in get() 88 return null; in get() 107 if (result.get().getException() != null) { in get() 110 return null; in get()
|
H A D | LocalStrings.properties | 93 wsRemoteEndpoint.nullData=Invalid null data argument 94 wsRemoteEndpoint.nullHandler=Invalid null handler argument
|
H A D | PerMessageDeflate.java | 120 if (param.getValue() == null) { in negotiate() 164 return null; in negotiate() 248 if (next == null) { in validateRsv() 259 if (next == null) { in validateRsv() 275 params.add(new WsExtensionParameter(SERVER_NO_CONTEXT_TAKEOVER, null)); in getExtensionResponse() 282 params.add(new WsExtensionParameter(CLIENT_NO_CONTEXT_TAKEOVER, null)); in getExtensionResponse() 295 if (next == null) { in setNext() 308 if (next == null) { in validateRsvBits() 442 if (next == null) { in sendMessagePart()
|
H A D | TransformationFactory.java | 45 return null; in create()
|
H A D | Util.java | 149 if (sr == null) { in generateMask() 210 if (superClazz == null) { in getGenericType() 212 return null; in getGenericType() 260 return null; in getGenericType() 282 return new TypeResult(null, i, 0); in getTypeParameter() 285 return null; in getTypeParameter() 338 if (decoderClazzes != null) { in getDecoders() 458 return null; in matchDecoders() 506 value = null; in parseExtensionHeader() 523 if (value != null && in parseExtensionHeader() [all …]
|
H A D | WsFrameBase.java | 72 private MessageHandler binaryMsgHandler = null; 73 private MessageHandler textMsgHandler = null; 104 if (transformation == null) { in WsFrameBase() 189 textMsgHandler = null; in processInitialHeader() 197 binaryMsgHandler = null; in processInitialHeader() 290 if (textMsgHandler == null) { in processData() 296 if (binaryMsgHandler == null) { in processData() 318 String reason = null; in processDataControl() 353 if (mhPong != null) { in processDataControl() 906 return null; in getExtensionResponse()
|
H A D | WsFrameClient.java | 101 channel.read(response, null, handler); in processSocketRead()
|
H A D | WsRemoteEndpointImplBase.java | 130 if (data == null) { in sendBytes() 147 if (data == null) { in sendBytesByCompletion() 150 if (handler == null) { in sendBytesByCompletion() 191 if (text == null) { in sendString() 207 if (text == null) { in sendStringByCompletion() 210 if (handler == null) { in sendStringByCompletion() 385 if (handler != null) { in endMessage() 446 mask = null; in writeMessagePart() 533 if (obj == null) { in sendObject() 584 if (obj == null) { in sendObjectByCompletion() [all …]
|
H A D | WsSession.java | 186 if (subProtocol == null) { in WsSession() 200 if (instanceManager == null) { in WsSession() 203 if (instanceManager != null) { in WsSession() 328 if (listener == null) { in removeMessageHandler() 332 MessageHandler wrapped = null; in removeMessageHandler() 338 if (wrapped == null) { in removeMessageHandler() 344 textMessageHandler = null; in removeMessageHandler() 354 pongMessageHandler = null; in removeMessageHandler() 578 Throwable throwable = null; in fireEndpointOnClose() 580 if (instanceManager == null) { in fireEndpointOnClose() [all …]
|
H A D | WsWebSocketContainer.java | 120 if (annotation == null) { in connectToServer() 221 if (host == null) { in connectToServerRecursive() 227 SocketAddress sa = null; in connectToServerRecursive() 259 if (sa == null) { in connectToServerRecursive() 497 this, null, null, null, null, null, extensionsAgreed, in connectToServerRecursive() 728 if (query != null) { in createRequest() 796 String line = null; in processResponse() 865 if (values == null) { in parseHeaders() 921 sslContext.init(null, tmf.getTrustManagers(), null); in createSSLEngine() 923 sslContext.init(null, null, null); in createSSLEngine() [all …]
|
/unit/src/java/nginx/unit/websocket/pojo/ |
H A D | PojoEndpointBase.java | 63 if (methodMapping.getOnOpen() != null) { in doOnOpen() 101 if (methodMapping.getOnClose() != null) { in onClose() 125 if (methodMapping.getOnError() == null) { in onError()
|
H A D | PojoEndpointClient.java | 39 new PojoMethodMapping(pojo.getClass(), decoders, null)); in PojoEndpointClient()
|
H A D | PojoMessageHandlerBase.java | 71 if (result == null) { in processResult() 102 return null; in getWrappedHandler()
|
H A D | PojoMessageHandlerPartialBase.java | 69 Object result = null; in onMessage()
|
H A D | PojoMessageHandlerWholeBase.java | 63 if (payload == null) { in onMessage() 78 Object result = null; in onMessage()
|
H A D | PojoMessageHandlerWholeBinary.java | 66 if (decoderClazzes != null) { in PojoMessageHandlerWholeBinary() 109 return null; in decode()
|
H A D | PojoMessageHandlerWholePong.java | 40 return null; in decode()
|