| /dpdk/examples/ipsec-secgw/test/ |
| H A D | tun_null_header_reconstruct.py | 135 return pkt
140 return pkt
145 pkt = self.sa_ipv4v4.encrypt(pkt)
148 pkt[IP].tos = tos_outter
149 return pkt
154 pkt = self.sa_ipv6v6.encrypt(pkt)
158 return pkt
163 pkt = self.sa_ipv4v6.encrypt(pkt)
167 return pkt
172 pkt = self.sa_ipv6v4.encrypt(pkt)
[all …]
|
| H A D | trs_ipv6opts.py | 40 def decrypt(pkt, sa): argument
41 esp = pkt[ESP]
48 pkt[ESP].underlayer.nh = d[IPv6].nh
49 pkt[ESP].underlayer.remove_payload()
52 npkt = pkt/d[IPv6].payload
65 pkt = IPv6(src=SRC_ADDR, dst=DST_ADDR)
69 resp = self.px.xfer_unprotected(pkt)
96 resp = self.px.xfer_unprotected(pkt)
123 e = self.inb_sa.encrypt(pkt)
149 e = self.inb_sa.encrypt(pkt)
[all …]
|
| /dpdk/examples/vm_power_manager/ |
| H A D | channel_monitor.c | 120 pkt->vfid[idx] = 0; in set_policy_mac()
172 memset(pkt, 0, sizeof(*pkt)); in parse_json_to_pkt()
477 if (strcmp(policies[i].pkt.vm_name, pkt->vm_name) == 0) { in update_policy()
479 policies[i].pkt = *pkt; in update_policy()
497 policies[i].pkt = *pkt; in update_policy()
526 if (strcmp(policies[i].pkt.vm_name, pkt->vm_name) == 0) { in remove_policy()
678 struct rte_power_channel_packet *pkt = &pol->pkt; in apply_policy() local
816 sizeof(*pkt), in send_ack_for_received_cmd()
887 pkt->vm_name); in process_request()
893 update_policy(pkt); in process_request()
[all …]
|
| /dpdk/examples/vm_power_manager/guest_cli/ |
| H A D | vm_power_cli_guest.c | 78 pkt->nb_mac_to_monitor = 0; in set_policy_defaults()
86 pkt->num_vcpu = 2; in set_policy_defaults()
106 strlcpy(pkt->vm_name, "ubuntu2", sizeof(pkt->vm_name)); in set_policy_defaults()
188 memset(&pkt, 0, sizeof(pkt)); in cmd_query_freq_list_parsed()
203 strlcpy(pkt.vm_name, policy.vm_name, sizeof(pkt.vm_name)); in cmd_query_freq_list_parsed()
214 strlcpy(pkt.vm_name, policy.vm_name, sizeof(pkt.vm_name)); in cmd_query_freq_list_parsed()
298 memset(&pkt, 0, sizeof(pkt)); in cmd_query_caps_list_parsed()
313 strlcpy(pkt.vm_name, policy.vm_name, sizeof(pkt.vm_name)); in cmd_query_caps_list_parsed()
324 strlcpy(pkt.vm_name, policy.vm_name, sizeof(pkt.vm_name)); in cmd_query_caps_list_parsed()
382 ret = rte_power_guest_channel_receive_msg(&pkt, sizeof pkt, lcore_id); in check_response_cmd()
[all …]
|
| /dpdk/examples/ipsec-secgw/ |
| H A D | ipsec_worker.c | 81 vec->port = pkt->port; in ev_vector_attr_update()
289 struct rte_mbuf *pkt; in process_ipsec_ev_inbound() local
296 pkt = ev->mbuf; in process_ipsec_ev_inbound()
390 struct rte_mbuf *pkt; in process_ipsec_ev_outbound() local
398 pkt = ev->mbuf; in process_ipsec_ev_outbound()
493 struct rte_mbuf *pkt; in ipsec_ev_route_pkts() local
508 free_pkts(&pkt, 1); in ipsec_ev_route_pkts()
581 free_pkts(&pkt, 1); in classify_pkt()
693 pkt = vec->mbufs[0]; in ipsec_ev_vector_process()
721 pkt = vec->mbufs[0]; in ipsec_ev_vector_drv_mode_process()
[all …]
|
| /dpdk/drivers/bus/vmbus/ |
| H A D | vmbus_channel.c | 114 pkt.hdr.type = type; in rte_vmbus_chan_send()
163 pkt.rsvd = 0; in rte_vmbus_chan_send_sglist()
233 error = vmbus_rxbr_peek(&chan->rxbr, &pkt, sizeof(pkt)); in rte_vmbus_chan_recv()
243 if (unlikely(pkt.hlen > pkt.tlen)) { in rte_vmbus_chan_recv()
245 pkt.hlen, pkt.tlen); in rte_vmbus_chan_recv()
278 error = vmbus_rxbr_peek(&chan->rxbr, &pkt, sizeof(pkt)); in rte_vmbus_chan_recv_raw()
288 if (unlikely(pkt.hlen > pkt.tlen)) { in rte_vmbus_chan_recv_raw()
290 pkt.hlen, pkt.tlen); in rte_vmbus_chan_recv_raw()
418 if (vmbus_rxbr_peek(br, &pkt, sizeof(pkt)) == 0) in vmbus_dump_ring()
420 pkt.type, in vmbus_dump_ring()
[all …]
|
| /dpdk/app/test/ |
| H A D | packet_burst_generator.c | 26 seg = pkt; in copy_buf_to_pkt_segs()
270 struct rte_mbuf *pkt; in generate_packet_burst() local
274 if (pkt == NULL) { in generate_packet_burst()
282 pkt_seg = pkt; in generate_packet_burst()
286 pkt->nb_segs = i; in generate_packet_burst()
308 pkt, eth_hdr_size); in generate_packet_burst()
313 pkt, eth_hdr_size); in generate_packet_burst()
351 struct rte_mbuf *pkt; in generate_packet_burst_proto() local
355 if (pkt == NULL) { in generate_packet_burst_proto()
363 pkt_seg = pkt; in generate_packet_burst_proto()
[all …]
|
| /dpdk/lib/gso/ |
| H A D | rte_gso.c | 28 rte_gso_segment(struct rte_mbuf *pkt, in rte_gso_segment() argument
45 if (gso_ctx->gso_size >= pkt->pkt_len) { in rte_gso_segment()
54 ol_flags = pkt->ol_flags; in rte_gso_segment()
56 if ((IS_IPV4_VXLAN_TCP4(pkt->ol_flags) && in rte_gso_segment()
58 ((IS_IPV4_GRE_TCP4(pkt->ol_flags) && in rte_gso_segment()
60 pkt->ol_flags &= (~RTE_MBUF_F_TX_TCP_SEG); in rte_gso_segment()
67 pkt->ol_flags &= (~RTE_MBUF_F_TX_UDP_SEG); in rte_gso_segment()
71 } else if (IS_IPV4_TCP(pkt->ol_flags) && in rte_gso_segment()
73 pkt->ol_flags &= (~RTE_MBUF_F_TX_TCP_SEG); in rte_gso_segment()
77 } else if (IS_IPV4_UDP(pkt->ol_flags) && in rte_gso_segment()
[all …]
|
| H A D | gso_tunnel_tcp4.c | 9 update_tunnel_ipv4_tcp_headers(struct rte_mbuf *pkt, uint8_t ipid_delta, in update_tunnel_ipv4_tcp_headers() argument
20 outer_ipv4_offset = pkt->outer_l2_len; in update_tunnel_ipv4_tcp_headers()
21 udp_gre_offset = outer_ipv4_offset + pkt->outer_l3_len; in update_tunnel_ipv4_tcp_headers()
22 inner_ipv4_offset = udp_gre_offset + pkt->l2_len; in update_tunnel_ipv4_tcp_headers()
23 tcp_offset = inner_ipv4_offset + pkt->l3_len; in update_tunnel_ipv4_tcp_headers()
26 ipv4_hdr = (struct rte_ipv4_hdr *)(rte_pktmbuf_mtod(pkt, char *) + in update_tunnel_ipv4_tcp_headers()
35 tcp_hdr = (struct rte_tcp_hdr *)((char *)ipv4_hdr + pkt->l3_len); in update_tunnel_ipv4_tcp_headers()
55 gso_tunnel_tcp4_segment(struct rte_mbuf *pkt, in gso_tunnel_tcp4_segment() argument
67 hdr_offset = pkt->outer_l2_len + pkt->outer_l3_len + pkt->l2_len; in gso_tunnel_tcp4_segment()
79 hdr_offset += pkt->l3_len + pkt->l4_len; in gso_tunnel_tcp4_segment()
[all …]
|
| H A D | gso_tunnel_udp4.c | 20 outer_ipv4_offset = pkt->outer_l2_len; in update_tunnel_ipv4_udp_headers()
21 outer_udp_offset = outer_ipv4_offset + pkt->outer_l3_len; in update_tunnel_ipv4_udp_headers()
22 inner_ipv4_offset = outer_udp_offset + pkt->l2_len; in update_tunnel_ipv4_udp_headers()
25 ipv4_hdr = (struct rte_ipv4_hdr *)(rte_pktmbuf_mtod(pkt, char *) + in update_tunnel_ipv4_udp_headers()
30 ipv4_hdr = (struct rte_ipv4_hdr *)(rte_pktmbuf_mtod(pkt, char *) + in update_tunnel_ipv4_udp_headers()
51 length = segs[i]->pkt_len - inner_ipv4_offset - pkt->l3_len; in update_tunnel_ipv4_udp_headers()
58 gso_tunnel_udp4_segment(struct rte_mbuf *pkt, in gso_tunnel_udp4_segment() argument
69 hdr_offset = pkt->outer_l2_len + pkt->outer_l3_len + pkt->l2_len; in gso_tunnel_udp4_segment()
80 hdr_offset += pkt->l3_len; in gso_tunnel_udp4_segment()
82 if ((hdr_offset + pkt->l4_len) >= pkt->pkt_len) in gso_tunnel_udp4_segment()
[all …]
|
| H A D | gso_tcp4.c | 9 update_ipv4_tcp_headers(struct rte_mbuf *pkt, uint8_t ipid_delta, in update_ipv4_tcp_headers() argument
16 uint16_t l3_offset = pkt->l2_len; in update_ipv4_tcp_headers()
17 uint16_t l4_offset = l3_offset + pkt->l3_len; in update_ipv4_tcp_headers()
19 ipv4_hdr = (struct rte_ipv4_hdr *)(rte_pktmbuf_mtod(pkt, char*) + in update_ipv4_tcp_headers()
21 tcp_hdr = (struct rte_tcp_hdr *)((char *)ipv4_hdr + pkt->l3_len); in update_ipv4_tcp_headers()
35 gso_tcp4_segment(struct rte_mbuf *pkt, in gso_tcp4_segment() argument
49 ipv4_hdr = (struct rte_ipv4_hdr *)(rte_pktmbuf_mtod(pkt, char *) + in gso_tcp4_segment()
50 pkt->l2_len); in gso_tcp4_segment()
57 hdr_offset = pkt->l2_len + pkt->l3_len + pkt->l4_len; in gso_tcp4_segment()
58 if (unlikely(hdr_offset >= pkt->pkt_len)) { in gso_tcp4_segment()
[all …]
|
| H A D | gso_udp4.c | 11 update_ipv4_udp_headers(struct rte_mbuf *pkt, struct rte_mbuf **segs, in update_ipv4_udp_headers() argument
16 uint16_t l2_hdrlen = pkt->l2_len, l3_hdrlen = pkt->l3_len; in update_ipv4_udp_headers()
38 gso_udp4_segment(struct rte_mbuf *pkt, in gso_udp4_segment() argument
51 ipv4_hdr = rte_pktmbuf_mtod_offset(pkt, struct rte_ipv4_hdr *, in gso_udp4_segment()
52 pkt->l2_len); in gso_udp4_segment()
63 hdr_offset = pkt->l2_len + pkt->l3_len; in gso_udp4_segment()
66 if (unlikely(hdr_offset + pkt->l4_len >= pkt->pkt_len)) { in gso_udp4_segment()
76 ret = gso_do_segment(pkt, hdr_offset, pyld_unit_size, direct_pool, in gso_udp4_segment()
79 update_ipv4_udp_headers(pkt, pkts_out, ret); in gso_udp4_segment()
|
| /dpdk/lib/gro/ |
| H A D | gro_vxlan_udp4.c | 99 struct rte_mbuf *pkt, in insert_new_item() argument
222 l2_offset = pkt->outer_l2_len + pkt->outer_l3_len; in udp4_check_vxlan_neighbor()
244 pkt->outer_l2_len + pkt->outer_l3_len)) { in merge_two_vxlan_udp4_packets()
261 len = pkt->pkt_len - pkt->outer_l2_len; in update_vxlan_header()
263 pkt->outer_l2_len); in update_vxlan_header()
272 len -= pkt->l2_len; in update_vxlan_header()
307 pkt->outer_l2_len); in gro_vxlan_udp4_reassemble()
324 hdr_len = pkt->outer_l2_len + pkt->outer_l3_len + pkt->l2_len + in gro_vxlan_udp4_reassemble()
325 pkt->l3_len; in gro_vxlan_udp4_reassemble()
463 hdr_len = pkt->outer_l2_len + pkt->outer_l3_len + pkt->l2_len + in gro_vxlan_udp4_merge_items()
[all …]
|
| H A D | gro_vxlan_tcp4.c | 99 struct rte_mbuf *pkt, in insert_new_item() argument
227 l2_offset = pkt->outer_l2_len + pkt->outer_l3_len; in check_vxlan_seq_option()
245 struct rte_mbuf *pkt, in merge_two_vxlan_tcp4_packets() argument
253 pkt->outer_l3_len)) { in merge_two_vxlan_tcp4_packets()
271 len = pkt->pkt_len - pkt->outer_l2_len; in update_vxlan_header()
273 pkt->outer_l2_len); in update_vxlan_header()
282 len -= pkt->l2_len; in update_vxlan_header()
318 pkt->outer_l2_len); in gro_vxlan_tcp4_reassemble()
320 pkt->outer_l3_len); in gro_vxlan_tcp4_reassemble()
335 hdr_len = pkt->outer_l2_len + pkt->outer_l3_len + pkt->l2_len + in gro_vxlan_tcp4_reassemble()
[all …]
|
| H A D | gro_udp4.c | 100 struct rte_mbuf *pkt, in insert_new_item() argument
183 pkt->l2_len); in update_header()
185 pkt->l2_len); in update_header()
215 hdr_len = pkt->l2_len + pkt->l3_len; in gro_udp4_reassemble()
227 if (pkt->pkt_len <= hdr_len) in gro_udp4_reassemble()
231 if (ip_dl <= pkt->l3_len) in gro_udp4_reassemble()
234 ip_dl -= pkt->l3_len; in gro_udp4_reassemble()
293 pkt, cmp, frag_offset, in gro_udp4_reassemble()
345 struct rte_mbuf *pkt; in gro_udp4_merge_items() local
353 hdr_len = pkt->l2_len + pkt->l3_len; in gro_udp4_merge_items()
[all …]
|
| /dpdk/app/test-pmd/ |
| H A D | txonly.c | 76 seg = pkt; in copy_buf_to_pkt_segs()
213 pkt->ol_flags |= ol_flags; in pkt_burst_prepare()
214 pkt->vlan_tci = vlan_tci; in pkt_burst_prepare()
219 pkt_len = pkt->data_len; in pkt_burst_prepare()
220 pkt_seg = pkt; in pkt_burst_prepare()
318 pkt->nb_segs = nb_segs; in pkt_burst_prepare()
319 pkt->pkt_len = pkt_len; in pkt_burst_prepare()
332 struct rte_mbuf *pkt; in pkt_burst_transmit() local
381 if (pkt == NULL) in pkt_burst_transmit()
388 rte_pktmbuf_free(pkt); in pkt_burst_transmit()
[all …]
|
| H A D | flowgen.c | 68 struct rte_mbuf *pkt = NULL; in pkt_burst_flow_gen() local
115 pkt = rte_mbuf_raw_alloc(mbp); in pkt_burst_flow_gen()
116 if (!pkt) in pkt_burst_flow_gen()
119 pkt->data_len = pkt_size; in pkt_burst_flow_gen()
120 pkt->next = NULL; in pkt_burst_flow_gen()
152 pkt->nb_segs = 1; in pkt_burst_flow_gen()
153 pkt->pkt_len = pkt_size; in pkt_burst_flow_gen()
155 pkt->ol_flags |= ol_flags; in pkt_burst_flow_gen()
156 pkt->vlan_tci = vlan_tci; in pkt_burst_flow_gen()
162 rte_mbuf_refcnt_update(pkt, 1); in pkt_burst_flow_gen()
[all …]
|
| /dpdk/lib/port/ |
| H A D | rte_swx_port_fd.c | 125 pkt->handle = m; in reader_pkt_rx()
126 pkt->pkt = m->buf_addr; in reader_pkt_rx()
127 pkt->offset = m->data_off; in reader_pkt_rx()
128 pkt->length = m->pkt_len; in reader_pkt_rx()
133 pkt->length, in reader_pkt_rx()
134 pkt->offset); in reader_pkt_rx()
199 struct rte_mbuf *pkt; in __writer_flush() local
206 pkt = p->pkts[i]; in __writer_flush()
234 pkt->length, in writer_pkt_tx()
235 pkt->offset); in writer_pkt_tx()
[all …]
|
| H A D | rte_swx_port_source_sink.c | 168 pkt->handle = m_dst; in source_pkt_rx()
169 pkt->pkt = m_dst->buf_addr; in source_pkt_rx()
170 pkt->offset = m_dst->data_off; in source_pkt_rx()
171 pkt->length = m_dst->pkt_len; in source_pkt_rx()
174 pkt->length, in source_pkt_rx()
175 pkt->offset); in source_pkt_rx()
177 rte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length); in source_pkt_rx()
293 pkt->length, in sink_pkt_tx()
294 pkt->offset); in sink_pkt_tx()
296 rte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length); in sink_pkt_tx()
[all …]
|
| H A D | rte_swx_port_ring.c | 109 pkt->handle = m; in reader_pkt_rx()
110 pkt->pkt = m->buf_addr; in reader_pkt_rx()
111 pkt->offset = m->data_off; in reader_pkt_rx()
112 pkt->length = m->pkt_len; in reader_pkt_rx()
117 pkt->length, in reader_pkt_rx()
118 pkt->offset); in reader_pkt_rx()
143 rte_pktmbuf_free(pkt); in reader_free()
250 pkt->length, in writer_pkt_tx()
251 pkt->offset); in writer_pkt_tx()
253 rte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length); in writer_pkt_tx()
[all …]
|
| H A D | rte_swx_port_ethdev.c | 113 pkt->handle = m; in reader_pkt_rx()
114 pkt->pkt = m->buf_addr; in reader_pkt_rx()
115 pkt->offset = m->data_off; in reader_pkt_rx()
116 pkt->length = m->pkt_len; in reader_pkt_rx()
122 pkt->length, in reader_pkt_rx()
123 pkt->offset); in reader_pkt_rx()
148 rte_pktmbuf_free(pkt); in reader_free()
250 pkt->length, in writer_pkt_tx()
251 pkt->offset); in writer_pkt_tx()
253 rte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length); in writer_pkt_tx()
[all …]
|
| /dpdk/drivers/net/netvsc/ |
| H A D | hn_rxtx.c | 141 return pkt->pktinfooffset + pkt->pktinfolen; in hn_rndis_pktlen()
678 hn_rndis_dump(pkt); in hn_rndis_rx_data()
686 if (unlikely(pkt->len < pkt->datalen in hn_rndis_rx_data()
687 + pkt->oobdatalen + pkt->pktinfolen)) in hn_rndis_rx_data()
1239 olen = pkt->len; in hn_try_txagg()
1247 chim = (uint8_t *)pkt + pkt->len; in hn_try_txagg()
1319 pkt->pktinfooffset = sizeof(*pkt); in hn_encap()
1321 pkt->vchandle = 0; in hn_encap()
1322 pkt->reserved = 0; in hn_encap()
1375 pkt_hlen = pkt->pktinfooffset + pkt->pktinfolen; in hn_encap()
[all …]
|
| /dpdk/lib/power/ |
| H A D | guest_channel.c | 56 struct rte_power_channel_packet pkt; in guest_channel_host_connect() local
101 pkt.command = RTE_POWER_CPU_POWER_CONNECT; in guest_channel_host_connect()
103 ret = guest_channel_send_msg(&pkt, lcore_id); in guest_channel_host_connect()
123 int ret, buffer_len = sizeof(*pkt); in guest_channel_send_msg()
124 void *buffer = pkt; in guest_channel_send_msg()
154 return guest_channel_send_msg(pkt, lcore_id); in rte_power_guest_channel_send_msg()
157 int power_guest_channel_read_msg(void *pkt, in power_guest_channel_read_msg() argument
164 if (pkt_len == 0 || pkt == NULL) in power_guest_channel_read_msg()
193 pkt, pkt_len); in power_guest_channel_read_msg()
205 pkt = (char *)pkt + ret; in power_guest_channel_read_msg()
[all …]
|
| /dpdk/drivers/net/thunderx/ |
| H A D | nicvf_rxtx.c | 54 sqe.hdr.l4_offset = pkt->l3_len + pkt->l2_len; in fill_sq_desc_header()
154 struct rte_mbuf *pkt; in nicvf_xmit_pkts() local
161 pkt = tx_pkts[i]; in nicvf_xmit_pkts()
167 txbuffs[tail] = pkt; in nicvf_xmit_pkts()
204 pkt = tx_pkts[i]; in nicvf_xmit_pkts_multiseg()
222 seg = pkt->next; in nicvf_xmit_pkts_multiseg()
459 pkt->vlan_tci = in nicvf_recv_pkts()
468 rx_pkts[i] = pkt; in nicvf_recv_pkts()
547 pkt->ol_flags = 0; in nicvf_process_cq_mseg_entry()
559 *rx_pkt = pkt; in nicvf_process_cq_mseg_entry()
[all …]
|
| /dpdk/examples/l3fwd/ |
| H A D | l3fwd_lpm_sse.h | 14 processx4_step1(struct rte_mbuf *pkt[FWDSTEP], in processx4_step1()
22 eth_hdr = rte_pktmbuf_mtod(pkt[0], struct rte_ether_hdr *); in processx4_step1()
25 ipv4_flag[0] = pkt[0]->packet_type & RTE_PTYPE_L3_IPV4; in processx4_step1()
27 eth_hdr = rte_pktmbuf_mtod(pkt[1], struct rte_ether_hdr *); in processx4_step1()
30 ipv4_flag[0] &= pkt[1]->packet_type; in processx4_step1()
32 eth_hdr = rte_pktmbuf_mtod(pkt[2], struct rte_ether_hdr *); in processx4_step1()
35 ipv4_flag[0] &= pkt[2]->packet_type; in processx4_step1()
37 eth_hdr = rte_pktmbuf_mtod(pkt[3], struct rte_ether_hdr *); in processx4_step1()
40 ipv4_flag[0] &= pkt[3]->packet_type; in processx4_step1()
54 struct rte_mbuf *pkt[FWDSTEP], in processx4_step2()
[all …]
|