Home
last modified time | relevance | path

Searched refs:sent (Results 1 – 25 of 83) sorted by relevance

1234

/dpdk/examples/l2fwd-event/
H A Dl2fwd_poll.c13 int sent; in l2fwd_poll_simple_forward() local
22 sent = rte_eth_tx_buffer(dst_port, 0, buffer, m); in l2fwd_poll_simple_forward()
23 if (sent) in l2fwd_poll_simple_forward()
24 rsrc->port_stats[dst_port].tx += sent; in l2fwd_poll_simple_forward()
39 int32_t sent; in l2fwd_poll_main_loop() local
76 sent = rte_eth_tx_buffer_flush(port_id, 0, buf); in l2fwd_poll_main_loop()
77 if (sent) in l2fwd_poll_main_loop()
78 rsrc->port_stats[port_id].tx += sent; in l2fwd_poll_main_loop()
/dpdk/examples/multi_process/client_server_mp/mp_client/
H A Dclient.c187 int sent; in handle_packet() local
192 sent = rte_eth_tx_buffer(out_port, client_id, buffer, buf); in handle_packet()
193 if (sent) in handle_packet()
194 tx_stats->tx[out_port] += sent; in handle_packet()
212 uint16_t sent; in main() local
256 sent = rte_eth_tx_buffer_flush(port, in main()
259 tx_stats->tx[port] += sent; in main()
/dpdk/examples/server_node_efd/node/
H A Dnode.c257 int sent; in transmit_packet() local
262 sent = rte_eth_tx_buffer(out_port, node_id, buffer, buf); in transmit_packet()
263 if (sent) in transmit_packet()
264 tx_stats->tx[out_port] += sent; in transmit_packet()
316 uint16_t sent; in main() local
377 sent = rte_eth_tx_buffer_flush( in main()
381 if (unlikely(sent)) in main()
382 tx_stats->tx[port] += sent; in main()
/dpdk/examples/distributor/
H A Dmain.c276 uint16_t sent = rte_ring_enqueue_burst(tx_ring, in lcore_rx()
291 app_stats.rx.enqueued_pkts += sent; in lcore_rx()
292 if (unlikely(sent < nb_ret)) { in lcore_rx()
293 app_stats.rx.enqdrop_pkts += nb_ret - sent; in lcore_rx()
296 while (sent < nb_ret) in lcore_rx()
297 rte_pktmbuf_free(bufs[sent++]); in lcore_rx()
371 uint16_t sent = rte_ring_enqueue_burst(out_r, in lcore_distributor() local
373 app_stats.dist.sent_pkts += sent; in lcore_distributor()
374 if (unlikely(sent < nb_ret)) { in lcore_distributor()
379 while (sent < nb_ret) in lcore_distributor()
[all …]
/dpdk/examples/link_status_interrupt/
H A Dmain.c178 int sent; in lsi_simple_forward() local
191 sent = rte_eth_tx_buffer(dst_port, 0, buffer, m); in lsi_simple_forward()
192 if (sent) in lsi_simple_forward()
193 port_statistics[dst_port].tx += sent; in lsi_simple_forward()
204 unsigned sent; in lsi_main_loop() local
248 sent = rte_eth_tx_buffer_flush(portid, 0, buffer); in lsi_main_loop()
249 if (sent) in lsi_main_loop()
250 port_statistics[portid].tx += sent; in lsi_main_loop()
/dpdk/doc/guides/platform/
H A Dcnxk.rst410 Total octets sent on the interface: 0
412 Control/Pause frames sent: 0
414 Total frames sent with VLAN header: 0
416 Packets sent to unicast DMAC: 0
417 Packets sent to the multicast DMAC: 0
418 Packets sent to a broadcast DMAC: 0
419 Packets sent with an octet count == 64: 0
420 Packets sent with an octet count of 65–127: 0
425 Packets sent with an octet count of > 1518: 0
442 MAC control packets sent: 0
[all …]
/dpdk/examples/l2fwd-keepalive/
H A Dmain.c171 int sent; in l2fwd_simple_forward() local
186 sent = rte_eth_tx_buffer(dst_port, 0, buffer, m); in l2fwd_simple_forward()
187 if (sent) in l2fwd_simple_forward()
188 port_statistics[dst_port].tx += sent; in l2fwd_simple_forward()
197 int sent; in l2fwd_main_loop() local
253 sent = rte_eth_tx_buffer_flush(portid, 0, buffer); in l2fwd_main_loop()
254 if (sent) in l2fwd_main_loop()
255 port_statistics[portid].tx += sent; in l2fwd_main_loop()
/dpdk/examples/packet_ordering/
H A Dmain.c537 unsigned sent; in send_thread() local
602 sent = rte_eth_tx_buffer(outp1, 0, outbuf, rombufs[i]); in send_thread()
603 if (sent) in send_thread()
604 app_stats.tx.ro_tx_pkts += sent; in send_thread()
621 unsigned sent; in tx_thread() local
651 sent = rte_eth_tx_buffer(outp, 0, outbuf, mbufs[i]); in tx_thread()
652 if (sent) in tx_thread()
653 app_stats.tx.ro_tx_pkts += sent; in tx_thread()
/dpdk/examples/l2fwd/
H A Dmain.c187 int sent; in l2fwd_simple_forward() local
196 sent = rte_eth_tx_buffer(dst_port, 0, buffer, m); in l2fwd_simple_forward()
197 if (sent) in l2fwd_simple_forward()
198 port_statistics[dst_port].tx += sent; in l2fwd_simple_forward()
208 int sent; in l2fwd_main_loop() local
254 sent = rte_eth_tx_buffer_flush(portid, 0, buffer); in l2fwd_main_loop()
255 if (sent) in l2fwd_main_loop()
256 port_statistics[portid].tx += sent; in l2fwd_main_loop()
/dpdk/app/test-pmd/
H A Dnoisy_vnf.c210 unsigned int sent; in pkt_burst_noisy_vnf() local
213 sent = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_noisy_vnf()
215 if (unlikely(sent < nb_deqd) && fs->retry_enabled) in pkt_burst_noisy_vnf()
218 fs->fwd_dropped += drop_pkts(tmp_pkts, nb_deqd, sent); in pkt_burst_noisy_vnf()
/dpdk/examples/l2fwd-jobstats/
H A Dmain.c345 int sent; in l2fwd_simple_forward() local
360 sent = rte_eth_tx_buffer(dst_port, 0, buffer, m); in l2fwd_simple_forward()
361 if (sent) in l2fwd_simple_forward()
362 port_statistics[dst_port].tx += sent; in l2fwd_simple_forward()
445 uint32_t sent; in l2fwd_flush_job() local
464 sent = rte_eth_tx_buffer_flush(portid, 0, buffer); in l2fwd_flush_job()
465 if (sent) in l2fwd_flush_job()
466 port_statistics[portid].tx += sent; in l2fwd_flush_job()
/dpdk/doc/guides/howto/
H A Drte_flow.rst281 received packet with src ip = 176.80.50.4 sent to queue 2
282 received packet with src ip = 176.80.50.5 sent to queue 1
283 received packet with src ip = 176.80.50.6 sent to queue 0
303 received packet with src ip = 176.80.50.4 sent to queue 3
304 received packet with src ip = 176.80.50.5 sent to queue 1
305 received packet with src ip = 176.80.50.6 sent to queue 3
/dpdk/examples/eventdev_pipeline/
H A Dpipeline_worker_generic.c17 size_t sent = 0, received = 0; in worker_generic() local
54 sent++; in worker_generic()
60 rte_lcore_id(), received, sent); in worker_generic()
73 size_t sent = 0, received = 0; in worker_generic_burst() local
113 sent += nb_tx; in worker_generic_burst()
120 rte_lcore_id(), received, sent); in worker_generic_burst()
/dpdk/app/test/
H A Dtest_table.h83 #define VERIFY_TRAFFIC(ring, sent, expected) do { \ argument
87 for (i = 0; i < (sent); i++) { \
/dpdk/lib/eventdev/
H A Drte_event_eth_tx_adapter.c489 uint16_t sent = 0; in txa_service_buffer_retry() local
499 &pkts[sent], unsent - sent); in txa_service_buffer_retry()
501 sent += n; in txa_service_buffer_retry()
502 } while (sent != unsent && retry++ < TXA_RETRY_CNT); in txa_service_buffer_retry()
504 for (i = sent; i < unsent; i++) in txa_service_buffer_retry()
508 stats->tx_packets += sent; in txa_service_buffer_retry()
509 stats->tx_dropped += unsent - sent; in txa_service_buffer_retry()
/dpdk/doc/guides/prog_guide/
H A Dmulti_proc_support.rst206 In other words, any IPC message sent in a primary process will be delivered to
207 all secondaries, while any IPC message sent in a secondary process will only be
252 descriptor either to all secondary processes (if sent from primary process), or
253 to primary process (if sent from secondary process). The function will return
270 * ``nb_sent`` - number indicating how many requests were sent (i.e. how many
281 out, or will have received a response to all the messages that were sent.
291 (so that it would be possible to determine for which sent message this is a
306 identical to ones sent by the sender.
309 constructed and sent via ``rte_mp_reply()`` function, along with ``peer``
314 response to the request - it must always be explicitly sent even in case
/dpdk/doc/guides/contributing/
H A Dvulnerability.rst92 The confirmation mail should be sent within **3 business days**.
113 The CVE request should be sent
181 When the fix is ready, the security advisory and patches are sent
206 and will be sent signed with a security team's member GPG key.
242 a security advisory is sent to downstream stakeholders
291 Patches are then sent to `[email protected] <mailto:[email protected]>`_
/dpdk/examples/pipeline/examples/
H A Dselector.spec15 ; next hop action prepares the output packet for being sent next hop in the network by prepending
27 ; rates of output packets sent on different ports.
H A Dmeter.spec6 ; header "Source Address" field. All green packets are sent out on port 0, the yellow ones on port 1
/dpdk/drivers/compress/qat/
H A Dqat_comp.c494 uint32_t prod, sent; in qat_comp_response_data_copy() local
510 sent = left_in_current; in qat_comp_response_data_copy()
517 sent, in qat_comp_response_data_copy()
521 sent += rte_pktmbuf_data_len(sgl_buf); in qat_comp_response_data_copy()
529 ((uint8_t *)cookie->dest_buffer) + sent, in qat_comp_response_data_copy()
/dpdk/doc/guides/nics/
H A Dnull.rst9 On Rx it returns requested number of empty packets (all zero). On Tx it just frees all sent packets.
H A Dkni.rst20 Packets sent to the KNI Linux interface will be received by the DPDK
41 When testpmd forwarding starts, any packets sent to ``kni0`` interface
/dpdk/doc/guides/sample_app_ug/
H A Dip_frag.rst50 then the input packet is fragmented and several fragments are sent via the output interface.
117 seven IPv4 packets will be sent out from port #0 to the destination address 100.10.1.1:
/dpdk/drivers/net/dpaa/
H A Ddpaa_rxtx.c1060 uint32_t frames_to_send, loop, sent = 0; in dpaa_eth_queue_tx() local
1167 sent += frames_to_send; in dpaa_eth_queue_tx()
1170 DPAA_DP_LOG(DEBUG, "Transmitted %d buffers on queue: %p", sent, q); in dpaa_eth_queue_tx()
1174 while (loop < sent) { in dpaa_eth_queue_tx()
1181 return sent; in dpaa_eth_queue_tx()
/dpdk/drivers/bus/dpaa/base/qbman/
H A Dqman.c2314 u8 i = 0, diff, old_ci, sent = 0; in qman_enqueue_multi() local
2341 sent++; in qman_enqueue_multi()
2350 for (i = 0; i < sent; i++) { in qman_enqueue_multi()
2364 for (i = 0; i < sent; i++) { in qman_enqueue_multi()
2371 return sent; in qman_enqueue_multi()
2384 u8 i = 0, diff, old_ci, sent = 0; in qman_enqueue_multi_fq() local
2398 eq->fqid = fq[sent]->fqid_le; in qman_enqueue_multi_fq()
2412 sent++; in qman_enqueue_multi_fq()
2421 for (i = 0; i < sent; i++) { in qman_enqueue_multi_fq()
2435 for (i = 0; i < sent; i++) { in qman_enqueue_multi_fq()
[all …]

1234