numam-dpdk/drivers/net/tap/tap_intr.c
Quentin Armitage 0809d870fc net/tap: fix interrupt handler freeing
rte_pmd_tun/tap_probe() allocates pmd->intr_handle in eth_dev_tap_create()
and it should not be freed until rte_pmd_tap_remove() is called.

Inspection of tap_rx_intr_vec_set() shows that the call to
tap_tx_intr_vec_uninstall() was calling rte_intr_instance_free() but
tap_tx_intr_vec_install() can then be immediately called, and this then
uses pmd->intr_handle without it being reallocated.

Move rte_intr_instance_free() call from tap_tx_intr_vec_uninstall()
to rte_pmd_tap_remove().

Fixes: d61138d4f0 ("drivers: remove direct access to interrupt handle")
Cc: stable@dpdk.org

Signed-off-by: Quentin Armitage <quentin@armitage.org.uk>
Reviewed-by: David Marchand <david.marchand@redhat.com>
2022-05-12 10:11:16 +02:00

114 lines
2.8 KiB
C

/* SPDX-License-Identifier: BSD-3-Clause
* Copyright 2018 Mellanox Technologies, Ltd
*/
/**
* @file
* Interrupts handling for tap driver.
*/
#include <errno.h>
#include <fcntl.h>
#include <signal.h>
#include <stdint.h>
#include <stdlib.h>
#include <unistd.h>
#include <rte_eth_tap.h>
#include <rte_errno.h>
#include <rte_interrupts.h>
/**
* Unregister Rx interrupts free the queue interrupt vector.
*
* @param dev
* Pointer to the tap rte_eth_dev structure.
*/
static void
tap_rx_intr_vec_uninstall(struct rte_eth_dev *dev)
{
struct pmd_internals *pmd = dev->data->dev_private;
struct rte_intr_handle *intr_handle = pmd->intr_handle;
rte_intr_free_epoll_fd(intr_handle);
rte_intr_vec_list_free(intr_handle);
rte_intr_nb_efd_set(intr_handle, 0);
}
/**
* Allocate Rx queue interrupt vector and register Rx interrupts.
*
* @param dev
* Pointer to the tap rte_eth_dev device structure.
*
* @return
* 0 on success, negative errno value otherwise and rte_errno is set.
*/
static int
tap_rx_intr_vec_install(struct rte_eth_dev *dev)
{
struct pmd_internals *pmd = dev->data->dev_private;
struct pmd_process_private *process_private = dev->process_private;
unsigned int rxqs_n = pmd->dev->data->nb_rx_queues;
struct rte_intr_handle *intr_handle = pmd->intr_handle;
unsigned int n = RTE_MIN(rxqs_n, (uint32_t)RTE_MAX_RXTX_INTR_VEC_ID);
unsigned int i;
unsigned int count = 0;
if (!dev->data->dev_conf.intr_conf.rxq)
return 0;
if (rte_intr_vec_list_alloc(intr_handle, NULL, rxqs_n)) {
rte_errno = ENOMEM;
TAP_LOG(ERR,
"failed to allocate memory for interrupt vector,"
" Rx interrupts will not be supported");
return -rte_errno;
}
for (i = 0; i < n; i++) {
struct rx_queue *rxq = pmd->dev->data->rx_queues[i];
/* Skip queues that cannot request interrupts. */
if (!rxq || process_private->rxq_fds[i] == -1) {
/* Use invalid intr_vec[] index to disable entry. */
if (rte_intr_vec_list_index_set(intr_handle, i,
RTE_INTR_VEC_RXTX_OFFSET + RTE_MAX_RXTX_INTR_VEC_ID))
return -rte_errno;
continue;
}
if (rte_intr_vec_list_index_set(intr_handle, i,
RTE_INTR_VEC_RXTX_OFFSET + count))
return -rte_errno;
if (rte_intr_efds_index_set(intr_handle, count,
process_private->rxq_fds[i]))
return -rte_errno;
count++;
}
if (!count)
tap_rx_intr_vec_uninstall(dev);
else if (rte_intr_nb_efd_set(intr_handle, count))
return -rte_errno;
return 0;
}
/**
* Register or unregister the Rx interrupts.
*
* @param dev
* Pointer to the tap rte_eth_dev device structure.
* @param set
* should the operation be register or unregister the interrupts.
*
* @return
* 0 on success, negative errno value otherwise and rte_errno is set.
*/
int
tap_rx_intr_vec_set(struct rte_eth_dev *dev, int set)
{
tap_rx_intr_vec_uninstall(dev);
if (set)
return tap_rx_intr_vec_install(dev);
return 0;
}