Home
last modified time | relevance | path

Searched refs:channel (Results 1 – 5 of 5) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DWsRemoteEndpointImplClient.java30 private final AsyncChannelWrapper channel; field in WsRemoteEndpointImplClient
32 public WsRemoteEndpointImplClient(AsyncChannelWrapper channel) { in WsRemoteEndpointImplClient() argument
33 this.channel = channel; in WsRemoteEndpointImplClient()
62 channel.write(byteBuffer).get(timeout, TimeUnit.MILLISECONDS); in doWrite()
73 channel.close(); in doClose()
H A DWsFrameClient.java36 private final AsyncChannelWrapper channel; field in WsFrameClient
41 public WsFrameClient(ByteBuffer response, AsyncChannelWrapper channel, WsSession wsSession, in WsFrameClient() argument
45 this.channel = channel; in WsFrameClient()
101 channel.read(response, null, handler); in processSocketRead()
H A DWsWebSocketContainer.java304 AsyncChannelWrapper channel = null; in connectToServerRecursive() local
311 writeRequest(channel, proxyConnect, timeout); in connectToServerRecursive()
320 if (channel != null) { in connectToServerRecursive()
321 channel.close(); in connectToServerRecursive()
334 } else if (channel == null) { in connectToServerRecursive()
343 Future<Void> fHandshake = channel.handshake(); in connectToServerRecursive()
346 writeRequest(channel, request, timeout); in connectToServerRecursive()
489 channel.close(); in connectToServerRecursive()
530 Future<Integer> fWrite = channel.write(request); in writeRequest()
535 fWrite = channel.write(request); in writeRequest()
[all …]
H A DLocalStrings.properties18 asyncChannelWrapperSecure.closeFail=Failed to close channel cleanly
/unit/
H A DREADME.md163 our [Slack channel](https://nginxcommunity.slack.com/).