Lines Matching refs:buf

59 import org.apache.tomcat.util.buf.Utf8Decoder;
815 public void processFrame(ByteBuffer buf, byte opCode, boolean last) in processFrame() argument
826 rawFragments.put(buf); in processFrame()
828 buf = rawFragments; in processFrame()
847 final ByteBuffer b = buf; in processFrame()
863 if (buf.remaining() >= 2) { in processFrame()
864 short closeCode = buf.order(ByteOrder.BIG_ENDIAN).getShort(); in processFrame()
868 buf.asCharBuffer().toString()); in processFrame()
878 onMessage(buf, last); in processFrame()
886 CoderResult cr = utf8DecoderMessage.decode(buf, messageBufferText, last); in processFrame()
897 cr = utf8DecoderMessage.decode(buf, messageBufferText, last); in processFrame()
905 updateRawFragments(buf, last); in processFrame()
918 updateRawFragments(buf, last); in processFrame()
930 private void onMessage(CharBuffer buf, boolean last) throws IOException { in onMessage() argument
931 buf.flip(); in onMessage()
933 onMessage(buf.toString(), last); in onMessage()
937 buf.clear(); in onMessage()
942 private void updateRawFragments(ByteBuffer buf, boolean last) { in updateRawFragments() argument
943 if (!last && buf.remaining() > 0) { in updateRawFragments()
944 if (buf == rawFragments) { in updateRawFragments()
945 buf.compact(); in updateRawFragments()
950 rawFragments.put(buf); in updateRawFragments()
972 public void onMessage(ByteBuffer buf, boolean last) in onMessage() argument
976 ((MessageHandler.Partial<ByteBuffer>) binaryMessageHandler).onMessage(buf, last); in onMessage()
979 ((MessageHandler.Whole<ByteBuffer>) binaryMessageHandler).onMessage(buf); in onMessage()
989 if (binaryBuffer.remaining() < buf.remaining()) { in onMessage()
995 binaryBuffer.put(buf); in onMessage()