Lines Matching refs:inputBuffer

50     protected final ByteBuffer inputBuffer;  field in WsFrameBase
93 inputBuffer = ByteBuffer.allocate(Constants.DEFAULT_BUFFER_SIZE); in WsFrameBase()
94 inputBuffer.position(0).limit(0); in WsFrameBase()
146 if (inputBuffer.remaining() < 2) { in processInitialHeader()
149 int b = inputBuffer.get(); in processInitialHeader()
213 b = inputBuffer.get(); in processInitialHeader()
252 if (inputBuffer.remaining() < headerLength) { in processRemainingHeader()
257 payloadLength = byteArrayToLong(inputBuffer.array(), in processRemainingHeader()
258 inputBuffer.arrayOffset() + inputBuffer.position(), 2); in processRemainingHeader()
259 inputBuffer.position(inputBuffer.position() + 2); in processRemainingHeader()
261 payloadLength = byteArrayToLong(inputBuffer.array(), in processRemainingHeader()
262 inputBuffer.arrayOffset() + inputBuffer.position(), 8); in processRemainingHeader()
263 inputBuffer.position(inputBuffer.position() + 8); in processRemainingHeader()
278 inputBuffer.get(mask, 0, 4); in processRemainingHeader()
599 if (inputBuffer.remaining() == 0) { in newFrame()
600 inputBuffer.position(0).limit(0); in newFrame()
617 if (inputBuffer.capacity() - inputBuffer.position() < 131) { in checkRoomHeaders()
625 if (inputBuffer.capacity() - inputBuffer.position() - payloadLength + payloadWritten < 0) { in checkRoomPayload()
632 inputBuffer.compact(); in makeRoom()
633 inputBuffer.flip(); in makeRoom()
650 long toSkip = Math.min(payloadLength - payloadWritten, inputBuffer.remaining()); in swallowInput()
651 inputBuffer.position(inputBuffer.position() + (int) toSkip); in swallowInput()
943 long toWrite = Math.min(payloadLength - payloadWritten, inputBuffer.remaining()); in getMoreData()
946 int orgLimit = inputBuffer.limit(); in getMoreData()
947 inputBuffer.limit(inputBuffer.position() + (int) toWrite); in getMoreData()
948 dest.put(inputBuffer); in getMoreData()
949 inputBuffer.limit(orgLimit); in getMoreData()
954 } else if (inputBuffer.remaining() == 0) { in getMoreData()
984 while (payloadWritten < payloadLength && inputBuffer.remaining() > 0 && in getMoreData()
986 byte b = (byte) ((inputBuffer.get() ^ mask[maskIndex]) & 0xFF); in getMoreData()
996 } else if (inputBuffer.remaining() == 0) { in getMoreData()