Lines Matching refs:q
48 static inline void __mbq_init(struct mbq *q) in __mbq_init() argument
50 q->head = q->tail = NULL; in __mbq_init()
51 q->count = 0; in __mbq_init()
55 void mbq_safe_init(struct mbq *q) in mbq_safe_init() argument
57 mtx_init(&q->lock, "mbq", NULL, MTX_SPIN); in mbq_safe_init()
58 __mbq_init(q); in mbq_safe_init()
62 void mbq_init(struct mbq *q) in mbq_init() argument
64 __mbq_init(q); in mbq_init()
68 static inline void __mbq_enqueue(struct mbq *q, struct mbuf *m) in __mbq_enqueue() argument
71 if (q->tail) { in __mbq_enqueue()
72 q->tail->m_nextpkt = m; in __mbq_enqueue()
73 q->tail = m; in __mbq_enqueue()
75 q->head = q->tail = m; in __mbq_enqueue()
77 q->count++; in __mbq_enqueue()
81 void mbq_safe_enqueue(struct mbq *q, struct mbuf *m) in mbq_safe_enqueue() argument
83 mbq_lock(q); in mbq_safe_enqueue()
84 __mbq_enqueue(q, m); in mbq_safe_enqueue()
85 mbq_unlock(q); in mbq_safe_enqueue()
89 void mbq_enqueue(struct mbq *q, struct mbuf *m) in mbq_enqueue() argument
91 __mbq_enqueue(q, m); in mbq_enqueue()
95 static inline struct mbuf *__mbq_dequeue(struct mbq *q) in __mbq_dequeue() argument
99 if (q->head) { in __mbq_dequeue()
100 ret = q->head; in __mbq_dequeue()
101 q->head = ret->m_nextpkt; in __mbq_dequeue()
102 if (q->head == NULL) { in __mbq_dequeue()
103 q->tail = NULL; in __mbq_dequeue()
105 q->count--; in __mbq_dequeue()
113 struct mbuf *mbq_safe_dequeue(struct mbq *q) in mbq_safe_dequeue() argument
117 mbq_lock(q); in mbq_safe_dequeue()
118 ret = __mbq_dequeue(q); in mbq_safe_dequeue()
119 mbq_unlock(q); in mbq_safe_dequeue()
125 struct mbuf *mbq_dequeue(struct mbq *q) in mbq_dequeue() argument
127 return __mbq_dequeue(q); in mbq_dequeue()
132 static void __mbq_purge(struct mbq *q, int safe) in __mbq_purge() argument
137 m = safe ? mbq_safe_dequeue(q) : mbq_dequeue(q); in __mbq_purge()
147 void mbq_purge(struct mbq *q) in mbq_purge() argument
149 __mbq_purge(q, 0); in mbq_purge()
153 void mbq_safe_purge(struct mbq *q) in mbq_safe_purge() argument
155 __mbq_purge(q, 1); in mbq_safe_purge()
159 void mbq_safe_fini(struct mbq *q) in mbq_safe_fini() argument
161 mtx_destroy(&q->lock); in mbq_safe_fini()
165 void mbq_fini(struct mbq *q) in mbq_fini() argument