Lines Matching refs:fq_cl
169 fq_detect_dequeue_stall(fq_if_t *fqs, fq_t *flowq, fq_if_classq_t *fq_cl, in fq_detect_dequeue_stall() argument
187 fq_cl->fcl_stat.fcl_dequeue_stall++; in fq_detect_dequeue_stall()
190 fq_cl->fcl_stat.fcl_dequeue_stall, flowq->fq_sc_index, in fq_detect_dequeue_stall()
239 fq_compressor(fq_if_t *fqs, fq_t *fq, fq_if_classq_t *fq_cl, in fq_compressor() argument
260 fq_cl->fcl_stat.fcl_pkts_compressible++; in fq_compressor()
302 fq_cl->fcl_stat.fcl_byte_cnt -= old_pktlen; in fq_compressor()
303 fq_cl->fcl_stat.fcl_pkt_cnt--; in fq_compressor()
317 fq_if_classq_t *fq_cl) in fq_addq() argument
367 fq_cl->fcl_stat.fcl_drop_memfailure += cnt; in fq_addq()
377 fq_detect_dequeue_stall(fqs, fq, fq_cl, &now); in fq_addq()
390 fq_cl->fcl_stat.fcl_drop_early += cnt; in fq_addq()
394 fq_if_classq_t *, fq_cl, fq_t *, fq, in fq_addq()
413 fq_cl->fcl_stat.fcl_drop_early += cnt; in fq_addq()
416 fq_if_classq_t *, fq_cl, fq_t *, fq, in fq_addq()
424 if (fq_if_add_fcentry(fqs, pkt, pkt_flowsrc, fq, fq_cl)) { in fq_addq()
440 fq_cl->fcl_stat.fcl_flow_control_fail++; in fq_addq()
462 fq_if_classq_t *, fq_cl, fq_t *, fq, in fq_addq()
468 fq_cl->fcl_stat.fcl_drop_overflow += cnt; in fq_addq()
478 if (fq_if_add_fcentry(fqs, pkt, pkt_flowsrc, fq, fq_cl)) { in fq_addq()
481 fq_cl->fcl_stat.fcl_overwhelming++; in fq_addq()
489 fq_cl->fcl_stat.fcl_drop_overflow += cnt; in fq_addq()
493 fq_if_classq_t *, fq_cl, fq_t *, fq, in fq_addq()
503 fq_if_move_to_empty_flow(fqs, fq_cl, in fq_addq()
509 fq_if_t *, fqs, fq_if_classq_t *, fq_cl, in fq_addq()
529 ret = fq_compressor(fqs, fq, fq_cl, pkt); in fq_addq()
533 fq_cl->fcl_stat.fcl_pkts_compressed++; in fq_addq()
536 DTRACE_IP5(fq_enqueue, fq_if_t *, fqs, fq_if_classq_t *, fq_cl, in fq_addq()
542 fq_cl->fcl_stat.fcl_byte_cnt += chain_len; in fq_addq()
543 fq_cl->fcl_stat.fcl_pkt_cnt += cnt; in fq_addq()
561 STAILQ_INSERT_TAIL(&fq_cl->fcl_new_flows, fq, fq_actlink); in fq_addq()
564 fq_cl->fcl_stat.fcl_newflows_cnt++; in fq_addq()
566 fq->fq_deficit = fq_cl->fcl_quantum; in fq_addq()
576 fq_if_classq_t *fq_cl; in fq_getq_flow_internal() local
591 fq_cl = &FQ_CLASSQ(fq); in fq_getq_flow_internal()
592 fq_cl->fcl_stat.fcl_byte_cnt -= plen; in fq_getq_flow_internal()
593 fq_cl->fcl_stat.fcl_pkt_cnt--; in fq_getq_flow_internal()
609 fq_if_classq_t *fq_cl; in fq_getq_flow() local
627 fq_cl = &FQ_CLASSQ(fq); in fq_getq_flow()
635 if (fq_cl->fcl_stat.fcl_min_qdelay == 0 || in fq_getq_flow()
636 (qdelay > 0 && (u_int64_t)qdelay < fq_cl->fcl_stat.fcl_min_qdelay)) { in fq_getq_flow()
637 fq_cl->fcl_stat.fcl_min_qdelay = qdelay; in fq_getq_flow()
640 if (fq_cl->fcl_stat.fcl_max_qdelay == 0 || in fq_getq_flow()
641 (qdelay > 0 && (u_int64_t)qdelay > fq_cl->fcl_stat.fcl_max_qdelay)) { in fq_getq_flow()
642 fq_cl->fcl_stat.fcl_max_qdelay = qdelay; in fq_getq_flow()
645 uint64_t num_dequeues = fq_cl->fcl_stat.fcl_dequeue; in fq_getq_flow()
648 fq_cl->fcl_stat.fcl_avg_qdelay = qdelay; in fq_getq_flow()
653 fq_cl->fcl_stat.fcl_dequeue = num_dequeues = 0; in fq_getq_flow()
654 fq_cl->fcl_stat.fcl_dequeue_bytes = 0; in fq_getq_flow()
655 fq_cl->fcl_stat.fcl_avg_qdelay = qdelay; in fq_getq_flow()
661 if (os_mul_overflow(fq_cl->fcl_stat.fcl_avg_qdelay, in fq_getq_flow()
663 fq_cl->fcl_stat.fcl_avg_qdelay = qdelay; in fq_getq_flow()
665 fq_cl->fcl_stat.fcl_avg_qdelay = res / in fq_getq_flow()
697 fq_if_flow_feedback(fqs, fq, fq_cl); in fq_getq_flow()