Home
last modified time | relevance | path

Searched refs:WebSocketFrame (Results 1 – 11 of 11) sorted by relevance

/arkcompiler/toolchain/websocket/
Dframe_builder.cpp59 auto headerBytes = WebSocketFrame::HEADER_LEN; in PushFullHeader()
63 if (payloadBytes <= WebSocketFrame::ONE_BYTE_LENTH_ENC_LIMIT) { in PushFullHeader()
65 } else if (payloadBytes < WebSocketFrame::TWO_BYTES_LENGTH_LIMIT) { in PushFullHeader()
66 payloadLenField = WebSocketFrame::TWO_BYTES_LENTH_ENC; in PushFullHeader()
67 headerBytes += WebSocketFrame::TWO_BYTES_LENTH; in PushFullHeader()
69 payloadLenField = WebSocketFrame::EIGHT_BYTES_LENTH_ENC; in PushFullHeader()
70 headerBytes += WebSocketFrame::EIGHT_BYTES_LENTH; in PushFullHeader()
95 if (payloadLenField == WebSocketFrame::TWO_BYTES_LENTH_ENC) { in PushPayloadLength()
97 } else if (payloadLenField == WebSocketFrame::EIGHT_BYTES_LENTH_ENC) { in PushPayloadLength()
107 …lientFrameBuilder(bool final, FrameType opcode, const uint8_t maskingKey[WebSocketFrame::MASK_LEN]) in ClientFrameBuilder()
[all …]
Dwebsocket_base.cpp85 bool WebSocketBase::ReadPayload(WebSocketFrame& wsFrame) const in ReadPayload()
87 if (wsFrame.payloadLen == WebSocketFrame::TWO_BYTES_LENTH_ENC) { in ReadPayload()
88 uint8_t recvbuf[WebSocketFrame::TWO_BYTES_LENTH] = {0}; in ReadPayload()
89 if (!RecvUnderLock(recvbuf, WebSocketFrame::TWO_BYTES_LENTH)) { in ReadPayload()
93 wsFrame.payloadLen = NetToHostLongLong(recvbuf, WebSocketFrame::TWO_BYTES_LENTH); in ReadPayload()
94 } else if (wsFrame.payloadLen == WebSocketFrame::EIGHT_BYTES_LENTH_ENC) { in ReadPayload()
95 uint8_t recvbuf[WebSocketFrame::EIGHT_BYTES_LENTH] = {0}; in ReadPayload()
96 if (!RecvUnderLock(recvbuf, WebSocketFrame::EIGHT_BYTES_LENTH)) { in ReadPayload()
100 wsFrame.payloadLen = NetToHostLongLong(recvbuf, WebSocketFrame::EIGHT_BYTES_LENTH); in ReadPayload()
105 bool WebSocketBase::HandleDataFrame(WebSocketFrame& wsFrame) const in HandleDataFrame()
[all …]
Dwebsocket_base.h148 bool HandleDataFrame(WebSocketFrame& wsFrame) const;
149 bool HandleControlFrame(WebSocketFrame& wsFrame);
150 bool ReadPayload(WebSocketFrame& wsFrame) const;
159 virtual bool ValidateIncomingFrame(const WebSocketFrame& wsFrame) const = 0;
163 virtual bool DecodeMessage(WebSocketFrame& wsFrame) const = 0;
Dweb_socket_frame.h44 struct WebSocketFrame { struct
61 WebSocketFrame() = default; argument
62 explicit WebSocketFrame(const uint8_t headerRaw[HEADER_LEN]) in WebSocketFrame() function
Dframe_builder.h66 …ClientFrameBuilder(bool final, FrameType opcode, const uint8_t maskingKey[WebSocketFrame::MASK_LEN…
68 ClientFrameBuilder& SetMask(const uint8_t maskingKey[WebSocketFrame::MASK_LEN]);
76 uint8_t maskingKey_[WebSocketFrame::MASK_LEN] = {0};
/arkcompiler/toolchain/websocket/test/
Dweb_socket_frame_test.cpp24 static constexpr uint8_t HEADER_RAW[WebSocketFrame::HEADER_LEN] = {0x01, 0x9a};
33 WebSocketFrame wsFrame(HEADER_RAW);
41 for (size_t i = 0; i < WebSocketFrame::MASK_LEN; ++i) {
Dframe_builder_test.cpp27 static constexpr uint8_t MASKING_KEY[WebSocketFrame::MASK_LEN] = {0xab};
145 constexpr size_t EXPECTED_MESSAGE_SIZE = 2 + WebSocketFrame::MASK_LEN;
160 constexpr size_t HEADER_LENGTH = 2 + 2 + WebSocketFrame::MASK_LEN;
172 ASSERT_EQ(static_cast<uint8_t>(message[i] ^ MASKING_KEY[i % WebSocketFrame::MASK_LEN]),
/arkcompiler/toolchain/websocket/client/
Dwebsocket_client.h43 bool DecodeMessage(WebSocketFrame& wsFrame) const override;
46 bool ValidateIncomingFrame(const WebSocketFrame& wsFrame) const override;
Dwebsocket_client.cpp243 bool WebSocketClient::DecodeMessage(WebSocketFrame& wsFrame) const in DecodeMessage()
280 bool WebSocketClient::ValidateIncomingFrame(const WebSocketFrame& wsFrame) const in ValidateIncomingFrame()
/arkcompiler/toolchain/websocket/server/
Dwebsocket_server.h101 bool ValidateIncomingFrame(const WebSocketFrame& wsFrame) const override;
105 bool DecodeMessage(WebSocketFrame& wsFrame) const override;
Dwebsocket_server.cpp54 bool WebSocketServer::DecodeMessage(WebSocketFrame& wsFrame) const in DecodeMessage()
75 const auto j = i % WebSocketFrame::MASK_LEN; in DecodeMessage()
395 bool WebSocketServer::ValidateIncomingFrame(const WebSocketFrame& wsFrame) const in ValidateIncomingFrame()