Lines Matching defs:msgq

17  * Function: struct msgqueue_entry *mqe_alloc(MsgQueue_t *msgq)
19 * Params : msgq - message queue to claim entry for
22 static struct msgqueue_entry *mqe_alloc(MsgQueue_t *msgq)
26 if ((mq = msgq->free) != NULL)
27 msgq->free = mq->next;
33 * Function: void mqe_free(MsgQueue_t *msgq, struct msgqueue_entry *mq)
35 * Params : msgq - message queue to free entry from
38 static void mqe_free(MsgQueue_t *msgq, struct msgqueue_entry *mq)
41 mq->next = msgq->free;
42 msgq->free = mq;
47 * Function: void msgqueue_initialise(MsgQueue_t *msgq)
49 * Params : msgq - queue to initialise
51 void msgqueue_initialise(MsgQueue_t *msgq)
55 msgq->qe = NULL;
56 msgq->free = &msgq->entries[0];
59 msgq->entries[i].next = &msgq->entries[i + 1];
61 msgq->entries[NR_MESSAGES - 1].next = NULL;
66 * Function: void msgqueue_free(MsgQueue_t *msgq)
68 * Params : msgq - queue to free
70 void msgqueue_free(MsgQueue_t *msgq)
75 * Function: int msgqueue_msglength(MsgQueue_t *msgq)
77 * Params : msgq - queue to examine
80 int msgqueue_msglength(MsgQueue_t *msgq)
82 struct msgqueue_entry *mq = msgq->qe;
85 for (mq = msgq->qe; mq; mq = mq->next)
92 * Function: struct message *msgqueue_getmsg(MsgQueue_t *msgq, int msgno)
94 * Params : msgq - queue to obtain message from
98 struct message *msgqueue_getmsg(MsgQueue_t *msgq, int msgno)
102 for (mq = msgq->qe; mq && msgno; mq = mq->next, msgno--);
108 * Function: int msgqueue_addmsg(MsgQueue_t *msgq, int length, ...)
110 * Params : msgq - queue to add message on
115 int msgqueue_addmsg(MsgQueue_t *msgq, int length, ...)
117 struct msgqueue_entry *mq = mqe_alloc(msgq);
133 mqp = &msgq->qe;
144 * Function: void msgqueue_flush(MsgQueue_t *msgq)
146 * Params : msgq - queue to flush
148 void msgqueue_flush(MsgQueue_t *msgq)
152 for (mq = msgq->qe; mq; mq = mqnext) {
154 mqe_free(msgq, mq);
156 msgq->qe = NULL;