/unit/src/java/nginx/unit/websocket/ |
H A D | LocalStrings.properties | 140 …etContainer.pathWrongScheme=The scheme [{0}] is not supported. The supported schemes are ws and wss
|
/unit/src/nodejs/unit-http/ |
H A D | unit.cpp | 345 Unit::websocket_handler_cb(nxt_unit_websocket_frame_t *ws) in websocket_handler_cb() argument 349 obj = reinterpret_cast<Unit *>(ws->req->unit->data); in websocket_handler_cb() 351 obj->websocket_handler(ws); in websocket_handler_cb() 356 Unit::websocket_handler(nxt_unit_websocket_frame_t *ws) in websocket_handler() argument 361 req_data = (req_data_t *) ws->req->data; in websocket_handler() 368 frame = create_websocket_frame(server_obj, ws); in websocket_handler() 383 nxt_unit_websocket_done(ws); in websocket_handler() 725 if (ws->header->opcode == NXT_WEBSOCKET_OP_CLOSE) { in create_websocket_frame() 726 if (ws->payload_len >= 2) { in create_websocket_frame() 727 nxt_unit_websocket_read(ws, sc, 2); in create_websocket_frame() [all …]
|
H A D | unit.h | 34 static void websocket_handler_cb(nxt_unit_websocket_frame_t *ws); 35 void websocket_handler(nxt_unit_websocket_frame_t *ws); 62 nxt_unit_websocket_frame_t *ws);
|
/unit/src/ |
H A D | nxt_java.c | 37 static void nxt_java_websocket_handler(nxt_unit_websocket_frame_t *ws); 558 nxt_java_websocket_handler(nxt_unit_websocket_frame_t *ws) in nxt_java_websocket_handler() argument 565 env = ws->req->ctx->data; in nxt_java_websocket_handler() 566 data = ws->req->data; in nxt_java_websocket_handler() 568 b = malloc(ws->payload_len); in nxt_java_websocket_handler() 570 nxt_unit_websocket_read(ws, b, ws->payload_len); in nxt_java_websocket_handler() 572 jbuf = (*env)->NewDirectByteBuffer(env, b, ws->payload_len); in nxt_java_websocket_handler() 575 ws->header->opcode, ws->header->fin); in nxt_java_websocket_handler() 588 nxt_unit_websocket_done(ws); in nxt_java_websocket_handler()
|
H A D | nxt_unit.c | 268 nxt_unit_websocket_frame_t ws; member 1650 ws_impl->ws.req = req; in nxt_unit_process_websocket() 1687 ws_impl->ws.header); in nxt_unit_process_websocket() 1701 ws_impl->ws.content_length = ws_impl->ws.payload_len; in nxt_unit_process_websocket() 1896 ws_impl = nxt_container_of(ws, nxt_unit_websocket_frame_impl_t, ws); in nxt_unit_websocket_frame_release() 1902 ws->req = NULL; in nxt_unit_websocket_frame_release() 3423 res = nxt_unit_buf_read(&ws->content_buf, &ws->content_length, in nxt_unit_websocket_read() 3426 if (ws->mask == NULL) { in nxt_unit_websocket_read() 3431 d = (ws->payload_len - ws->content_length - res) % 4; in nxt_unit_websocket_read() 3448 ws_impl = nxt_container_of(ws, nxt_unit_websocket_frame_impl_t, ws); in nxt_unit_websocket_retain() [all …]
|
H A D | nxt_unit.h | 130 void (*websocket_handler)(nxt_unit_websocket_frame_t *ws); 328 ssize_t nxt_unit_websocket_read(nxt_unit_websocket_frame_t *ws, void *dst, 331 int nxt_unit_websocket_retain(nxt_unit_websocket_frame_t *ws); 333 void nxt_unit_websocket_done(nxt_unit_websocket_frame_t *ws);
|
/unit/src/python/ |
H A D | nxt_python_asgi.h | 64 void nxt_py_asgi_websocket_handler(nxt_unit_websocket_frame_t *ws);
|
H A D | nxt_python_asgi_websocket.c | 122 ws->req = req; in nxt_py_asgi_websocket_create() 129 ws->pending_fins = 0; in nxt_py_asgi_websocket_create() 132 return (PyObject *) ws; in nxt_py_asgi_websocket_create() 265 switch(ws->state) { in nxt_py_asgi_websocket_accept() 352 Py_INCREF(ws); in nxt_py_asgi_websocket_accept() 354 return (PyObject *) ws; in nxt_py_asgi_websocket_accept() 410 Py_INCREF(ws); in nxt_py_asgi_websocket_close() 483 Py_INCREF(ws); in nxt_py_asgi_websocket_send_frame() 497 ws = frame->req->data; in nxt_py_asgi_websocket_handler() 682 ws = frame->req->data; in nxt_py_asgi_websocket_suspend_frame() [all …]
|
/unit/src/test/ |
H A D | nxt_unit_websocket_chat.c | 161 ws_chat_websocket_handler(nxt_unit_websocket_frame_t *ws) in ws_chat_websocket_handler() argument 167 if (ws->header->opcode != NXT_WEBSOCKET_OP_TEXT) { in ws_chat_websocket_handler() 171 data = ws->req->data; in ws_chat_websocket_handler() 175 buf_size += nxt_unit_websocket_read(ws, buf + buf_size, in ws_chat_websocket_handler() 177 ws->content_length)); in ws_chat_websocket_handler() 181 nxt_unit_websocket_done(ws); in ws_chat_websocket_handler()
|
H A D | nxt_unit_websocket_echo.c | 52 ws_echo_websocket_handler(nxt_unit_websocket_frame_t *ws) in ws_echo_websocket_handler() argument 61 if (buf_size < ws->content_length) { in ws_echo_websocket_handler() 62 buf = realloc(buf, ws->content_length); in ws_echo_websocket_handler() 63 buf_size = ws->content_length; in ws_echo_websocket_handler() 66 req = ws->req; in ws_echo_websocket_handler() 67 opcode = ws->header->opcode; in ws_echo_websocket_handler() 70 nxt_unit_websocket_done(ws); in ws_echo_websocket_handler() 74 size = nxt_unit_websocket_read(ws, buf, ws->content_length); in ws_echo_websocket_handler() 76 nxt_unit_websocket_send(req, opcode, ws->header->fin, buf, size); in ws_echo_websocket_handler() 77 nxt_unit_websocket_done(ws); in ws_echo_websocket_handler()
|
/unit/test/ |
H A D | test_asgi_websockets.py | 30 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 93 ws.frame_write(sock, ws.OP_TEXT, message) 98 ws.frame_write(sock, ws.OP_TEXT, message) 519 ws.frame_write(sock, ws.OP_PONG, '') 1140 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1141 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1149 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1161 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1174 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1188 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) [all …]
|
H A D | test_java_websockets.py | 27 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 74 ws.frame_write(sock, ws.OP_TEXT, message) 79 ws.frame_write(sock, ws.OP_TEXT, message) 447 ws.frame_write(sock, ws.OP_PONG, '') 1068 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1069 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1077 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1089 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1102 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1116 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) [all …]
|
H A D | test_node_es_modules.py | 11 ws = ApplicationWebsocket() variable 37 _, sock, _ = ws.upgrade() 39 ws.frame_write(sock, ws.OP_TEXT, message) 40 frame = ws.frame_read(sock) 44 ws.frame_write(sock, ws.OP_TEXT, message) 45 frame = ws.frame_read(sock)
|
H A D | test_node_websockets.py | 27 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 74 ws.frame_write(sock, ws.OP_TEXT, message) 79 ws.frame_write(sock, ws.OP_TEXT, message) 467 ws.frame_write(sock, ws.OP_PONG, '') 1088 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1089 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1097 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1109 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1122 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) 1136 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close()) [all …]
|