| /dpdk/drivers/bus/dpaa/base/qbman/ |
| H A D | dpaa_alloc.c | 13 int bman_alloc_bpid_range(u32 *result, u32 count, u32 align, int partial) in bman_alloc_bpid_range() argument
15 return process_alloc(dpaa_id_bpid, result, count, align, partial); in bman_alloc_bpid_range()
18 void bman_release_bpid_range(u32 bpid, u32 count) in bman_release_bpid_range() argument
20 process_release(dpaa_id_bpid, bpid, count); in bman_release_bpid_range()
23 int bman_reserve_bpid_range(u32 bpid, u32 count) in bman_reserve_bpid_range() argument
25 return process_reserve(dpaa_id_bpid, bpid, count); in bman_reserve_bpid_range()
28 int qman_alloc_fqid_range(u32 *result, u32 count, u32 align, int partial) in qman_alloc_fqid_range() argument
30 return process_alloc(dpaa_id_fqid, result, count, align, partial); in qman_alloc_fqid_range()
33 void qman_release_fqid_range(u32 fqid, u32 count) in qman_release_fqid_range() argument
35 process_release(dpaa_id_fqid, fqid, count); in qman_release_fqid_range()
[all …]
|
| /dpdk/drivers/net/ngbe/ |
| H A D | ngbe_regs_group.h | 14 uint32_t count; member
25 for (i = 0; i < reg->count; i++) in ngbe_read_regs()
27 return reg->count; in ngbe_read_regs()
33 int count = 0; in ngbe_regs_group_count() local
36 while (regs[i].count) in ngbe_regs_group_count()
37 count += regs[i++].count; in ngbe_regs_group_count()
38 return count; in ngbe_regs_group_count()
45 int count = 0; in ngbe_read_regs_group() local
49 while (regs[i].count) in ngbe_read_regs_group()
50 count += ngbe_read_regs(hw, ®s[i++], ®_buf[count]); in ngbe_read_regs_group()
[all …]
|
| /dpdk/drivers/net/txgbe/ |
| H A D | txgbe_regs_group.h | 14 uint32_t count; member
25 for (i = 0; i < reg->count; i++) in txgbe_read_regs()
28 return reg->count; in txgbe_read_regs()
34 int count = 0; in txgbe_regs_group_count() local
37 while (regs[i].count) in txgbe_regs_group_count()
38 count += regs[i++].count; in txgbe_regs_group_count()
39 return count; in txgbe_regs_group_count()
46 int count = 0; in txgbe_read_regs_group() local
50 while (regs[i].count) in txgbe_read_regs_group()
51 count += txgbe_read_regs(hw, ®s[i++], ®_buf[count]); in txgbe_read_regs_group()
[all …]
|
| /dpdk/drivers/raw/ifpga/base/ |
| H A D | opae_at24_eeprom.c | 31 u32 offset, u8 *buf, int count) in at24_eeprom_read() argument
37 if (!count) in at24_eeprom_read()
38 return count; in at24_eeprom_read()
40 if (count > AT24C512_IO_LIMIT) in at24_eeprom_read()
43 len = count; in at24_eeprom_read()
45 while (count) { in at24_eeprom_read()
53 count -= len; in at24_eeprom_read()
61 u32 offset, u8 *buf, int count) in at24_eeprom_write() argument
67 if (!count) in at24_eeprom_write()
68 return count; in at24_eeprom_write()
[all …]
|
| /dpdk/drivers/net/hns3/ |
| H A D | hns3_stats.c | 822 int *count) in hns3_queue_stats_get() argument
833 xstats[*count].value = hns3_read_dev(hw, in hns3_queue_stats_get()
835 xstats[*count].id = *count; in hns3_queue_stats_get()
836 (*count)++; in hns3_queue_stats_get()
844 xstats[*count].value = hns3_read_dev(hw, in hns3_queue_stats_get()
846 xstats[*count].id = *count; in hns3_queue_stats_get()
847 (*count)++; in hns3_queue_stats_get()
854 int *count) in hns3_rxq_dfx_stats_get() argument
870 xstats[*count].value = *(uint64_t *)val; in hns3_rxq_dfx_stats_get()
871 xstats[*count].id = *count; in hns3_rxq_dfx_stats_get()
[all …]
|
| /dpdk/drivers/event/sw/ |
| H A D | iq_chunk.h | 20 return (iq->count == 0); in iq_empty()
26 return iq->count; in iq_count()
63 iq->count = 0; in iq_init()
70 iq->count++; in iq_enqueue()
88 iq->count--; in iq_pop()
109 uint16_t count) in iq_dequeue_burst() argument
114 count = RTE_MIN(count, iq_count(iq)); in iq_dequeue_burst()
126 if (unlikely(total == count)) in iq_dequeue_burst()
148 iq->count -= total; in iq_dequeue_burst()
157 unsigned int count) in iq_put_back() argument
[all …]
|
| /dpdk/app/test/ |
| H A D | test_atomic.c | 107 static rte_atomic64_t count; variable
155 rte_atomic64_inc(&count); in test_atomic_tas()
157 rte_atomic64_inc(&count); in test_atomic_tas()
159 rte_atomic64_inc(&count); in test_atomic_tas()
177 rte_atomic64_add(&count, tmp16); in test_atomic_addsub_and_return()
180 rte_atomic64_sub(&count, tmp16+1); in test_atomic_addsub_and_return()
183 rte_atomic64_add(&count, tmp32); in test_atomic_addsub_and_return()
186 rte_atomic64_sub(&count, tmp32+1); in test_atomic_addsub_and_return()
189 rte_atomic64_add(&count, tmp64); in test_atomic_addsub_and_return()
192 rte_atomic64_sub(&count, tmp64+1); in test_atomic_addsub_and_return()
[all …]
|
| /dpdk/drivers/mempool/cnxk/ |
| H A D | cn10k_mempool_ops.c | 188 unsigned int count = 0; in cn10k_mempool_get_count() local
201 count += roc_npa_aura_batch_alloc_count( in cn10k_mempool_get_count()
206 count += mem->sz; in cn10k_mempool_get_count()
210 count += cnxk_mempool_get_count(mp); in cn10k_mempool_get_count()
212 return count; in cn10k_mempool_get_count()
226 unsigned int count = 0; in mempool_deq_batch_async() local
259 cur_sz = n - count; in mempool_deq_batch_async()
264 memcpy(&obj_table[count], &mem->objs[mem->sz - cur_sz], in mempool_deq_batch_async()
267 count += cur_sz; in mempool_deq_batch_async()
270 loop &= (count != n); in mempool_deq_batch_async()
[all …]
|
| /dpdk/lib/eal/common/ |
| H A D | eal_common_trace.c | 263 uint32_t count; in trace_lcore_mem_dump() local
270 for (count = 0; count < trace->nb_trace_mem_list; count++) { in trace_lcore_mem_dump()
271 header = trace->lcore_meta[count].mem; in trace_lcore_mem_dump()
273 count, header, in trace_lcore_mem_dump()
274 trace_area_to_string(trace->lcore_meta[count].area), in trace_lcore_mem_dump()
322 uint32_t count; in __rte_trace_mem_per_thread_alloc() local
332 count = trace->nb_trace_mem_list; in __rte_trace_mem_per_thread_alloc()
336 sizeof(trace->lcore_meta[0]) * (count + 1)); in __rte_trace_mem_per_thread_alloc()
348 trace->lcore_meta[count].area = TRACE_AREA_HUGEPAGE; in __rte_trace_mem_per_thread_alloc()
362 trace->lcore_meta[count].area = TRACE_AREA_HEAP; in __rte_trace_mem_per_thread_alloc()
[all …]
|
| /dpdk/examples/vm_power_manager/ |
| H A D | channel_monitor.c | 368 pcpu_monitor(struct policy *pol, struct core_info *ci, int pcpu, int count) in pcpu_monitor()
385 pol->core_share[count].pcpu = pcpu; in pcpu_monitor()
399 int pcpu, count; in get_pcpu_to_control()
419 for (count = 0; count < pol->pkt.num_vcpu; count++) { in get_pcpu_to_control()
420 pcpu = info.pcpu_map[pol->pkt.vcpu_to_control[count]]; in get_pcpu_to_control()
421 pcpu_monitor(pol, ci, pcpu, count); in get_pcpu_to_control()
428 for (count = 0; count < po in get_pcpu_to_control()
367 pcpu_monitor(struct policy * pol,struct core_info * ci,int pcpu,int count) pcpu_monitor() argument
398 int pcpu, count; get_pcpu_to_control() local
580 int count; apply_traffic_profile() local
610 int count, x; apply_time_profile() local
652 int count; apply_workload_profile() local
[all...] |
| /dpdk/drivers/net/octeon_ep/ |
| H A D | cnxk_ep_rx.h | 15 cnxk_ep_rx_refill_mbuf(struct otx_ep_droq *droq, uint32_t count) in cnxk_ep_rx_refill_mbuf() argument
24 rc = rte_mempool_get_bulk(droq->mpool, (void **)&recv_buf_list[refill_idx], count); in cnxk_ep_rx_refill_mbuf()
30 for (i = 0; i < count; i++) { in cnxk_ep_rx_refill_mbuf()
32 if (i < count - 1) in cnxk_ep_rx_refill_mbuf()
39 droq->refill_idx = otx_ep_incr_index(droq->refill_idx, count, droq->nb_desc); in cnxk_ep_rx_refill_mbuf()
40 droq->refill_count -= count; in cnxk_ep_rx_refill_mbuf()
50 uint32_t desc_refilled = 0, count; in cnxk_ep_rx_refill() local
57 count = droq->read_idx - refill_idx; in cnxk_ep_rx_refill()
58 rc = cnxk_ep_rx_refill_mbuf(droq, count); in cnxk_ep_rx_refill()
63 desc_refilled = count; in cnxk_ep_rx_refill()
[all …]
|
| /dpdk/lib/eal/include/ |
| H A D | rte_seqlock.h | 102 rte_seqcount_t count; /**< Sequence count for the protected data. */ member
111 .count = RTE_SEQCOUNT_INITIALIZER, \
127 rte_seqcount_init(&seqlock->count); in rte_seqlock_init()
148 return rte_seqcount_read_begin(&seqlock->count); in rte_seqlock_read_begin()
170 return rte_seqcount_read_retry(&seqlock->count, begin_sn); in rte_seqlock_read_retry()
205 rte_seqcount_write_begin(&seqlock->count); in rte_seqlock_write_lock()
224 rte_seqcount_write_end(&seqlock->count); in rte_seqlock_write_unlock()
|
| /dpdk/lib/pdcp/ |
| H A D | pdcp_process.c | 39 pdcp_iv_gen_null_null(struct rte_crypto_op *cop, const struct entity_priv *en_priv, uint32_t count) in pdcp_iv_gen_null_null() argument
44 RTE_SET_USED(count); in pdcp_iv_gen_null_null()
49 uint32_t count) in pdcp_iv_gen_null_aes_cmac() argument
61 m = en_priv->auth_iv_part.u64[0] | ((uint64_t)(rte_cpu_to_be_32(count))); in pdcp_iv_gen_null_aes_cmac()
67 pdcp_iv_gen_null_zs(struct rte_crypto_op *cop, const struct entity_priv *en_priv, uint32_t count) in pdcp_iv_gen_null_zs() argument
74 iv_u64[0] = en_priv->auth_iv_part.u64[0] | ((uint64_t)(rte_cpu_to_be_32(count))); in pdcp_iv_gen_null_zs()
83 uint32_t count) in pdcp_iv_gen_aes_ctr_null() argument
90 iv_u64[0] = en_priv->cipher_iv_part.u64[0] | ((uint64_t)(rte_cpu_to_be_32(count))); in pdcp_iv_gen_aes_ctr_null()
96 pdcp_iv_gen_zs_null(struct rte_crypto_op *cop, const struct entity_priv *en_priv, uint32_t count) in pdcp_iv_gen_zs_null() argument
103 iv_u64 = en_priv->cipher_iv_part.u64[0] | ((uint64_t)(rte_cpu_to_be_32(count))); in pdcp_iv_gen_zs_null()
[all …]
|
| H A D | pdcp_entity.h | 22 uint32_t count);
35 uint64_t count : 32; member
41 uint64_t count : 32;
50 uint64_t count : 32; member
62 uint64_t count : 32;
81 uint64_t count : 32; member
87 uint64_t count : 32;
97 uint64_t count : 32; member
103 uint64_t count : 32;
233 pdcp_sn_from_count_get(uint32_t count, enum rte_security_pdcp_sn_size sn_size) in pdcp_sn_from_count_get() argument
[all …]
|
| /dpdk/drivers/net/bnxt/tf_core/ |
| H A D | dpool.c | 92 uint32_t count; in dpool_defrag() local
141 count = 0; in dpool_defrag()
146 if (count == 0) in dpool_defrag()
148 count++; in dpool_defrag()
149 } else if (count > 0) { in dpool_defrag()
151 free_list->entry[free_list->size].size = count; in dpool_defrag()
153 if (count > largest_free_size) { in dpool_defrag()
155 largest_free_size = count; in dpool_defrag()
159 count = 0; in dpool_defrag()
164 largest_free_size = count; in dpool_defrag()
[all …]
|
| /dpdk/lib/distributor/ |
| H A D | rte_distributor.c | 37 unsigned int count) in EAL_REGISTER_TAILQ()
46 worker_id, count ? oldpkt[0] : NULL); in EAL_REGISTER_TAILQ()
68 for (i = count; i < RTE_DIST_BURST_SIZE; i++) in EAL_REGISTER_TAILQ()
72 for (i = count; i-- > 0; ) in EAL_REGISTER_TAILQ()
92 int count = 0; in rte_distributor_poll_pkt() local
114 pkts[count++] = (struct rte_mbuf *)((uintptr_t)(ret)); in rte_distributor_poll_pkt()
127 return count; in rte_distributor_poll_pkt()
135 int count; in rte_distributor_get_pkt() local
148 count = rte_distributor_poll_pkt(d, worker_id, pkts); in rte_distributor_get_pkt()
149 while (count == -1) { in rte_distributor_get_pkt()
[all …]
|
| H A D | rte_distributor_single.c | 88 if (bl->count == RTE_DISTRIB_BACKLOG_SIZE) in add_to_backlog()
91 bl->pkts[(bl->start + bl->count++) & (RTE_DISTRIB_BACKLOG_MASK)] in add_to_backlog()
100 bl->count--; in backlog_pop()
123 if (unlikely(d->backlog[wkr].count != 0)) { in handle_worker_shutdown()
138 for (i = 0; i < bl->count; i++) { in handle_worker_shutdown()
149 bl->count = bl->start = 0; in handle_worker_shutdown()
163 ret_count = d->returns.count; in process_returns()
173 if (d->backlog[wkr].count) in process_returns()
196 d->returns.count = ret_count; in process_returns()
212 ret_count = d->returns.count; in rte_distributor_process_single()
[all …]
|
| /dpdk/lib/eventdev/ |
| H A D | rte_event_ring.c | 12 unsigned int count, unsigned int flags) in rte_event_ring_init() argument
18 rte_eventdev_trace_ring_init(r, name, count, flags); in rte_event_ring_init()
21 return rte_ring_init(&r->r, name, count, flags); in rte_event_ring_init()
26 rte_event_ring_create(const char *name, unsigned int count, int socket_id, in rte_event_ring_create() argument
29 rte_eventdev_trace_ring_create(name, count, socket_id, flags); in rte_event_ring_create()
33 count, socket_id, flags); in rte_event_ring_create()
|
| /dpdk/drivers/dma/cnxk/ |
| H A D | cnxk_dmadev_fp.c | 139 int count; in __dpi_queue_write_single() local
150 count = dpi->chunk_size_m1 - dpi->chunk_head; in __dpi_queue_write_single()
153 __dpi_cpy_scalar(cmd, ptr, count); in __dpi_queue_write_single()
155 ptr += count; in __dpi_queue_write_single()
160 __dpi_cpy_scalar(cmd + count, ptr, CNXK_DPI_DW_PER_SINGLE_CMD - count); in __dpi_queue_write_single()
163 dpi->chunk_head = CNXK_DPI_DW_PER_SINGLE_CMD - count; in __dpi_queue_write_single()
189 uint16_t count; in __dpi_queue_write_sg() local
200 count = dpi->chunk_size_m1 - dpi->chunk_head; in __dpi_queue_write_sg()
203 if (count <= 4) { in __dpi_queue_write_sg()
204 __dpi_cpy(hdr, ptr, count); in __dpi_queue_write_sg()
[all …]
|
| /dpdk/examples/qos_sched/ |
| H A D | stats.c | 17 uint32_t count, i, queue_id = 0; in qavg_q() local
43 for (count = 0; count < qavg_ntimes; count++) { in qavg_q()
63 uint32_t count, i, queue_id = 0; in qavg_tcpipe() local
87 for (count = 0; count < qavg_ntimes; count++) { in qavg_tcpipe()
118 uint32_t count, i, queue_id = 0; in qavg_pipe() local
141 for (count = 0; count < qavg_ntimes; count++) { in qavg_pipe()
165 uint32_t queue_id, count, i, j, subport_queue_id = 0; in qavg_tcsubport() local
187 for (count = 0; count < qavg_ntimes; count++) { in qavg_tcsubport()
235 uint32_t queue_id, count, i, j, subport_queue_id = 0; in qavg_subport() local
255 for (count = 0; count < qavg_ntimes; count++) { in qavg_subport()
|
| /dpdk/examples/vhost/ |
| H A D | virtio_net.c | 189 struct rte_mbuf **pkts, uint32_t count) in vs_enqueue_pkts() argument
205 count = RTE_MIN(count, free_entries); in vs_enqueue_pkts()
206 count = RTE_MIN(count, (uint32_t)MAX_PKT_BURST); in vs_enqueue_pkts()
207 if (count == 0) in vs_enqueue_pkts()
212 for (i = 0; i < count; i++) { in vs_enqueue_pkts()
221 for (i = 0; i < count; i++) { in vs_enqueue_pkts()
231 if (i + 1 < count) in vs_enqueue_pkts()
235 rte_atomic_fetch_add_explicit((uint16_t __rte_atomic *)&vr->used->idx, count, in vs_enqueue_pkts()
237 queue->last_used_idx += count; in vs_enqueue_pkts()
241 return count; in vs_enqueue_pkts()
[all …]
|
| H A D | main.h | 66 uint32_t count);
70 struct rte_mbuf **pkts, uint16_t count);
112 struct rte_mbuf **pkts, uint32_t count);
115 struct rte_mbuf **pkts, uint32_t count);
118 struct rte_mbuf **pkts, uint16_t count);
120 struct rte_mbuf **pkts, uint32_t count);
123 struct rte_mbuf **pkts, uint16_t count);
125 struct rte_mbuf **pkts, uint32_t count);
128 struct rte_mbuf **pkts, uint16_t count);
|
| /dpdk/lib/graph/ |
| H A D | graph_stats.c | 227 rte_node_t count; in stats_mem_populate()
233 for (count = 0; count < stats->max_nodes; count++) { in stats_mem_populate()
323 rte_graph_t count; in expand_pattern_to_cluster()
327 for (count = 0; count < cluster->nb_graphs; count++) in rte_graph_cluster_stats_create()
328 if (cluster->graphs[count] == graph) in rte_graph_cluster_stats_create()
445 rte_node_t count; in rte_graph_cluster_stats_get() local
205 rte_node_t count; stats_mem_populate() local
270 rte_graph_t count; cluster_add() local
401 rte_node_t count; cluster_node_arregate_stats() local
466 rte_node_t count; rte_graph_cluster_stats_reset() local
[all...] |
| H A D | graph_populate.c | 80 rte_edge_t count, nb_edges; in graph_nodes_populate()
107 for (count = 0; count < nb_edges; count++) in graph_nodes_populate()
108 node->nodes[count] = (struct rte_node *)&graph_node
109 ->adjacency_list[count]
128 rte_node_t count; in graph_node_name_to_ptr()
132 rte_graph_foreach_node(count, off, graph, node) in graph_node_name_to_ptr()
142 rte_node_t count; in graph_node_nexts_populate()
146 rte_graph_foreach_node(count, of in graph_node_nexts_populate()
70 rte_edge_t count, nb_edges; graph_nodes_populate() local
112 rte_node_t count; graph_node_id_to_ptr() local
126 rte_node_t count; graph_node_name_to_ptr() local
140 rte_node_t count, val; graph_node_nexts_populate() local
224 rte_node_t count; graph_nodes_mem_destroy() local
[all...] |
| /dpdk/lib/node/ |
| H A D | ethdev_tx.c | 20 uint16_t count; in ethdev_tx_node_process() local
26 count = rte_eth_tx_burst(port, queue, (struct rte_mbuf **)objs, in ethdev_tx_node_process()
30 if (count != nb_objs) { in ethdev_tx_node_process()
32 &objs[count], nb_objs - count); in ethdev_tx_node_process()
35 return count; in ethdev_tx_node_process()
|