pktdev.h

Go to the documentation of this file.

/* SPDX-License-Identifier: BSD-3-Clause
 * Copyright (c) 2019-2022 Intel Corporation.
 */
 
#ifndef __PKTDEV_H
#define __PKTDEV_H
 
#include <cne_common.h>
#include <errno.h>            // for EINVAL, ENOTSUP
#include <stddef.h>           // for NULL
#include <stdint.h>           // for uint16_t, uint32_t, uint64_t, uint8_t
#include <x86intrin.h>        // _mm_shuffle_xxx
#include <mempool.h>          // for mempool_t
#include <pktmbuf.h>          // for pktmbuf_t
#include <emmintrin.h>        // for _mm_loadu_si128, _mm_set_epi8, _mm_storeu_s...
#include <stdbool.h>          // for bool
#include <tmmintrin.h>        // for _mm_shuffle_epi8
 
#ifdef __cplusplus
extern "C" {
#endif
 
#define PKTDEV_FOREACH(x) for (int x = 0; x < CNE_MAX_ETHPORTS; x++)
 
#define PKTDEV_FALLBACK_RX_RINGSIZE 512
#define PKTDEV_FALLBACK_TX_RINGSIZE 512
#define PKTDEV_FALLBACK_RX_NBQUEUES 1
#define PKTDEV_FALLBACK_TX_NBQUEUES 1
#define PKTDEV_ADMIN_STATE_DOWN     0xFFFF
 
#include <cne_lport.h>
 
struct pktdev_rxq_info {
    mempool_t *mp;    
    uint16_t nb_desc; 
} __cne_cache_min_aligned;
 
struct pktdev_txq_info {
    uint16_t nb_desc; 
} __cne_cache_min_aligned;
 
struct pktdev_portconf {
    uint16_t burst_size; 
    uint16_t ring_size;  
};
 
struct pktdev_info {
    const char *driver_name; 
    unsigned int if_index;   
    bool admin_state;        
    uint16_t min_mtu;        
    uint16_t max_mtu;        
    uint32_t min_rx_bufsize; 
    uint32_t max_rx_pktlen;  
    uint32_t min_tx_bufsize; 
    uint8_t hash_key_size;   
    uint32_t speed_capa; 
    struct pktdev_portconf default_rxportconf;
    struct pktdev_portconf default_txportconf;
    uint64_t dev_capa;
} __cne_cache_aligned;
 
#include <pktdev_api.h>         // for pktdev_admin_state
#include <pktdev_core.h>        // for cne_pktdev, pktdev_data, pktdev_devices
 
#include "cne_common.h"        // for CNE_MAX_ETHPORTS, __cne_cache_min_aligned
#include "cne_log.h"           // for CNE_LOG_ERR
 
// IWYU pragma: no_forward_declare cne_mempool
 
static inline uint16_t
pktdev_rx_burst(uint16_t lport_id, pktmbuf_t **rx_pkts, const uint16_t nb_pkts)
{
    struct cne_pktdev *dev = &pktdev_devices[lport_id];
    uint16_t nb_rx;
 
#ifdef PKTDEV_DEBUG
    if (dev->rx_pkt_burst == NULL)
        return 0;
#endif
 
    /* Check packet stream status */
    if (!pktdev_admin_state(lport_id)) {
        CNE_DEBUG("Packet stream is disabled for '%d'\n", lport_id);
        return PKTDEV_ADMIN_STATE_DOWN;
    }
 
    nb_rx = (*dev->rx_pkt_burst)(dev->data->rx_queue, rx_pkts, nb_pkts);
 
    return nb_rx;
}
 
static inline uint16_t
pktdev_tx_burst(uint16_t lport_id, pktmbuf_t **tx_pkts, uint16_t nb_pkts)
{
    struct cne_pktdev *dev;
 
#ifdef PKTDEV_DEBUG
    if (lport_id >= CNE_MAX_ETHPORTS)
        return 0;
#endif
 
    dev = &pktdev_devices[lport_id];
 
#ifdef PKTDEV_DEBUG
    if (dev->tx_pkt_burst == NULL)
        return 0;
#endif
 
    /* Check packet stream status */
    if (!pktdev_admin_state(lport_id)) {
        CNE_DEBUG("Packet stream is disabled for '%d'\n", lport_id);
        return PKTDEV_ADMIN_STATE_DOWN;
    }
 
    return (*dev->tx_pkt_burst)(dev->data->tx_queue, tx_pkts, nb_pkts);
}
 
static inline uint16_t
pktdev_tx_prepare(uint16_t lport_id, pktmbuf_t **tx_pkts, uint16_t nb_pkts)
{
    struct cne_pktdev *dev;
 
    dev = &pktdev_devices[lport_id];
 
    if (!dev->tx_pkt_prepare)
        return nb_pkts;
 
    return (*dev->tx_pkt_prepare)(dev->data->tx_queue, tx_pkts, nb_pkts);
}
 
static inline void
pktdev_mac_swap(void *data)
{
    __m128i shfl_msk = _mm_set_epi8(15, 14, 13, 12, 5, 4, 3, 2, 1, 0, 11, 10, 9, 8, 7, 6);
 
    __m128i hdr = _mm_loadu_si128((const __m128i_u *)data);
    hdr         = _mm_shuffle_epi8(hdr, shfl_msk);
    _mm_storeu_si128((__m128i_u *)data, hdr);
}
 
#ifdef __cplusplus
}
#endif
 
#endif /* __PKTDEV_H */