Home
last modified time | relevance | path

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

/unit/src/java/nginx/unit/websocket/
H A DWsSession.java115 private ByteBuffer binaryBuffer; field in WsSession
978 if (last && (binaryBuffer == null || binaryBuffer.position() == 0)) { in onMessage()
983 if (binaryBuffer == null || in onMessage()
984 … (binaryBuffer.position() == 0 && binaryBuffer.capacity() != maxBinaryMessageBufferSize)) in onMessage()
986 binaryBuffer = ByteBuffer.allocateDirect(maxBinaryMessageBufferSize); in onMessage()
989 if (binaryBuffer.remaining() < buf.remaining()) { in onMessage()
995 binaryBuffer.put(buf); in onMessage()
998 binaryBuffer.flip(); in onMessage()
1000 … ((MessageHandler.Whole<ByteBuffer>) binaryMessageHandler).onMessage(binaryBuffer); in onMessage()
1002 binaryBuffer.clear(); in onMessage()