Home
last modified time | relevance | path

Searched refs:cr (Results 1 – 6 of 6) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DWsFrameClient.java121 CloseReason cr; in close() local
123 cr = ((WsIOException) t).getCloseReason(); in close()
125 cr = new CloseReason(CloseCodes.CLOSED_ABNORMALLY, t.getMessage()); in close()
129 wsSession.close(cr); in close()
H A DWsFrameBase.java332 if (cr.isError()) { in processDataControl()
414 if (cr.isError()) { in processDataText()
418 } else if (cr.isOverflow()) { in processDataText()
429 } else if (cr.isUnderflow()) { in processDataText()
457 if (cr.isError()) { in processDataText()
461 } else if (cr.isOverflow()) { in processDataText()
472 } else if (cr.isUnderflow() && !last) { in processDataText()
515 CloseReason cr = new CloseReason(CloseCodes.TOO_BIG, in processDataBinary() local
519 throw new WsIOException(cr); in processDataBinary()
559 CloseReason cr = new CloseReason(CloseCodes.CLOSED_ABNORMALLY, in handleThrowableOnSend() local
[all …]
H A DWsSession.java886 CoderResult cr = utf8DecoderMessage.decode(buf, messageBufferText, last); in processFrame() local
887 if (cr.isError()) { in processFrame()
891 } else if (cr.isOverflow()) { in processFrame()
897 cr = utf8DecoderMessage.decode(buf, messageBufferText, last); in processFrame()
898 } while (cr.isOverflow()); in processFrame()
904 } else if (cr.isUnderflow() && !last) { in processFrame()
1012 CloseReason cr = new CloseReason(CloseCodes.CLOSED_ABNORMALLY, in handleThrowableOnSend() local
1014 throw new WsIOException(cr); in handleThrowableOnSend()
H A DWsRemoteEndpointImplBase.java248 CoderResult cr = encoder.encode(part, encoderBuffer, true); in sendMessageBlock() local
249 if (cr.isError()) { in sendMessageBlock()
250 throw new IllegalArgumentException(cr.toString()); in sendMessageBlock()
252 isDone = !cr.isOverflow(); in sendMessageBlock()
768 CoderResult cr = encoder.encode(message, buffer, true); in write() local
769 if (cr.isError()) { in write()
770 throw new IllegalArgumentException(cr.toString()); in write()
772 isDone = !cr.isOverflow(); in write()
H A DWsWebSocketContainer.java1028 CloseReason cr = new CloseReason( in destroy() local
1033 session.close(cr); in destroy()
/unit/src/java/nginx/unit/websocket/server/
H A DWsHttpUpgradeHandler.java161 private void close(CloseReason cr) { in close() argument
170 wsSession.onClose(cr); in close()