Home
last modified time | relevance | path

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

/xnu-8020.121.3/bsd/net/classq/
H A Dclassq_fq_codel.c88 fq_t *fq = NULL; in fq_alloc() local
89 fq = mcache_alloc(flowq_cache, MCR_SLEEP); in fq_alloc()
90 if (fq == NULL) { in fq_alloc()
95 bzero(fq, flowq_size); in fq_alloc()
96 fq->fq_ptype = ptype; in fq_alloc()
98 MBUFQ_INIT(&fq->fq_mbufq); in fq_alloc()
103 KPKTQ_INIT(&fq->fq_kpktq); in fq_alloc()
106 CLASSQ_PKT_INIT(&fq->fq_dq_head); in fq_alloc()
107 CLASSQ_PKT_INIT(&fq->fq_dq_tail); in fq_alloc()
108 fq->fq_in_dqlist = false; in fq_alloc()
[all …]
/xnu-8020.121.3/bsd/net/pktsched/
H A Dpktsched_fq_codel.c79 static void fq_if_empty_new_flow(fq_t *fq, fq_if_classq_t *fq_cl,
82 fq_t *fq, bool remove_hash, bool destroy);
112 fq_getq_flow_kpkt(fq_if_t *fqs, fq_if_classq_t *fq_cl, fq_t *fq, in fq_getq_flow_kpkt() argument
129 while (fq->fq_deficit > 0 && limit_reached == FALSE && in fq_getq_flow_kpkt()
130 !KPKTQ_EMPTY(&fq->fq_kpktq)) { in fq_getq_flow_kpkt()
132 fq_getq_flow(fqs, fq, &pkt); in fq_getq_flow_kpkt()
136 fq->fq_deficit -= plen; in fq_getq_flow_kpkt()
161 *qempty = KPKTQ_EMPTY(&fq->fq_kpktq); in fq_getq_flow_kpkt()
167 fq_getq_flow_mbuf(fq_if_t *fqs, fq_if_classq_t *fq_cl, fq_t *fq, in fq_getq_flow_mbuf() argument
178 while (fq->fq_deficit > 0 && limit_reached == FALSE && in fq_getq_flow_mbuf()
[all …]
/xnu-8020.121.3/bsd/net/
H A Dif_fake.c2151 fake_queue *fq; in feth_nx_queue_init() local
2167 fq = &fqs->fqs_tx_queue[qidx]; in feth_nx_queue_init()
2175 fq = &fqs->fqs_rx_queue[qidx]; in feth_nx_queue_init()
2177 ASSERT(fq->fq_queue == NULL); in feth_nx_queue_init()
2178 fq->fq_queue = queue; in feth_nx_queue_init()
2179 *queue_ctx = fq; in feth_nx_queue_init()
2189 fake_queue *fq = queue_ctx; in feth_nx_queue_fini() local
2192 ASSERT(fq->fq_queue != NULL); in feth_nx_queue_fini()
2193 fq->fq_queue = NULL; in feth_nx_queue_fini()
/xnu-8020.121.3/bsd/netinet/
H A Dip_input.c2219 struct ipq *fq = TAILQ_LAST(head, ipqhead); in ip_reass() local
2220 if (fq == NULL) { /* gak */ in ip_reass()
2230 ipstat.ips_fragtimeout += fq->ipq_nfrags; in ip_reass()
2231 frag_freef(head, fq); in ip_reass()