Home
last modified time | relevance | path

Searched refs:cb (Results 1 – 25 of 63) sorted by relevance

123

/dpdk/app/test/
H A Dtest_cmdline_cirbuf.c23 struct cirbuf cb; in test_cirbuf_string_misc() local
134 struct cirbuf cb; in test_cirbuf_string_add_del() local
822 if (cb.start != 0 || cb.len != LEN1 || cb.end != cb.len - 1) { in test_cirbuf_align_left()
855 if (cb.start != 0 || cb.len != LEN2 || cb.end != cb.len - 1) { in test_cirbuf_align_left()
888 if (cb.start != 0 || cb.len != LEN3 || cb.end != cb.len - 1) { in test_cirbuf_align_left()
921 if (cb.start != 0 || cb.len != LEN4 || in test_cirbuf_align_left()
922 cb.end != cb.len - 1) { in test_cirbuf_align_left()
1024 if (cb.start != END_OFFSET || cb.len != LEN1 || cb.end != cb.len - 2) { in test_cirbuf_align_right()
1054 if (cb.start != END_OFFSET || cb.len != LEN2 || cb.end != cb.len - 2) { in test_cirbuf_align_right()
1084 if (cb.end != END_OFFSET || cb.len != LEN3 || cb.start != cb.end - cb.len + 1) { in test_cirbuf_align_right()
[all …]
/dpdk/lib/eal/freebsd/
H A Deal_interrupts.c127 callback->cb_fn = cb; in rte_intr_callback_register()
254 for (cb = TAILQ_FIRST(&src->callbacks); cb != NULL; cb = next) { in rte_intr_callback_unregister_pending()
258 cb->pending_delete = 1; in rte_intr_callback_unregister_pending()
259 cb->ucb_fn = ucb_fn; in rte_intr_callback_unregister_pending()
333 for (cb = TAILQ_FIRST(&src->callbacks); cb != NULL; cb = next) { in rte_intr_callback_unregister()
338 free(cb); in rte_intr_callback_unregister()
535 active_cb = *cb; in eal_intr_process_interrupts()
550 for (cb = TAILQ_FIRST(&src->callbacks); cb != NULL; cb = next) { in eal_intr_process_interrupts()
578 if (cb->ucb_fn) in eal_intr_process_interrupts()
579 cb->ucb_fn(src->intr_handle, cb->cb_arg); in eal_intr_process_interrupts()
[all …]
/dpdk/lib/eal/linux/
H A Deal_interrupts.c602 for (cb = TAILQ_FIRST(&src->callbacks); cb != NULL; cb = next) { in rte_intr_callback_unregister_pending()
652 for (cb = TAILQ_FIRST(&src->callbacks); cb != NULL; cb = next) { in rte_intr_callback_unregister()
659 free(cb); in rte_intr_callback_unregister()
988 for (cb = TAILQ_FIRST(&src->callbacks); cb; in eal_intr_process_interrupts()
989 cb = next) { in eal_intr_process_interrupts()
992 free(cb); in eal_intr_process_interrupts()
1013 active_cb = *cb; in eal_intr_process_interrupts()
1029 for (cb = TAILQ_FIRST(&src->callbacks); cb != NULL; cb = next) { in eal_intr_process_interrupts()
1033 if (cb->ucb_fn) in eal_intr_process_interrupts()
1034 cb->ucb_fn(src->intr_handle, cb->cb_arg); in eal_intr_process_interrupts()
[all …]
/dpdk/lib/bpf/
H A Dbpf_pkt.c270 rc = (cbi->cb != NULL) ? in bpf_rx_callback_vm()
287 rc = (cbi->cb != NULL) ? in bpf_rx_callback_jit()
303 rc = (cbi->cb != NULL) ? in bpf_tx_callback_vm()
319 rc = (cbi->cb != NULL) ? in bpf_tx_callback_jit()
340 rc = (cbi->cb != NULL) ? in bpf_rx_callback_mb_vm()
357 rc = (cbi->cb != NULL) ? in bpf_rx_callback_mb_jit()
373 rc = (cbi->cb != NULL) ? in bpf_tx_callback_mb_vm()
389 rc = (cbi->cb != NULL) ? in bpf_tx_callback_mb_jit()
441 bc->cb = NULL; in bpf_eth_cbi_unload()
539 if (bc->cb != NULL) in bpf_eth_elf_load()
[all …]
/dpdk/lib/cryptodev/
H A Drte_cryptodev.h1745 struct rte_cryptodev_cb *cb);
1813 struct rte_cryptodev_cb *cb);
1869 struct rte_cryptodev_cb *cb; in rte_cryptodev_dequeue_burst() local
1881 while (cb != NULL) { in rte_cryptodev_dequeue_burst()
1882 nb_ops = cb->fn(dev_id, qp_id, ops, nb_ops, in rte_cryptodev_dequeue_burst()
1883 cb->arg); in rte_cryptodev_dequeue_burst()
1884 cb = cb->next; in rte_cryptodev_dequeue_burst()
1936 struct rte_cryptodev_cb *cb; in rte_cryptodev_enqueue_burst() local
1948 while (cb != NULL) { in rte_cryptodev_enqueue_burst()
1950 cb->arg); in rte_cryptodev_enqueue_burst()
[all …]
H A Drte_cryptodev.c471 rte_free(cb); in cryptodev_cb_cleanup()
472 cb = next; in cryptodev_cb_cleanup()
484 cb = next; in cryptodev_cb_cleanup()
1294 cb = rte_zmalloc(NULL, sizeof(*cb), 0); in rte_cryptodev_add_enq_callback()
1327 return cb; in rte_cryptodev_add_enq_callback()
1342 if (!cb) { in rte_cryptodev_remove_enq_callback()
1429 cb = rte_zmalloc(NULL, sizeof(*cb), 0); in rte_cryptodev_add_deq_callback()
1462 return cb; in rte_cryptodev_add_deq_callback()
1477 if (!cb) { in rte_cryptodev_remove_deq_callback()
1659 for (cb = TAILQ_FIRST(&dev->link_intr_cbs); cb != NULL; cb = next) { in rte_cryptodev_callback_unregister()
[all …]
/dpdk/drivers/common/cnxk/
H A Droc_irq.c128 dev_irq_register(struct plt_intr_handle *intr_handle, plt_intr_callback_fn cb, in dev_irq_register() argument
157 rc = plt_intr_callback_register(tmp_handle, cb, data); in dev_irq_register()
183 dev_irq_unregister(struct plt_intr_handle *intr_handle, plt_intr_callback_fn cb, in dev_irq_unregister() argument
206 rc = plt_intr_callback_unregister(tmp_handle, cb, data); in dev_irq_unregister()
234 dev_irq_register(struct plt_intr_handle *intr_handle, plt_intr_callback_fn cb, in dev_irq_register() argument
238 PLT_SET_USED(cb); in dev_irq_register()
246 dev_irq_unregister(struct plt_intr_handle *intr_handle, plt_intr_callback_fn cb, in dev_irq_unregister() argument
250 PLT_SET_USED(cb); in dev_irq_unregister()
H A Droc_platform.c15 roc_plt_init_cb_register(roc_plt_init_cb_t cb) in roc_plt_init_cb_register() argument
20 plt_init_cbs[plt_init_cb_num++] = cb; in roc_plt_init_cb_register()
H A Droc_dev_priv.h109 plt_intr_callback_fn cb, void *data, unsigned int vec);
111 plt_intr_callback_fn cb, void *data, unsigned int vec);
/dpdk/lib/ethdev/
H A Dethdev_private.c292 const struct rte_eth_rxtx_callback *cb = opaque; in rte_eth_call_rx_callbacks() local
294 while (cb != NULL) { in rte_eth_call_rx_callbacks()
295 nb_rx = cb->fn.rx(port_id, queue_id, rx_pkts, nb_rx, in rte_eth_call_rx_callbacks()
296 nb_pkts, cb->param); in rte_eth_call_rx_callbacks()
297 cb = cb->next; in rte_eth_call_rx_callbacks()
307 const struct rte_eth_rxtx_callback *cb = opaque; in rte_eth_call_tx_callbacks() local
309 while (cb != NULL) { in rte_eth_call_tx_callbacks()
310 nb_pkts = cb->fn.tx(port_id, queue_id, tx_pkts, nb_pkts, in rte_eth_call_tx_callbacks()
311 cb->param); in rte_eth_call_tx_callbacks()
312 cb = cb->next; in rte_eth_call_tx_callbacks()
H A Drte_ethdev.c4549 for (cb = TAILQ_FIRST(&dev->link_intr_cbs); cb != NULL; in rte_eth_dev_callback_unregister()
4554 if (cb->cb_fn != cb_fn || cb->event != event || in rte_eth_dev_callback_unregister()
4564 rte_free(cb); in rte_eth_dev_callback_unregister()
4752 cb->fn.rx = fn; in rte_eth_add_rx_callback()
4778 return cb; in rte_eth_add_rx_callback()
4803 cb->fn.rx = fn; in rte_eth_add_first_rx_callback()
4817 return cb; in rte_eth_add_first_rx_callback()
4850 cb->fn.tx = fn; in rte_eth_add_tx_callback()
4876 return cb; in rte_eth_add_tx_callback()
4900 cb = *prev_cb; in rte_eth_remove_rx_callback()
[all …]
/dpdk/drivers/net/pcap/
H A Dpcap_osdep_windows.c20 const char *ob, *cb; in iface_guid() local
26 cb = strchr(ob, '}'); in iface_guid()
27 if (cb == NULL || cb - ob != GUID_LENGTH + 1) /* + 1 opening '{' */ in iface_guid()
/dpdk/examples/fips_validation/
H A Dfips_validation.c376 ret = info.interim_callbacks[j].cb( in fips_test_parse_one_case()
410 ret = info.callbacks[j].cb( in fips_test_parse_one_case()
679 const struct fips_test_callback *cb; in update_info_vec() local
685 cb = &info.writeback_callbacks[0]; in update_info_vec()
687 if ((info.version == 21.4f) && (!(strstr(info.vec[0], cb->key)))) { in update_info_vec()
688 fprintf(info.fp_wr, "%s%u\n", cb->key, count); in update_info_vec()
691 snprintf(info.vec[0], strlen(info.vec[0]) + 4, "%s%u", cb->key, in update_info_vec()
698 cb = &info.writeback_callbacks[j]; in update_info_vec()
699 if (strstr(info.vec[i], cb->key)) { in update_info_vec()
700 cb->cb(cb->key, info.vec[i], cb->val); in update_info_vec()
/dpdk/lib/latencystats/
H A Drte_latencystats.c58 const struct rte_eth_rxtx_callback *cb; member
275 cbs->cb = rte_eth_add_first_rx_callback(pid, qid, in rte_latencystats_init()
277 if (!cbs->cb) in rte_latencystats_init()
284 cbs->cb = rte_eth_add_tx_callback(pid, qid, in rte_latencystats_init()
286 if (!cbs->cb) in rte_latencystats_init()
319 ret = rte_eth_remove_rx_callback(pid, qid, cbs->cb); in rte_latencystats_uninit()
327 ret = rte_eth_remove_tx_callback(pid, qid, cbs->cb); in rte_latencystats_uninit()
/dpdk/lib/bbdev/
H A Drte_bbdev.c234 struct rte_bbdev_callback *cb, *next; in rte_bbdev_release() local
243 for (cb = TAILQ_FIRST(&bbdev->list_cbs); cb != NULL; cb = next) { in rte_bbdev_release()
245 next = TAILQ_NEXT(cb, next); in rte_bbdev_release()
246 TAILQ_REMOVE(&(bbdev->list_cbs), cb, next); in rte_bbdev_release()
247 rte_free(cb); in rte_bbdev_release()
976 struct rte_bbdev_callback *cb, *next; in rte_bbdev_callback_unregister() local
996 for (cb = TAILQ_FIRST(&dev->list_cbs); cb != NULL; cb = next) { in rte_bbdev_callback_unregister()
998 next = TAILQ_NEXT(cb, next); in rte_bbdev_callback_unregister()
1000 if (cb->cb_fn != cb_fn || cb->event != event || in rte_bbdev_callback_unregister()
1005 if (cb->active == 0) { in rte_bbdev_callback_unregister()
[all …]
/dpdk/lib/pdump/
H A Drte_pdump.c59 const struct rte_eth_rxtx_callback *cb; member
183 if (cbs->cb) { in pdump_register_rx_callbacks()
195 cbs->cb = rte_eth_add_first_rx_callback(port, qid, in pdump_register_rx_callbacks()
197 if (cbs->cb == NULL) { in pdump_register_rx_callbacks()
206 if (cbs->cb == NULL) { in pdump_register_rx_callbacks()
212 ret = rte_eth_remove_rx_callback(port, qid, cbs->cb); in pdump_register_rx_callbacks()
219 cbs->cb = NULL; in pdump_register_rx_callbacks()
241 if (cbs->cb) { in pdump_register_tx_callbacks()
255 if (cbs->cb == NULL) { in pdump_register_tx_callbacks()
264 if (cbs->cb == NULL) { in pdump_register_tx_callbacks()
[all …]
/dpdk/lib/mempool/
H A Drte_mempool.c1392 cb->func(event, mp, cb->user_data); in mempool_event_callback_invoke()
1416 cb = te->data; in rte_mempool_event_callback_register()
1417 if (cb->func == func && cb->user_data == user_data) { in rte_mempool_event_callback_register()
1431 cb = rte_malloc("mempool_cb_data", sizeof(*cb), 0); in rte_mempool_event_callback_register()
1432 if (cb == NULL) { in rte_mempool_event_callback_register()
1440 cb->func = func; in rte_mempool_event_callback_register()
1441 cb->user_data = user_data; in rte_mempool_event_callback_register()
1442 te->data = cb; in rte_mempool_event_callback_register()
1464 cb = te->data; in rte_mempool_event_callback_unregister()
1465 if (cb->func == func && cb->user_data == user_data) { in rte_mempool_event_callback_unregister()
[all …]
/dpdk/lib/eal/include/
H A Drte_eal_trace.h152 rte_intr_callback_fn cb, void *cb_arg, int rc),
159 rte_trace_point_emit_ptr(cb);
165 rte_intr_callback_fn cb, void *cb_arg, int rc),
172 rte_trace_point_emit_ptr(cb);
H A Drte_interrupts.h85 rte_intr_callback_fn cb, void *cb_arg);
103 rte_intr_callback_fn cb, void *cb_arg);
153 rte_intr_callback_fn cb, void *cb_arg);
/dpdk/drivers/net/tap/
H A Dtap_bpf_program.c58 __u32 queue = skb->cb[1]; in match_q()
68 skb->cb[1] = 0; in match_q()
209 skb->cb[1] = QUEUE_OFFSET + queue; in rss_l3_l4()
H A Dtap_netlink.c237 tap_nl_recv(int nlsk_fd, int (*cb)(struct nlmsghdr *, void *arg), void *arg) in tap_nl_recv()
275 if (cb) in tap_nl_recv()
276 ret = cb(nh, arg); in tap_nl_recv()
/dpdk/lib/power/
H A Drte_power_pmd_mgmt.c49 const struct rte_eth_rxtx_callback *cb; member
583 queue_cfg->cb = rte_eth_add_rx_callback(port_id, queue_id, in rte_power_ethdev_pmgmt_queue_enable()
642 rte_eth_remove_rx_callback(port_id, queue_id, queue_cfg->cb); in rte_power_ethdev_pmgmt_queue_disable()
645 rte_eth_remove_rx_callback(port_id, queue_id, queue_cfg->cb); in rte_power_ethdev_pmgmt_queue_disable()
658 rte_free((void *)queue_cfg->cb); in rte_power_ethdev_pmgmt_queue_disable()
/dpdk/drivers/baseband/fpga_lte_fec/
H A Dfpga_lte_fec.c1453 cb = &turbo_enc->cb_params; in validate_enc_op()
1454 if (cb->k < RTE_BBDEV_TURBO_MIN_CB_SIZE in validate_enc_op()
1455 || cb->k > RTE_BBDEV_TURBO_MAX_CB_SIZE) { in validate_enc_op()
1458 cb->k, RTE_BBDEV_TURBO_MIN_CB_SIZE, in validate_enc_op()
1463 if (cb->e < RTE_BBDEV_TURBO_MIN_CB_SIZE || (cb->e % 2)) { in validate_enc_op()
1466 cb->e, RTE_BBDEV_TURBO_MIN_CB_SIZE); in validate_enc_op()
1471 if (cb->ncb < cb->k || cb->ncb > kw) { in validate_enc_op()
1474 cb->ncb, cb->k, kw); in validate_enc_op()
1764 cb = &turbo_dec->cb_params; in validate_dec_op()
1765 if (cb->k < RTE_BBDEV_TURBO_MIN_CB_SIZE in validate_dec_op()
[all …]
/dpdk/drivers/bus/dpaa/base/qbman/
H A Dqman.c798 qman_free_mbuf_cb = cb; in qman_ern_register_cb()
902 if (fq->cb.fqs) in __poll_portal_slow()
903 fq->cb.fqs(p, fq, &swapped_msg); in __poll_portal_slow()
913 if (fq->cb.fqs) in __poll_portal_slow()
941 fq->cb.ern(p, fq, &swapped_msg); in __poll_portal_slow()
1046 res = fq->cb.dqrr(p, fq, dq); in __poll_portal_fast()
1060 res = fq->cb.dqrr(p, fq, dq); in __poll_portal_fast()
1232 if (fq->cb.dqrr_prepare) in qman_portal_poll_rx()
1796 if (fq->cb.fqs) { in qman_retire_fq()
1816 fq->cb.fqs(p, fq, &msg); in qman_retire_fq()
[all …]
/dpdk/drivers/net/qede/base/
H A Decore_spq.h47 struct ecore_spq_comp_cb cb; member
97 ecore_spq_async_comp_cb cb);

123