Searched refs:frame (Results 1 – 10 of 10) sorted by relevance
/unit/src/nodejs/unit-http/ |
H A D | websocket_connection.js | 330 if (this.frameQueue.length !== 0 && (frame.opcode > 0x00 && frame.opcode < 0x08)) { 337 switch(frame.opcode) { 483 else if (frame.closeStatus === -1 || validateCloseReason(frame.closeStatus)) { 558 frame.fin = true; 571 this.sendFrame(frame); 586 frame.fin = true; 588 this.sendFrame(frame); 593 if (frame.opcode > 0x07) { 603 frame.fin = true; 654 frame.fin = true; [all …]
|
H A D | unit.cpp | 358 napi_value frame, server_obj, process_frame, conn; in websocket_handler() local 368 frame = create_websocket_frame(server_obj, ws); in websocket_handler() 377 make_callback(async_context, conn, process_frame, frame); in websocket_handler() 1045 napi_value this_arg, frame, payload; in websocket_send_frame() local 1053 this_arg = napi.get_cb_info(info, frame); in websocket_send_frame() 1057 opcode = napi.get_value_uint32(napi.get_named_property(frame, in websocket_send_frame() 1060 sc = napi.get_value_uint32(napi.get_named_property(frame, in websocket_send_frame() 1071 fin = napi.get_value_bool(napi.get_named_property(frame, "fin")); in websocket_send_frame() 1077 payload = napi.get_named_property(frame, "binaryPayload"); in websocket_send_frame()
|
/unit/test/unit/applications/ |
H A D | websockets.py | 91 frame = {} 111 if frame['mask']: 119 if frame['mask']: 136 frame['data'] = data 138 if frame['mask']: 141 return frame 154 frame = b'' 179 frame += mask_bits 184 frame += data 186 return frame [all …]
|
/unit/src/python/ |
H A D | nxt_python_asgi_websocket.c | 497 ws = frame->req->data; in nxt_py_asgi_websocket_handler() 679 frame->header->opcode, frame->payload_len, in nxt_py_asgi_websocket_suspend_frame() 682 ws = frame->req->data; in nxt_py_asgi_websocket_suspend_frame() 709 p->frame = frame; in nxt_py_asgi_websocket_suspend_frame() 746 || (frame != NULL in nxt_py_asgi_websocket_pop_msg() 752 if (frame != NULL) { in nxt_py_asgi_websocket_pop_msg() 856 buf += nxt_unit_websocket_read(frame, buf, frame->payload_len); in nxt_py_asgi_websocket_pop_msg() 865 buf += nxt_unit_websocket_read(frame, buf, frame->payload_len); in nxt_py_asgi_websocket_pop_msg() 958 frame = p->frame; in nxt_py_asgi_websocket_pop_frame() 966 frame->header->opcode, frame->payload_len, in nxt_py_asgi_websocket_pop_frame() [all …]
|
/unit/test/ |
H A D | test_node_websockets.py | 31 if frame == None: 43 data = frame['data'] 47 assert frame['fin'] == fin, 'fin' 72 frame = self.ws.frame_read(sock) 77 frame = self.ws.frame_read(sock) 129 frame.pop('data') 130 assert frame == { 892 frame = None 894 self.check_close(sock, 1002, frame=frame) 1405 sock.sendall(frame[:2]) [all …]
|
H A D | test_asgi_websockets.py | 37 if frame == None: 49 data = frame['data'] 53 assert frame['fin'] == fin, 'fin' 93 frame = self.ws.frame_read(sock) 98 frame = self.ws.frame_read(sock) 183 frame.pop('data') 184 assert frame == { 946 frame = None 948 self.check_close(sock, 1002, frame=frame) 1459 sock.sendall(frame[:2]) [all …]
|
H A D | test_java_websockets.py | 31 if frame == None: 43 data = frame['data'] 47 assert frame['fin'] == fin, 'fin' 72 frame = self.ws.frame_read(sock) 77 frame = self.ws.frame_read(sock) 129 frame.pop('data') 130 assert frame == { 873 frame = None 875 self.check_close(sock, 1002, frame=frame) 1386 sock.sendall(frame[:2]) [all …]
|
H A D | test_node_es_modules.py | 39 frame = self.ws.frame_read(sock) 41 assert message == frame['data'].decode('utf-8'), 'mirror' 44 frame = self.ws.frame_read(sock) 46 assert message == frame['data'].decode('utf-8'), 'mirror 2'
|
/unit/src/java/nginx/unit/websocket/ |
H A D | LocalStrings.properties | 39 perMessageDeflate.deflateFailed=Failed to decompress a compressed WebSocket frame 59 wsFrame.closed=New frame received after a close control frame 60 wsFrame.controlFragmented=A fragmented control frame was received but control frames may not be fra… 64 wsFrame.invalidOpCode= A WebSocket frame was sent with an unrecognised opCode of [{0}] 66 wsFrame.invalidUtf8Close=A WebSocket close frame was received with a close reason that contained in… 69 wsFrame.noContinuation=A new message was started when a continuation frame was expected 70 wsFrame.notMasked=The client frame was not masked but all client frames must be masked 71 wsFrame.oneByteCloseCode=The client sent a close frame with a single byte payload which is not valid 72 wsFrame.partialHeaderComplete=WebSocket frame received. fin [{0}], rsv [{1}], OpCode [{2}], payload… 100 # frame and therefore must be 123 bytes (not characters) or less in length. [all …]
|
/unit/auto/cc/ |
H A D | test | 120 #NXT_CFLAGS="$NXT_CFLAGS -fomit-frame-pointer" 121 #NXT_CFLAGS="$NXT_CFLAGS -momit-leaf-frame-pointer" 153 #NXT_CFLAGS="$NXT_CFLAGS -fomit-frame-pointer"
|