Home
last modified time | relevance | path

Searched refs:payload_len (Results 1 – 9 of 9) sorted by relevance

/unit/src/
H A Dnxt_websocket.c62 p = h->payload_len; in nxt_websocket_frame_header_size()
87 p = h->payload_len; in nxt_websocket_frame_payload_len()
100 nxt_websocket_frame_init(void *data, uint64_t payload_len) in nxt_websocket_frame_init() argument
108 if (payload_len < 126) { in nxt_websocket_frame_init()
109 h->payload_len = payload_len; in nxt_websocket_frame_init()
113 if (payload_len < 65536) { in nxt_websocket_frame_init()
114 h->payload_len = 126; in nxt_websocket_frame_init()
115 nxt_hton16(h->payload_len_, payload_len); in nxt_websocket_frame_init()
119 h->payload_len = 127; in nxt_websocket_frame_init()
120 nxt_hton64(h->payload_len_, payload_len); in nxt_websocket_frame_init()
H A Dnxt_websocket_header.h21 uint8_t payload_len:7; member
31 uint8_t payload_len:7; member
H A Dnxt_h1proto_websocket.c220 uint64_t payload_len; in nxt_h1p_conn_ws_frame_header_read() local
285 if (nxt_slow_path(wsh->payload_len > 125)) { in nxt_h1p_conn_ws_frame_header_read()
292 && wsh->payload_len == 1)) in nxt_h1p_conn_ws_frame_header_read()
321 payload_len = nxt_websocket_frame_payload_len(wsh); in nxt_h1p_conn_ws_frame_header_read()
332 frame_size = payload_len + hsize; in nxt_h1p_conn_ws_frame_header_read()
417 if (wsh->payload_len >= 2) { in nxt_h1p_conn_ws_frame_process()
648 uint8_t payload_len, i; in nxt_h1p_conn_ws_pong() local
660 payload_len = wsh->payload_len; in nxt_h1p_conn_ws_pong()
668 out = nxt_http_buf_mem(task, r, 2 + payload_len); in nxt_h1p_conn_ws_pong()
678 out->mem.free = nxt_websocket_frame_init(wsh, payload_len); in nxt_h1p_conn_ws_pong()
[all …]
H A Dnxt_unit_websocket.h18 uint64_t payload_len; member
H A Dnxt_websocket.h17 NXT_EXPORT void *nxt_websocket_frame_init(void *data, uint64_t payload_len);
H A Dnxt_java.c568 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()
H A Dnxt_unit.c1686 ws_impl->ws.payload_len = nxt_websocket_frame_payload_len( in nxt_unit_process_websocket()
1701 ws_impl->ws.content_length = ws_impl->ws.payload_len; in nxt_unit_process_websocket()
1706 ws_impl->ws.payload_len); in nxt_unit_process_websocket()
3336 uint32_t payload_len, buf_size, alloc_size; in nxt_unit_websocket_sendv() local
3343 payload_len = 0; in nxt_unit_websocket_sendv()
3346 payload_len += iov[i].iov_len; in nxt_unit_websocket_sendv()
3349 buf_size = 10 + payload_len; in nxt_unit_websocket_sendv()
3368 buf->free = nxt_websocket_frame_init(wh, payload_len); in nxt_unit_websocket_sendv()
3431 d = (ws->payload_len - ws->content_length - res) % 4; in nxt_unit_websocket_read()
/unit/src/python/
H A Dnxt_python_asgi_websocket.c524 if (nxt_slow_path(frame->payload_len > rest)) { in nxt_py_asgi_websocket_handler()
712 ws->pending_payload_len += frame->payload_len; in nxt_py_asgi_websocket_suspend_frame()
738 uint64_t payload_len; in nxt_py_asgi_websocket_pop_msg() local
749 payload_len = frame->payload_len; in nxt_py_asgi_websocket_pop_msg()
753 payload_len = ws->pending_payload_len + frame->payload_len; in nxt_py_asgi_websocket_pop_msg()
783 (int) payload_len); in nxt_py_asgi_websocket_pop_msg()
802 (int) payload_len); in nxt_py_asgi_websocket_pop_msg()
817 if (frame->payload_len >= 2) { in nxt_py_asgi_websocket_pop_msg()
882 buf -= payload_len; in nxt_py_asgi_websocket_pop_msg()
931 res += p->frame->payload_len; in nxt_py_asgi_websocket_pending_len()
[all …]
/unit/src/nodejs/unit-http/
H A Dunit.cpp717 set_named_property(res, "length", (int64_t) ws->payload_len); in create_websocket_frame()
720 if (ws->payload_len >= 2) { in create_websocket_frame()