Lines Matching full:buffer_
37 MessageBufferTest() : buffer_{kBufferSizeBytes} {}
48 EXPECT_TRUE(buffer_.Append(message.data(), message.size()));
50 EXPECT_EQ(0U, buffer_.GetFreeSize());
57 std::tie(start, len) = buffer_.ConsumeNextMessage();
61 MessageBuffer buffer_;
67 EXPECT_TRUE(buffer_.Append(kSmallestMessage.data(), kSmallestMessage.size()));
71 EXPECT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
75 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
76 ASSERT_FALSE(buffer_.CanFitNow(1));
78 buffer_.Clear();
79 EXPECT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
87 while (buffer_.CanFitNow(message.size())) {
88 ASSERT_TRUE(buffer_.Append(message.data(), message.size()));
95 buffer_.Append(oversized_message.data(), oversized_message.size()));
100 ASSERT_FALSE(buffer_.CanFitNow(expected_free + 1));
104 buffer_.Append(oversized_message.data(), oversized_message.size()));
112 EXPECT_TRUE(buffer_.CanFitNow(kLargestMessage.size()));
113 EXPECT_FALSE(buffer_.CanFitNow(kLargestMessage.size() + 1));
117 ASSERT_TRUE(buffer_.Append(kSmallestMessage.data(), kSmallestMessage.size()));
122 EXPECT_TRUE(buffer_.CanFitNow(expected_free));
123 EXPECT_FALSE(buffer_.CanFitNow(expected_free + 1));
127 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
128 EXPECT_FALSE(buffer_.CanFitNow(1));
132 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
133 buffer_.Rewind();
134 EXPECT_FALSE(buffer_.CanFitNow(1));
138 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
139 ASSERT_FALSE(buffer_.CanFitNow(1));
141 buffer_.Clear();
142 EXPECT_TRUE(buffer_.CanFitNow(kLargestMessage.size()));
146 EXPECT_TRUE(buffer_.CanFitEver(kLargestMessage.size()));
147 EXPECT_FALSE(buffer_.CanFitEver(kLargestMessage.size() + 1));
151 ASSERT_TRUE(buffer_.Append(kSmallestMessage.data(), kSmallestMessage.size()));
152 EXPECT_TRUE(buffer_.CanFitEver(kLargestMessage.size()));
153 EXPECT_FALSE(buffer_.CanFitEver(kLargestMessage.size() + 1));
157 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
158 EXPECT_TRUE(buffer_.CanFitEver(kLargestMessage.size()));
159 EXPECT_FALSE(buffer_.CanFitEver(kLargestMessage.size() + 1));
163 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
164 buffer_.Rewind();
165 EXPECT_TRUE(buffer_.CanFitEver(kLargestMessage.size()));
166 EXPECT_FALSE(buffer_.CanFitEver(kLargestMessage.size() + 1));
170 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
171 buffer_.Clear();
172 EXPECT_TRUE(buffer_.CanFitEver(kLargestMessage.size()));
173 EXPECT_FALSE(buffer_.CanFitEver(kLargestMessage.size() + 1));
178 EXPECT_EQ(expected, buffer_.ConsumeNextMessage());
182 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
183 buffer_.Clear();
186 EXPECT_EQ(expected, buffer_.ConsumeNextMessage());
190 ASSERT_TRUE(buffer_.Append(kSmallestMessage.data(), kSmallestMessage.size()));
192 const auto& ptr_and_size = buffer_.ConsumeNextMessage();
198 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
200 const auto& ptr_and_size = buffer_.ConsumeNextMessage();
207 ASSERT_TRUE(buffer_.Append(kSmallestMessage.data(), kSmallestMessage.size()));
208 buffer_.ConsumeNextMessage();
211 EXPECT_EQ(expected, buffer_.ConsumeNextMessage());
216 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
217 buffer_.ConsumeNextMessage();
220 EXPECT_EQ(expected, buffer_.ConsumeNextMessage());
227 while (std::get<0>(buffer_.ConsumeNextMessage())) {
233 EXPECT_EQ(expected, buffer_.ConsumeNextMessage());
239 while (std::get<0>(buffer_.ConsumeNextMessage())) {
242 buffer_.Rewind();
245 while (std::get<0>(buffer_.ConsumeNextMessage())) {
257 while (buffer_.CanFitNow(message.size())) {
258 ASSERT_TRUE(buffer_.Append(message.data(), message.size()));
263 while (std::get<0>(buffer_.ConsumeNextMessage())) {
273 buffer_.Append(message1.data(), static_cast<uint16_t>(message1.size())));
275 buffer_.Append(message2.data(), static_cast<uint16_t>(message2.size())));
281 EXPECT_EQ(kBufferSizeBytes, buffer_.GetFreeSize());
285 ASSERT_TRUE(buffer_.Append(kSmallestMessage.data(), kSmallestMessage.size()));
287 buffer_.GetFreeSize());
291 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
292 EXPECT_EQ(0U, buffer_.GetFreeSize());
296 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
297 buffer_.Rewind();
298 EXPECT_EQ(0U, buffer_.GetFreeSize());
302 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size()));
303 buffer_.Clear();
304 EXPECT_EQ(kBufferSizeBytes, buffer_.GetFreeSize());
310 buffer_.Append(message1.data(), static_cast<uint16_t>(message1.size())));
311 buffer_.Rewind();
315 buffer_.Append(message2.data(), static_cast<uint16_t>(message2.size())));
328 EXPECT_DEATH(buffer_.Append(message.data(), 0), "Check failed");
