Home
last modified time | relevance | path

Searched refs:position (Results 1 – 10 of 10) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DPerMessageDeflate.java204 dest.array(), dest.arrayOffset() + dest.position(), dest.remaining()); in getMoreData()
208 dest.position(dest.position() + written); in getMoreData()
216 readBuffer.array(), readBuffer.arrayOffset(), readBuffer.position()); in getMoreData()
220 readBuffer.position() == 0) { in getMoreData()
339 uncompressedPayload.arrayOffset() + uncompressedPayload.position(), in sendMessagePart()
349 compressedPayload.arrayOffset() + compressedPayload.position(), in sendMessagePart()
351 compressedPayload.position(compressedPayload.position() + written); in sendMessagePart()
H A DWsFrameBase.java94 inputBuffer.position(0).limit(0); in WsFrameBase()
258 inputBuffer.arrayOffset() + inputBuffer.position(), 2); in processRemainingHeader()
259 inputBuffer.position(inputBuffer.position() + 2); in processRemainingHeader()
262 inputBuffer.arrayOffset() + inputBuffer.position(), 8); in processRemainingHeader()
263 inputBuffer.position(inputBuffer.position() + 8); in processRemainingHeader()
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()
651 inputBuffer.position(inputBuffer.position() + (int) toSkip); in swallowInput()
947 inputBuffer.limit(inputBuffer.position() + (int) toWrite); in getMoreData()
H A DWsFrameClient.java80 inputBuffer.position(inputBuffer.limit()).limit(inputBuffer.capacity()); in processSocketRead()
88 response.limit(response.position() + toCopy); in processSocketRead()
92 inputBuffer.limit(inputBuffer.position()).reset(); in processSocketRead()
H A DWsSession.java825 if (rawFragments != null && rawFragments.position() > 0) { in processFrame()
882 …if (messageBufferText.position() == 0 && maxTextMessageBufferSize != messageBufferText.capacity())… in processFrame()
947 …if (rawFragments == null || (rawFragments.position() == 0 && maxTextMessageBufferSize != rawFragme… in updateRawFragments()
978 if (last && (binaryBuffer == null || binaryBuffer.position() == 0)) { in onMessage()
984 … (binaryBuffer.position() == 0 && binaryBuffer.capacity() != maxBinaryMessageBufferSize)) in onMessage()
H A DAsyncChannelWrapperSecure.java361 socketReadBuffer.position(socketReadBuffer.limit()); in run()
383 if (socketReadBuffer.position() == 0 || in run()
H A DWsRemoteEndpointImplBase.java848 payload.limit(payload.position() + toWrite); in write()
990 if (!Constants.STREAMS_DROP_EMPTY_MESSAGES || buffer.position() > 0) { in flush()
1067 if (!Constants.STREAMS_DROP_EMPTY_MESSAGES || buffer.position() > 0) { in flush()
/unit/src/java/nginx/unit/
H A DRequest.java1287 trace("processWsFrame: " + opCode + ", [" + buf.position() + ", " + buf.limit() + "]"); in processWsFrame()
1306 trace("sendWsFrame: " + opCode + ", [" + payload.position() + in sendWsFrame()
1310 sendWsFrame(req_info_ptr, payload, payload.position(), in sendWsFrame()
1311 payload.limit() - payload.position(), opCode, last); in sendWsFrame()
1313 sendWsFrame(req_info_ptr, payload.array(), payload.position(), in sendWsFrame()
1314 payload.limit() - payload.position(), opCode, last); in sendWsFrame()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeBinary.java98 byte[] array = new byte[message.limit() - message.position()]; in decode()
/unit/src/
H A Dnxt_var.c24 uint32_t position; member
386 subs[n].position = p - str->start; in nxt_var_compile()
558 next = subs[i].position; in nxt_var_interpreter()
/unit/docs/
H A Dchanges.xsls143 prefix = { X:if "position() = 1" { !{$prefix} } else { !{$indent} } })