Home
last modified time | relevance | path

Searched refs:fq (Results 1 – 5 of 5) sorted by relevance

/xnu-8792.41.9/bsd/net/classq/
H A Dclassq_fq_codel.c134 fq_t *fq = NULL; in fq_alloc() local
135 fq = mcache_alloc(flowq_cache, MCR_SLEEP); in fq_alloc()
136 if (fq == NULL) { in fq_alloc()
141 bzero(fq, flowq_size); in fq_alloc()
143 MBUFQ_INIT(&fq->fq_mbufq); in fq_alloc()
148 KPKTQ_INIT(&fq->fq_kpktq); in fq_alloc()
151 CLASSQ_PKT_INIT(&fq->fq_dq_head); in fq_alloc()
152 CLASSQ_PKT_INIT(&fq->fq_dq_tail); in fq_alloc()
153 fq->fq_in_dqlist = false; in fq_alloc()
154 return fq; in fq_alloc()
[all …]
H A Dclassq_fq_codel.h249 extern void fq_codel_dequeue(fq_if_t *fqs, fq_t *fq,
/xnu-8792.41.9/bsd/net/pktsched/
H A Dpktsched_fq_codel.c80 static void fq_if_empty_new_flow(fq_t *fq, fq_if_classq_t *fq_cl);
82 fq_t *fq, uint64_t now);
83 static void fq_if_purge_empty_flow(fq_if_t *fqs, fq_t *fq);
86 static inline void fq_if_reuse_empty_flow(fq_if_t *fqs, fq_t *fq, uint64_t now);
209 fq_getq_flow_kpkt(fq_if_t *fqs, fq_if_classq_t *fq_cl, fq_t *fq, in fq_getq_flow_kpkt() argument
226 while (fq->fq_deficit > 0 && limit_reached == FALSE && in fq_getq_flow_kpkt()
227 !KPKTQ_EMPTY(&fq->fq_kpktq)) { in fq_getq_flow_kpkt()
229 fq_getq_flow(fqs, fq, &pkt, now); in fq_getq_flow_kpkt()
233 fq->fq_deficit -= plen; in fq_getq_flow_kpkt()
257 KDBG(AQM_KTRACE_STATS_FLOW_DEQUEUE, fq->fq_flowhash, in fq_getq_flow_kpkt()
[all …]
/xnu-8792.41.9/bsd/net/
H A Dif_fake.c2402 fake_queue *fq; in feth_nx_queue_init() local
2418 fq = &fqs->fqs_tx_queue[qidx]; in feth_nx_queue_init()
2426 fq = &fqs->fqs_rx_queue[qidx]; in feth_nx_queue_init()
2428 ASSERT(fq->fq_queue == NULL); in feth_nx_queue_init()
2429 fq->fq_queue = queue; in feth_nx_queue_init()
2430 *queue_ctx = fq; in feth_nx_queue_init()
2440 fake_queue *fq = queue_ctx; in feth_nx_queue_fini() local
2443 ASSERT(fq->fq_queue != NULL); in feth_nx_queue_fini()
2444 fq->fq_queue = NULL; in feth_nx_queue_fini()
/xnu-8792.41.9/bsd/netinet/
H A Dip_input.c2225 struct ipq *fq = TAILQ_LAST(head, ipqhead); in ip_reass() local
2226 if (fq == NULL) { /* gak */ in ip_reass()
2236 ipstat.ips_fragtimeout += fq->ipq_nfrags; in ip_reass()
2237 frag_freef(head, fq); in ip_reass()