Lines Matching refs:payload_len
524 if (nxt_slow_path(frame->payload_len > rest)) { in nxt_py_asgi_websocket_handler()
532 if (nxt_slow_path(frame->payload_len > rest)) { in nxt_py_asgi_websocket_handler()
679 frame->header->opcode, frame->payload_len, in nxt_py_asgi_websocket_suspend_frame()
712 ws->pending_payload_len += frame->payload_len; in nxt_py_asgi_websocket_suspend_frame()
720 ws->pending_frame_len += frame->payload_len; in nxt_py_asgi_websocket_suspend_frame()
723 ws->pending_frame_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()
757 payload_len = nxt_py_asgi_websocket_pending_len(ws); in nxt_py_asgi_websocket_pop_msg()
779 buf = nxt_unit_malloc(frame->req->ctx, payload_len); in nxt_py_asgi_websocket_pop_msg()
783 (int) payload_len); in nxt_py_asgi_websocket_pop_msg()
789 (int) payload_len); in nxt_py_asgi_websocket_pop_msg()
798 data = PyBytes_FromStringAndSize(NULL, 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()
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()
876 fin_frame->payload_len); in nxt_py_asgi_websocket_pop_msg()
882 buf -= payload_len; in nxt_py_asgi_websocket_pop_msg()
884 data = PyUnicode_DecodeUTF8(buf, payload_len, NULL); in nxt_py_asgi_websocket_pop_msg()
891 (int) payload_len); in nxt_py_asgi_websocket_pop_msg()
931 res += p->frame->payload_len; in nxt_py_asgi_websocket_pending_len()
959 ws->pending_payload_len -= frame->payload_len; in nxt_py_asgi_websocket_pop_frame()
966 frame->header->opcode, frame->payload_len, in nxt_py_asgi_websocket_pop_frame()