Function sfc_mae_counter_get

dpdk/drivers/net/sfc/sfc_mae_counter.c:994–1055

}

int
sfc_mae_counter_get(struct sfc_adapter *sa,
		    const struct sfc_mae_counter *counter,
		    struct rte_flow_query_count *data)
{
	struct sfc_ft_ctx *ft_ctx = counter->ft_ctx;
	struct sfc_mae_counter_records *counters;
	uint64_t non_reset_tunnel_hit_counter;
	struct sfc_mae_counter_record *p;
	union sfc_pkts_bytes value;
	bool need_byte_count;

	switch (counter->type) {
	case EFX_COUNTER_TYPE_ACTION:
		counters = &sa->mae.counter_registry.action_counters;
		need_byte_count = true;
		break;
	case EFX_COUNTER_TYPE_CONNTRACK:
		counters = &sa->mae.counter_registry.conntrack_counters;
		need_byte_count = false;
		break;
	default:
		return EINVAL;
	}

	SFC_ASSERT(counter->fw_rsrc.counter_id.id < counters->n_mae_counters);
	p = &counters->mae_counters[counter->fw_rsrc.counter_id.id];

	/*
	 * Ordering is relaxed since it is the only operation on counter value.
	 * And it does not depend on different stores/loads in other threads.
	 * Paired with relaxed ordering in counter increment.
	 */
	value.pkts_bytes.int128 = __atomic_load_n(&p->value.pkts_bytes.int128,
						  __ATOMIC_RELAXED);

	data->hits_set = 1;
	data->hits = value.pkts - p->reset.pkts;

	if (ft_ctx != NULL) {
		data->hits += ft_ctx->switch_hit_counter;
		non_reset_tunnel_hit_counter = data->hits;
		data->hits -= ft_ctx->reset_tunnel_hit_counter;
	} else if (need_byte_count) {
		data->bytes_set = 1;
		data->bytes = value.bytes - p->reset.bytes;
	}

	if (data->reset != 0) {
		if (ft_ctx != NULL) {
			ft_ctx->reset_tunnel_hit_counter =
				non_reset_tunnel_hit_counter;
		} else {
			p->reset.pkts = value.pkts;

			if (need_byte_count)
				p->reset.bytes = value.bytes;
		}