Searched refs:channel (Results 1 – 5 of 5) sorted by relevance
| /unit/src/java/nginx/unit/websocket/ |
| H A D | WsRemoteEndpointImplClient.java | 30 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 D | WsFrameClient.java | 36 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 D | WsWebSocketContainer.java | 304 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 D | LocalStrings.properties | 18 asyncChannelWrapperSecure.closeFail=Failed to close channel cleanly
|
| /unit/ |
| H A D | README.md | 163 our [Slack channel](https://nginxcommunity.slack.com/).
|