Lines Matching refs:dev_info
279 struct eth_device_info *dev_info = in rxa_event_buf_get() local
281 *stats = dev_info->rx_queue[rx_queue_id].stats; in rxa_event_buf_get()
282 return dev_info->rx_queue[rx_queue_id].event_buf; in rxa_event_buf_get()
367 rxa_shared_intr(struct eth_device_info *dev_info, in rxa_shared_intr() argument
372 if (dev_info->dev->intr_handle == NULL) in rxa_shared_intr()
375 multi_intr_cap = rte_intr_cap_multiple(dev_info->dev->intr_handle); in rxa_shared_intr()
381 rxa_intr_queue(struct eth_device_info *dev_info, in rxa_intr_queue() argument
386 queue_info = &dev_info->rx_queue[rx_queue_id]; in rxa_intr_queue()
387 return dev_info->rx_queue && in rxa_intr_queue()
388 !dev_info->internal_event_port && in rxa_intr_queue()
393 rxa_polled_queue(struct eth_device_info *dev_info, in rxa_polled_queue() argument
398 queue_info = &dev_info->rx_queue[rx_queue_id]; in rxa_polled_queue()
399 return !dev_info->internal_event_port && in rxa_polled_queue()
400 dev_info->rx_queue && in rxa_polled_queue()
406 rxa_nb_intr_vect(struct eth_device_info *dev_info, int rx_queue_id, int add) in rxa_nb_intr_vect() argument
412 nbq = dev_info->dev->data->nb_rx_queues; in rxa_nb_intr_vect()
418 if (!rxa_shared_intr(dev_info, i)) in rxa_nb_intr_vect()
419 n += add ? !rxa_intr_queue(dev_info, i) : in rxa_nb_intr_vect()
420 rxa_intr_queue(dev_info, i); in rxa_nb_intr_vect()
422 s += add ? !rxa_intr_queue(dev_info, i) : in rxa_nb_intr_vect()
423 rxa_intr_queue(dev_info, i); in rxa_nb_intr_vect()
427 if ((add && dev_info->nb_shared_intr == 0) || in rxa_nb_intr_vect()
428 (!add && dev_info->nb_shared_intr)) in rxa_nb_intr_vect()
432 if (!rxa_shared_intr(dev_info, rx_queue_id)) in rxa_nb_intr_vect()
433 n = add ? !rxa_intr_queue(dev_info, rx_queue_id) : in rxa_nb_intr_vect()
434 rxa_intr_queue(dev_info, rx_queue_id); in rxa_nb_intr_vect()
436 n = add ? !dev_info->nb_shared_intr : in rxa_nb_intr_vect()
437 dev_info->nb_shared_intr == 1; in rxa_nb_intr_vect()
447 struct eth_device_info *dev_info, int rx_queue_id, in rxa_calc_nb_post_intr_del() argument
453 intr_diff = dev_info->nb_rx_intr; in rxa_calc_nb_post_intr_del()
455 intr_diff = rxa_intr_queue(dev_info, rx_queue_id); in rxa_calc_nb_post_intr_del()
465 struct eth_device_info *dev_info, int rx_queue_id, in rxa_calc_nb_post_add_intr() argument
474 intr_diff = dev_info->dev->data->nb_rx_queues - in rxa_calc_nb_post_add_intr()
475 dev_info->nb_rx_intr; in rxa_calc_nb_post_add_intr()
476 poll_diff = dev_info->nb_rx_poll; in rxa_calc_nb_post_add_intr()
477 wrr_len_diff = dev_info->wrr_len; in rxa_calc_nb_post_add_intr()
479 intr_diff = !rxa_intr_queue(dev_info, rx_queue_id); in rxa_calc_nb_post_add_intr()
480 poll_diff = rxa_polled_queue(dev_info, rx_queue_id); in rxa_calc_nb_post_add_intr()
481 wrr_len_diff = poll_diff ? dev_info->rx_queue[rx_queue_id].wt : in rxa_calc_nb_post_add_intr()
495 struct eth_device_info *dev_info, int rx_queue_id, in rxa_calc_nb_post_poll_del() argument
502 poll_diff = dev_info->nb_rx_poll; in rxa_calc_nb_post_poll_del()
503 wrr_len_diff = dev_info->wrr_len; in rxa_calc_nb_post_poll_del()
505 poll_diff = rxa_polled_queue(dev_info, rx_queue_id); in rxa_calc_nb_post_poll_del()
506 wrr_len_diff = poll_diff ? dev_info->rx_queue[rx_queue_id].wt : in rxa_calc_nb_post_poll_del()
518 struct eth_device_info *dev_info, int rx_queue_id, in rxa_calc_nb_post_add_poll() argument
527 intr_diff = dev_info->nb_rx_intr; in rxa_calc_nb_post_add_poll()
528 poll_diff = dev_info->dev->data->nb_rx_queues - in rxa_calc_nb_post_add_poll()
529 dev_info->nb_rx_poll; in rxa_calc_nb_post_add_poll()
530 wrr_len_diff = wt*dev_info->dev->data->nb_rx_queues in rxa_calc_nb_post_add_poll()
531 - dev_info->wrr_len; in rxa_calc_nb_post_add_poll()
533 intr_diff = rxa_intr_queue(dev_info, rx_queue_id); in rxa_calc_nb_post_add_poll()
534 poll_diff = !rxa_polled_queue(dev_info, rx_queue_id); in rxa_calc_nb_post_add_poll()
535 wrr_len_diff = rxa_polled_queue(dev_info, rx_queue_id) ? in rxa_calc_nb_post_add_poll()
536 wt - dev_info->rx_queue[rx_queue_id].wt : in rxa_calc_nb_post_add_poll()
548 struct eth_device_info *dev_info, int rx_queue_id, in rxa_calc_nb_post_add() argument
553 rxa_calc_nb_post_add_poll(rx_adapter, dev_info, rx_queue_id, in rxa_calc_nb_post_add()
556 rxa_calc_nb_post_add_intr(rx_adapter, dev_info, rx_queue_id, in rxa_calc_nb_post_add()
563 struct eth_device_info *dev_info, int rx_queue_id, in rxa_calc_nb_post_del() argument
567 rxa_calc_nb_post_poll_del(rx_adapter, dev_info, rx_queue_id, nb_rx_poll, in rxa_calc_nb_post_del()
569 rxa_calc_nb_post_intr_del(rx_adapter, dev_info, rx_queue_id, in rxa_calc_nb_post_del()
656 struct eth_device_info *dev_info = in rxa_calc_wrr_sequence() local
658 nb_rx_queues = dev_info->dev->data->nb_rx_queues; in rxa_calc_wrr_sequence()
659 if (dev_info->rx_queue == NULL) in rxa_calc_wrr_sequence()
661 if (dev_info->internal_event_port) in rxa_calc_wrr_sequence()
663 dev_info->wrr_len = 0; in rxa_calc_wrr_sequence()
666 &dev_info->rx_queue[q]; in rxa_calc_wrr_sequence()
669 if (!rxa_polled_queue(dev_info, q)) in rxa_calc_wrr_sequence()
675 dev_info->wrr_len += wt; in rxa_calc_wrr_sequence()
928 struct eth_device_info *dev_info = in rxa_buffer_mbufs() local
931 &dev_info->rx_queue[rx_queue_id]; in rxa_buffer_mbufs()
978 if (num && dev_info->cb_fn) { in rxa_buffer_mbufs()
981 nb_cb = dev_info->cb_fn(eth_dev_id, rx_queue_id, in rxa_buffer_mbufs()
988 dev_info->cb_arg, in rxa_buffer_mbufs()
1077 struct eth_device_info *dev_info; in rxa_intr_ring_enqueue() local
1085 dev_info = &rx_adapter->eth_devices[port_id]; in rxa_intr_ring_enqueue()
1086 queue_info = &dev_info->rx_queue[queue]; in rxa_intr_ring_enqueue()
1088 if (rxa_shared_intr(dev_info, queue)) in rxa_intr_ring_enqueue()
1089 intr_enabled = &dev_info->shared_intr_enabled; in rxa_intr_ring_enqueue()
1128 struct eth_device_info *dev_info, in rxa_intr_ring_del_entries() argument
1139 if (!rxa_shared_intr(dev_info, rx_queue_id)) { in rxa_intr_ring_del_entries()
1140 if (qd.port == dev_info->dev->data->port_id && in rxa_intr_ring_del_entries()
1144 if (qd.port == dev_info->dev->data->port_id) in rxa_intr_ring_del_entries()
1210 struct eth_device_info *dev_info; in rxa_intr_ring_dequeue() local
1230 dev_info = &rx_adapter->eth_devices[port]; in rxa_intr_ring_dequeue()
1231 if (rxa_shared_intr(dev_info, queue)) in rxa_intr_ring_dequeue()
1232 dev_info->shared_intr_enabled = 1; in rxa_intr_ring_dequeue()
1234 queue_info = &dev_info->rx_queue[queue]; in rxa_intr_ring_dequeue()
1243 dev_info = &rx_adapter->eth_devices[port]; in rxa_intr_ring_dequeue()
1246 if (rxa_shared_intr(dev_info, queue)) { in rxa_intr_ring_dequeue()
1250 nb_queues = dev_info->dev->data->nb_rx_queues; in rxa_intr_ring_dequeue()
1252 for (i = dev_info->next_q_idx; i < nb_queues; i++) { in rxa_intr_ring_dequeue()
1255 if (!rxa_intr_queue(dev_info, i)) in rxa_intr_ring_dequeue()
1266 dev_info->next_q_idx = i; in rxa_intr_ring_dequeue()
1274 dev_info->next_q_idx = dev_info->multi_intr_cap ? in rxa_intr_ring_dequeue()
1626 struct eth_device_info *dev_info, uint16_t rx_queue_id) in rxa_disable_intr() argument
1629 uint16_t eth_dev_id = dev_info->dev->data->port_id; in rxa_disable_intr()
1630 int sintr = rxa_shared_intr(dev_info, rx_queue_id); in rxa_disable_intr()
1647 dev_info->rx_queue[rx_queue_id].intr_enabled = 0; in rxa_disable_intr()
1649 dev_info->shared_intr_enabled = 0; in rxa_disable_intr()
1655 struct eth_device_info *dev_info, int rx_queue_id) in rxa_del_intr_queue() argument
1661 if (dev_info->nb_rx_intr == 0) in rxa_del_intr_queue()
1666 s = dev_info->nb_shared_intr; in rxa_del_intr_queue()
1667 for (i = 0; i < dev_info->nb_rx_intr; i++) { in rxa_del_intr_queue()
1671 q = dev_info->intr_queue[i]; in rxa_del_intr_queue()
1672 sintr = rxa_shared_intr(dev_info, q); in rxa_del_intr_queue()
1677 err = rxa_disable_intr(rx_adapter, dev_info, in rxa_del_intr_queue()
1681 rxa_intr_ring_del_entries(rx_adapter, dev_info, in rxa_del_intr_queue()
1686 if (!rxa_intr_queue(dev_info, rx_queue_id)) in rxa_del_intr_queue()
1688 if (!rxa_shared_intr(dev_info, rx_queue_id) || in rxa_del_intr_queue()
1689 dev_info->nb_shared_intr == 1) { in rxa_del_intr_queue()
1690 err = rxa_disable_intr(rx_adapter, dev_info, in rxa_del_intr_queue()
1694 rxa_intr_ring_del_entries(rx_adapter, dev_info, in rxa_del_intr_queue()
1698 for (i = 0; i < dev_info->nb_rx_intr; i++) { in rxa_del_intr_queue()
1699 if (dev_info->intr_queue[i] == rx_queue_id) { in rxa_del_intr_queue()
1700 for (; i < dev_info->nb_rx_intr - 1; i++) in rxa_del_intr_queue()
1701 dev_info->intr_queue[i] = in rxa_del_intr_queue()
1702 dev_info->intr_queue[i + 1]; in rxa_del_intr_queue()
1713 struct eth_device_info *dev_info, uint16_t rx_queue_id) in rxa_config_intr() argument
1716 uint16_t eth_dev_id = dev_info->dev->data->port_id; in rxa_config_intr()
1720 int sintr = rxa_shared_intr(dev_info, rx_queue_id); in rxa_config_intr()
1722 if (rxa_intr_queue(dev_info, rx_queue_id)) in rxa_config_intr()
1725 intr_queue = dev_info->intr_queue; in rxa_config_intr()
1726 if (dev_info->intr_queue == NULL) { in rxa_config_intr()
1728 dev_info->dev->data->nb_rx_queues * sizeof(uint16_t); in rxa_config_intr()
1729 dev_info->intr_queue = in rxa_config_intr()
1735 if (dev_info->intr_queue == NULL) in rxa_config_intr()
1768 dev_info->shared_intr_enabled = 1; in rxa_config_intr()
1770 dev_info->rx_queue[rx_queue_id].intr_enabled = 1; in rxa_config_intr()
1795 rte_free(dev_info->intr_queue); in rxa_config_intr()
1802 struct eth_device_info *dev_info, int rx_queue_id) in rxa_add_intr_queue() argument
1807 int shared_done = (dev_info->nb_shared_intr > 0); in rxa_add_intr_queue()
1810 if (rxa_shared_intr(dev_info, rx_queue_id) && shared_done) in rxa_add_intr_queue()
1812 return rxa_config_intr(rx_adapter, dev_info, rx_queue_id); in rxa_add_intr_queue()
1816 for (i = 0; i < dev_info->dev->data->nb_rx_queues; i++) { in rxa_add_intr_queue()
1818 if (rxa_shared_intr(dev_info, i) && shared_done) in rxa_add_intr_queue()
1821 err = rxa_config_intr(rx_adapter, dev_info, i); in rxa_add_intr_queue()
1823 shared_done = err == 0 && rxa_shared_intr(dev_info, i); in rxa_add_intr_queue()
1826 dev_info->shared_intr_enabled = 1; in rxa_add_intr_queue()
1835 shared_done = (dev_info->nb_shared_intr > 0); in rxa_add_intr_queue()
1837 if (rxa_intr_queue(dev_info, j)) in rxa_add_intr_queue()
1839 if (rxa_shared_intr(dev_info, j) && si != j) in rxa_add_intr_queue()
1841 err = rxa_disable_intr(rx_adapter, dev_info, j); in rxa_add_intr_queue()
1895 struct eth_device_info *dev_info, int32_t rx_queue_id, in rxa_update_queue() argument
1902 if (dev_info->rx_queue == NULL) in rxa_update_queue()
1906 for (i = 0; i < dev_info->dev->data->nb_rx_queues; i++) in rxa_update_queue()
1907 rxa_update_queue(rx_adapter, dev_info, i, add); in rxa_update_queue()
1909 queue_info = &dev_info->rx_queue[rx_queue_id]; in rxa_update_queue()
1913 dev_info->nb_dev_queues += !enabled; in rxa_update_queue()
1916 dev_info->nb_dev_queues -= enabled; in rxa_update_queue()
1947 struct eth_device_info *dev_info, int32_t rx_queue_id) in rxa_sw_del() argument
1962 nb_rx_queues = dev_info->dev->data->nb_rx_queues; in rxa_sw_del()
1964 rxa_sw_del(rx_adapter, dev_info, i); in rxa_sw_del()
1976 pollq = rxa_polled_queue(dev_info, rx_queue_id); in rxa_sw_del()
1977 intrq = rxa_intr_queue(dev_info, rx_queue_id); in rxa_sw_del()
1978 sintrq = rxa_shared_intr(dev_info, rx_queue_id); in rxa_sw_del()
1979 rxa_update_queue(rx_adapter, dev_info, rx_queue_id, 0); in rxa_sw_del()
1981 dev_info->nb_rx_poll -= pollq; in rxa_sw_del()
1983 dev_info->nb_rx_intr -= intrq; in rxa_sw_del()
1984 dev_info->nb_shared_intr -= intrq && sintrq; in rxa_sw_del()
1987 dev_info->rx_queue[rx_queue_id].event_buf; in rxa_sw_del()
1989 dev_info->rx_queue[rx_queue_id].stats; in rxa_sw_del()
1993 dev_info->rx_queue[rx_queue_id].event_buf = NULL; in rxa_sw_del()
1994 dev_info->rx_queue[rx_queue_id].stats = NULL; in rxa_sw_del()
2000 struct eth_device_info *dev_info, int32_t rx_queue_id, in rxa_add_queue() argument
2011 uint16_t eth_dev_id = dev_info->dev->data->port_id; in rxa_add_queue()
2018 nb_rx_queues = dev_info->dev->data->nb_rx_queues; in rxa_add_queue()
2020 ret = rxa_add_queue(rx_adapter, dev_info, i, conf); in rxa_add_queue()
2027 pollq = rxa_polled_queue(dev_info, rx_queue_id); in rxa_add_queue()
2028 intrq = rxa_intr_queue(dev_info, rx_queue_id); in rxa_add_queue()
2029 sintrq = rxa_shared_intr(dev_info, rx_queue_id); in rxa_add_queue()
2031 queue_info = &dev_info->rx_queue[rx_queue_id]; in rxa_add_queue()
2052 rx_queue_id, dev_info->dev->data->port_id); in rxa_add_queue()
2064 rxa_update_queue(rx_adapter, dev_info, rx_queue_id, 1); in rxa_add_queue()
2065 if (rxa_polled_queue(dev_info, rx_queue_id)) { in rxa_add_queue()
2067 dev_info->nb_rx_poll += !pollq; in rxa_add_queue()
2069 dev_info->nb_rx_intr -= intrq; in rxa_add_queue()
2070 dev_info->nb_shared_intr -= intrq && sintrq; in rxa_add_queue()
2073 if (rxa_intr_queue(dev_info, rx_queue_id)) { in rxa_add_queue()
2075 dev_info->nb_rx_poll -= pollq; in rxa_add_queue()
2077 dev_info->nb_rx_intr += !intrq; in rxa_add_queue()
2078 dev_info->nb_shared_intr += !intrq && sintrq; in rxa_add_queue()
2079 if (dev_info->nb_shared_intr == 1) { in rxa_add_queue()
2080 if (dev_info->multi_intr_cap) in rxa_add_queue()
2081 dev_info->next_q_idx = in rxa_add_queue()
2084 dev_info->next_q_idx = 0; in rxa_add_queue()
2140 struct eth_device_info *dev_info = &rx_adapter->eth_devices[eth_dev_id]; in rxa_sw_add() local
2153 struct rte_eth_dev_data *data = dev_info->dev->data; in rxa_sw_add()
2173 nb_rx_queues = dev_info->dev->data->nb_rx_queues; in rxa_sw_add()
2174 rx_queue = dev_info->rx_queue; in rxa_sw_add()
2177 if (dev_info->rx_queue == NULL) { in rxa_sw_add()
2178 dev_info->rx_queue = in rxa_sw_add()
2183 if (dev_info->rx_queue == NULL) in rxa_sw_add()
2189 rxa_calc_nb_post_add(rx_adapter, dev_info, rx_queue_id, in rxa_sw_add()
2193 if (dev_info->dev->intr_handle) in rxa_sw_add()
2194 dev_info->multi_intr_cap = in rxa_sw_add()
2195 rte_intr_cap_multiple(dev_info->dev->intr_handle); in rxa_sw_add()
2203 num_intr_vec = rxa_nb_intr_vect(dev_info, rx_queue_id, 1); in rxa_sw_add()
2209 ret = rxa_add_intr_queue(rx_adapter, dev_info, rx_queue_id); in rxa_sw_add()
2216 num_intr_vec = rxa_nb_intr_vect(dev_info, in rxa_sw_add()
2223 dev_info, rx_queue_id); in rxa_sw_add()
2239 for (i = 0; i < dev_info->dev->data->nb_rx_queues; i++) in rxa_sw_add()
2240 dev_info->intr_queue[i] = i; in rxa_sw_add()
2242 if (!rxa_intr_queue(dev_info, rx_queue_id)) in rxa_sw_add()
2243 dev_info->intr_queue[nb_rx_intr - 1] = in rxa_sw_add()
2250 ret = rxa_add_queue(rx_adapter, dev_info, rx_queue_id, queue_conf); in rxa_sw_add()
2266 rte_free(dev_info->rx_queue); in rxa_sw_add()
2267 dev_info->rx_queue = NULL; in rxa_sw_add()
2281 struct eth_device_info *dev_info; in rxa_ctrl() local
2294 dev_info = &rx_adapter->eth_devices[i]; in rxa_ctrl()
2296 if (start && !dev_info->nb_dev_queues) in rxa_ctrl()
2299 if (stop && !dev_info->dev_rx_started) in rxa_ctrl()
2301 use_service |= !dev_info->internal_event_port; in rxa_ctrl()
2302 dev_info->dev_rx_started = start; in rxa_ctrl()
2303 if (dev_info->internal_event_port == 0) in rxa_ctrl()
2561 struct eth_device_info *dev_info; in rte_event_eth_rx_adapter_queue_add() local
2655 dev_info = &rx_adapter->eth_devices[eth_dev_id]; in rte_event_eth_rx_adapter_queue_add()
2660 if (dev_info->rx_queue == NULL) { in rte_event_eth_rx_adapter_queue_add()
2661 dev_info->rx_queue = in rte_event_eth_rx_adapter_queue_add()
2663 dev_info->dev->data->nb_rx_queues * in rte_event_eth_rx_adapter_queue_add()
2666 if (dev_info->rx_queue == NULL) in rte_event_eth_rx_adapter_queue_add()
2674 dev_info->internal_event_port = 1; in rte_event_eth_rx_adapter_queue_add()
2682 dev_info->internal_event_port = 0; in rte_event_eth_rx_adapter_queue_add()
2720 struct eth_device_info *dev_info; in rte_event_eth_rx_adapter_queue_del() local
2750 dev_info = &rx_adapter->eth_devices[eth_dev_id]; in rte_event_eth_rx_adapter_queue_del()
2763 if (dev_info->nb_dev_queues == 0) { in rte_event_eth_rx_adapter_queue_del()
2764 rte_free(dev_info->rx_queue); in rte_event_eth_rx_adapter_queue_del()
2765 dev_info->rx_queue = NULL; in rte_event_eth_rx_adapter_queue_del()
2769 rxa_calc_nb_post_del(rx_adapter, dev_info, rx_queue_id, in rte_event_eth_rx_adapter_queue_del()
2782 num_intr_vec = rxa_nb_intr_vect(dev_info, in rte_event_eth_rx_adapter_queue_del()
2784 ret = rxa_del_intr_queue(rx_adapter, dev_info, in rte_event_eth_rx_adapter_queue_del()
2796 rxa_sw_del(rx_adapter, dev_info, rx_queue_id); in rte_event_eth_rx_adapter_queue_del()
2803 rte_free(dev_info->intr_queue); in rte_event_eth_rx_adapter_queue_del()
2804 dev_info->intr_queue = NULL; in rte_event_eth_rx_adapter_queue_del()
2817 if (dev_info->nb_dev_queues == 0) { in rte_event_eth_rx_adapter_queue_del()
2818 rte_free(dev_info->rx_queue); in rte_event_eth_rx_adapter_queue_del()
2819 dev_info->rx_queue = NULL; in rte_event_eth_rx_adapter_queue_del()
2908 struct eth_device_info *dev_info; in rte_event_eth_rx_adapter_stats_get() local
2930 dev_info = &rx_adapter->eth_devices[i]; in rte_event_eth_rx_adapter_stats_get()
2932 if (rx_adapter->use_queue_event_buf && dev_info->rx_queue) { in rte_event_eth_rx_adapter_stats_get()
2934 for (j = 0; j < dev_info->dev->data->nb_rx_queues; in rte_event_eth_rx_adapter_stats_get()
2936 queue_info = &dev_info->rx_queue[j]; in rte_event_eth_rx_adapter_stats_get()
2951 if (dev_info->internal_event_port == 0 || in rte_event_eth_rx_adapter_stats_get()
2979 struct eth_device_info *dev_info; in rte_event_eth_rx_adapter_queue_stats_get() local
3004 dev_info = &rx_adapter->eth_devices[eth_dev_id]; in rte_event_eth_rx_adapter_queue_stats_get()
3005 if (dev_info->rx_queue == NULL || in rte_event_eth_rx_adapter_queue_stats_get()
3006 !dev_info->rx_queue[rx_queue_id].queue_enabled) { in rte_event_eth_rx_adapter_queue_stats_get()
3011 if (dev_info->internal_event_port == 0) { in rte_event_eth_rx_adapter_queue_stats_get()
3012 queue_info = &dev_info->rx_queue[rx_queue_id]; in rte_event_eth_rx_adapter_queue_stats_get()
3038 struct eth_device_info *dev_info; in rte_event_eth_rx_adapter_stats_reset() local
3054 dev_info = &rx_adapter->eth_devices[i]; in rte_event_eth_rx_adapter_stats_reset()
3056 if (rx_adapter->use_queue_event_buf && dev_info->rx_queue) { in rte_event_eth_rx_adapter_stats_reset()
3058 for (j = 0; j < dev_info->dev->data->nb_rx_queues; in rte_event_eth_rx_adapter_stats_reset()
3060 queue_info = &dev_info->rx_queue[j]; in rte_event_eth_rx_adapter_stats_reset()
3067 if (dev_info->internal_event_port == 0 || in rte_event_eth_rx_adapter_stats_reset()
3085 struct eth_device_info *dev_info; in rte_event_eth_rx_adapter_queue_stats_reset() local
3107 dev_info = &rx_adapter->eth_devices[eth_dev_id]; in rte_event_eth_rx_adapter_queue_stats_reset()
3109 if (dev_info->rx_queue == NULL || in rte_event_eth_rx_adapter_queue_stats_reset()
3110 !dev_info->rx_queue[rx_queue_id].queue_enabled) { in rte_event_eth_rx_adapter_queue_stats_reset()
3115 if (dev_info->internal_event_port == 0) { in rte_event_eth_rx_adapter_queue_stats_reset()
3116 queue_info = &dev_info->rx_queue[rx_queue_id]; in rte_event_eth_rx_adapter_queue_stats_reset()
3177 struct eth_device_info *dev_info; in rte_event_eth_rx_adapter_cb_register() local
3188 dev_info = &rx_adapter->eth_devices[eth_dev_id]; in rte_event_eth_rx_adapter_cb_register()
3189 if (dev_info->rx_queue == NULL) in rte_event_eth_rx_adapter_cb_register()
3208 dev_info->cb_fn = cb_fn; in rte_event_eth_rx_adapter_cb_register()
3209 dev_info->cb_arg = cb_arg; in rte_event_eth_rx_adapter_cb_register()
3224 struct eth_device_info *dev_info; in rte_event_eth_rx_adapter_queue_conf_get() local
3248 dev_info = &rx_adapter->eth_devices[eth_dev_id]; in rte_event_eth_rx_adapter_queue_conf_get()
3249 if (dev_info->rx_queue == NULL || in rte_event_eth_rx_adapter_queue_conf_get()
3250 !dev_info->rx_queue[rx_queue_id].queue_enabled) { in rte_event_eth_rx_adapter_queue_conf_get()
3255 queue_info = &dev_info->rx_queue[rx_queue_id]; in rte_event_eth_rx_adapter_queue_conf_get()