Home
last modified time | relevance | path

Searched refs:frame (Results 1 – 10 of 10) sorted by relevance

/unit/src/nodejs/unit-http/
H A Dwebsocket_connection.js330 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 Dunit.cpp358 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()
1046 napi_value this_arg, frame, payload; in websocket_send_frame() local
1054 this_arg = napi.get_cb_info(info, frame); in websocket_send_frame()
1058 opcode = napi.get_value_uint32(napi.get_named_property(frame, in websocket_send_frame()
1061 sc = napi.get_value_uint32(napi.get_named_property(frame, in websocket_send_frame()
1072 fin = napi.get_value_bool(napi.get_named_property(frame, "fin")); in websocket_send_frame()
1078 payload = napi.get_named_property(frame, "binaryPayload"); in websocket_send_frame()
/unit/test/unit/applications/
H A Dwebsockets.py90 frame = {}
110 if frame['mask']:
118 if frame['mask']:
135 frame['data'] = data
137 if frame['mask']:
140 return frame
153 frame = b''
178 frame += mask_bits
183 frame += data
185 return frame
[all …]
/unit/src/python/
H A Dnxt_python_asgi_websocket.c497 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 Dtest_node_websockets.py31 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 Dtest_asgi_websockets.py37 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 Dtest_java_websockets.py31 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 Dtest_node_es_modules.py39 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 DLocalStrings.properties39 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 Dtest120 #NXT_CFLAGS="$NXT_CFLAGS -fomit-frame-pointer"
121 #NXT_CFLAGS="$NXT_CFLAGS -momit-leaf-frame-pointer"
153 #NXT_CFLAGS="$NXT_CFLAGS -fomit-frame-pointer"