| /aosp_15_r20/external/cronet/net/websockets/ |
| H A D | websocket_channel_test.cc | 78 std::ostream& operator<<(std::ostream& os, const WebSocketFrameHeader& header) { in operator <<()
322 WebSocketFrameHeader::OpCode opcode;
370 WebSocketFrameHeader& result_header = result_frame->header; in CreateFrameVector()
662 WebSocketFrameHeader& header = frame->header; in MoveFrames()
664 if (header.opcode == WebSocketFrameHeader::kOpCodeClose) in MoveFrames()
1081 {FINAL_FRAME, WebSocketFrameHeader::kOpCodeText, NOT_MASKED, "HELLO"}}; in TEST_F()
1088 OnDataFrameVector(true, WebSocketFrameHeader::kOpCodeText, in TEST_F()
1100 {FINAL_FRAME, WebSocketFrameHeader::kOpCodeClose, in TEST_F()
1123 {FINAL_FRAME, WebSocketFrameHeader::kOpCodeClose, NOT_MASKED, in TEST_F()
1173 {FINAL_FRAME, WebSocketFrameHeader::kOpCodeText, NOT_MASKED, "HELLO"}}; in TEST_F()
[all …]
|
| H A D | websocket_deflate_stream_test.cc | 120 if (!WebSocketFrameHeader::IsKnownDataOpCode(frame->header.opcode)) { in RecordInputDataFrame()
139 if (!WebSocketFrameHeader::IsKnownDataOpCode(frame->header.opcode)) { in RecordWrittenDataFrame()
151 if (!WebSocketFrameHeader::IsKnownDataOpCode(frame->header.opcode)) in AddFrameToBeInput()
157 if (!WebSocketFrameHeader::IsKnownDataOpCode(frame->header.opcode)) in VerifySentFrame()
226 WebSocketFrameHeader::OpCode opcode, in AppendTo()
235 WebSocketFrameHeader::OpCode opcode, in AppendTo()
292 AppendTo(&frames_, WebSocketFrameHeader::kOpCodeText, kFinal, payload); in AddCompressibleFrameString()
379 WebSocketFrameHeader::kOpCodeText, in TEST_F()
393 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode); in TEST_F()
419 WebSocketFrameHeader::kOpCodeText, in TEST_F()
[all …]
|
| H A D | websocket_frame.h | 24 struct NET_EXPORT WebSocketFrameHeader { struct
61 uint8_t key[WebSocketFrameHeader::kMaskingKeyLength]; argument
65 explicit WebSocketFrameHeader(OpCode opCode) : opcode(opCode) {} in WebSocketFrameHeader() argument
67 WebSocketFrameHeader(const WebSocketFrameHeader&) = delete;
68 WebSocketFrameHeader& operator=(const WebSocketFrameHeader&) = delete; argument
71 std::unique_ptr<WebSocketFrameHeader> Clone() const;
74 void CopyFrom(const WebSocketFrameHeader& source);
93 explicit WebSocketFrame(WebSocketFrameHeader::OpCode opcode); argument
101 WebSocketFrameHeader header;
140 std::unique_ptr<WebSocketFrameHeader> header;
[all …]
|
| H A D | websocket_frame_test.cc | 41 WebSocketFrameHeader header(WebSocketFrameHeader::kOpCodeText); in TEST()
57 static_assert(kMaskingKey.size() == WebSocketFrameHeader::kMaskingKeyLength, in TEST()
79 WebSocketFrameHeader header(WebSocketFrameHeader::kOpCodeText); in TEST()
98 WebSocketFrameHeader::OpCode opcode; in TEST()
101 {"\x80\x00", 2, WebSocketFrameHeader::kOpCodeContinuation}, in TEST()
102 {"\x81\x00", 2, WebSocketFrameHeader::kOpCodeText}, in TEST()
103 {"\x82\x00", 2, WebSocketFrameHeader::kOpCodeBinary}, in TEST()
104 {"\x88\x00", 2, WebSocketFrameHeader::kOpCodeClose}, in TEST()
105 {"\x89\x00", 2, WebSocketFrameHeader::kOpCodePing}, in TEST()
106 {"\x8A\x00", 2, WebSocketFrameHeader::kOpCodePong}, in TEST()
[all …]
|
| H A D | websocket_channel.cc | 103 void GetFrameTypeForOpcode(WebSocketFrameHeader::OpCode opcode, in GetFrameTypeForOpcode()
106 case WebSocketFrameHeader::kOpCodeText: // fall-thru in GetFrameTypeForOpcode()
107 case WebSocketFrameHeader::kOpCodeBinary: // fall-thru in GetFrameTypeForOpcode()
108 case WebSocketFrameHeader::kOpCodeContinuation: in GetFrameTypeForOpcode()
112 case WebSocketFrameHeader::kOpCodePing: in GetFrameTypeForOpcode()
116 case WebSocketFrameHeader::kOpCodePong: in GetFrameTypeForOpcode()
120 case WebSocketFrameHeader::kOpCodeClose: in GetFrameTypeForOpcode()
310 WebSocketFrameHeader::OpCode op_code, in SendFrame()
326 DCHECK(WebSocketFrameHeader::IsKnownDataOpCode(op_code)) in SendFrame()
330 if (op_code == WebSocketFrameHeader::kOpCodeText || in SendFrame()
[all …]
|
| H A D | websocket_frame_parser_test.cc | 61 const WebSocketFrameHeader* header = frame->header.get(); in TEST()
68 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, header->opcode); in TEST()
88 const WebSocketFrameHeader* header = frame->header.get(); in TEST()
95 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, header->opcode); in TEST()
179 const WebSocketFrameHeader* header = frame->header.get(); in TEST()
187 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, header->opcode); in TEST()
225 const WebSocketFrameHeader* header1 = frame1->header.get(); in TEST()
233 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, header1->opcode); in TEST()
256 const WebSocketFrameHeader* header2 = frame2->header.get(); in TEST()
286 const WebSocketFrameHeader* header1 = frame1->header.get(); in TEST()
[all …]
|
| H A D | websocket_frame.cc | 58 WebSocketFrameHeader::kMaskingKeyLength]; in MaskWebSocketFramePayloadByBytes()
64 std::unique_ptr<WebSocketFrameHeader> WebSocketFrameHeader::Clone() const { in Clone()
65 auto ret = std::make_unique<WebSocketFrameHeader>(opcode); in Clone()
70 void WebSocketFrameHeader::CopyFrom(const WebSocketFrameHeader& source) { in CopyFrom()
81 WebSocketFrame::WebSocketFrame(WebSocketFrameHeader::OpCode opcode) in WebSocketFrame()
90 size_t GetWebSocketFrameHeaderSize(const WebSocketFrameHeader& header) { in GetWebSocketFrameHeaderSize()
99 return (WebSocketFrameHeader::kBaseHeaderSize + extended_length_size + in GetWebSocketFrameHeaderSize()
100 (header.masked ? WebSocketFrameHeader::kMaskingKeyLength : 0u)); in GetWebSocketFrameHeaderSize()
103 int WriteWebSocketFrameHeader(const WebSocketFrameHeader& header, in WriteWebSocketFrameHeader()
184 base::RandBytes(masking_key.key, WebSocketFrameHeader::kMaskingKeyLength); in GenerateWebSocketMaskingKey()
[all …]
|
| H A D | websocket_deflate_stream.cc | 126 if (!WebSocketFrameHeader::IsKnownDataOpCode((*frames)[i]->header.opcode)) { in Deflate()
141 current_writing_opcode_ = WebSocketFrameHeader::kOpCodeContinuation; in Deflate()
191 DCHECK(current_writing_opcode_ == WebSocketFrameHeader::kOpCodeText || in OnMessageStart()
192 current_writing_opcode_ == WebSocketFrameHeader::kOpCodeBinary); in OnMessageStart()
211 const WebSocketFrameHeader& header, in AppendCompressedFrame()
213 const WebSocketFrameHeader::OpCode opcode = current_writing_opcode_; in AppendCompressedFrame()
227 (opcode != WebSocketFrameHeader::kOpCodeContinuation); in AppendCompressedFrame()
231 current_writing_opcode_ = WebSocketFrameHeader::kOpCodeContinuation; in AppendCompressedFrame()
242 const WebSocketFrameHeader::OpCode opcode = current_writing_opcode_; in AppendPossiblyCompressedMessage()
256 DCHECK(WebSocketFrameHeader::IsKnownDataOpCode(frame->header.opcode)); in AppendPossiblyCompressedMessage()
[all …]
|
| H A D | websocket_basic_stream_test.cc | 271 std::make_unique<WebSocketFrame>(WebSocketFrameHeader::kOpCodeText); in PrepareWriteFrame()
273 kWriteFrameSize - (WebSocketFrameHeader::kBaseHeaderSize + in PrepareWriteFrame()
274 WebSocketFrameHeader::kMaskingKeyLength); in PrepareWriteFrame()
280 WebSocketFrameHeader& header = frame->header; in PrepareWriteFrame()
393 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames_[0]->header.opcode); in TEST_F()
407 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames_[0]->header.opcode); in TEST_F()
415 EXPECT_EQ(WebSocketFrameHeader::kOpCodeContinuation, in TEST_F()
476 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames_[0]->header.opcode); in TEST_F()
486 EXPECT_EQ(WebSocketFrameHeader::kOpCodeContinuation, in TEST_F()
635 EXPECT_EQ(WebSocketFrameHeader::kOpCodePong, frames_[0]->header.opcode); in TEST_F()
[all …]
|
| H A D | websocket_deflate_stream.h | 89 const WebSocketFrameHeader& header,
106 WebSocketFrameHeader::OpCode current_reading_opcode_ =
107 WebSocketFrameHeader::kOpCodeText;
108 WebSocketFrameHeader::OpCode current_writing_opcode_ =
109 WebSocketFrameHeader::kOpCodeText;
|
| H A D | websocket_frame_parser.cc | 31 net::WebSocketFrameHeader::kBaseHeaderSize +
32 net::WebSocketFrameHeader::kMaximumExtendedLengthSize +
33 net::WebSocketFrameHeader::kMaskingKeyLength;
113 typedef WebSocketFrameHeader::OpCode OpCode; in DecodeFrameHeader()
161 WebSocketFrameHeader::kMaskingKeyLength; in DecodeFrameHeader()
170 current_frame_header_ = std::make_unique<WebSocketFrameHeader>(opcode); in DecodeFrameHeader()
|
| H A D | websocket_deflate_stream_fuzzer.cc | 75 WebSocketFrameHeader::OpCode opcode = in CreateFrame()
77 ->ConsumeIntegralInRange<WebSocketFrameHeader::OpCode>( in CreateFrame()
78 WebSocketFrameHeader::kOpCodeContinuation, in CreateFrame()
79 WebSocketFrameHeader::kOpCodeControlUnused); in CreateFrame()
|
| H A D | websocket_basic_stream.cc | 122 base::Value::Dict NetLogFrameHeaderParam(const WebSocketFrameHeader* header) { in NetLogFrameHeaderParam()
437 const WebSocketFrameHeader::OpCode opcode = current_frame_header_->opcode; in ConvertChunkToFrame()
438 if (WebSocketFrameHeader::IsKnownControlOpCode(opcode)) { in ConvertChunkToFrame()
493 const WebSocketFrameHeader::OpCode opcode = current_frame_header_->opcode; in CreateFrame()
498 WebSocketFrameHeader::kOpCodeContinuation) { in CreateFrame()
509 if (!is_final_chunk && WebSocketFrameHeader::IsKnownDataOpCode(opcode)) { in CreateFrame()
510 current_frame_header_->opcode = WebSocketFrameHeader::kOpCodeContinuation; in CreateFrame()
|
| H A D | websocket_channel.h | 114 WebSocketFrameHeader::OpCode op_code,
273 const WebSocketFrameHeader::OpCode opcode,
281 WebSocketFrameHeader::OpCode opcode,
299 WebSocketFrameHeader::OpCode op_code,
|
| H A D | websocket_frame_parser.h | 21 struct WebSocketFrameHeader;
83 std::unique_ptr<WebSocketFrameHeader> current_frame_header_;
|
| H A D | websocket_deflate_predictor_impl_test.cc | 22 std::make_unique<WebSocketFrame>(WebSocketFrameHeader::kOpCodeText)); in TEST()
|
| H A D | websocket_frame_perftest.cc | 37 static_assert(kMaskingKey.size() == WebSocketFrameHeader::kMaskingKeyLength,
|
| H A D | websocket_basic_stream.h | 228 std::unique_ptr<WebSocketFrameHeader> current_frame_header_;
|
| H A D | websocket_stream_test.cc | 1872 EXPECT_EQ(frames[0]->header.opcode, WebSocketFrameHeader::kOpCodeClose); in TEST_P()
|
| /aosp_15_r20/external/cronet/net/server/ |
| H A D | http_server_unittest.cc | 325 WebSocketFrameHeader::OpCodeEnum op_code, in EncodeFrame()
328 WebSocketFrameHeader header(op_code); in EncodeFrame()
533 EncodeFrame(message, WebSocketFrameHeader::OpCodeEnum::kOpCodePing, in TEST_F()
536 EncodeFrame(message, WebSocketFrameHeader::OpCodeEnum::kOpCodePong, in TEST_F()
557 EncodeFrame(message, WebSocketFrameHeader::OpCodeEnum::kOpCodePing, in TEST_F()
560 EncodeFrame(message, WebSocketFrameHeader::OpCodeEnum::kOpCodePong, in TEST_F()
580 /* message= */ "", WebSocketFrameHeader::OpCodeEnum::kOpCodePing, in TEST_F()
583 /* message= */ "", WebSocketFrameHeader::OpCodeEnum::kOpCodePong, in TEST_F()
586 /* message= */ "", WebSocketFrameHeader::OpCodeEnum::kOpCodePong, in TEST_F()
610 EncodeFrame(text_frame, WebSocketFrameHeader::OpCodeEnum::kOpCodeText, in TEST_F()
[all …]
|
| H A D | web_socket_encoder.cc | 73 case WebSocketFrameHeader::OpCodeEnum::kOpCodeClose: in DecodeFrameHybi17()
77 case WebSocketFrameHeader::OpCodeEnum::kOpCodeText: in DecodeFrameHybi17()
78 case WebSocketFrameHeader::OpCodeEnum:: in DecodeFrameHybi17()
80 case WebSocketFrameHeader::OpCodeEnum::kOpCodePing: in DecodeFrameHybi17()
81 case WebSocketFrameHeader::OpCodeEnum::kOpCodePong: in DecodeFrameHybi17()
84 case WebSocketFrameHeader::OpCodeEnum::kOpCodeBinary: // We don't support in DecodeFrameHybi17()
138 if (op_code == WebSocketFrameHeader::OpCodeEnum::kOpCodePing) in DecodeFrameHybi17()
141 if (op_code == WebSocketFrameHeader::OpCodeEnum::kOpCodePong) in DecodeFrameHybi17()
153 WebSocketFrameHeader::OpCodeEnum op_code, in EncodeFrameHybi17()
337 constexpr auto op_code = WebSocketFrameHeader::OpCodeEnum::kOpCodeText; in EncodeTextFrame()
[all …]
|
| H A D | web_socket.cc | 148 Send(*message, WebSocketFrameHeader::kOpCodePong, *traffic_annotation_); in Read()
154 WebSocketFrameHeader::OpCodeEnum op_code, in Send()
160 case WebSocketFrameHeader::kOpCodeText: in Send()
164 case WebSocketFrameHeader::kOpCodePong: in Send()
|
| H A D | web_socket.h | 43 WebSocketFrameHeader::OpCodeEnum op_code,
|
| H A D | web_socket_encoder_unittest.cc | 132 first_byte |= WebSocketFrameHeader::OpCodeEnum::kOpCodeText; in GenerateFragmentedFrames()
134 first_byte |= WebSocketFrameHeader::OpCodeEnum::kOpCodeContinuation; in GenerateFragmentedFrames()
|
| /aosp_15_r20/external/webrtc/examples/androidapp/third_party/autobanh/lib/ |
| HD | autobanh.jar | META-INF/MANIFEST.MF
de/tavendo/autobahn/ByteBufferInputStream.class
ByteBufferInputStream.java
... |