Cross Reference: /external/perfetto/src/ipc/buffered_frame_deserializer

Lines Matching defs:bfd
98   BufferedFrameDeserializer bfd;
101     BufferedFrameDeserializer::ReceiveBuffer rbuf = bfd.BeginReceive();
106     ASSERT_TRUE(bfd.EndReceive(frame.size()));
109     auto decoded_frame = bfd.PopNextFrame();
113     ASSERT_FALSE(bfd.PopNextFrame());
114     ASSERT_EQ(0u, bfd.size());
125   BufferedFrameDeserializer bfd;
146   BufferedFrameDeserializer::ReceiveBuffer rbuf = bfd.BeginReceive();
149   ASSERT_TRUE(bfd.EndReceive(simple_frame.size() + frame_chunk1.size()));
153   rbuf = bfd.BeginReceive();
155   ASSERT_TRUE(bfd.EndReceive(frame_chunk2.size()));
159   rbuf = bfd.BeginReceive();
161   ASSERT_TRUE(bfd.EndReceive(frame_chunk3.size()));
164   std::unique_ptr<Frame> decoded_simple_frame = bfd.PopNextFrame();
169   std::unique_ptr<Frame> decoded_frame = bfd.PopNextFrame();
176   BufferedFrameDeserializer bfd;
181   BufferedFrameDeserializer::ReceiveBuffer rbuf = bfd.BeginReceive();
183   ASSERT_TRUE(bfd.EndReceive(frame_chunk1.size()));
185   rbuf = bfd.BeginReceive();
186   ASSERT_TRUE(bfd.EndReceive(0));
188   rbuf = bfd.BeginReceive();
190   ASSERT_TRUE(bfd.EndReceive(frame_chunk2.size()));
193   std::unique_ptr<Frame> decoded_frame = bfd.PopNextFrame();
196   ASSERT_FALSE(bfd.PopNextFrame());
197   ASSERT_EQ(0u, bfd.size());
203   BufferedFrameDeserializer bfd;
206   BufferedFrameDeserializer::ReceiveBuffer rbuf = bfd.BeginReceive();
209   ASSERT_TRUE(bfd.EndReceive(kHeaderSize));
211   rbuf = bfd.BeginReceive();
213   ASSERT_TRUE(bfd.EndReceive(frame.size()));
216   std::unique_ptr<Frame> decoded_frame = bfd.PopNextFrame();
219   ASSERT_FALSE(bfd.PopNextFrame());
225   BufferedFrameDeserializer bfd;
230     BufferedFrameDeserializer::ReceiveBuffer rbuf = bfd.BeginReceive();
237     ASSERT_TRUE(bfd.EndReceive(frame_offset_in_batch));
239       auto frame = bfd.PopNextFrame();
244     ASSERT_FALSE(bfd.PopNextFrame());
245     ASSERT_EQ(0u, bfd.size());
250   BufferedFrameDeserializer bfd;
251   BufferedFrameDeserializer::ReceiveBuffer rbuf = bfd.BeginReceive();
255   ASSERT_FALSE(bfd.EndReceive(kHeaderSize + 20));
262   BufferedFrameDeserializer bfd;
266       BufferedFrameDeserializer::ReceiveBuffer rbuf = bfd.BeginReceive();
270       ASSERT_TRUE(bfd.EndReceive(1));
272         ASSERT_FALSE(bfd.PopNextFrame()) << off << "/" << frame.size();
273         ASSERT_EQ(off + 1, bfd.size());
275         ASSERT_TRUE(bfd.PopNextFrame());
285   BufferedFrameDeserializer bfd;
293     BufferedFrameDeserializer::ReceiveBuffer rbuf = bfd.BeginReceive();
295     ASSERT_TRUE(bfd.EndReceive(frame.size()));
299     auto decoded_frame = bfd.PopNextFrame();
307     ASSERT_EQ(0u, bfd.size());
326   BufferedFrameDeserializer bfd(kMaxCapacity);
345     BufferedFrameDeserializer::ReceiveBuffer rbuf = bfd.BeginReceive();
348     ASSERT_TRUE(bfd.EndReceive(frame1.size() + frame2_chunk1.size()));
350     rbuf = bfd.BeginReceive();
352     ASSERT_TRUE(bfd.EndReceive(frame2_chunk2.size()));
354     rbuf = bfd.BeginReceive();
356     ASSERT_TRUE(bfd.EndReceive(frame3.size()));
358     rbuf = bfd.BeginReceive();
360     ASSERT_TRUE(bfd.EndReceive(frame4.size()));
362     std::unique_ptr<Frame> decoded_frame_1 = bfd.PopNextFrame();
366     std::unique_ptr<Frame> decoded_frame_2 = bfd.PopNextFrame();
370     std::unique_ptr<Frame> decoded_frame_3 = bfd.PopNextFrame();
374     std::unique_ptr<Frame> decoded_frame_4 = bfd.PopNextFrame();
378     ASSERT_FALSE(bfd.PopNextFrame());