src/dpdk/lib/librte_eventdev/rte_event_eth_rx_adapter.c
static void
rxa_intr_ring_del_entries(struct rte_event_eth_rx_adapter *rx_adapter,
			struct eth_device_info *dev_info,
			uint16_t rx_queue_id)
{
	int i, n;
	union queue_data qd;

	rte_spinlock_lock(&rx_adapter->intr_ring_lock);

	n = rte_ring_count(rx_adapter->intr_ring);
	for (i = 0; i < n; i++) {
		rte_ring_dequeue(rx_adapter->intr_ring, &qd.ptr);
		if (!rxa_shared_intr(dev_info, rx_queue_id)) {
			if (qd.port == dev_info->dev->data->port_id &&
				qd.queue == rx_queue_id)
				continue;
		} else {
			if (qd.port == dev_info->dev->data->port_id)
				continue;
		}
		rte_ring_enqueue(rx_adapter->intr_ring, qd.ptr);
	}

	rte_spinlock_unlock(&rx_adapter->intr_ring_lock);
}
/* Delete entries for (dev, queue) from the interrupt ring */
Delete entries for (dev, queue) from the interrupt ring
Delete entries for ( dev queue ) from the interrupt ring
static void
rxa_intr_ring_del_entries(struct rte_event_eth_rx_adapter *rx_adapter,
			struct eth_device_info *dev_info,
			uint16_t rx_queue_id)
{
	int i, n;
	union queue_data qd;
	rte_spinlock_lock(&rx_adapter->intr_ring_lock);
	n = rte_ring_count(rx_adapter->intr_ring);
	for (i = 0; i < n; i++) {
		rte_ring_dequeue(rx_adapter->intr_ring, &qd.ptr);
		if (!rxa_shared_intr(dev_info, rx_queue_id)) {
			if (qd.port == dev_info->dev->data->port_id &&
				qd.queue == rx_queue_id)
				continue;
		} else {
			if (qd.port == dev_info->dev->data->port_id)
				continue;
		}
		rte_ring_enqueue(rx_adapter->intr_ring, qd.ptr);
	}
	rte_spinlock_unlock(&rx_adapter->intr_ring_lock);
}
static void rxa_intr_ring_del_entries ( struct rte_event_eth_rx_adapter * rx_adapter , struct eth_device_info * dev_info , uint16_t rx_queue_id ) { int i , n ; union queue_data qd ; rte_spinlock_lock ( & rx_adapter -> intr_ring_lock ) ; n = rte_ring_count ( rx_adapter -> intr_ring ) ; for ( i = 0 ; i < n ; i ++ ) { rte_ring_dequeue ( rx_adapter -> intr_ring , & qd . ptr ) ; if ( ! rxa_shared_intr ( dev_info , rx_queue_id ) ) { if ( qd . port == dev_info -> dev -> data -> port_id && qd . queue == rx_queue_id ) continue ; } else { if ( qd . port == dev_info -> dev -> data -> port_id ) continue ; } rte_ring_enqueue ( rx_adapter -> intr_ring , qd . ptr ) ; } rte_spinlock_unlock ( & rx_adapter -> intr_ring_lock ) ; }
Delete entries for (dev, queue) from the interrupt ring
Delete entries for ( dev queue ) from the interrupt ring