Home
last modified time | relevance | path

Searched refs:remaining (Results 1 – 8 of 8) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DWsFrameBase.java146 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 …]
H A DWsRemoteEndpointImplBase.java173 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() local
974 written += remaining; in write()
976 remaining = buffer.remaining(); in write()
1045 if (buffer.remaining() == 0) { in write()
1048 int remaining = buffer.remaining(); in write() local
1053 written += remaining; in write()
[all …]
H A DWsFrameClient.java82 int toCopy = Math.min(response.remaining(), inputBuffer.remaining()); in processSocketRead()
H A DPerMessageDeflate.java200 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()
H A DWsSession.java681 int remaining = 123 - ELLIPSIS_BYTES_LEN; in appendCloseReasonWithTruncation() local
684 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()
H A DLocalStrings.properties90 …ed messages still enabled after session has been closed. Unable to flush remaining batched message.
H A DWsWebSocketContainer.java763 if (bytes.length > input.remaining()) { in putWithExpand()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeBinary.java115 byte[] array = new byte[message.remaining()]; in convert()