Home
last modified time | relevance | path

Searched refs:ws (Results 1 – 14 of 14) sorted by path

/unit/src/java/nginx/unit/websocket/
H A DLocalStrings.properties140 …etContainer.pathWrongScheme=The scheme [{0}] is not supported. The supported schemes are ws and wss
/unit/src/nodejs/unit-http/
H A Dunit.cpp345 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 Dunit.h34 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 Dnxt_java.c37 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 Dnxt_unit.c268 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 Dnxt_unit.h130 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 Dnxt_python_asgi.h64 void nxt_py_asgi_websocket_handler(nxt_unit_websocket_frame_t *ws);
H A Dnxt_python_asgi_websocket.c122 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 Dnxt_unit_websocket_chat.c161 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 Dnxt_unit_websocket_echo.c52 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 Dtest_asgi_websockets.py30 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 Dtest_java_websockets.py27 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 Dtest_node_es_modules.py11 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 Dtest_node_websockets.py27 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 …]