96fd2bd69b
For now, a rule may have only one dedicated counter, shared counters are not supported. HW delivers (or "streams") counter readings using special packets. The driver creates a dedicated Rx queue to receive such packets and requests that HW start "streaming" the readings to it. The counter queue is polled periodically, and the first available service core is used for that. Hence, the user has to specify at least one service core for counters to work. Such a core is shared by all MAE-capable devices managed by sfc driver. Signed-off-by: Igor Romanov <igor.romanov@oktetlabs.ru> Signed-off-by: Andrew Rybchenko <andrew.rybchenko@oktetlabs.ru> Reviewed-by: Andy Moreton <amoreton@xilinx.com> Reviewed-by: Ivan Malov <ivan.malov@oktetlabs.ru>
81 lines
1.7 KiB
C
81 lines
1.7 KiB
C
/* SPDX-License-Identifier: BSD-3-Clause
|
|
*
|
|
* Copyright(c) 2019-2021 Xilinx, Inc.
|
|
* Copyright(c) 2019 Solarflare Communications Inc.
|
|
*
|
|
* This software was jointly developed between OKTET Labs (under contract
|
|
* for Solarflare) and Solarflare Communications, Inc.
|
|
*/
|
|
|
|
#ifndef _SFC_STATS_H
|
|
#define _SFC_STATS_H
|
|
|
|
#include <stdint.h>
|
|
|
|
#include <rte_atomic.h>
|
|
|
|
#include "sfc_tweak.h"
|
|
|
|
#ifdef __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
|
|
/**
|
|
* 64-bit packets and bytes counters covered by 128-bit integer
|
|
* in order to do atomic updates to guarantee consistency if
|
|
* required.
|
|
*/
|
|
union sfc_pkts_bytes {
|
|
RTE_STD_C11
|
|
struct {
|
|
uint64_t pkts;
|
|
uint64_t bytes;
|
|
};
|
|
rte_int128_t pkts_bytes;
|
|
};
|
|
|
|
/**
|
|
* Update packets and bytes counters atomically in assumption that
|
|
* the counter is written on one core only.
|
|
*/
|
|
static inline void
|
|
sfc_pkts_bytes_add(union sfc_pkts_bytes *st, uint64_t pkts, uint64_t bytes)
|
|
{
|
|
#if SFC_SW_STATS_ATOMIC
|
|
union sfc_pkts_bytes result;
|
|
|
|
/* Stats are written on single core only, so just load values */
|
|
result.pkts = st->pkts + pkts;
|
|
result.bytes = st->bytes + bytes;
|
|
|
|
/*
|
|
* Store the result atomically to guarantee that the reader
|
|
* core sees both counter updates together.
|
|
*/
|
|
__atomic_store_n(&st->pkts_bytes.int128, result.pkts_bytes.int128,
|
|
__ATOMIC_RELEASE);
|
|
#else
|
|
st->pkts += pkts;
|
|
st->bytes += bytes;
|
|
#endif
|
|
}
|
|
|
|
/**
|
|
* Get an atomic copy of a packets and bytes counters.
|
|
*/
|
|
static inline void
|
|
sfc_pkts_bytes_get(const union sfc_pkts_bytes *st, union sfc_pkts_bytes *result)
|
|
{
|
|
#if SFC_SW_STATS_ATOMIC
|
|
result->pkts_bytes.int128 = __atomic_load_n(&st->pkts_bytes.int128,
|
|
__ATOMIC_ACQUIRE);
|
|
#else
|
|
*result = *st;
|
|
#endif
|
|
}
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
#endif /* _SFC_STATS_H */
|