Function main_loop

lib/ff_dpdk_if.c:2216–2382

}

static int
main_loop(void *arg)
{
    struct loop_routine *lr = (struct loop_routine *)arg;

    struct rte_mbuf *pkts_burst[MAX_PKT_BURST];
    uint64_t prev_tsc, diff_tsc, cur_tsc, usch_tsc, div_tsc, usr_tsc, sys_tsc, end_tsc, idle_sleep_tsc;
    int i, j, nb_rx, idle;
    uint16_t port_id, queue_id;
    struct lcore_conf *qconf;
    uint64_t drain_tsc = 0;
    struct ff_dpdk_if_context *ctx;

    if (pkt_tx_delay) {
        drain_tsc = (rte_get_tsc_hz() + US_PER_S - 1) / US_PER_S * pkt_tx_delay;
    }

    prev_tsc = 0;
    usch_tsc = 0;

    qconf = &lcore_conf;

    while (1) {

        if (unlikely(stop_loop)) {
            break;
        }

        cur_tsc = rte_rdtsc();
        if (unlikely(freebsd_clock.expire < cur_tsc)) {
            rte_timer_manage();

#ifdef FF_KNI
            /* reset kni ratelimt */
            if (enable_kni &&
                    (ff_global_cfg.kni.console_packets_ratelimit ||
                        ff_global_cfg.kni.general_packets_ratelimit ||
                        ff_global_cfg.kni.kernel_packets_ratelimit)) {
                static time_t last_sec = 0;
                time_t sec;
                long nsec;

                ff_get_current_time(&sec, &nsec);
                if (sec > last_sec) {
                    if (kni_rate_limt.gerneal_packets > (uint64_t)ff_global_cfg.kni.general_packets_ratelimit ||
                        kni_rate_limt.console_packets > (uint64_t)ff_global_cfg.kni.console_packets_ratelimit ||
                        kni_rate_limt.kernel_packets > (uint64_t)ff_global_cfg.kni.kernel_packets_ratelimit) {
                        ff_log(FF_LOG_NOTICE, FF_LOGTYPE_FSTACK_LIB, "kni ratelimit, general:%lu/%d, console:%lu/%d, kernel:%lu/%d, last sec:%ld, sec:%ld\n",
                            kni_rate_limt.gerneal_packets, ff_global_cfg.kni.general_packets_ratelimit,
                            kni_rate_limt.console_packets, ff_global_cfg.kni.console_packets_ratelimit,
                            kni_rate_limt.kernel_packets, ff_global_cfg.kni.kernel_packets_ratelimit, last_sec, sec);
                    }
                    last_sec = sec;
                    kni_rate_limt.gerneal_packets = 0;
                    kni_rate_limt.console_packets = 0;
                    kni_rate_limt.kernel_packets = 0;
                }
            }