Home
last modified time | relevance | path

Searched refs:fin (Results 1 – 20 of 20) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DMessagePart.java24 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 DPerMessageDeflate.java179 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 DWsFrameBase.java76 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 DTransformation.java76 …TransformationResult getMoreData(byte opCode, boolean fin, int rsv, ByteBuffer dest) throws IOExce… in getMoreData() argument
H A DLocalStrings.properties62 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 DWsRemoteEndpointImplBase.java690 private static void writeHeader(ByteBuffer headerBuffer, boolean fin, in writeHeader() argument
696 if (fin) { in writeHeader()
/unit/test/
H A Dtest_java_websockets.py41 def check_frame(self, frame, fin, opcode, payload, decode=True): argument
47 assert frame['fin'] == fin, 'fin'
106 self.ws.frame_write(sock, self.ws.OP_TEXT, message, fin=False)
107 self.ws.frame_write(sock, self.ws.OP_CONT, ' ', fin=False)
125 self.ws.frame_write(sock, self.ws.OP_PING, message, fin=False)
735 sock, self.ws.OP_CONT, 'fragment2', fin=True, chopsize=1
816 fin=True,
852 fin=False,
976 self.ws.frame_write(sock, self.ws.OP_TEXT, '', fin=False)
977 self.ws.frame_write(sock, self.ws.OP_CONT, '', fin=False)
[all …]
H A Dtest_node_websockets.py41 def check_frame(self, frame, fin, opcode, payload, decode=True): argument
47 assert frame['fin'] == fin, 'fin'
106 self.ws.frame_write(sock, self.ws.OP_TEXT, message, fin=False)
107 self.ws.frame_write(sock, self.ws.OP_CONT, ' ', fin=False)
125 self.ws.frame_write(sock, self.ws.OP_PING, message, fin=False)
754 sock, self.ws.OP_CONT, 'fragment2', fin=True, chopsize=1
835 fin=True,
871 fin=False,
995 self.ws.frame_write(sock, self.ws.OP_TEXT, '', fin=False)
996 self.ws.frame_write(sock, self.ws.OP_CONT, '', fin=False)
[all …]
H A Dtest_asgi_websockets.py47 def check_frame(self, frame, fin, opcode, payload, decode=True): argument
53 assert frame['fin'] == fin, 'fin'
148 self.ws.frame_write(sock, self.ws.OP_TEXT, message, fin=False)
149 self.ws.frame_write(sock, self.ws.OP_CONT, ' ', fin=False)
179 self.ws.frame_write(sock, self.ws.OP_PING, message, fin=False)
808 sock, self.ws.OP_CONT, 'fragment2', fin=True, chopsize=1
889 fin=True,
925 fin=False,
1049 self.ws.frame_write(sock, self.ws.OP_TEXT, '', fin=False)
1050 self.ws.frame_write(sock, self.ws.OP_CONT, '', fin=False)
[all …]
/unit/src/
H A Dnxt_websocket_header.h14 uint8_t fin:1; member
29 uint8_t fin:1; member
H A Dnxt_h1proto_websocket.c193 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 Dnxt_java.c575 ws->header->opcode, ws->header->fin); in nxt_java_websocket_handler()
H A Dnxt_unit.c3350 wh->fin = last; in nxt_unit_websocket_sendv()
/unit/test/unit/applications/
H A Dwebsockets.py147 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 Dnxt_python_asgi_websocket.c680 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 Dwebsocket_connection.js341 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 Dunit.cpp715 set_named_property(res, "fin", (bool) ws->header->fin); in create_websocket_frame()
1042 bool fin; in websocket_send_frame() local
1072 fin = napi.get_value_bool(napi.get_named_property(frame, "fin")); in websocket_send_frame()
1075 fin = true; in websocket_send_frame()
1097 ret = nxt_unit_websocket_sendv(req, opcode, fin ? 1 : 0, iov, iovec_len); in websocket_send_frame()
/unit/src/java/
H A Dnxt_jni_Request.h19 uint8_t opcode, uint8_t fin);
H A Dnxt_jni_Request.c813 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 Dnxt_unit_websocket_echo.c76 nxt_unit_websocket_send(req, opcode, ws->header->fin, buf, size); in ws_echo_websocket_handler()