Searched refs:remaining (Results 1 – 8 of 8) sorted by last modified time
173 if (applicationData.remaining() > 125) { in sendPing()183 if (applicationData.remaining() > 125) { in sendPong()945 if (buffer.remaining() == 0) { in write()966 if (buffer.remaining() == 0) { in write()969 int remaining = buffer.remaining(); in write() local974 written += remaining; in write()976 remaining = buffer.remaining(); in write()1045 if (buffer.remaining() == 0) { in write()1048 int remaining = buffer.remaining(); in write() local1053 written += remaining; in write()[all …]
146 if (inputBuffer.remaining() < 2) { in processInitialHeader()252 if (inputBuffer.remaining() < headerLength) { in processRemainingHeader()320 if (controlBufferBinary.remaining() == 1) { in processDataControl()327 if (controlBufferBinary.remaining() > 1) { in processDataControl()329 if (controlBufferBinary.remaining() > 0) { in processDataControl()569 if (maxMessageSize > -1 && msg.remaining() > maxMessageSize) { in sendMessageBinary()572 Long.valueOf(msg.remaining()), in sendMessageBinary()599 if (inputBuffer.remaining() == 0) { in newFrame()944 toWrite = Math.min(toWrite, dest.remaining()); in getMoreData()954 } else if (inputBuffer.remaining() == 0) { in getMoreData()[all …]
82 int toCopy = Math.min(response.remaining(), inputBuffer.remaining()); in processSocketRead()
681 int remaining = 123 - ELLIPSIS_BYTES_LEN; in appendCloseReasonWithTruncation() local684 while (remaining >= bytesNext.length) { in appendCloseReasonWithTruncation()686 remaining -= bytesNext.length; in appendCloseReasonWithTruncation()863 if (buf.remaining() >= 2) { in processFrame()943 if (!last && buf.remaining() > 0) { in updateRawFragments()989 if (binaryBuffer.remaining() < buf.remaining()) { in onMessage()
763 if (bytes.length > input.remaining()) { in putWithExpand()
90 …ed messages still enabled after session has been closed. Unable to flush remaining batched message.
200 while (dest.remaining() > 0) { in getMoreData()204 dest.array(), dest.arrayOffset() + dest.position(), dest.remaining()); in getMoreData()340 uncompressedPayload.remaining()); in sendMessagePart()350 compressedPayload.remaining(), flush); in sendMessagePart()
115 byte[] array = new byte[message.remaining()]; in convert()