/unit/src/java/nginx/unit/websocket/ |
H A D | MessagePart.java | 24 private final boolean fin; field in MessagePart 32 public MessagePart( boolean fin, int rsv, byte opCode, ByteBuffer payload, in MessagePart() argument 35 this.fin = fin; in MessagePart() 46 return fin; in isFin()
|
H A D | PerMessageDeflate.java | 179 public TransformationResult getMoreData(byte opCode, boolean fin, int rsv, ByteBuffer dest) in getMoreData() argument 184 return next.getMoreData(opCode, fin, rsv, dest); in getMoreData() 194 return next.getMoreData(opCode, fin, rsv, dest); in getMoreData() 214 next.getMoreData(opCode, fin, (rsv ^ RSV_BITMASK), readBuffer); in getMoreData() 221 if (fin) { in getMoreData() 230 if (fin && (isServer && !clientContextTakeover || in getMoreData() 370 boolean fin = uncompressedPart.isFin(); in sendMessagePart() 375 if (fin && !full && needsInput) { in sendMessagePart() 389 } else if (!fin && full && needsInput) { in sendMessagePart() 396 } else if (fin && full && needsInput) { in sendMessagePart()
|
H A D | WsFrameBase.java | 76 private boolean fin = false; field in WsFrameBase 150 fin = (b & 0x80) != 0; in processInitialHeader() 160 if (!fin) { in processInitialHeader() 211 continuationExpected = !fin; in processInitialHeader() 223 getLog().debug(sm.getString("wsFrame.partialHeaderComplete", Boolean.toString(fin), in processInitialHeader() 271 if (!fin) { in processRemainingHeader() 308 TransformationResult tr = transformation.getMoreData(opCode, fin, rsv, controlBufferBinary); in processDataControl() 447 tr = transformation.getMoreData(opCode, fin, rsv, messageBufferBinary); in processDataText() 528 tr = transformation.getMoreData(opCode, fin, rsv, messageBufferBinary); in processDataBinary() 938 public TransformationResult getMoreData(byte opCode, boolean fin, int rsv, in getMoreData() argument [all …]
|
H A D | Transformation.java | 76 …TransformationResult getMoreData(byte opCode, boolean fin, int rsv, ByteBuffer dest) throws IOExce… in getMoreData() argument
|
H A D | LocalStrings.properties | 62 wsFrame.controlNoFin=A control frame was sent that did not have the fin bit set. Control frames are… 72 wsFrame.partialHeaderComplete=WebSocket frame received. fin [{0}], rsv [{1}], OpCode [{2}], payload…
|
H A D | WsRemoteEndpointImplBase.java | 690 private static void writeHeader(ByteBuffer headerBuffer, boolean fin, in writeHeader() argument 696 if (fin) { in writeHeader()
|
/unit/test/ |
H A D | test_java_websockets.py | 44 def check_frame(frame, fin, opcode, payload, decode=True): argument 50 assert frame['fin'] == fin, 'fin' 111 ws.frame_write(sock, ws.OP_TEXT, message, fin=False) 112 ws.frame_write(sock, ws.OP_CONT, ' ', fin=False) 131 ws.frame_write(sock, ws.OP_PING, message, fin=False) 818 fin=True, 848 fin=False, 971 ws.frame_write(sock, ws.OP_TEXT, '', fin=False) 972 ws.frame_write(sock, ws.OP_CONT, '', fin=False) 982 ws.frame_write(sock, ws.OP_TEXT, '', fin=False) [all …]
|
H A D | test_asgi_websockets.py | 47 def check_frame(frame, fin, opcode, payload, decode=True): argument 53 assert frame['fin'] == fin, 'fin' 152 ws.frame_write(sock, ws.OP_TEXT, message, fin=False) 153 ws.frame_write(sock, ws.OP_CONT, ' ', fin=False) 183 ws.frame_write(sock, ws.OP_PING, message, fin=False) 890 fin=True, 920 fin=False, 1043 ws.frame_write(sock, ws.OP_TEXT, '', fin=False) 1044 ws.frame_write(sock, ws.OP_CONT, '', fin=False) 1054 ws.frame_write(sock, ws.OP_TEXT, '', fin=False) [all …]
|
H A D | test_node_websockets.py | 44 def check_frame(frame, fin, opcode, payload, decode=True): argument 50 assert frame['fin'] == fin, 'fin' 111 ws.frame_write(sock, ws.OP_TEXT, message, fin=False) 112 ws.frame_write(sock, ws.OP_CONT, ' ', fin=False) 131 ws.frame_write(sock, ws.OP_PING, message, fin=False) 838 fin=True, 868 fin=False, 991 ws.frame_write(sock, ws.OP_TEXT, '', fin=False) 992 ws.frame_write(sock, ws.OP_CONT, '', fin=False) 1002 ws.frame_write(sock, ws.OP_TEXT, '', fin=False) [all …]
|
/unit/src/ |
H A D | nxt_websocket_header.h | 14 uint8_t fin:1; member 29 uint8_t fin:1; member
|
H A D | nxt_h1proto_websocket.c | 193 wsh->fin = 1; in nxt_h1p_conn_ws_keepalive() 271 if (nxt_slow_path(wsh->fin == 0)) { in nxt_h1p_conn_ws_frame_header_read() 316 h1p->websocket_cont_expected = !wsh->fin; in nxt_h1p_conn_ws_frame_header_read() 615 wsh->fin = 1; in hxt_h1p_send_ws_error() 680 wsh->fin = 1; in nxt_h1p_conn_ws_pong()
|
H A D | nxt_java.c | 575 ws->header->opcode, ws->header->fin); in nxt_java_websocket_handler()
|
H A D | nxt_unit.c | 3369 wh->fin = last; in nxt_unit_websocket_sendv()
|
/unit/test/unit/applications/ |
H A D | websockets.py | 147 fin=True, argument 160 (0b10000000 if fin else 0) 224 fin = end == message_len 225 self.frame_write(sock, op_code, message[pos:end], fin=fin, **kwargs)
|
/unit/src/python/ |
H A D | nxt_python_asgi_websocket.c | 680 frame->header->fin); in nxt_py_asgi_websocket_suspend_frame() 713 ws->pending_fins += frame->header->fin; in nxt_py_asgi_websocket_suspend_frame() 715 if (frame->header->fin) { in nxt_py_asgi_websocket_suspend_frame() 733 int fin; in nxt_py_asgi_websocket_pop_msg() local 855 fin = frame->header->fin; in nxt_py_asgi_websocket_pop_msg() 860 if (!fin) { in nxt_py_asgi_websocket_pop_msg() 863 fin = frame->header->fin; in nxt_py_asgi_websocket_pop_msg() 869 if (fin) { in nxt_py_asgi_websocket_pop_msg() 933 if (p->frame->header->fin) { in nxt_py_asgi_websocket_pending_len() 960 ws->pending_fins -= frame->header->fin; in nxt_py_asgi_websocket_pop_frame() [all …]
|
/unit/src/nodejs/unit-http/ |
H A D | websocket_connection.js | 341 if (frame.fin) { 359 if (frame.fin) { 393 if (frame.fin) { 558 frame.fin = true; 586 frame.fin = true; 603 frame.fin = true; 631 currentFrame.fin = (i === numFragments); 654 frame.fin = true;
|
H A D | unit.cpp | 721 set_named_property(res, "fin", (bool) ws->header->fin); in create_websocket_frame() 1048 bool fin; in websocket_send_frame() local 1078 fin = napi.get_value_bool(napi.get_named_property(frame, "fin")); in websocket_send_frame() 1081 fin = true; in websocket_send_frame() 1103 ret = nxt_unit_websocket_sendv(req, opcode, fin ? 1 : 0, iov, iovec_len); in websocket_send_frame()
|
/unit/src/java/ |
H A D | nxt_jni_Request.h | 19 uint8_t opcode, uint8_t fin);
|
H A D | nxt_jni_Request.c | 813 uint8_t opcode, uint8_t fin) in nxt_java_Request_websocket() argument 815 (*env)->CallVoidMethod(env, jreq, nxt_java_Request_processWsFrame, jbuf, opcode, fin); in nxt_java_Request_websocket()
|
/unit/src/test/ |
H A D | nxt_unit_websocket_echo.c | 76 nxt_unit_websocket_send(req, opcode, ws->header->fin, buf, size); in ws_echo_websocket_handler()
|