If datapath supports multi-process, it should be possible to get
its RxQ structure by the queue index.
Signed-off-by: Andrew Rybchenko <arybchenko@solarflare.com>
if (rc != 0)
goto fail_rx_qinit;
if (rc != 0)
goto fail_rx_qinit;
- dev->data->rx_queues[rx_queue_id] = sa->rxq_info[rx_queue_id].rxq->dp;
+ dev->data->rx_queues[rx_queue_id] = sa->rxq_info[rx_queue_id].dp;
const struct sfc_adapter_priv *sap = sfc_adapter_priv_by_eth_dev(dev);
struct sfc_adapter *sa = dev->data->dev_private;
struct sfc_rxq_info *rxq_info;
const struct sfc_adapter_priv *sap = sfc_adapter_priv_by_eth_dev(dev);
struct sfc_adapter *sa = dev->data->dev_private;
struct sfc_rxq_info *rxq_info;
SFC_ASSERT(rx_queue_id < sa->rxq_count);
rxq_info = &sa->rxq_info[rx_queue_id];
SFC_ASSERT(rx_queue_id < sa->rxq_count);
rxq_info = &sa->rxq_info[rx_queue_id];
- if (rxq == NULL || (rxq_info->state & SFC_RXQ_STARTED) == 0)
+ if ((rxq_info->state & SFC_RXQ_STARTED) == 0)
- return sap->dp_rx->qdesc_npending(rxq->dp);
+ return sap->dp_rx->qdesc_npending(rxq_info->dp);
sfc_notice(sa, "RxQ %u flushed", sw_index);
}
sfc_notice(sa, "RxQ %u flushed", sw_index);
}
- sa->priv.dp_rx->qpurge(rxq->dp);
+ sa->priv.dp_rx->qpurge(rxq_info->dp);
efx_rx_qenable(rxq->common);
efx_rx_qenable(rxq->common);
- rc = sa->priv.dp_rx->qstart(rxq->dp, evq->read_ptr);
+ rc = sa->priv.dp_rx->qstart(rxq_info->dp, evq->read_ptr);
if (rc != 0)
goto fail_dp_qstart;
if (rc != 0)
goto fail_dp_qstart;
return 0;
fail_mac_filter_default_rxq_set:
return 0;
fail_mac_filter_default_rxq_set:
- sa->priv.dp_rx->qstop(rxq->dp, &rxq->evq->read_ptr);
+ sa->priv.dp_rx->qstop(rxq_info->dp, &rxq->evq->read_ptr);
fail_dp_qstart:
sfc_rx_qflush(sa, sw_index);
fail_dp_qstart:
sfc_rx_qflush(sa, sw_index);
sa->eth_dev->data->rx_queue_state[sw_index] =
RTE_ETH_QUEUE_STATE_STOPPED;
sa->eth_dev->data->rx_queue_state[sw_index] =
RTE_ETH_QUEUE_STATE_STOPPED;
- sa->priv.dp_rx->qstop(rxq->dp, &rxq->evq->read_ptr);
+ sa->priv.dp_rx->qstop(rxq_info->dp, &rxq->evq->read_ptr);
if (sw_index == 0)
efx_mac_filter_default_rxq_clear(sa->nic);
if (sw_index == 0)
efx_mac_filter_default_rxq_clear(sa->nic);
rc = sa->priv.dp_rx->qcreate(sa->eth_dev->data->port_id, sw_index,
&RTE_ETH_DEV_TO_PCI(sa->eth_dev)->addr,
rc = sa->priv.dp_rx->qcreate(sa->eth_dev->data->port_id, sw_index,
&RTE_ETH_DEV_TO_PCI(sa->eth_dev)->addr,
- socket_id, &info, &rxq->dp);
+ socket_id, &info, &rxq_info->dp);
if (rc != 0)
goto fail_dp_rx_qcreate;
if (rc != 0)
goto fail_dp_rx_qcreate;
+ evq->dp_rxq = rxq_info->dp;
rxq_info->state = SFC_RXQ_INITIALIZED;
rxq_info->state = SFC_RXQ_INITIALIZED;
rxq = rxq_info->rxq;
SFC_ASSERT(rxq_info->state == SFC_RXQ_INITIALIZED);
rxq = rxq_info->rxq;
SFC_ASSERT(rxq_info->state == SFC_RXQ_INITIALIZED);
- sa->priv.dp_rx->qdestroy(rxq->dp);
- rxq->dp = NULL;
+ sa->priv.dp_rx->qdestroy(rxq_info->dp);
+ rxq_info->dp = NULL;
rxq_info->rxq = NULL;
rxq_info->entries = 0;
rxq_info->rxq = NULL;
rxq_info->entries = 0;
efsys_mem_t mem;
unsigned int hw_index;
uint16_t buf_size;
efsys_mem_t mem;
unsigned int hw_index;
uint16_t buf_size;
};
static inline unsigned int
};
static inline unsigned int
efx_rxq_type_t type;
unsigned int type_flags;
struct sfc_rxq *rxq;
efx_rxq_type_t type;
unsigned int type_flags;
struct sfc_rxq *rxq;
boolean_t deferred_start;
boolean_t deferred_started;
unsigned int refill_threshold;
boolean_t deferred_start;
boolean_t deferred_started;
unsigned int refill_threshold;