Lines Matching refs:flows
146 SYSCTL_UINT(_net_inet_ip_dummynet_fqcodel, OID_AUTO, flows,
307 drop = codel_enqueue(&si->flows[idx], m, si); in fq_codel_enqueue()
316 if (!si->flows[idx].active ) { in fq_codel_enqueue()
317 STAILQ_INSERT_TAIL(&si->newflows, &si->flows[idx], flowchain); in fq_codel_enqueue()
318 si->flows[idx].deficit = param->quantum; in fq_codel_enqueue()
319 si->flows[idx].cst.dropping = false; in fq_codel_enqueue()
320 si->flows[idx].cst.first_above_time = 0; in fq_codel_enqueue()
321 si->flows[idx].active = 1; in fq_codel_enqueue()
331 if (si->flows[maxidx].active) in fq_codel_enqueue()
336 if (si->flows[i].active && si->flows[i].stats.length > in fq_codel_enqueue()
337 si->flows[maxidx].stats.length) in fq_codel_enqueue()
339 codel_drop_head(&si->flows[maxidx], si); in fq_codel_enqueue()
444 if(si->flows) { in fq_codel_new_sched()
456 si->flows = mallocarray(schk->cfg.flows_cnt, in fq_codel_new_sched()
458 if (si->flows == NULL) { in fq_codel_new_sched()
473 si->flows[i].cst.maxpkt_size = 500; in fq_codel_new_sched()
489 free(si->flows , M_DUMMYNET); in fq_codel_free_sched()
490 si->flows = NULL; in fq_codel_free_sched()