Home
last modified time | relevance | path

Searched refs:payload_len (Results 1 – 25 of 82) sorted by relevance

1234

/external/linux-kselftest/tools/testing/selftests/net/
Dip_defrag.c36 static int payload_len; variable
59 ret = recv(fd_udp, recv_buff, payload_len, 0); in recv_validate_udp()
75 payload_len, max_frag_len); in recv_validate_udp()
76 if (ret != payload_len) in recv_validate_udp()
77 error(1, 0, "recv: wrong size: %d vs %d", (int)ret, payload_len); in recv_validate_udp()
78 if (memcmp(udp_payload, recv_buff, payload_len)) in recv_validate_udp()
107 IPPROTO_UDP + (uint32_t)(UDP_HLEN + payload_len)); in udp_checksum()
109 sum = raw_checksum((uint8_t *)udp_payload, payload_len, sum); in udp_checksum()
126 sum = raw_checksum((uint8_t *)udp_payload, payload_len, sum); in udp6_checksum()
147 udphdr.len = htons(UDP_HLEN + payload_len); in send_fragment()
[all …]
Dpsock_snd.c117 static int build_ipv4_header(void *header, int payload_len) in build_ipv4_header() argument
124 iph->tot_len = htons(sizeof(*iph) + sizeof(struct udphdr) + payload_len); in build_ipv4_header()
134 static int build_udp_header(void *header, int payload_len) in build_udp_header() argument
138 int len = sizeof(*udph) + payload_len; in build_udp_header()
153 static int build_packet(int payload_len) in build_packet() argument
159 off += build_ipv4_header(tbuf + off, payload_len); in build_packet()
160 off += build_udp_header(tbuf + off, payload_len); in build_packet()
162 if (off + payload_len > sizeof(tbuf)) in build_packet()
165 memset(tbuf + off, DATA_CHAR, payload_len); in build_packet()
167 return off + payload_len; in build_packet()
Dmsg_zerocopy.c230 int i, payload_len, extra_len; in do_sendmsg_corked() local
233 payload_len = cfg_payload_len / cfg_cork; in do_sendmsg_corked()
234 extra_len = cfg_payload_len - (cfg_cork * payload_len); in do_sendmsg_corked()
246 msg->msg_iov[0].iov_len = payload_len + extra_len; in do_sendmsg_corked()
257 static int setup_iph(struct iphdr *iph, uint16_t payload_len) in setup_iph() argument
271 iph->tot_len = htons(sizeof(*iph) + payload_len); in setup_iph()
277 static int setup_ip6h(struct ipv6hdr *ip6h, uint16_t payload_len) in setup_ip6h() argument
285 ip6h->payload_len = htons(payload_len); in setup_ip6h()
/external/webrtc/modules/rtp_rtcp/source/
Drtp_format.cc67 int payload_len, in SplitAboutEqually() argument
69 RTC_DCHECK_GT(payload_len, 0); in SplitAboutEqually()
76 limits.single_packet_reduction_len + payload_len) { in SplitAboutEqually()
77 result.push_back(payload_len); in SplitAboutEqually()
89 int total_bytes = payload_len + limits.first_packet_reduction_len + in SplitAboutEqually()
99 if (payload_len < num_packets_left) { in SplitAboutEqually()
109 int remaining_data = payload_len; in SplitAboutEqually()
/external/linux-kselftest/tools/testing/selftests/bpf/progs/
Dtest_xdp_loop.c85 __u16 payload_len; in handle_ipv4() local
102 payload_len = bpf_ntohs(iph->tot_len); in handle_ipv4()
132 iph->tot_len = bpf_htons(payload_len + sizeof(*iph)); in handle_ipv4()
157 __u16 payload_len; in handle_ipv6() local
172 payload_len = ip6h->payload_len; in handle_ipv6()
198 ip6h->payload_len = bpf_htons(bpf_ntohs(payload_len) + sizeof(*ip6h)); in handle_ipv6()
Dtest_xdp.c89 __u16 payload_len; in handle_ipv4() local
106 payload_len = bpf_ntohs(iph->tot_len); in handle_ipv4()
136 iph->tot_len = bpf_htons(payload_len + sizeof(*iph)); in handle_ipv4()
161 __u16 payload_len; in handle_ipv6() local
176 payload_len = ip6h->payload_len; in handle_ipv6()
202 ip6h->payload_len = bpf_htons(bpf_ntohs(payload_len) + sizeof(*ip6h)); in handle_ipv6()
/external/webrtc/modules/audio_coding/neteq/
Dpacket_buffer_unittest.cc121 const int payload_len = 100; in TEST() local
122 const Packet packet = gen.NextPacket(payload_len, nullptr); in TEST()
141 const int payload_len = 10; in TEST() local
148 buffer.InsertPacket(gen.NextPacket(payload_len, nullptr), &mock_stats)); in TEST()
167 const int payload_len = 10; in TEST() local
172 buffer.InsertPacket(gen.NextPacket(payload_len, nullptr), &mock_stats)); in TEST()
179 const Packet packet = gen.NextPacket(payload_len, nullptr); in TEST()
198 const int payload_len = 10; in TEST() local
202 list.push_back(gen.NextPacket(payload_len, nullptr)); in TEST()
237 const int payload_len = 10; in TEST() local
[all …]
/external/grpc-grpc/tools/codegen/core/
Dgen_header_frame.py82 payload_len = 0 variable
88 payload_len += len(payload_line)
97 (payload_len >> 16) & 0xff,
98 (payload_len >> 8) & 0xff,
99 (payload_len) & 0xff,
/external/rust/crates/grpcio-sys/grpc/tools/codegen/core/
Dgen_header_frame.py87 payload_len = 0 variable
93 payload_len += len(payload_line)
102 (payload_len >> 16) & 0xff,
103 (payload_len >> 8) & 0xff,
104 (payload_len) & 0xff,
/external/wpa_supplicant_8/src/eap_peer/
Deap_pwd.c255 const u8 *payload, size_t payload_len) in eap_pwd_perform_id_exchange() argument
265 if (payload_len < sizeof(struct eap_pwd_id)) { in eap_pwd_perform_id_exchange()
316 data->id_server = os_malloc(payload_len - sizeof(struct eap_pwd_id)); in eap_pwd_perform_id_exchange()
322 data->id_server_len = payload_len - sizeof(struct eap_pwd_id); in eap_pwd_perform_id_exchange()
356 const u8 *payload, size_t payload_len) in eap_pwd_perform_commit_exchange() argument
396 if (payload_len != 2 * prime_len + order_len) { in eap_pwd_perform_commit_exchange()
399 (unsigned int) payload_len, in eap_pwd_perform_commit_exchange()
427 if (payload_len < 1 || *ptr == 0) { in eap_pwd_perform_commit_exchange()
433 if (payload_len != exp_len) { in eap_pwd_perform_commit_exchange()
436 (unsigned int) payload_len, in eap_pwd_perform_commit_exchange()
[all …]
Deap_sake.c145 size_t payload_len) in eap_sake_process_identity() argument
157 if (eap_sake_parse_attributes(payload, payload_len, &attr)) in eap_sake_process_identity()
188 size_t payload_len) in eap_sake_process_challenge() argument
206 if (eap_sake_parse_attributes(payload, payload_len, &attr)) in eap_sake_process_challenge()
291 size_t payload_len) in eap_sake_process_confirm() argument
305 if (eap_sake_parse_attributes(payload, payload_len, &attr)) in eap_sake_process_confirm()
/external/webrtc/modules/audio_coding/neteq/tools/
Dneteq_performance_test.cc74 size_t payload_len = WebRtcPcm16b_Encode(input_samples.data(), in Run() local
76 RTC_CHECK_EQ(sizeof(input_payload), payload_len); in Run()
101 payload_len = WebRtcPcm16b_Encode(input_samples.data(), in Run()
103 RTC_DCHECK_EQ(payload_len, kInputBlockSizeSamples * sizeof(int16_t)); in Run()
/external/android-clat/
Dnetlink_msg.c56 size_t payload_len) { in nlmsg_alloc_generic() argument
64 if ((sizeof(struct nl_msg) + payload_len) > msg->nm_size) { in nlmsg_alloc_generic()
69 msg->nm_nlh->nlmsg_len = NLMSG_LENGTH(payload_len); in nlmsg_alloc_generic()
73 memcpy(nlmsg_data(msg->nm_nlh), payload_struct, payload_len); in nlmsg_alloc_generic()
/external/webrtc/modules/audio_coding/neteq/test/
Dneteq_decoding_test.cc203 size_t* payload_len) { in PopulateCng() argument
210 *payload_len = 1; // Only noise level, no spectral parameters. in PopulateCng()
334 size_t payload_len; in LongCngWithClockDrift() local
336 PopulateCng(seq_no, timestamp, &rtp_info, payload, &payload_len); in LongCngWithClockDrift()
338 payload, payload_len))); in LongCngWithClockDrift()
376 size_t payload_len; in LongCngWithClockDrift() local
378 PopulateCng(seq_no, timestamp, &rtp_info, payload, &payload_len); in LongCngWithClockDrift()
380 payload, payload_len))); in LongCngWithClockDrift()
/external/rust/crates/quiche/src/
Dpacket.rs501 b: &'a mut octets::OctetsMut, pn: u64, pn_len: usize, payload_len: usize, in decrypt_pkt()
508 let payload_len = payload_len in decrypt_pkt() localVariable
512 let mut ciphertext = payload.peek_bytes_mut(payload_len)?; in decrypt_pkt()
514 let payload_len = in decrypt_pkt() localVariable
517 Ok(b.get_bytes(payload_len)?) in decrypt_pkt()
546 b: &mut octets::OctetsMut, pn: u64, pn_len: usize, payload_len: usize, in encrypt_pkt()
552 let ciphertext = payload.slice(payload_len)?; in encrypt_pkt()
557 Ok(payload_offset + payload_len) in encrypt_pkt()
1115 let payload_len = b.get_varint().unwrap() as usize; in assert_decrypt_initial_pkt() localVariable
1128 decrypt_pkt(&mut b, pn, hdr.pkt_num_len, payload_len, &aead).unwrap(); in assert_decrypt_initial_pkt()
[all …]
/external/wpa_supplicant_8/src/tls/
Dtlsv1_record.c151 size_t buf_size, const u8 *payload, size_t payload_len, in tlsv1_record_send() argument
171 WPA_PUT_BE16(length, payload_len); in tlsv1_record_send()
196 if (pos + payload_len > buf + buf_size) in tlsv1_record_send()
198 os_memmove(pos, payload, payload_len); in tlsv1_record_send()
199 pos += payload_len; in tlsv1_record_send()
217 crypto_hash_update(hmac, payload, payload_len); in tlsv1_record_send()
/external/autotest/client/cros/cellular/mbim_compliance/
Dmbim_message_response.py117 payload_len = primary_fragment.get_payload_len()
120 (payload_len != len(primary_fragment.payload_buffer))):
126 num_fragments, payload_len)
/external/perfetto/src/protozero/filtering/
Dmessage_tokenizer.h139 const auto payload_len = varint; in Push() local
140 if (payload_len > protozero::proto_utils::kMaxMessageLength) { in Push()
147 return Token{field_id_, ProtoWireType::kLengthDelimited, payload_len}; in Push()
/external/libwebsockets/lib/secure-streams/protocols/
Dss-mqtt.c91 if (pmqpp->payload_pos + len == pmqpp->payload_len) in secstream_mqtt()
157 mqpp.payload_len = h->writeable_len; in secstream_mqtt()
159 mqpp.payload_len = buflen; in secstream_mqtt()
161 lwsl_notice("%s: payload len %d\n", __func__, (int)mqpp.payload_len); in secstream_mqtt()
/external/libchrome/base/posix/
Dunix_domain_socket.cc171 const unsigned payload_len = cmsg->cmsg_len - CMSG_LEN(0); in RecvMsgWithFlags() local
173 DCHECK_EQ(payload_len % sizeof(int), 0u); in RecvMsgWithFlags()
176 wire_fds_len = payload_len / sizeof(int); in RecvMsgWithFlags()
183 DCHECK_EQ(payload_len, sizeof(struct ucred)); in RecvMsgWithFlags()
/external/linux-kselftest/tools/testing/selftests/bpf/
Dtest_flow_dissector.c167 int payload_len, uint8_t tos) in build_ipv4_header() argument
175 iph->tot_len = htons(sizeof(*iph) + payload_len); in build_ipv4_header()
196 int payload_len, uint8_t dsfield) in build_ipv6_header() argument
201 ip6h->payload_len = htons(payload_len); in build_ipv6_header()
232 pseudo_sum += ip6h->payload_len; in build_udp_v6_csum()
236 static void build_udp_header(void *header, int payload_len, in build_udp_header() argument
240 int len = sizeof(*udph) + payload_len; in build_udp_header()
/external/llvm-project/lldb/source/Plugins/ObjectFile/wasm/
DObjectFileWasm.cpp176 uint64_t payload_len = data.getULEB128(c); in DecodeNextSection() local
180 if (payload_len >= (uint64_t(1) << 32)) in DecodeNextSection()
192 if (payload_len < c.tell() - prev_offset) in DecodeNextSection()
195 uint32_t section_length = payload_len - (c.tell() - prev_offset); in DecodeNextSection()
201 static_cast<uint32_t>(payload_len), in DecodeNextSection()
203 *offset_ptr += (c.tell() + payload_len); in DecodeNextSection()
/external/tcpdump/
Dprint-ip6.c221 register u_int payload_len; in ip6_print() local
242 payload_len = EXTRACT_16BITS(&ip6->ip6_plen); in ip6_print()
243 len = payload_len + sizeof(struct ip6_hdr); in ip6_print()
269 payload_len)); in ip6_print()
/external/wpa_supplicant_8/wpa_supplicant/
Dhs20_supplicant.h18 const u8 *payload, size_t payload_len, int inmem);
19 void hs20_put_anqp_req(u32 stypes, const u8 *payload, size_t payload_len,
/external/linux-kselftest/tools/testing/selftests/networking/timestamping/
Dtxtimestamp.c123 uint32_t key, int payload_len) in __print_timestamp() argument
130 key, payload_len); in __print_timestamp()
148 int tskey, int payload_len) in print_timestamp() argument
171 __print_timestamp(tsname, &tss->ts[0], tskey, payload_len); in print_timestamp()
213 static void __recv_errmsg_cmsg(struct msghdr *msg, int payload_len) in __recv_errmsg_cmsg() argument
256 payload_len); in __recv_errmsg_cmsg()
360 ip6h->payload_len = htons(sizeof(struct udphdr) + cfg_payload_len); in fill_header_ipv6()

1234