Lines Matching refs:input_queue

75 static uint32_t dlil_trim_overcomitted_queue_locked(class_queue_t *input_queue, dlil_freeq_t *freeq…
411 class_queue_t *input_queue; in dlil_input_async() local
417 input_queue = &inpm->lo_rcvq_pkts; in dlil_input_async()
419 input_queue = &inp->dlth_pkts; in dlil_input_async()
422 _addq_multi(input_queue, &head, &tail, m_cnt, m_size); in dlil_input_async()
424 if (MBUF_QUEUE_IS_OVERCOMMITTED(input_queue)) { in dlil_input_async()
425 dlil_trim_overcomitted_queue_locked(input_queue, &freeq, &s_adj); in dlil_input_async()
432 __func__, if_name(ifp), qlimit(input_queue), if_rcvq_burst_limit, in dlil_input_async()
434 qlen(input_queue)); in dlil_input_async()
1776 dlil_trim_overcomitted_queue_locked(class_queue_t *input_queue, in dlil_trim_overcomitted_queue_locked() argument
1787 overcommitted_qlen = qlen(input_queue); in dlil_trim_overcomitted_queue_locked()
1788 overcommitted_qsize = qsize(input_queue); in dlil_trim_overcomitted_queue_locked()
1789 target_qlen = (qlimit(input_queue) * if_rcvq_trim_pct) / 100; in dlil_trim_overcomitted_queue_locked()
1806 MBUFQ_FOREACH_SAFE(m, &qmbufq(input_queue), m_tmp) { in dlil_trim_overcomitted_queue_locked()
1810 MBUFQ_REMOVE(&qmbufq(input_queue), m); in dlil_trim_overcomitted_queue_locked()
1823 qlen(input_queue) = target_qlen; in dlil_trim_overcomitted_queue_locked()
1826 if (dropped_bytes < qsize(input_queue)) { in dlil_trim_overcomitted_queue_locked()
1827 qsize(input_queue) -= dropped_bytes; in dlil_trim_overcomitted_queue_locked()
1829 qsize(input_queue) = 0; in dlil_trim_overcomitted_queue_locked()
1862 overcommitted_qlen, qlen(input_queue), in dlil_trim_overcomitted_queue_locked()
1863 overcommitted_qsize, qsize(input_queue), in dlil_trim_overcomitted_queue_locked()
1864 qlimit(input_queue), if_rcvq_burst_limit, in dlil_trim_overcomitted_queue_locked()