Home
last modified time | relevance | path

Searched refs:MessageFramer (Results 1 – 19 of 19) sorted by relevance

/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/cast_channel/
H A Dcast_framer.cc18 MessageFramer::MessageFramer(scoped_refptr<net::GrowableIOBuffer> input_buffer) in MessageFramer() function in cast_channel::MessageFramer
23 MessageFramer::~MessageFramer() {} in ~MessageFramer()
25 MessageFramer::MessageHeader::MessageHeader() : message_size(0) {} in MessageHeader()
27 void MessageFramer::MessageHeader::SetMessageSize(size_t size) { in SetMessageSize()
47 void MessageFramer::MessageHeader::Deserialize(char* data, in Deserialize()
56 size_t MessageFramer::MessageHeader::header_size() { in header_size()
61 size_t MessageFramer::MessageHeader::max_body_size() { in max_body_size()
66 size_t MessageFramer::MessageHeader::max_message_size() { in max_message_size()
70 std::string MessageFramer::MessageHeader::ToString() { in ToString()
90 size_t MessageFramer::BytesRequested() { in BytesRequested()
[all …]
H A Dcast_transport_unittest.cc278 MessageFramer::MessageHeader::header_size(), in TEST_F()
292 socket_cbs.Pop(MessageFramer::MessageHeader::header_size()); in TEST_F()
294 MessageFramer::MessageHeader::header_size()); in TEST_F()
318 MessageFramer::MessageHeader::header_size(), in TEST_F()
334 socket_cbs.Pop(MessageFramer::MessageHeader::header_size()); in TEST_F()
336 MessageFramer::MessageHeader::header_size() - 1); in TEST_F()
387 MessageFramer::MessageHeader::header_size(), in TEST_F()
398 socket_cbs.Pop(MessageFramer::MessageHeader::header_size()); in TEST_F()
415 for (size_t i = MessageFramer::MessageHeader::header_size(); in TEST_F()
442 socket_cbs.Pop(MessageFramer::MessageHeader::header_size()); in TEST_F()
[all …]
H A Dcast_framer_unittest.cc31 ASSERT_TRUE(MessageFramer::Serialize(cast_message_, &cast_message_str_)); in SetUp()
34 buffer_->SetCapacity(MessageFramer::MessageHeader::max_message_size()); in SetUp()
35 framer_.reset(new MessageFramer(buffer_.get())); in SetUp()
46 std::unique_ptr<MessageFramer> framer_;
66 cast_message_str_.size() - MessageFramer::MessageHeader::header_size(), in TEST_F()
84 payload.append(MessageFramer::MessageHeader::max_body_size() + 1, 'x'); in TEST_F()
86 EXPECT_FALSE(MessageFramer::Serialize(big_message, &serialized)); in TEST_F()
139 for (size_t i = MessageFramer::MessageHeader::header_size(); in TEST_F()
142 MessageFramer::MessageHeader::header_size(), in TEST_F()
H A Dcast_message_fuzzer.cc23 if (size > MessageFramer::MessageHeader::max_message_size()) in LLVMFuzzerTestOneInput()
28 buffer->SetCapacity(MessageFramer::MessageHeader::max_message_size()); in LLVMFuzzerTestOneInput()
31 std::unique_ptr<MessageFramer> framer = in LLVMFuzzerTestOneInput()
32 std::make_unique<MessageFramer>(buffer.get()); in LLVMFuzzerTestOneInput()
H A Dcast_framer.h24 class MessageFramer {
30 explicit MessageFramer(scoped_refptr<net::GrowableIOBuffer> input_buffer);
31 ~MessageFramer();
102 DISALLOW_COPY_AND_ASSIGN(MessageFramer);
H A Dcast_transport.h32 class MessageFramer; variable
173 std::unique_ptr<MessageFramer> framer_;
H A Dcast_socket_unittest.cc915 EXPECT_TRUE(MessageFramer::Serialize(challenge, &challenge_str)); in TEST_F()
921 EXPECT_TRUE(MessageFramer::Serialize(reply, &reply_str)); in TEST_F()
931 EXPECT_TRUE(MessageFramer::Serialize(test_message, &test_message_str)); in TEST_F()
961 EXPECT_TRUE(MessageFramer::Serialize(challenge, &challenge_str)); in TEST_F()
968 EXPECT_TRUE(MessageFramer::Serialize(reply, &reply_str)); in TEST_F()
978 EXPECT_TRUE(MessageFramer::Serialize(test_message, &test_message_str)); in TEST_F()
1072 EXPECT_TRUE(MessageFramer::Serialize(challenge, &challenge_str)); in TEST_F()
1087 EXPECT_TRUE(MessageFramer::Serialize(reply, &reply_str)); in TEST_F()
1111 EXPECT_TRUE(MessageFramer::Serialize(challenge, &challenge_str)); in TEST_F()
1127 EXPECT_TRUE(MessageFramer::Serialize(reply, &reply_str)); in TEST_F()
[all …]
H A Dcast_transport.cc62 read_buffer_->SetCapacity(MessageFramer::MessageHeader::max_message_size()); in CastTransportImpl()
63 framer_.reset(new MessageFramer(read_buffer_)); in CastTransportImpl()
103 if (!MessageFramer::Serialize(message, &serialized_message)) { in SendMessage()
H A DBUILD.gn115 # See MessageFramer::MessageHeader::max_message_size()
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/cast_channel/
H A Dcast_framer.cc20 MessageFramer::MessageFramer(scoped_refptr<net::GrowableIOBuffer> input_buffer) in MessageFramer() function in cast_channel::MessageFramer
25 MessageFramer::~MessageFramer() {} in ~MessageFramer()
27 MessageFramer::MessageHeader::MessageHeader() : message_size(0) {} in MessageHeader()
29 void MessageFramer::MessageHeader::SetMessageSize(size_t size) { in SetMessageSize()
49 void MessageFramer::MessageHeader::Deserialize(char* data, in Deserialize()
58 size_t MessageFramer::MessageHeader::header_size() { in header_size()
63 size_t MessageFramer::MessageHeader::max_body_size() { in max_body_size()
68 size_t MessageFramer::MessageHeader::max_message_size() { in max_message_size()
72 std::string MessageFramer::MessageHeader::ToString() { in ToString()
92 size_t MessageFramer::BytesRequested() { in BytesRequested()
[all …]
H A Dcast_transport_unittest.cc278 MessageFramer::MessageHeader::header_size(), in TEST_F()
292 socket_cbs.Pop(MessageFramer::MessageHeader::header_size()); in TEST_F()
294 MessageFramer::MessageHeader::header_size()); in TEST_F()
318 MessageFramer::MessageHeader::header_size(), in TEST_F()
334 socket_cbs.Pop(MessageFramer::MessageHeader::header_size()); in TEST_F()
336 MessageFramer::MessageHeader::header_size() - 1); in TEST_F()
387 MessageFramer::MessageHeader::header_size(), in TEST_F()
398 socket_cbs.Pop(MessageFramer::MessageHeader::header_size()); in TEST_F()
415 for (size_t i = MessageFramer::MessageHeader::header_size(); in TEST_F()
442 socket_cbs.Pop(MessageFramer::MessageHeader::header_size()); in TEST_F()
[all …]
H A Dcast_framer_unittest.cc31 ASSERT_TRUE(MessageFramer::Serialize(cast_message_, &cast_message_str_)); in SetUp()
34 buffer_->SetCapacity(MessageFramer::MessageHeader::max_message_size()); in SetUp()
35 framer_.reset(new MessageFramer(buffer_.get())); in SetUp()
46 std::unique_ptr<MessageFramer> framer_;
66 cast_message_str_.size() - MessageFramer::MessageHeader::header_size(), in TEST_F()
84 payload.append(MessageFramer::MessageHeader::max_body_size() + 1, 'x'); in TEST_F()
86 EXPECT_FALSE(MessageFramer::Serialize(big_message, &serialized)); in TEST_F()
139 for (size_t i = MessageFramer::MessageHeader::header_size(); in TEST_F()
142 MessageFramer::MessageHeader::header_size(), in TEST_F()
H A Dcast_framer_ingest_fuzzer.cc22 if (size > MessageFramer::MessageHeader::max_message_size()) in LLVMFuzzerTestOneInput()
27 buffer->SetCapacity(MessageFramer::MessageHeader::max_message_size()); in LLVMFuzzerTestOneInput()
30 std::unique_ptr<MessageFramer> framer = in LLVMFuzzerTestOneInput()
31 std::make_unique<MessageFramer>(buffer.get()); in LLVMFuzzerTestOneInput()
H A Dcast_framer.h24 class MessageFramer {
30 explicit MessageFramer(scoped_refptr<net::GrowableIOBuffer> input_buffer);
31 ~MessageFramer();
102 DISALLOW_COPY_AND_ASSIGN(MessageFramer);
H A Dcast_transport.h32 class MessageFramer; variable
173 std::unique_ptr<MessageFramer> framer_;
H A Dcast_socket_unittest.cc918 EXPECT_TRUE(MessageFramer::Serialize(challenge, &challenge_str)); in TEST_F()
924 EXPECT_TRUE(MessageFramer::Serialize(reply, &reply_str)); in TEST_F()
934 EXPECT_TRUE(MessageFramer::Serialize(test_message, &test_message_str)); in TEST_F()
964 EXPECT_TRUE(MessageFramer::Serialize(challenge, &challenge_str)); in TEST_F()
971 EXPECT_TRUE(MessageFramer::Serialize(reply, &reply_str)); in TEST_F()
981 EXPECT_TRUE(MessageFramer::Serialize(test_message, &test_message_str)); in TEST_F()
1075 EXPECT_TRUE(MessageFramer::Serialize(challenge, &challenge_str)); in TEST_F()
1090 EXPECT_TRUE(MessageFramer::Serialize(reply, &reply_str)); in TEST_F()
1114 EXPECT_TRUE(MessageFramer::Serialize(challenge, &challenge_str)); in TEST_F()
1130 EXPECT_TRUE(MessageFramer::Serialize(reply, &reply_str)); in TEST_F()
[all …]
H A Dcast_framer_serialize_fuzzer.cc18 MessageFramer::Serialize(input, &native_input); in DEFINE_PROTO_FUZZER()
H A Dcast_transport.cc62 read_buffer_->SetCapacity(MessageFramer::MessageHeader::max_message_size()); in CastTransportImpl()
63 framer_.reset(new MessageFramer(read_buffer_)); in CastTransportImpl()
103 if (!MessageFramer::Serialize(message, &serialized_message)) { in SendMessage()
H A DBUILD.gn172 # See MessageFramer::MessageHeader::max_message_size()