1329602b6c
Adding per core packet handling stats to analyze traffic distribution when multiple cores are engaged. Since aggregating the packet stats across cores would affect performance, keeping the feature disabled using compile time flags. Signed-off-by: Anoob Joseph <anoobj@marvell.com> Acked-by: Konstantin Ananyev <konstantin.ananyev@intel.com> Acked-by: Akhil Goyal <akhil.goyal@nxp.com>
155 lines
3.3 KiB
C
155 lines
3.3 KiB
C
/* SPDX-License-Identifier: BSD-3-Clause
|
|
* Copyright (C) 2020 Marvell International Ltd.
|
|
*/
|
|
#ifndef _IPSEC_SECGW_H_
|
|
#define _IPSEC_SECGW_H_
|
|
|
|
#include <stdbool.h>
|
|
|
|
#ifndef STATS_INTERVAL
|
|
#define STATS_INTERVAL 0
|
|
#endif
|
|
|
|
#define NB_SOCKETS 4
|
|
|
|
#define MAX_PKT_BURST 32
|
|
|
|
#define RTE_LOGTYPE_IPSEC RTE_LOGTYPE_USER1
|
|
|
|
#if RTE_BYTE_ORDER != RTE_LITTLE_ENDIAN
|
|
#define __BYTES_TO_UINT64(a, b, c, d, e, f, g, h) \
|
|
(((uint64_t)((a) & 0xff) << 56) | \
|
|
((uint64_t)((b) & 0xff) << 48) | \
|
|
((uint64_t)((c) & 0xff) << 40) | \
|
|
((uint64_t)((d) & 0xff) << 32) | \
|
|
((uint64_t)((e) & 0xff) << 24) | \
|
|
((uint64_t)((f) & 0xff) << 16) | \
|
|
((uint64_t)((g) & 0xff) << 8) | \
|
|
((uint64_t)(h) & 0xff))
|
|
#else
|
|
#define __BYTES_TO_UINT64(a, b, c, d, e, f, g, h) \
|
|
(((uint64_t)((h) & 0xff) << 56) | \
|
|
((uint64_t)((g) & 0xff) << 48) | \
|
|
((uint64_t)((f) & 0xff) << 40) | \
|
|
((uint64_t)((e) & 0xff) << 32) | \
|
|
((uint64_t)((d) & 0xff) << 24) | \
|
|
((uint64_t)((c) & 0xff) << 16) | \
|
|
((uint64_t)((b) & 0xff) << 8) | \
|
|
((uint64_t)(a) & 0xff))
|
|
#endif
|
|
|
|
#define ETHADDR(a, b, c, d, e, f) (__BYTES_TO_UINT64(a, b, c, d, e, f, 0, 0))
|
|
|
|
struct traffic_type {
|
|
const uint8_t *data[MAX_PKT_BURST * 2];
|
|
struct rte_mbuf *pkts[MAX_PKT_BURST * 2];
|
|
void *saptr[MAX_PKT_BURST * 2];
|
|
uint32_t res[MAX_PKT_BURST * 2];
|
|
uint32_t num;
|
|
};
|
|
|
|
struct ipsec_traffic {
|
|
struct traffic_type ipsec;
|
|
struct traffic_type ip4;
|
|
struct traffic_type ip6;
|
|
};
|
|
|
|
/* Fields optimized for devices without burst */
|
|
struct traffic_type_nb {
|
|
const uint8_t *data;
|
|
struct rte_mbuf *pkt;
|
|
uint32_t res;
|
|
uint32_t num;
|
|
};
|
|
|
|
struct ipsec_traffic_nb {
|
|
struct traffic_type_nb ipsec;
|
|
struct traffic_type_nb ip4;
|
|
struct traffic_type_nb ip6;
|
|
};
|
|
|
|
/* port/source ethernet addr and destination ethernet addr */
|
|
struct ethaddr_info {
|
|
uint64_t src, dst;
|
|
};
|
|
|
|
#if (STATS_INTERVAL > 0)
|
|
struct ipsec_core_statistics {
|
|
uint64_t tx;
|
|
uint64_t rx;
|
|
uint64_t rx_call;
|
|
uint64_t tx_call;
|
|
uint64_t dropped;
|
|
uint64_t burst_rx;
|
|
} __rte_cache_aligned;
|
|
|
|
struct ipsec_core_statistics core_statistics[RTE_MAX_LCORE];
|
|
#endif /* STATS_INTERVAL */
|
|
|
|
extern struct ethaddr_info ethaddr_tbl[RTE_MAX_ETHPORTS];
|
|
|
|
/* Port mask to identify the unprotected ports */
|
|
extern uint32_t unprotected_port_mask;
|
|
|
|
/* Index of SA in single mode */
|
|
extern uint32_t single_sa_idx;
|
|
|
|
extern volatile bool force_quit;
|
|
|
|
static inline uint8_t
|
|
is_unprotected_port(uint16_t port_id)
|
|
{
|
|
return unprotected_port_mask & (1 << port_id);
|
|
}
|
|
|
|
static inline void
|
|
core_stats_update_rx(int n)
|
|
{
|
|
#if (STATS_INTERVAL > 0)
|
|
int lcore_id = rte_lcore_id();
|
|
core_statistics[lcore_id].rx += n;
|
|
core_statistics[lcore_id].rx_call++;
|
|
if (n == MAX_PKT_BURST)
|
|
core_statistics[lcore_id].burst_rx += n;
|
|
#else
|
|
RTE_SET_USED(n);
|
|
#endif /* STATS_INTERVAL */
|
|
}
|
|
|
|
static inline void
|
|
core_stats_update_tx(int n)
|
|
{
|
|
#if (STATS_INTERVAL > 0)
|
|
int lcore_id = rte_lcore_id();
|
|
core_statistics[lcore_id].tx += n;
|
|
core_statistics[lcore_id].tx_call++;
|
|
#else
|
|
RTE_SET_USED(n);
|
|
#endif /* STATS_INTERVAL */
|
|
}
|
|
|
|
static inline void
|
|
core_stats_update_drop(int n)
|
|
{
|
|
#if (STATS_INTERVAL > 0)
|
|
int lcore_id = rte_lcore_id();
|
|
core_statistics[lcore_id].dropped += n;
|
|
#else
|
|
RTE_SET_USED(n);
|
|
#endif /* STATS_INTERVAL */
|
|
}
|
|
|
|
/* helper routine to free bulk of packets */
|
|
static inline void
|
|
free_pkts(struct rte_mbuf *mb[], uint32_t n)
|
|
{
|
|
uint32_t i;
|
|
|
|
for (i = 0; i != n; i++)
|
|
rte_pktmbuf_free(mb[i]);
|
|
|
|
core_stats_update_drop(n);
|
|
}
|
|
|
|
#endif /* _IPSEC_SECGW_H_ */
|