From: Long Li <lon...@microsoft.com> Set the queue state when queue is started/stopped.
Signed-off-by: Long Li <lon...@microsoft.com> --- drivers/net/netvsc/hn_ethdev.c | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/drivers/net/netvsc/hn_ethdev.c b/drivers/net/netvsc/hn_ethdev.c index d0bbc0a4c0..0c15f9f826 100644 --- a/drivers/net/netvsc/hn_ethdev.c +++ b/drivers/net/netvsc/hn_ethdev.c @@ -1017,6 +1017,11 @@ hn_dev_start(struct rte_eth_dev *dev) if (error == 0) hn_dev_link_update(dev, 0); + for (int i = 0; i < hv->num_queues; i++) { + dev->data->tx_queue_state[i] = RTE_ETH_QUEUE_STATE_STARTED; + dev->data->rx_queue_state[i] = RTE_ETH_QUEUE_STATE_STARTED; + } + return error; } @@ -1024,13 +1029,21 @@ static int hn_dev_stop(struct rte_eth_dev *dev) { struct hn_data *hv = dev->data->dev_private; + int ret; PMD_INIT_FUNC_TRACE(); dev->data->dev_started = 0; rte_dev_event_callback_unregister(NULL, netvsc_hotadd_callback, hv); hn_rndis_set_rxfilter(hv, 0); - return hn_vf_stop(dev); + ret = hn_vf_stop(dev); + + for (int i = 0; i < hv->num_queues; i++) { + dev->data->tx_queue_state[i] = RTE_ETH_QUEUE_STATE_STOPPED; + dev->data->rx_queue_state[i] = RTE_ETH_QUEUE_STATE_STOPPED; + } + + return ret; } static int -- 2.34.1