Searched refs:wsFrame (Results 1 - 7 of 7) sorted by relevance
| /arkcompiler/toolchain/websocket/test/ |
| H A D | web_socket_frame_test.cpp | 33 WebSocketFrame wsFrame(HEADER_RAW); in HWTEST_F()
35 ASSERT_EQ(wsFrame.fin, EXPECTED_FIN); in HWTEST_F()
36 ASSERT_EQ(wsFrame.opcode, EXPECTED_OPCODE); in HWTEST_F()
37 ASSERT_EQ(wsFrame.mask, EXPECTED_MASK_BIT); in HWTEST_F()
38 ASSERT_EQ(wsFrame.payloadLen, EXPECTED_PAYLOAD_LEN); in HWTEST_F()
40 ASSERT_TRUE(wsFrame.payload.empty()); in HWTEST_F()
42 ASSERT_EQ(wsFrame.maskingKey[i], 0); in HWTEST_F()
|
| /arkcompiler/toolchain/websocket/ |
| H A D | websocket_base.cpp | 85 bool WebSocketBase::ReadPayload(WebSocketFrame& wsFrame) const in ReadPayload()
87 if (wsFrame.payloadLen == WebSocketFrame::TWO_BYTES_LENTH_ENC) { 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()
100 wsFrame.payloadLen = NetToHostLongLong(recvbuf, WebSocketFrame::EIGHT_BYTES_LENTH); in ReadPayload()
102 return DecodeMessage(wsFrame); in ReadPayload()
105 bool WebSocketBase::HandleDataFrame(WebSocketFrame& wsFrame) const in HandleDataFrame()
107 if (wsFrame.opcode == EnumToNumber(FrameType::TEXT)) { in HandleDataFrame()
108 return ReadPayload(wsFrame); in HandleDataFrame()
110 LOGW("Received unsupported data frame, opcode = %{public}d", wsFrame in HandleDataFrame()
115 HandleControlFrame(WebSocketFrame& wsFrame) HandleControlFrame() argument
[all...] |
| H A D | websocket_base.h | 148 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;
|
| /arkcompiler/toolchain/websocket/server/ |
| H A D | websocket_server.cpp | 54 bool WebSocketServer::DecodeMessage(WebSocketFrame& wsFrame) const in DecodeMessage()
56 const uint64_t msgLen = wsFrame.payloadLen; in DecodeMessage()
61 auto& buffer = wsFrame.payload; in DecodeMessage()
64 if (!RecvUnderLock(wsFrame.maskingKey, sizeof(wsFrame.maskingKey))) { in DecodeMessage()
76 buffer[i] = static_cast<uint8_t>(buffer[i]) ^ wsFrame.maskingKey[j]; in DecodeMessage()
395 bool WebSocketServer::ValidateIncomingFrame(const WebSocketFrame& wsFrame) const in ValidateIncomingFrame()
399 return wsFrame.mask == 1; in ValidateIncomingFrame()
|
| H A D | websocket_server.h | 101 bool ValidateIncomingFrame(const WebSocketFrame& wsFrame) const override;
105 bool DecodeMessage(WebSocketFrame& wsFrame) const override;
|
| /arkcompiler/toolchain/websocket/client/ |
| H A D | websocket_client.cpp | 243 bool WebSocketClient::DecodeMessage(WebSocketFrame& wsFrame) const in DecodeMessage()
245 uint64_t msgLen = wsFrame.payloadLen; in DecodeMessage()
250 auto& buffer = wsFrame.payload; in DecodeMessage()
280 bool WebSocketClient::ValidateIncomingFrame(const WebSocketFrame& wsFrame) const in ValidateIncomingFrame()
284 return wsFrame.mask == 0; in ValidateIncomingFrame()
|
| H A D | websocket_client.h | 43 bool DecodeMessage(WebSocketFrame& wsFrame) const override;
46 bool ValidateIncomingFrame(const WebSocketFrame& wsFrame) const override;
|
Completed in 4 milliseconds