Lines Matching refs:opcode
420 uint8_t opcode; in nxt_py_asgi_websocket_send_frame() local
471 opcode = NXT_WEBSOCKET_OP_BINARY; in nxt_py_asgi_websocket_send_frame()
475 opcode = NXT_WEBSOCKET_OP_TEXT; in nxt_py_asgi_websocket_send_frame()
478 rc = nxt_unit_websocket_send(ws->req, opcode, 1, buf, buf_size); in nxt_py_asgi_websocket_send_frame()
491 uint8_t opcode; in nxt_py_asgi_websocket_handler() local
501 opcode = frame->header->opcode; in nxt_py_asgi_websocket_handler()
502 if (nxt_slow_path(opcode != NXT_WEBSOCKET_OP_CONT in nxt_py_asgi_websocket_handler()
503 && opcode != NXT_WEBSOCKET_OP_TEXT in nxt_py_asgi_websocket_handler()
504 && opcode != NXT_WEBSOCKET_OP_BINARY in nxt_py_asgi_websocket_handler()
505 && opcode != NXT_WEBSOCKET_OP_CLOSE)) in nxt_py_asgi_websocket_handler()
511 opcode); in nxt_py_asgi_websocket_handler()
545 if (nxt_slow_path(opcode == NXT_WEBSOCKET_OP_TEXT in nxt_py_asgi_websocket_handler()
546 || opcode == NXT_WEBSOCKET_OP_BINARY)) in nxt_py_asgi_websocket_handler()
550 "CONT frame expected. (%d)", opcode); in nxt_py_asgi_websocket_handler()
679 frame->header->opcode, frame->payload_len, in nxt_py_asgi_websocket_suspend_frame()
719 if (frame->header->opcode == NXT_WEBSOCKET_OP_CONT) { in nxt_py_asgi_websocket_suspend_frame()
735 uint8_t code_buf[2], opcode; in nxt_py_asgi_websocket_pop_msg() local
747 && frame->header->opcode == NXT_WEBSOCKET_OP_CLOSE)) in nxt_py_asgi_websocket_pop_msg()
763 opcode = frame->header->opcode; in nxt_py_asgi_websocket_pop_msg()
765 if (nxt_slow_path(opcode == NXT_WEBSOCKET_OP_CONT)) { in nxt_py_asgi_websocket_pop_msg()
777 switch (opcode) { in nxt_py_asgi_websocket_pop_msg()
846 nxt_unit_req_alert(ws->req, "Unexpected opcode %d", opcode); in nxt_py_asgi_websocket_pop_msg()
851 opcode); in nxt_py_asgi_websocket_pop_msg()
881 if (opcode == NXT_WEBSOCKET_OP_TEXT) { in nxt_py_asgi_websocket_pop_msg()
966 frame->header->opcode, frame->payload_len, in nxt_py_asgi_websocket_pop_frame()