Home
last modified time | relevance | path

Searched refs:socketChannel (Results 1 – 3 of 3) sorted by path

/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelWrapperNonSecure.java37 private final AsynchronousSocketChannel socketChannel; field in AsyncChannelWrapperNonSecure
40 AsynchronousSocketChannel socketChannel) { in AsyncChannelWrapperNonSecure() argument
41 this.socketChannel = socketChannel; in AsyncChannelWrapperNonSecure()
46 return socketChannel.read(dst); in read()
52 socketChannel.read(dst, attachment, handler); in read()
57 return socketChannel.write(src); in write()
64 socketChannel.write( in write()
71 socketChannel.close(); in close()
H A DAsyncChannelWrapperSecure.java57 private final AsynchronousSocketChannel socketChannel; field in AsyncChannelWrapperSecure
67 public AsyncChannelWrapperSecure(AsynchronousSocketChannel socketChannel, in AsyncChannelWrapperSecure() argument
69 this.socketChannel = socketChannel; in AsyncChannelWrapperSecure()
150 socketChannel.close(); in close()
224 socketChannel.write(socketWriteBuffer); in run()
268 Future<Integer> f = socketChannel.read(socketReadBuffer); in run()
377 socketChannel.write(socketWriteBuffer); in run()
386 socketChannel.read(socketReadBuffer); in run()
H A DWsWebSocketContainer.java277 AsynchronousSocketChannel socketChannel; in connectToServerRecursive() local
279 socketChannel = AsynchronousSocketChannel.open(getAsynchronousChannelGroup()); in connectToServerRecursive()
303 Future<Void> fConnect = socketChannel.connect(sa); in connectToServerRecursive()
310 channel = new AsyncChannelWrapperNonSecure(socketChannel); in connectToServerRecursive()
333 channel = new AsyncChannelWrapperSecure(socketChannel, sslEngine); in connectToServerRecursive()
337 channel = new AsyncChannelWrapperNonSecure(socketChannel); in connectToServerRecursive()