4 * Copyright 2017 6WIND S.A.
5 * Copyright 2017 Mellanox.
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
11 * * Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * * Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in
15 * the documentation and/or other materials provided with the
17 * * Neither the name of 6WIND S.A. nor the names of its
18 * contributors may be used to endorse or promote products derived
19 * from this software without specific prior written permission.
21 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
22 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
23 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
24 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
25 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
26 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
27 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
28 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
29 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
30 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
31 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
35 #include <rte_ethdev.h>
37 #include "failsafe_private.h"
40 * TODO: write fast version,
41 * without additional checks, to be activated once
42 * everything has been verified to comply.
45 failsafe_rx_burst(void *queue,
46 struct rte_mbuf **rx_pkts,
50 struct sub_device *sdev;
54 uint8_t nb_polled, nb_subs;
59 nb_subs = priv->subs_tail - priv->subs_head;
61 for (i = rxq->last_polled; nb_polled < nb_subs; nb_polled++) {
63 if (i == priv->subs_tail)
65 sdev = &priv->subs[i];
66 if (unlikely(ETH(sdev) == NULL))
68 if (unlikely(ETH(sdev)->rx_pkt_burst == NULL))
70 if (unlikely(sdev->state != DEV_STARTED))
72 sub_rxq = ETH(sdev)->data->rx_queues[rxq->qid];
74 rx_pkt_burst(sub_rxq, rx_pkts, nb_pkts);
84 * TODO: write fast version,
85 * without additional checks, to be activated once
86 * everything has been verified to comply.
89 failsafe_tx_burst(void *queue,
90 struct rte_mbuf **tx_pkts,
93 struct sub_device *sdev;
98 sdev = TX_SUBDEV(txq->priv->dev);
99 if (unlikely(sdev == NULL))
101 if (unlikely(ETH(sdev) == NULL))
103 if (unlikely(ETH(sdev)->tx_pkt_burst == NULL))
105 sub_txq = ETH(sdev)->data->tx_queues[txq->qid];
106 return ETH(sdev)->tx_pkt_burst(sub_txq, tx_pkts, nb_pkts);