Function ff_kni_enqueue

lib/ff_dpdk_kni.c:502–535

enqueue the packet, and own it */

/* enqueue the packet, and own it */
int
ff_kni_enqueue(enum FilterReturn filter, uint16_t port_id, struct rte_mbuf *pkt)
{
    if (filter >= FILTER_ARP) {
        if (ff_global_cfg.kni.console_packets_ratelimit) {
            kni_rate_limt.console_packets++;
            if (kni_rate_limt.console_packets > (uint64_t)ff_global_cfg.kni.console_packets_ratelimit) {
                goto error;
            }
        }
    } else {
        if (ff_global_cfg.kni.general_packets_ratelimit) {
            kni_rate_limt.gerneal_packets++;
            if (kni_rate_limt.gerneal_packets > (uint64_t)ff_global_cfg.kni.general_packets_ratelimit) {
                goto error;
            }
        }
    }

    int ret = rte_ring_enqueue(kni_rp[port_id], pkt);
    if (ret < 0) {
        goto error;
    }

    return 0;

error:
    if (rte_eal_process_type() == RTE_PROC_PRIMARY) {
        kni_stat[port_id]->rx_dropped++;
    }
    rte_pktmbuf_free(pkt);

    return -1;
}