Lines Matching refs:mq

1223 mbufq_init(struct mbufq *mq, int maxlen)  in mbufq_init()  argument
1226 STAILQ_INIT(&mq->mq_head); in mbufq_init()
1227 mq->mq_maxlen = maxlen; in mbufq_init()
1228 mq->mq_len = 0; in mbufq_init()
1232 mbufq_flush(struct mbufq *mq) in mbufq_flush() argument
1236 m = STAILQ_FIRST(&mq->mq_head); in mbufq_flush()
1237 STAILQ_INIT(&mq->mq_head); in mbufq_flush()
1238 mq->mq_len = 0; in mbufq_flush()
1243 mbufq_drain(struct mbufq *mq) in mbufq_drain() argument
1247 n = mbufq_flush(mq); in mbufq_drain()
1255 mbufq_first(const struct mbufq *mq) in mbufq_first() argument
1258 return (STAILQ_FIRST(&mq->mq_head)); in mbufq_first()
1262 mbufq_last(const struct mbufq *mq) in mbufq_last() argument
1265 return (STAILQ_LAST(&mq->mq_head, mbuf, m_stailqpkt)); in mbufq_last()
1269 mbufq_full(const struct mbufq *mq) in mbufq_full() argument
1272 return (mq->mq_len >= mq->mq_maxlen); in mbufq_full()
1276 mbufq_len(const struct mbufq *mq) in mbufq_len() argument
1279 return (mq->mq_len); in mbufq_len()
1283 mbufq_enqueue(struct mbufq *mq, struct mbuf *m) in mbufq_enqueue() argument
1286 if (mbufq_full(mq)) in mbufq_enqueue()
1288 STAILQ_INSERT_TAIL(&mq->mq_head, m, m_stailqpkt); in mbufq_enqueue()
1289 mq->mq_len++; in mbufq_enqueue()
1294 mbufq_dequeue(struct mbufq *mq) in mbufq_dequeue() argument
1298 m = STAILQ_FIRST(&mq->mq_head); in mbufq_dequeue()
1300 STAILQ_REMOVE_HEAD(&mq->mq_head, m_stailqpkt); in mbufq_dequeue()
1302 mq->mq_len--; in mbufq_dequeue()
1308 mbufq_prepend(struct mbufq *mq, struct mbuf *m) in mbufq_prepend() argument
1311 STAILQ_INSERT_HEAD(&mq->mq_head, m, m_stailqpkt); in mbufq_prepend()
1312 mq->mq_len++; in mbufq_prepend()