Function flow_print_counters

dpdk/examples/ipsec-secgw/flow.c:366–414

}

void
flow_print_counters(void)
{
	struct rte_flow_query_count count_query;
	struct rte_flow_action action;
	struct flow_rule_entry *rule;
	struct rte_flow_error error;
	int i = 0, ret = 0;

	action.type = RTE_FLOW_ACTION_TYPE_COUNT;

	for (i = 0; i < nb_flow_rule; i++) {
		rule = &flow_rule_tbl[i];
		if (!rule->flow || !rule->enable_count)
			continue;

		/* Poisoning to make sure PMDs update it in case of error. */
		memset(&error, 0x55, sizeof(error));
		memset(&count_query, 0, sizeof(count_query));
		ret = rte_flow_query(rule->port, rule->flow, &action,
				     &count_query, &error);
		if (ret)
			RTE_LOG(ERR, IPSEC,
				"Failed to get flow counter "
				" for port %u, err msg: %s\n",
				rule->port, error.message);

		printf("Flow #%3d:", i);
		if (rule->is_ipv4) {
			printf(" spec ipv4 ");
			ipv4_hdr_print(&rule->ipv4.spec.hdr);
		}
		if (rule->is_ipv6) {
			printf(" spec ipv6 ");
			ipv6_hdr_print(&rule->ipv6.spec.hdr);
		}

		if (rule->set_security_action)
			printf(" Security action set,");

		if (rule->enable_mark)
			printf(" Mark Enabled");

		printf(" Port: %d,", rule->port);
		if (rule->is_queue_set)
			printf(" Queue: %d", rule->queue);
		printf(" Hits: %"PRIu64"\n", count_query.hits);
	}
}

void
flow_init(void)