| /dpdk/lib/telemetry/ |
| H A D | telemetry_legacy.c | 39 telemetry_legacy_cb fn; member 48 .fn = register_client 57 telemetry_legacy_cb fn) in rte_telemetry_legacy_register() argument 59 if (fn == NULL) in rte_telemetry_legacy_register() 71 callbacks[num_legacy_callbacks].fn = fn; in rte_telemetry_legacy_register() 162 perform_command(telemetry_legacy_cb fn, const char *param, int s) in perform_command() argument 167 ret = fn("", param, out_buf, sizeof(out_buf)); in perform_command() 184 telemetry_legacy_cb fn = NULL; in parse_client_request() local 219 fn = callbacks[i].fn; in parse_client_request() 223 if (!fn) in parse_client_request() [all …]
|
| H A D | telemetry.c | 36 telemetry_cb fn; member 44 handler fn; member 75 if (strlen(cmd) >= MAX_CMD_LEN || fn == NULL || cmd[0] != '/' in rte_telemetry_register_cmd() 95 callbacks[i].fn = fn; in rte_telemetry_register_cmd() 332 int ret = fn(cmd, param, &data); in perform_command() 371 telemetry_cb fn = unknown_command; in client_handler() local 378 fn = callbacks[i].fn; in client_handler() 383 perform_command(fn, cmd, param, s); in client_handler() 414 rc = pthread_create(&th, NULL, s->fn, in socket_listener() 523 v1_socket.fn = legacy_client_handler; in telemetry_legacy_init() [all …]
|
| H A D | telemetry_internal.h | 84 telemetry_legacy_cb fn);
|
| H A D | rte_telemetry.h | 277 rte_telemetry_register_cmd(const char *cmd, telemetry_cb fn, const char *help);
|
| /dpdk/drivers/event/cnxk/ |
| H A D | cn9k_worker.h | 431 #define SSO_DEQ_SEG(fn, flags) SSO_DEQ(fn, flags | NIX_RX_MULTI_SEG_F) argument 432 #define SSO_DEQ_CA(fn, flags) SSO_DEQ(fn, flags | CPT_RX_WQE_F) argument 433 #define SSO_DEQ_CA_SEG(fn, flags) SSO_DEQ_SEG(fn, flags | CPT_RX_WQE_F) argument 454 #define SSO_DEQ_TMO_SEG(fn, flags) SSO_DEQ_TMO(fn, flags | NIX_RX_MULTI_SEG_F) argument 455 #define SSO_DEQ_TMO_CA(fn, flags) SSO_DEQ_TMO(fn, flags | CPT_RX_WQE_F) argument 456 #define SSO_DEQ_TMO_CA_SEG(fn, flags) SSO_DEQ_TMO_SEG(fn, flags | CPT_RX_WQE_F) argument 523 #define SSO_DUAL_DEQ_SEG(fn, flags) SSO_DUAL_DEQ(fn, flags | NIX_RX_MULTI_SEG_F) argument 524 #define SSO_DUAL_DEQ_CA(fn, flags) SSO_DUAL_DEQ(fn, flags | CPT_RX_WQE_F) argument 526 SSO_DUAL_DEQ_SEG(fn, flags | CPT_RX_WQE_F) 557 SSO_DUAL_DEQ_TMO(fn, flags | CPT_RX_WQE_F) [all …]
|
| H A D | cn10k_worker.h | 445 uint16_t __rte_hot fn(void *port, struct rte_event *ev, \ 459 #define SSO_DEQ_SEG(fn, flags) SSO_DEQ(fn, flags | NIX_RX_MULTI_SEG_F) argument 460 #define SSO_DEQ_CA(fn, flags) SSO_DEQ(fn, flags | CPT_RX_WQE_F) argument 461 #define SSO_DEQ_CA_SEG(fn, flags) SSO_DEQ_SEG(fn, flags | CPT_RX_WQE_F) argument 464 uint16_t __rte_hot fn(void *port, struct rte_event *ev, \ 482 #define SSO_DEQ_TMO_SEG(fn, flags) SSO_DEQ_TMO(fn, flags | NIX_RX_MULTI_SEG_F) argument 483 #define SSO_DEQ_TMO_CA(fn, flags) SSO_DEQ_TMO(fn, flags | CPT_RX_WQE_F) argument 484 #define SSO_DEQ_TMO_CA_SEG(fn, flags) SSO_DEQ_TMO_SEG(fn, flags | CPT_RX_WQE_F) argument 491 return fn(port, ev, timeout_ticks); \ 499 return fn(port, ev, timeout_ticks); \ [all …]
|
| H A D | cnxk_eventdev_selftest.c | 368 consume_events(uint8_t port, const uint32_t total_events, validate_event_cb fn) in consume_events() argument 390 if (fn != NULL) { in consume_events() 391 ret = fn(index, port, &ev); in consume_events() 1234 launch_multi_port_max_stages_random_sched_type(int (*fn)(void *)) in launch_multi_port_max_stages_random_sched_type() 1260 return launch_workers_and_wait(fn, fn, MAX_EVENTS, nr_ports, in launch_multi_port_max_stages_random_sched_type() 1395 test_producer_consumer_ingress_order_test(int (*fn)(void *)) in test_producer_consumer_ingress_order_test() 1410 launch_workers_and_wait(worker_ordered_flow_producer, fn, NUM_PACKETS, in test_producer_consumer_ingress_order_test()
|
| /dpdk/app/test/ |
| H A D | test.h | 117 #define TEST_CASE(fn) { NULL, NULL, fn, NULL, #fn, 1, NULL } argument 119 #define TEST_CASE_NAMED(name, fn) { NULL, NULL, fn, NULL, name, 1, NULL } argument 133 #define TEST_CASE_DISABLED(fn) { NULL, NULL, fn, NULL, #fn, 0, NULL } argument
|
| H A D | test_stack_perf.c | 170 lcore_function_t fn) in run_on_core_pair() argument 182 rte_eal_remote_launch(fn, &args[1], cores->c2); in run_on_core_pair() 183 fn(&args[0]); in run_on_core_pair() 186 rte_eal_remote_launch(fn, &args[0], cores->c1); in run_on_core_pair() 187 rte_eal_remote_launch(fn, &args[1], cores->c2); in run_on_core_pair() 199 run_on_n_cores(struct rte_stack *s, lcore_function_t fn, int n) in run_on_n_cores() argument 218 if (rte_eal_remote_launch(fn, &args[lcore_id], in run_on_n_cores() 229 fn(&args[lcore_id]); in run_on_n_cores()
|
| /dpdk/app/test-sad/ |
| H A D | main.c | 551 uint32_t i, j, f, fn, n; in add_rules() local 557 for (n = 0, j = 0; n != config.nb_rules; n = fn, j++) { in add_rules() 559 fn = n + f; in add_rules() 560 fn = fn > config.nb_rules ? config.nb_rules : fn; in add_rules() 563 for (i = n; i != fn; i++) { in add_rules() 572 nm[j] = fn - n; in add_rules() 585 uint32_t i, j, f, fn, n; in del_rules() local 593 fn = n + f; in del_rules() 594 fn = fn > config.nb_rules ? config.nb_rules : fn; in del_rules() 597 for (i = n; i != fn; i++) { in del_rules() [all …]
|
| /dpdk/lib/graph/ |
| H A D | graph_stats.c | 32 rte_graph_cluster_stats_cb_t fn; member 107 rte_graph_cluster_stats_cb_t fn; in stats_mem_init() local 112 fn = prm->fn; in stats_mem_init() 113 if (fn == NULL) in stats_mem_init() 114 fn = graph_cluster_stats_cb; in stats_mem_init() 124 stats->fn = fn; in stats_mem_init() 377 rc = stat->fn(!count, (count == stat->max_nodes - 1), in rte_graph_cluster_stats_get()
|
| /dpdk/lib/eal/x86/ |
| H A D | rte_power_intrinsics.c | 97 if (pmc->fn == NULL) in rte_power_monitor() 122 if (pmc->fn(cur_value, pmc->opaque) != 0) in rte_power_monitor() 267 if (c->fn == NULL) { in rte_power_monitor_multi() 275 if (c->fn(val, c->opaque) != 0) in rte_power_monitor_multi()
|
| /dpdk/drivers/event/sw/ |
| H A D | sw_evdev_xstats.c | 42 xstats_fn fn; member 272 .fn = get_dev_stat, in sw_xstats_init() 288 .fn = get_port_stat, in sw_xstats_init() 303 .fn = get_port_bucket_stat, in sw_xstats_init() 330 .fn = get_qid_stat, in sw_xstats_init() 342 .fn = get_qid_iq_stat, in sw_xstats_init() 358 .fn = get_qid_port_stat, in sw_xstats_init() 492 uint64_t val = xs->fn(sw, xs->obj_idx, xs->stat, xs->extra_arg) in sw_xstats_update() 534 return xs->fn(sw, xs->obj_idx, xs->stat, xs->extra_arg) in sw_xstats_get_by_name() 552 uint64_t val = xs->fn(sw, xs->obj_idx, xs->stat, xs->extra_arg); in sw_xstats_reset_range()
|
| /dpdk/drivers/event/dlb2/ |
| H A D | dlb2_xstats.c | 749 dlb2_xstats_fn fn; in dlb2_xstats_update() local 760 fn = get_dev_stat; in dlb2_xstats_update() 763 fn = get_port_stat; in dlb2_xstats_update() 766 fn = get_queue_stat; in dlb2_xstats_update() 809 dlb2_xstats_fn fn; in dlb2_eventdev_xstats_get_by_name() local 821 fn = get_dev_stat; in dlb2_eventdev_xstats_get_by_name() 824 fn = get_port_stat; in dlb2_eventdev_xstats_get_by_name() 849 dlb2_xstats_fn fn; in dlb2_xstats_reset_range() local 859 fn = get_dev_stat; in dlb2_xstats_reset_range() 862 fn = get_port_stat; in dlb2_xstats_reset_range() [all …]
|
| /dpdk/drivers/net/liquidio/base/ |
| H A D | lio_mbox.c | 203 if (mbox_cmd.fn) in lio_mbox_process_message() 204 mbox_cmd.fn(mbox->lio_dev, &mbox_cmd, in lio_mbox_process_message() 222 if (mbox_cmd.fn) in lio_mbox_process_message() 223 mbox_cmd.fn(mbox->lio_dev, &mbox_cmd, mbox_cmd.fn_arg); in lio_mbox_process_message()
|
| H A D | lio_mbox.h | 55 lio_mbox_callback fn; member
|
| /dpdk/lib/fib/ |
| H A D | rte_fib.c | 324 rte_fib_lookup_fn_t fn; in rte_fib_select_lookup() local 328 fn = dir24_8_get_lookup_fn(fib->dp, type); in rte_fib_select_lookup() 329 if (fn == NULL) in rte_fib_select_lookup() 331 fib->lookup = fn; in rte_fib_select_lookup()
|
| H A D | rte_fib6.c | 325 rte_fib6_lookup_fn_t fn; in rte_fib6_select_lookup() local 329 fn = trie_get_lookup_fn(fib->dp, type); in rte_fib6_select_lookup() 330 if (fn == NULL) in rte_fib6_select_lookup() 332 fib->lookup = fn; in rte_fib6_select_lookup()
|
| /dpdk/drivers/event/dsw/ |
| H A D | dsw_xstats.c | 176 dsw_xstats_dev_foreach(dsw_xstats_foreach_fn fn, void *fn_data) in dsw_xstats_dev_foreach() argument 181 fn(dsw_dev_xstats[i].name, RTE_EVENT_DEV_XSTATS_DEVICE, 0, in dsw_xstats_dev_foreach() 187 dsw_xstats_foreach_fn fn, void *fn_data) in dsw_xstats_port_foreach() argument 210 fn(xstats_name, RTE_EVENT_DEV_XSTATS_PORT, port_id, in dsw_xstats_port_foreach()
|
| /dpdk/drivers/event/octeontx/ |
| H A D | ssovf_evdev_selftest.c | 387 consume_events(uint8_t port, const uint32_t total_events, validate_event_cb fn) in consume_events() argument 409 if (fn != NULL) { in consume_events() 410 ret = fn(index, port, &ev); in consume_events() 1227 launch_multi_port_max_stages_random_sched_type(int (*fn)(void *)) in launch_multi_port_max_stages_random_sched_type() 1255 return launch_workers_and_wait(fn, fn, MAX_EVENTS, nr_ports, in launch_multi_port_max_stages_random_sched_type() 1384 test_producer_consumer_ingress_order_test(int (*fn)(void *)) in test_producer_consumer_ingress_order_test() 1398 launch_workers_and_wait(worker_ordered_flow_producer, fn, in test_producer_consumer_ingress_order_test()
|
| /dpdk/lib/bpf/ |
| H A D | bpf_load_elf.c | 37 const struct rte_bpf_xsym fp[], uint32_t fn) in bpf_find_xsym() argument 44 for (i = 0; i != fn; i++) { in bpf_find_xsym() 49 return (i != fn) ? i : UINT32_MAX; in bpf_find_xsym()
|
| /dpdk/lib/eal/include/generic/ |
| H A D | rte_power_intrinsics.h | 48 rte_power_monitor_clb_t fn; /**< Callback to be used to check if member
|
| /dpdk/lib/eventdev/ |
| H A D | rte_eventdev.h | 1897 const event_enqueue_burst_t fn) in __rte_event_enqueue_burst() argument 1916 rte_eventdev_trace_enq_burst(dev_id, port_id, ev, nb_events, (void *)fn); in __rte_event_enqueue_burst() 1924 return fn(port, ev, nb_events); in __rte_event_enqueue_burst()
|
| /dpdk/drivers/net/cnxk/ |
| H A D | cn9k_rx.h | 1076 #define NIX_RX_RECV(fn, flags) \ argument 1077 uint16_t __rte_noinline __rte_hot fn( \ 1083 #define NIX_RX_RECV_MSEG(fn, flags) NIX_RX_RECV(fn, flags | NIX_RX_MULTI_SEG_F) argument 1085 #define NIX_RX_RECV_VEC(fn, flags) \ argument 1086 uint16_t __rte_noinline __rte_hot fn( \ 1093 #define NIX_RX_RECV_VEC_MSEG(fn, flags) \ argument 1094 NIX_RX_RECV_VEC(fn, flags | NIX_RX_MULTI_SEG_F)
|
| /dpdk/lib/cryptodev/ |
| H A D | rte_cryptodev.h | 881 rte_cryptodev_callback_fn fn; member 1882 nb_ops = cb->fn(dev_id, qp_id, ops, nb_ops, in rte_cryptodev_dequeue_burst() 1949 nb_ops = cb->fn(dev_id, qp_id, ops, nb_ops, in rte_cryptodev_enqueue_burst()
|