| /dpdk/examples/qos_sched/ |
| H A D | cfg_file.c | 28 int parse_u64(const char *entry, uint64_t *val) in parse_u64() argument 31 if (!entry || !val) in parse_u64() 36 *val = strtoull(entry, &endptr, 0); in parse_u64() 46 const char *entry; in cfg_load_port() local 51 entry = rte_cfgfile_get_entry(cfg, "port", "frame overhead"); in cfg_load_port() 52 if (entry) in cfg_load_port() 53 port_params->frame_overhead = (uint32_t)atoi(entry); in cfg_load_port() 55 entry = rte_cfgfile_get_entry(cfg, "port", "number of subports per port"); in cfg_load_port() 56 if (entry) in cfg_load_port() 57 port_params->n_subports_per_port = (uint32_t)atoi(entry); in cfg_load_port() [all …]
|
| /dpdk/drivers/net/cxgbe/ |
| H A D | mps_tcam.c | 9 match_entry(struct mps_tcam_entry *entry, const u8 *eth_addr, const u8 *mask) in match_entry() argument 11 if (!memcmp(eth_addr, entry->eth_addr, RTE_ETHER_ADDR_LEN) && in match_entry() 12 !memcmp(mask, entry->mask, RTE_ETHER_ADDR_LEN)) in match_entry() 19 struct mps_tcam_entry *entry = t->entry; in cxgbe_update_free_idx() local 22 if (entry[t->free_idx].state == MPS_ENTRY_UNUSED) in cxgbe_update_free_idx() 32 if (entry[i].state == MPS_ENTRY_UNUSED) { in cxgbe_update_free_idx() 45 struct mps_tcam_entry *entry = t->entry; in cxgbe_mpstcam_lookup() local 48 if (!entry) in cxgbe_mpstcam_lookup() 52 if (entry[i].state == MPS_ENTRY_UNUSED || in cxgbe_mpstcam_lookup() 53 entry[i].state == MPS_ENTRY_RAWF) in cxgbe_mpstcam_lookup() [all …]
|
| /dpdk/drivers/net/bnxt/tf_core/ |
| H A D | ll.c | 21 struct ll_entry *entry) in ll_insert() argument 24 ll->head = entry; in ll_insert() 25 ll->tail = entry; in ll_insert() 26 entry->next = NULL; in ll_insert() 27 entry->prev = NULL; in ll_insert() 29 entry->next = ll->head; in ll_insert() 30 entry->prev = NULL; in ll_insert() 31 entry->next->prev = entry; in ll_insert() 32 ll->head = entry->next->prev; in ll_insert() 39 struct ll_entry *entry) in ll_delete() argument [all …]
|
| H A D | dpool.c | 33 dpool->entry = parms.mem_va; in dpool_init() 43 dpool->entry[i].flags = 0; in dpool_init() 44 dpool->entry[i].index = start_index; in dpool_init() 45 dpool->entry[i].entry_data = 0UL; in dpool_init() 59 if (DP_IS_FREE(dpool->entry[dst_index].flags)) { in dpool_move() 60 size = DP_FLAGS_SIZE(dpool->entry[src_index].flags); in dpool_move() 62 dpool->entry[dst_index].flags = dpool->entry[src_index].flags; in dpool_move() 63 dpool->entry[dst_index].entry_data = dpool->entry[src_index].entry_data; in dpool_move() 67 dpool->entry[src_index].entry_data, in dpool_move() 71 dpool->entry[src_index].flags = 0; in dpool_move() [all …]
|
| /dpdk/lib/eal/common/ |
| H A D | eal_common_memalloc.c | 151 struct mem_event_callback_entry *entry; in eal_memalloc_mem_event_callback_register() local 167 entry = find_mem_event_callback(name, arg); in eal_memalloc_mem_event_callback_register() 168 if (entry != NULL) { in eal_memalloc_mem_event_callback_register() 174 entry = malloc(sizeof(*entry)); in eal_memalloc_mem_event_callback_register() 175 if (entry == NULL) { in eal_memalloc_mem_event_callback_register() 182 entry->clb = clb; in eal_memalloc_mem_event_callback_register() 183 entry->arg = arg; in eal_memalloc_mem_event_callback_register() 184 strlcpy(entry->name, name, RTE_MEM_EVENT_CALLBACK_NAME_LEN); in eal_memalloc_mem_event_callback_register() 185 TAILQ_INSERT_TAIL(&mem_event_callback_list, entry, next); in eal_memalloc_mem_event_callback_register() 200 struct mem_event_callback_entry *entry; in eal_memalloc_mem_event_callback_unregister() local [all …]
|
| H A D | malloc_mp.c | 301 struct mp_request *entry; in handle_request() local 308 entry = find_request_by_id(m->id); in handle_request() 309 if (entry != NULL) { in handle_request() 314 entry = malloc(sizeof(*entry)); in handle_request() 315 if (entry == NULL) { in handle_request() 321 memset(entry, 0, sizeof(*entry)); in handle_request() 324 ret = handle_alloc_request(m, entry); in handle_request() 352 free(entry); in handle_request() 407 struct mp_request *entry; handle_sync_response() local 558 struct mp_request *entry; handle_rollback_response() local 605 struct mp_request *entry; handle_response() local 702 struct mp_request *entry; request_to_primary() local [all...] |
| /dpdk/drivers/common/mlx5/ |
| H A D | mlx5_common_utils.c | 77 struct mlx5_list_entry *entry = in __list_lookup() local 81 while (entry != NULL) { in __list_lookup() 82 if (l_const->cb_match(l_const->ctx, entry, ctx) == 0) { in __list_lookup() 84 ret = rte_atomic_fetch_add_explicit(&entry->ref_cnt, 1, in __list_lookup() 87 l_const->name, (void *)entry, in __list_lookup() 88 entry->ref_cnt); in __list_lookup() 90 ret = rte_atomic_load_explicit(&entry->ref_cnt, in __list_lookup() 94 return entry; in __list_lookup() 96 entry->ref_cnt--; /* Invalid entry. */ in __list_lookup() 98 entry = LIST_NEXT(entry, next); in __list_lookup() [all …]
|
| H A D | mlx5_common_mr.c | 169 mr_btree_insert(struct mlx5_mr_btree *bt, struct mr_cache_entry *entry) in mr_btree_insert() argument 180 if (mr_btree_lookup(bt, &idx, entry->start) != UINT32_MAX) { in mr_btree_insert() 184 (void *)bt, idx, entry->start, entry->end, entry->lkey); in mr_btree_insert() 195 lkp_tbl[idx] = *entry; in mr_btree_insert() 200 (void *)bt, idx, entry->start, entry->end, entry->lkey); in mr_btree_insert() 280 struct mr_cache_entry *entry = &lkp_tbl[idx]; in mlx5_mr_btree_dump() local 284 (void *)bt, idx, entry->start, entry->end, entry->lkey); in mlx5_mr_btree_dump() 332 mr_find_next_chunk(struct mlx5_mr *mr, struct mr_cache_entry *entry, in mr_find_next_chunk() argument 348 entry->start = (uintptr_t)mr->pmd_mr.addr; in mr_find_next_chunk() 349 entry->end = (uintptr_t)mr->pmd_mr.addr + mr->pmd_mr.len; in mr_find_next_chunk() [all …]
|
| /dpdk/drivers/net/sfc/ |
| H A D | sfc_dp.c | 37 struct sfc_dp *entry; in sfc_dp_find_by_name() local 39 TAILQ_FOREACH(entry, head, links) { in sfc_dp_find_by_name() 40 if (entry->type != type) in sfc_dp_find_by_name() 43 if (strcmp(entry->name, name) == 0) in sfc_dp_find_by_name() 44 return entry; in sfc_dp_find_by_name() 54 struct sfc_dp *entry; in sfc_dp_find_by_caps() local 56 TAILQ_FOREACH(entry, head, links) { in sfc_dp_find_by_caps() 57 if (entry->type != type) in sfc_dp_find_by_caps() 61 if (sfc_dp_match_hw_fw_caps(entry, avail_caps)) in sfc_dp_find_by_caps() 62 return entry; in sfc_dp_find_by_caps() [all …]
|
| /dpdk/drivers/crypto/mlx5/ |
| H A D | mlx5_crypto_dek.c | 41 return mlx5_hlist_unregister(priv->dek_hlist, &dek->entry); in mlx5_crypto_dek_destroy() 56 struct mlx5_list_entry *entry; in mlx5_crypto_dek_prepare() local 61 entry = mlx5_hlist_register(dek_hlist, key64, &dek_ctx); in mlx5_crypto_dek_prepare() 62 return entry == NULL ? NULL : in mlx5_crypto_dek_prepare() 63 container_of(entry, struct mlx5_crypto_dek, entry); in mlx5_crypto_dek_prepare() 71 struct mlx5_crypto_dek *entry = rte_zmalloc(__func__, sizeof(*entry), in mlx5_crypto_dek_clone_cb() local 74 if (!entry) { in mlx5_crypto_dek_clone_cb() 79 memcpy(entry, oentry, sizeof(*entry)); in mlx5_crypto_dek_clone_cb() 80 return &entry->entry; in mlx5_crypto_dek_clone_cb() 85 struct mlx5_list_entry *entry) in mlx5_crypto_dek_clone_free_cb() argument [all …]
|
| /dpdk/app/test-mldev/ |
| H A D | ml_test.c | 10 ml_test_register(struct ml_test_entry *entry) in ml_test_register() argument 12 STAILQ_INSERT_TAIL(&head, entry, next); in ml_test_register() 18 struct ml_test_entry *entry; in ml_test_get() local 23 STAILQ_FOREACH(entry, &head, next) in ml_test_get() 24 if (!strncmp(entry->test.name, name, strlen(name))) in ml_test_get() 25 return &entry->test; in ml_test_get() 33 struct ml_test_entry *entry; in ml_test_dump_names() local 35 STAILQ_FOREACH(entry, &head, next) in ml_test_dump_names() 37 if (entry->test.name) in ml_test_dump_names() 38 printf("\t %s\n", entry->test.name); in ml_test_dump_names() [all …]
|
| /dpdk/drivers/net/thunderx/ |
| H A D | nicvf_svf.c | 18 struct svf_entry *entry = NULL; in nicvf_svf_push() local 22 entry = rte_zmalloc("nicvf", sizeof(*entry), RTE_CACHE_LINE_SIZE); in nicvf_svf_push() 23 if (entry == NULL) in nicvf_svf_push() 26 entry->vf = vf; in nicvf_svf_push() 28 nicvf_bsvf_push(entry); in nicvf_svf_push() 35 struct svf_entry *entry; in nicvf_svf_pop() local 37 entry = nicvf_bsvf_pop(); in nicvf_svf_pop() 39 vf = entry->vf; in nicvf_svf_pop() 41 rte_free(entry); in nicvf_svf_pop()
|
| /dpdk/app/test-eventdev/ |
| H A D | evt_test.c | 14 evt_test_register(struct evt_test_entry *entry) in evt_test_register() argument 16 STAILQ_INSERT_TAIL(&head, entry, next); in evt_test_register() 22 struct evt_test_entry *entry; in evt_test_get() local 27 STAILQ_FOREACH(entry, &head, next) in evt_test_get() 28 if (!strncmp(entry->test.name, name, strlen(name))) in evt_test_get() 29 return &entry->test; in evt_test_get() 37 struct evt_test_entry *entry; in evt_test_dump_names() local 39 STAILQ_FOREACH(entry, &head, next) in evt_test_dump_names() 40 if (entry->test.name) in evt_test_dump_names() 41 printf("\t %s\n", entry->test.name); in evt_test_dump_names()
|
| /dpdk/drivers/common/dpaax/ |
| H A D | dpaax_iova_table.c | 163 struct dpaax_iovat_element *entry; in dpaax_iova_table_populate() local 210 entry = dpaax_iova_table_p->entries; in dpaax_iova_table_populate() 212 DPAAX_DEBUG("IOVA Table entries: (entry start = %p)", (void *)entry); in dpaax_iova_table_populate() 230 entry[i].start = nodes[i].addr; in dpaax_iova_table_populate() 231 entry[i].len = nodes[i].len; in dpaax_iova_table_populate() 233 entry[i].pages = entry[i-1].pages + in dpaax_iova_table_populate() 234 ((entry[i-1].len/DPAAX_MEM_SPLIT)); in dpaax_iova_table_populate() 236 entry[i].pages = (uint64_t *)((unsigned char *)entry + in dpaax_iova_table_populate() 241 i, entry[i].start, entry[i].len, entry[i].pages); in dpaax_iova_table_populate() 272 struct dpaax_iovat_element *entry; in dpaax_iova_table_update() local [all …]
|
| H A D | dpaax_iova_table.h | 82 struct dpaax_iovat_element *entry; in dpaax_iova_table_get_va() local 87 entry = dpaax_iova_table_p->entries; in dpaax_iova_table_get_va() 93 if (paddr_align < entry[i].start) { in dpaax_iova_table_get_va() 98 if (paddr_align > (entry[i].start + entry[i].len)) { in dpaax_iova_table_get_va() 104 index = (paddr_align - entry[i].start)/DPAAX_MEM_SPLIT; in dpaax_iova_table_get_va() 108 if ((void *)(uintptr_t)entry[i].pages[index] == NULL) in dpaax_iova_table_get_va() 111 vaddr = (void *)((uintptr_t)entry[i].pages[index] + offset); in dpaax_iova_table_get_va()
|
| /dpdk/drivers/net/thunderx/base/ |
| H A D | nicvf_bsvf.c | 15 nicvf_bsvf_push(struct svf_entry *entry) in nicvf_bsvf_push() argument 17 assert(entry != NULL); in nicvf_bsvf_push() 18 assert(entry->vf != NULL); in nicvf_bsvf_push() 20 STAILQ_INSERT_TAIL(&head, entry, next); in nicvf_bsvf_push() 26 struct svf_entry *entry; in nicvf_bsvf_pop() local 30 entry = STAILQ_FIRST(&head); in nicvf_bsvf_pop() 32 assert(entry != NULL); in nicvf_bsvf_pop() 33 assert(entry->vf != NULL); in nicvf_bsvf_pop() 37 return entry; in nicvf_bsvf_pop()
|
| /dpdk/lib/ipsec/ |
| H A D | ipsec_telemetry.c | 24 struct ipsec_telemetry_entry *entry; in handle_telemetry_cmd_ipsec_sa_list() local 27 LIST_FOREACH(entry, &ipsec_telemetry_list, next) { in handle_telemetry_cmd_ipsec_sa_list() 28 const struct rte_ipsec_sa *sa = entry->sa; in handle_telemetry_cmd_ipsec_sa_list() 50 struct ipsec_telemetry_entry *entry; in handle_telemetry_cmd_ipsec_sa_stats() local 62 LIST_FOREACH(entry, &ipsec_telemetry_list, next) { in handle_telemetry_cmd_ipsec_sa_stats() 64 sa = entry->sa; in handle_telemetry_cmd_ipsec_sa_stats() 108 struct ipsec_telemetry_entry *entry; in handle_telemetry_cmd_ipsec_sa_details() local 121 LIST_FOREACH(entry, &ipsec_telemetry_list, next) { in handle_telemetry_cmd_ipsec_sa_details() 123 sa = entry->sa; in handle_telemetry_cmd_ipsec_sa_details() 210 struct ipsec_telemetry_entry *entry = rte_zmalloc(NULL, in rte_ipsec_telemetry_sa_add() local [all …]
|
| /dpdk/lib/pipeline/ |
| H A D | rte_swx_ctl.c | 286 table_entry_free(struct rte_swx_table_entry *entry) in table_entry_free() argument 288 if (!entry) in table_entry_free() 291 free(entry->key); in table_entry_free() 292 free(entry->key_mask); in table_entry_free() 293 free(entry->action_data); in table_entry_free() 294 free(entry); in table_entry_free() 300 struct rte_swx_table_entry *entry; in table_entry_alloc() local 302 entry = calloc(1, sizeof(struct rte_swx_table_entry)); in table_entry_alloc() 303 if (!entry) in table_entry_alloc() 308 entry->key = calloc(1, table->params.key_size); in table_entry_alloc() [all …]
|
| /dpdk/drivers/common/sfc_efx/base/ |
| H A D | efx_tunnel.c | 88 __in efx_tunnel_udp_entry_t *entry) in ef10_entry_staged() argument 90 switch (entry->etue_state) { in ef10_entry_staged() 92 return (entry->etue_busy); in ef10_entry_staged() 94 return (!entry->etue_busy); in ef10_entry_staged() 118 unsigned int entry; in efx_mcdi_set_tunnel_encap_udp_ports() local 146 for (i = 0, entry = 0; entry < entries_num; ++entry, ++i) { in efx_mcdi_set_tunnel_encap_udp_ports() 173 SET_TUNNEL_ENCAP_UDP_PORTS_IN_ENTRIES)[entry], in efx_mcdi_set_tunnel_encap_udp_ports() 326 unsigned int entry; in efx_tunnel_config_udp_add() local 343 rc = efx_tunnel_config_find_udp_tunnel_entry(etcp, port, &entry); in efx_tunnel_config_udp_add() 390 __in unsigned int entry) in efx_tunnel_config_udp_do_remove() argument [all …]
|
| /dpdk/lib/metrics/ |
| H A D | rte_metrics.c | 117 struct rte_metrics_meta_s *entry = NULL; in rte_metrics_reg_names() local 146 entry = &stats->metadata[idx_name + stats->cnt_stats]; in rte_metrics_reg_names() 147 strlcpy(entry->name, names[idx_name], RTE_METRICS_MAX_NAME_LEN); in rte_metrics_reg_names() 148 memset(entry->value, 0, sizeof(entry->value)); in rte_metrics_reg_names() 149 entry->idx_next_stat = idx_name + stats->cnt_stats + 1; in rte_metrics_reg_names() 151 entry->idx_next_stat = 0; in rte_metrics_reg_names() 152 entry->idx_next_set = 0; in rte_metrics_reg_names() 172 struct rte_metrics_meta_s *entry; in rte_metrics_update_values() local 200 entry = &stats->metadata[idx_metric]; in rte_metrics_update_values() 201 if (entry->idx_next_stat == 0) in rte_metrics_update_values() [all …]
|
| /dpdk/drivers/event/octeontx/ |
| H A D | timvf_worker.c | 32 struct tim_mem_entry * const entry) in timvf_format_event() argument 34 entry->w0 = (tim->ev.event & 0xFFC000000000) >> 6 | in timvf_format_event() 36 entry->wqe = tim->ev.u64; in timvf_format_event() 72 struct tim_mem_entry entry; in timvf_timer_arm_burst_sp() local 78 timvf_format_event(tim[index], &entry); in timvf_timer_arm_burst_sp() 80 tim[index], &entry); in timvf_timer_arm_burst_sp() 109 struct tim_mem_entry entry; in timvf_timer_arm_burst_mp() local 114 timvf_format_event(tim[index], &entry); in timvf_timer_arm_burst_mp() 116 tim[index], &entry); in timvf_timer_arm_burst_mp() 149 alignas(RTE_CACHE_LINE_SIZE) struct tim_mem_entry entry[TIMVF_MAX_BURST]; in timvf_timer_arm_tmo_brst() local [all …]
|
| /dpdk/drivers/net/octeontx/ |
| H A D | octeontx_ethdev_ops.c | 74 struct vlan_entry *entry = NULL; in octeontx_dev_vlan_filter_set() local 79 TAILQ_FOREACH(entry, &vlan->fltr_tbl, next) in octeontx_dev_vlan_filter_set() 80 if (entry->vlan_id == vlan_id) { in octeontx_dev_vlan_filter_set() 85 TAILQ_FOREACH(entry, &vlan->fltr_tbl, next) in octeontx_dev_vlan_filter_set() 98 entry = rte_zmalloc("octeontx_nic_vlan_entry", in octeontx_dev_vlan_filter_set() 100 if (!entry) { in octeontx_dev_vlan_filter_set() 111 rte_free(entry); in octeontx_dev_vlan_filter_set() 117 entry->vlan_id = vlan_id; in octeontx_dev_vlan_filter_set() 118 TAILQ_INSERT_HEAD(&vlan->fltr_tbl, entry, next); in octeontx_dev_vlan_filter_set() 120 TAILQ_FOREACH(entry, &vlan->fltr_tbl, next) { in octeontx_dev_vlan_filter_set() [all …]
|
| /dpdk/drivers/vdpa/mlx5/ |
| H A D | mlx5_vdpa_mem.c | 22 struct mlx5_vdpa_query_mr *entry; in mlx5_vdpa_mem_dereg() local 27 entry = &mrs[i]; in mlx5_vdpa_mem_dereg() 28 if (entry->is_indirect) { in mlx5_vdpa_mem_dereg() 29 if (entry->mkey) in mlx5_vdpa_mem_dereg() 31 mlx5_devx_cmd_destroy(entry->mkey)); in mlx5_vdpa_mem_dereg() 33 if (entry->mr) in mlx5_vdpa_mem_dereg() 35 mlx5_glue->dereg_mr(entry->mr)); in mlx5_vdpa_mem_dereg() 184 struct mlx5_vdpa_query_mr *entry; in mlx5_vdpa_create_indirect_mkey() local 199 entry = &mrs[i]; in mlx5_vdpa_create_indirect_mkey() 229 klm_array[klm_index].mkey = entry->mr->lkey; in mlx5_vdpa_create_indirect_mkey() [all …]
|
| /dpdk/app/test-crypto-perf/ |
| H A D | cperf_test_vector_parsing.c | 278 parse_entry(char *entry, struct cperf_test_vector *vector, in parse_entry() argument 287 if (entry == NULL) { in parse_entry() 293 token = strtok(entry, CPERF_ENTRY_DELIMITER); in parse_entry() 299 printf("Expected 'key = values' but was '%.40s'..\n", entry); in parse_entry() 470 char *entry = NULL; in parse_file() local 507 entry = (char *) rte_realloc(entry, in parse_file() 509 if (entry == NULL) in parse_file() 512 strcpy(entry, line); in parse_file() 515 if (entry[strlen(entry) - 1] == ',' in parse_file() 516 || entry[strlen(entry) - 1] == '=') { in parse_file() [all …]
|
| /dpdk/lib/hash/ |
| H A D | rte_fbk_hash.h | 57 /** Individual entry in the four-byte key hash table. */ 59 uint64_t whole_entry; /**< For accessing entire entry. */ 61 uint16_t is_entry; /**< Non-zero if entry is active. */ 64 } entry; /**< For accessing each entry part. */ member 132 /* Set entry if unused. */ in rte_fbk_hash_add_key_with_bucket() 133 if (! ht->t[bucket + i].entry.is_entry) { in rte_fbk_hash_add_key_with_bucket() 139 if (ht->t[bucket + i].entry.key == key) { in rte_fbk_hash_add_key_with_bucket() 140 ht->t[bucket + i].entry.value = value; in rte_fbk_hash_add_key_with_bucket() 191 if (ht->t[bucket + i].entry in rte_fbk_hash_delete_key_with_bucket() [all...] |