| /unit/src/java/nginx/unit/websocket/ |
| H A D | MessagePart.java | 26 private final byte opCode; field in MessagePart
32 public MessagePart( boolean fin, int rsv, byte opCode, ByteBuffer payload, in MessagePart() argument
37 this.opCode = opCode; in MessagePart()
56 return opCode; in getOpCode()
|
| H A D | WsFrameBase.java | 78 private byte opCode = 0; field in WsFrameBase
152 opCode = (byte) (b & 0x0F); in processInitialHeader()
159 if (Util.isControl(opCode)) { in processInitialHeader()
165 if (opCode != Constants.OPCODE_PING && in processInitialHeader()
166 opCode != Constants.OPCODE_PONG && in processInitialHeader()
174 if (!Util.isContinuation(opCode)) { in processInitialHeader()
265 if (Util.isControl(opCode)) { in processRemainingHeader()
287 if (Util.isControl(opCode)) { in processData()
316 if (opCode == Constants.OPCODE_CLOSE) { in processDataControl()
347 } else if (opCode == Constants.OPCODE_PING) { in processDataControl()
[all …]
|
| H A D | PerMessageDeflate.java | 183 if (Util.isControl(opCode)) { in getMoreData()
184 return next.getMoreData(opCode, fin, rsv, dest); in getMoreData()
187 if (!Util.isContinuation(opCode)) { in getMoreData()
194 return next.getMoreData(opCode, fin, rsv, dest); in getMoreData()
243 public boolean validateRsv(int rsv, byte opCode) { in validateRsv() argument
244 if (Util.isControl(opCode)) { in validateRsv()
251 return next.validateRsv(rsv, opCode); in validateRsv()
262 return next.validateRsv(rsvNext, opCode); in validateRsv()
321 byte opCode = uncompressedPart.getOpCode(); in sendMessagePart()
324 if (Util.isControl(opCode)) { in sendMessagePart()
[all …]
|
| H A D | Transformation.java | 76 …TransformationResult getMoreData(byte opCode, boolean fin, int rsv, ByteBuffer dest) throws IOExce… in getMoreData() argument
91 boolean validateRsv(int rsv, byte opCode); in validateRsv() argument
|
| H A D | WsRemoteEndpointImplBase.java | 262 sendMessageBlock(opCode, payload, last, getTimeoutExpiry()); in sendMessageBlock()
284 if (opCode == currentOpCode) { in sendMessageBlock()
285 opCode = Constants.OPCODE_CONTINUATION; in sendMessageBlock()
288 request.sendWsFrame(payload, opCode, last, timeoutExpiry); in sendMessageBlock()
290 if (!last && opCode != Constants.OPCODE_CONTINUATION) { in sendMessageBlock()
291 currentOpCode = opCode; in sendMessageBlock()
294 if (last && opCode == Constants.OPCODE_CONTINUATION) { in sendMessageBlock()
300 void startMessage(byte opCode, ByteBuffer payload, boolean last, in startMessage() argument
306 messageParts.add(new MessagePart(last, 0, opCode, payload, in startMessage()
691 int rsv, byte opCode, boolean masked, ByteBuffer payload, in writeHeader() argument
[all …]
|
| H A D | WsSession.java | 815 public void processFrame(ByteBuffer buf, byte opCode, boolean last) in processFrame() argument
822 if (opCode == Constants.OPCODE_CONTINUATION) { in processFrame()
823 opCode = startOpCode; in processFrame()
831 if (!last && (opCode == Constants.OPCODE_BINARY || in processFrame()
832 opCode == Constants.OPCODE_TEXT)) { in processFrame()
833 startOpCode = opCode; in processFrame()
845 if (opCode == Constants.OPCODE_PONG) { in processFrame()
860 if (opCode == Constants.OPCODE_CLOSE) { in processFrame()
877 if (opCode == Constants.OPCODE_BINARY) { in processFrame()
881 if (opCode == Constants.OPCODE_TEXT) { in processFrame()
|
| H A D | Util.java | 71 static boolean isControl(byte opCode) { in isControl() argument
72 return (opCode & 0x08) != 0; in isControl()
76 static boolean isText(byte opCode) { in isText() argument
77 return opCode == Constants.OPCODE_TEXT; in isText()
81 static boolean isContinuation(byte opCode) { in isContinuation() argument
82 return opCode == Constants.OPCODE_CONTINUATION; in isContinuation()
|
| H A D | LocalStrings.properties | 64 wsFrame.invalidOpCode= A WebSocket frame was sent with an unrecognised opCode of [{0}]
76 wsFrame.wrongRsv=The client frame set the reserved bits to [{0}] for a message with opCode [{1}] wh…
|
| /unit/src/java/nginx/unit/ |
| H A D | Request.java | 1284 private void processWsFrame(ByteBuffer buf, byte opCode, boolean last) in processWsFrame() argument
1287 trace("processWsFrame: " + opCode + ", [" + buf.position() + ", " + buf.limit() + "]"); in processWsFrame()
1289 wsSession.processFrame(buf, opCode, last); in processWsFrame()
1303 public void sendWsFrame(ByteBuffer payload, byte opCode, boolean last, in sendWsFrame() argument
1306 trace("sendWsFrame: " + opCode + ", [" + payload.position() + in sendWsFrame()
1311 payload.limit() - payload.position(), opCode, last); in sendWsFrame()
1314 payload.limit() - payload.position(), opCode, last); in sendWsFrame()
1319 ByteBuffer buf, int pos, int len, byte opCode, boolean last); in sendWsFrame() argument
1322 byte[] arr, int pos, int len, byte opCode, boolean last); in sendWsFrame() argument
|
| /unit/src/java/ |
| H A D | nxt_jni_Request.c | 72 jlong req_info_ptr, jobject buf, jint pos, jint len, jbyte opCode, jboolean last);
74 jlong req_info_ptr, jarray arr, jint pos, jint len, jbyte opCode, jboolean last);
754 jlong req_info_ptr, jobject buf, jint pos, jint len, jbyte opCode, jboolean last) in nxt_java_Request_sendWsFrameBuf() argument
762 nxt_unit_websocket_send(req, opCode, last, b + pos, len); in nxt_java_Request_sendWsFrameBuf()
772 jlong req_info_ptr, jarray arr, jint pos, jint len, jbyte opCode, jboolean last) in nxt_java_Request_sendWsFrameArr() argument
784 nxt_unit_websocket_send(req, opCode, last, b + pos, len); in nxt_java_Request_sendWsFrameArr()
|