Home
last modified time | relevance | path

Searched refs:packet_buffer (Results 1 – 25 of 70) sorted by relevance

123

/external/webrtc/modules/video_coding/
Dh264_packet_buffer_unittest.cc246 H264PacketBuffer packet_buffer(/*allow_idr_only_keyframes=*/true); in TEST() local
249 packet_buffer.InsertPacket(Packet(kH264SingleNalu).Idr().Marker().Build()) in TEST()
255 H264PacketBuffer packet_buffer(/*allow_idr_only_keyframes=*/false); in TEST() local
258 packet_buffer.InsertPacket(Packet(kH264SingleNalu).Idr().Marker().Build()) in TEST()
264 H264PacketBuffer packet_buffer(/*allow_idr_only_keyframes=*/true); in TEST() local
268 packet_buffer in TEST()
273 EXPECT_THAT(packet_buffer in TEST()
280 EXPECT_THAT(packet_buffer in TEST()
290 EXPECT_THAT(packet_buffer in TEST()
298 H264PacketBuffer packet_buffer(/*allow_idr_only_keyframes=*/false); in TEST() local
[all …]
/external/pigweed/pw_bluetooth_hci/
Duart_transport_test.cc67 std::array<std::byte, CommandPacket::kHeaderSizeBytes> packet_buffer; in TEST_F() local
69 const Result<ConstByteSpan> result = packet.Encode(packet_buffer); in TEST_F()
84 std::array<std::byte, CommandPacket::kHeaderSizeBytes> packet_buffer; in TEST_F() local
86 const Result<ConstByteSpan> result = packet.Encode(packet_buffer); in TEST_F()
116 std::array<std::byte, AsyncDataPacket::kHeaderSizeBytes> packet_buffer; in TEST_F() local
118 const Result<ConstByteSpan> result = packet.Encode(packet_buffer); in TEST_F()
133 std::array<std::byte, AsyncDataPacket::kHeaderSizeBytes> packet_buffer; in TEST_F() local
135 const Result<ConstByteSpan> result = packet.Encode(packet_buffer); in TEST_F()
165 std::array<std::byte, SyncDataPacket::kHeaderSizeBytes> packet_buffer; in TEST_F() local
167 const Result<ConstByteSpan> result = packet.Encode(packet_buffer); in TEST_F()
[all …]
/external/pigweed/pw_rpc_transport/public/pw_rpc_transport/
Dlocal_rpc_egress.h106 auto packet_buffer = packet_queue_.Pop(); in SendRpcPacket() local
107 if (!packet_buffer.ok()) { in SendRpcPacket()
108 internal::LogNoPacketAvailable(packet_buffer.status()); in SendRpcPacket()
109 return packet_buffer.status(); in SendRpcPacket()
112 PW_TRY(packet_buffer.value()->CopyPacket(packet)); in SendRpcPacket()
114 transmit_queue_.Push(**packet_buffer); in SendRpcPacket()
134 Result<PacketBuffer*> packet_buffer = transmit_queue_.Pop(); in Run() local
135 if (!packet_buffer.ok()) { in Run()
138 Result<ConstByteSpan> packet = (*packet_buffer)->GetPacket(); in Run()
147 packet_queue_.Push(**packet_buffer); in Run()
/external/rust/android-crates-io/crates/gdbstub/src/stub/
Dbuilder.rs41 packet_buffer: Option<&'a mut [u8]>, field
52 packet_buffer: None, in new()
62 pub fn with_packet_buffer(mut self, packet_buffer: &'a mut [u8]) -> Self { in with_packet_buffer()
63 self.packet_buffer = Some(packet_buffer); in with_packet_buffer()
78 let packet_buffer = match self.packet_buffer { in build() localVariable
109 packet_buffer, in build()
Dstate_machine.rs169 packet_buffer: ManagedSlice<'a, u8>, field
200 packet_buffer: stub.packet_buffer, in from_plain_gdbstub()
216 let packet_buffer = match self.i.recv_packet.pump(&mut self.i.packet_buffer, byte)? { in incoming_data() localVariable
221 let packet = Packet::from_buf(target, packet_buffer).map_err(InternalError::PacketParse)?; in incoming_data()
280 let packet_buffer = match self.i.recv_packet.pump(&mut self.i.packet_buffer, byte)? { in incoming_data() localVariable
285 let packet = Packet::from_buf(target, packet_buffer).map_err(InternalError::PacketParse)?; in incoming_data()
/external/perfetto/src/trace_redaction/
Dredact_sched_events_unittest.cc136 auto packet_buffer = packet_.SerializeAsString(); in TEST_F() local
138 ASSERT_OK(redact_.Transform(context_, &packet_buffer)); in TEST_F()
141 ASSERT_TRUE(packet.ParseFromString(packet_buffer)); in TEST_F()
167 auto packet_buffer = packet_.SerializeAsString(); in TEST_F() local
169 ASSERT_OK(redact_.Transform(context_, &packet_buffer)); in TEST_F()
172 ASSERT_TRUE(packet.ParseFromString(packet_buffer)); in TEST_F()
242 auto packet_buffer = packet_.SerializeAsString(); in TEST_F() local
244 ASSERT_OK(redact_.Transform(context_, &packet_buffer)); in TEST_F()
247 ASSERT_TRUE(packet.ParseFromString(packet_buffer)); in TEST_F()
273 auto packet_buffer = packet_.SerializeAsString(); in TEST_F() local
[all …]
/external/pigweed/pw_rpc_transport/internal/
Dpacket_buffer_queue_test.cc30 PacketBufferQueue<kMaxPacketSize>::PacketBuffer packet_buffer = {}; in TEST() local
34 auto packet = packet_buffer.GetPacket(); in TEST()
38 ASSERT_EQ(packet_buffer.CopyPacket(input), OkStatus()); in TEST()
40 packet = packet_buffer.GetPacket(); in TEST()
47 EXPECT_EQ(packet_buffer.CopyPacket(long_input), Status::ResourceExhausted()); in TEST()
70 PacketBufferQueue<kMaxPacketSize>::PacketBuffer packet_buffer; in TEST() local
77 queue.Push(packet_buffer); in TEST()
/external/pigweed/pw_rpc/size_report/
Dserver_only.cc47 std::byte packet_buffer[128]; in main() local
48 pw::sys_io::ReadBytes(packet_buffer) in main()
50 pw::sys_io::WriteBytes(packet_buffer) in main()
53 my_product::server.ProcessPacket(packet_buffer) in main()
56 return static_cast<int>(packet_buffer[92]); in main()
Dbase.cc29 std::byte packet_buffer[128]; in main() local
30 pw::sys_io::ReadBytes(packet_buffer) in main()
32 pw::sys_io::WriteBytes(packet_buffer) in main()
35 return static_cast<int>(packet_buffer[92]); in main()
Dserver_with_echo_service.cc77 std::byte packet_buffer[128]; in main() local
78 pw::sys_io::ReadBytes(packet_buffer); in main()
79 pw::sys_io::WriteBytes(packet_buffer); in main()
82 my_product::server.ProcessPacket(packet_buffer); in main()
84 return static_cast<int>(packet_buffer[92]); in main()
Dbase_with_nanopb.cc61 std::byte packet_buffer[128]; in main() local
62 pw::sys_io::ReadBytes(packet_buffer); in main()
63 pw::sys_io::WriteBytes(packet_buffer); in main()
65 return static_cast<int>(packet_buffer[92]); in main()
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/
Dquic_packet_reader.cc27 read_results_[i].packet_buffer.buffer = read_buffers_[i].packet_buffer; in QuicPacketReader()
28 read_results_[i].packet_buffer.buffer_len = in QuicPacketReader()
29 sizeof(read_buffers_[i].packet_buffer); in QuicPacketReader()
45 /*packet_buffer_length=*/sizeof(read_buffers_[i].packet_buffer)); in ReadAndDispatchPackets()
107 result.packet_buffer.buffer, result.packet_buffer.buffer_len, now, in ReadAndDispatchPackets()
Dquic_udp_socket_test.cc60 read_result.packet_buffer = {&packet_buffer_[0], sizeof(packet_buffer_)}; in TEST_F()
66 absl::string_view(read_result.packet_buffer.buffer, in TEST_F()
67 read_result.packet_buffer.buffer_len)); in TEST_F()
79 absl::string_view(read_result.packet_buffer.buffer, in TEST_F()
80 read_result.packet_buffer.buffer_len)); in TEST_F()
116 read_result.packet_buffer = {&packet_buffer_[0], sizeof(packet_buffer_)}; in TEST_F()
Dquic_udp_socket_posix.inc294 BufferSpan& packet_buffer = result->packet_buffer;
300 struct iovec iov = {packet_buffer.buffer, packet_buffer.buffer_len};
319 // if |packet_buffer| is too small to receive it.
342 // Normally "bytes_read > packet_buffer.buffer_len" implies the MSG_TRUNC
344 static_cast<size_t>(bytes_read) > packet_buffer.buffer_len) {
347 << packet_buffer.buffer_len << " packet size:" << bytes_read;
351 packet_buffer.buffer_len = bytes_read;
407 packet_data->iov.iov_base = (*results)[i].packet_buffer.buffer;
408 packet_data->iov.iov_len = (*results)[i].packet_buffer.buffer_len;
448 << (*results)[i].packet_buffer.buffer_len
[all …]
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/
Dquic_packet_reader.cc27 read_results_[i].packet_buffer.buffer = read_buffers_[i].packet_buffer; in QuicPacketReader()
28 read_results_[i].packet_buffer.buffer_len = in QuicPacketReader()
29 sizeof(read_buffers_[i].packet_buffer); in QuicPacketReader()
45 /*packet_buffer_length=*/sizeof(read_buffers_[i].packet_buffer)); in ReadAndDispatchPackets()
107 result.packet_buffer.buffer, result.packet_buffer.buffer_len, now, in ReadAndDispatchPackets()
Dquic_udp_socket_test.cc60 read_result.packet_buffer = {&packet_buffer_[0], sizeof(packet_buffer_)}; in TEST_F()
66 absl::string_view(read_result.packet_buffer.buffer, in TEST_F()
67 read_result.packet_buffer.buffer_len)); in TEST_F()
79 absl::string_view(read_result.packet_buffer.buffer, in TEST_F()
80 read_result.packet_buffer.buffer_len)); in TEST_F()
116 read_result.packet_buffer = {&packet_buffer_[0], sizeof(packet_buffer_)}; in TEST_F()
Dquic_udp_socket_posix.inc294 BufferSpan& packet_buffer = result->packet_buffer;
300 struct iovec iov = {packet_buffer.buffer, packet_buffer.buffer_len};
319 // if |packet_buffer| is too small to receive it.
342 // Normally "bytes_read > packet_buffer.buffer_len" implies the MSG_TRUNC
344 static_cast<size_t>(bytes_read) > packet_buffer.buffer_len) {
347 << packet_buffer.buffer_len << " packet size:" << bytes_read;
351 packet_buffer.buffer_len = bytes_read;
407 packet_data->iov.iov_base = (*results)[i].packet_buffer.buffer;
408 packet_data->iov.iov_len = (*results)[i].packet_buffer.buffer_len;
448 << (*results)[i].packet_buffer.buffer_len
[all …]
/external/webrtc/test/fuzzers/
Dforward_error_correction_fuzzer.cc72 uint8_t* packet_buffer = received_packet.pkt->data.MutableData(); in FuzzOneInput() local
78 if (!fuzz_buffer.ReadBytes(reinterpret_cast<char*>(packet_buffer), in FuzzOneInput()
100 packet_buffer[0] = 0; // R, F bits. in FuzzOneInput()
101 ByteWriter<uint8_t>::WriteBigEndian(&packet_buffer[8], 1); // SSRCCount. in FuzzOneInput()
102 ByteWriter<uint32_t>::WriteBigEndian(&packet_buffer[12], in FuzzOneInput()
105 &packet_buffer[16], original_media_seqnum); // SN base_i. in FuzzOneInput()
/external/pigweed/pw_router/size_report/
Dstatic_router_with_one_route.cc75 std::array<std::byte, sizeof(BasicPacket)> packet_buffer; in main() local
76 if (!pw::sys_io::ReadBytes(packet_buffer).ok()) { in main()
80 if (!pw::sys_io::WriteBytes(packet_buffer).ok()) { in main()
88 if (!pw::sys_io::ReadBytes(packet_buffer).ok()) { in main()
92 if (!router.RoutePacket(packet_buffer, parser).ok()) { in main()
Dbase.cc46 std::array<std::byte, sizeof(BasicPacket)> packet_buffer; in main() local
47 pw::sys_io::ReadBytes(packet_buffer).IgnoreError(); in main()
48 pw::sys_io::WriteBytes(packet_buffer).IgnoreError(); in main()
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/test_tools/fuzzing/
Dquic_framer_process_data_packet_fuzzer.cc209 std::array<char, kEthernetMTU> packet_buffer; in LLVMFuzzerTestOneInput() local
229 packet_buffer.size(), in LLVMFuzzerTestOneInput()
234 QuicDataWriter writer(packet_buffer.size(), packet_buffer.data()); in LLVMFuzzerTestOneInput()
250 writer.length(), packet_buffer.size(), packet_buffer.data()); in LLVMFuzzerTestOneInput()
255 QuicEncryptedPacket packet(packet_buffer.data(), encrypted_length); in LLVMFuzzerTestOneInput()
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/test_tools/fuzzing/
Dquic_framer_process_data_packet_fuzzer.cc209 std::array<char, kEthernetMTU> packet_buffer; in LLVMFuzzerTestOneInput() local
229 packet_buffer.size(), in LLVMFuzzerTestOneInput()
234 QuicDataWriter writer(packet_buffer.size(), packet_buffer.data()); in LLVMFuzzerTestOneInput()
250 writer.length(), packet_buffer.size(), packet_buffer.data()); in LLVMFuzzerTestOneInput()
255 QuicEncryptedPacket packet(packet_buffer.data(), encrypted_length); in LLVMFuzzerTestOneInput()
/external/rust/android-crates-io/crates/gdbstub/src/protocol/
Drecv_packet.rs30 packet_buffer: &'b mut ManagedSlice<'_, u8>, in pump()
33 let mut buf = ManagedVec::new_with_idx(packet_buffer, self.idx); in pump()
61 Ok(Some(packet_buffer)) in pump()
/external/webrtc/modules/audio_coding/neteq/tools/
Dconstant_pcm_packet_source.cc40 rtc::CopyOnWriteBuffer packet_buffer(packet_len_bytes_); in NextPacket() local
41 uint8_t* packet_memory = packet_buffer.MutableData(); in NextPacket()
48 std::make_unique<Packet>(std::move(packet_buffer), next_arrival_time_ms_); in NextPacket()
/external/pigweed/pw_rpc/public/pw_rpc/internal/
Dclient_server_testing.h52 std::array<std::byte, kOutputSize> packet_buffer; in ForwardNextPacket() local
53 Result<ConstByteSpan> result = EncodeNextUnsentPacket(packet_buffer); in ForwardNextPacket()
89 std::array<std::byte, kPayloadsBufferSizeBytes>& packet_buffer) { in EncodeNextUnsentPacket() argument
95 return packets[sent_packets_].Encode(packet_buffer); in EncodeNextUnsentPacket()

123