Function port_queue_flow_aged

dpdk/app/test-pmd/config.c:3398–3491

List simply and destroy all aged flows per queue. */

/** List simply and destroy all aged flows per queue. */
void
port_queue_flow_aged(portid_t port_id, uint32_t queue_id, uint8_t destroy)
{
	void **contexts;
	int nb_context, total = 0, idx;
	uint64_t *rules = NULL;
	struct rte_port *port;
	struct rte_flow_error error;
	enum age_action_context_type *type;
	union {
		struct port_flow *pf;
		struct port_indirect_action *pia;
	} ctx;

	if (port_id_is_invalid(port_id, ENABLED_WARN) ||
	    port_id == (portid_t)RTE_PORT_ALL)
		return;
	port = &ports[port_id];
	if (queue_id >= port->queue_nb) {
		printf("Error: queue #%u is invalid\n", queue_id);
		return;
	}
	total = rte_flow_get_q_aged_flows(port_id, queue_id, NULL, 0, &error);
	if (total < 0) {
		port_flow_complain(&error);
		return;
	}
	printf("Port %u queue %u total aged flows: %d\n",
	       port_id, queue_id, total);
	if (total == 0)
		return;
	contexts = calloc(total, sizeof(void *));
	if (contexts == NULL) {
		printf("Cannot allocate contexts for aged flow\n");
		return;
	}
	printf("%-20s\tID\tGroup\tPrio\tAttr\n", "Type");
	nb_context = rte_flow_get_q_aged_flows(port_id, queue_id, contexts,
					       total, &error);
	if (nb_context > total) {
		printf("Port %u queue %u get aged flows count(%d) > total(%d)\n",
		       port_id, queue_id, nb_context, total);
		free(contexts);
		return;
	}
	if (destroy) {
		rules = malloc(sizeof(uint32_t) * nb_context);
		if (rules == NULL)
			printf("Cannot allocate memory for destroy aged flow\n");
	}
	total = 0;
	for (idx = 0; idx < nb_context; idx++) {
		if (!contexts[idx]) {
			printf("Error: get Null context in port %u queue %u\n",
			       port_id, queue_id);
			continue;
		}
		type = (enum age_action_context_type *)contexts[idx];