#include <stdarg.h>
|
#include <stdarg.h>
|
#include <linux/stddef.h>
|
#include <linux/stddef.h>
|
|
|
#include "msgqueue.h"
|
#include "msgqueue.h"
|
|
|
/*
|
/*
|
* Function: struct msgqueue_entry *mqe_alloc(MsgQueue_t *msgq)
|
* Function: struct msgqueue_entry *mqe_alloc(MsgQueue_t *msgq)
|
* Purpose : Allocate a message queue entry
|
* Purpose : Allocate a message queue entry
|
* Params : msgq - message queue to claim entry for
|
* Params : msgq - message queue to claim entry for
|
* Returns : message queue entry or NULL.
|
* Returns : message queue entry or NULL.
|
*/
|
*/
|
static struct msgqueue_entry *mqe_alloc(MsgQueue_t *msgq)
|
static struct msgqueue_entry *mqe_alloc(MsgQueue_t *msgq)
|
{
|
{
|
struct msgqueue_entry *mq;
|
struct msgqueue_entry *mq;
|
|
|
if ((mq = msgq->free) != NULL)
|
if ((mq = msgq->free) != NULL)
|
msgq->free = mq->next;
|
msgq->free = mq->next;
|
|
|
return mq;
|
return mq;
|
}
|
}
|
|
|
/*
|
/*
|
* Function: void mqe_free(MsgQueue_t *msgq, struct msgqueue_entry *mq)
|
* Function: void mqe_free(MsgQueue_t *msgq, struct msgqueue_entry *mq)
|
* Purpose : free a message queue entry
|
* Purpose : free a message queue entry
|
* Params : msgq - message queue to free entry from
|
* Params : msgq - message queue to free entry from
|
* mq - message queue entry to free
|
* mq - message queue entry to free
|
*/
|
*/
|
static void mqe_free(MsgQueue_t *msgq, struct msgqueue_entry *mq)
|
static void mqe_free(MsgQueue_t *msgq, struct msgqueue_entry *mq)
|
{
|
{
|
if (mq) {
|
if (mq) {
|
mq->next = msgq->free;
|
mq->next = msgq->free;
|
msgq->free = mq;
|
msgq->free = mq;
|
}
|
}
|
}
|
}
|
|
|
/*
|
/*
|
* Function: void msgqueue_initialise(MsgQueue_t *msgq)
|
* Function: void msgqueue_initialise(MsgQueue_t *msgq)
|
* Purpose : initialise a message queue
|
* Purpose : initialise a message queue
|
* Params : msgq - queue to initialise
|
* Params : msgq - queue to initialise
|
*/
|
*/
|
void msgqueue_initialise(MsgQueue_t *msgq)
|
void msgqueue_initialise(MsgQueue_t *msgq)
|
{
|
{
|
int i;
|
int i;
|
|
|
msgq->qe = NULL;
|
msgq->qe = NULL;
|
msgq->free = &msgq->entries[0];
|
msgq->free = &msgq->entries[0];
|
|
|
for (i = 0; i < NR_MESSAGES; i++)
|
for (i = 0; i < NR_MESSAGES; i++)
|
msgq->entries[i].next = &msgq->entries[i + 1];
|
msgq->entries[i].next = &msgq->entries[i + 1];
|
|
|
msgq->entries[NR_MESSAGES - 1].next = NULL;
|
msgq->entries[NR_MESSAGES - 1].next = NULL;
|
}
|
}
|
|
|
|
|
/*
|
/*
|
* Function: void msgqueue_free(MsgQueue_t *msgq)
|
* Function: void msgqueue_free(MsgQueue_t *msgq)
|
* Purpose : free a queue
|
* Purpose : free a queue
|
* Params : msgq - queue to free
|
* Params : msgq - queue to free
|
*/
|
*/
|
void msgqueue_free(MsgQueue_t *msgq)
|
void msgqueue_free(MsgQueue_t *msgq)
|
{
|
{
|
}
|
}
|
|
|
/*
|
/*
|
* Function: int msgqueue_msglength(MsgQueue_t *msgq)
|
* Function: int msgqueue_msglength(MsgQueue_t *msgq)
|
* Purpose : calculate the total length of all messages on the message queue
|
* Purpose : calculate the total length of all messages on the message queue
|
* Params : msgq - queue to examine
|
* Params : msgq - queue to examine
|
* Returns : number of bytes of messages in queue
|
* Returns : number of bytes of messages in queue
|
*/
|
*/
|
int msgqueue_msglength(MsgQueue_t *msgq)
|
int msgqueue_msglength(MsgQueue_t *msgq)
|
{
|
{
|
struct msgqueue_entry *mq = msgq->qe;
|
struct msgqueue_entry *mq = msgq->qe;
|
int length = 0;
|
int length = 0;
|
|
|
for (mq = msgq->qe; mq; mq = mq->next)
|
for (mq = msgq->qe; mq; mq = mq->next)
|
length += mq->msg.length;
|
length += mq->msg.length;
|
|
|
return length;
|
return length;
|
}
|
}
|
|
|
/*
|
/*
|
* Function: char *msgqueue_getmsg(MsgQueue_t *msgq, int msgno)
|
* Function: char *msgqueue_getmsg(MsgQueue_t *msgq, int msgno)
|
* Purpose : return a message
|
* Purpose : return a message
|
* Params : msgq - queue to obtain message from
|
* Params : msgq - queue to obtain message from
|
* : msgno - message number
|
* : msgno - message number
|
* Returns : pointer to message string, or NULL
|
* Returns : pointer to message string, or NULL
|
*/
|
*/
|
struct message *msgqueue_getmsg(MsgQueue_t *msgq, int msgno)
|
struct message *msgqueue_getmsg(MsgQueue_t *msgq, int msgno)
|
{
|
{
|
struct msgqueue_entry *mq;
|
struct msgqueue_entry *mq;
|
|
|
for (mq = msgq->qe; mq && msgno; mq = mq->next, msgno--);
|
for (mq = msgq->qe; mq && msgno; mq = mq->next, msgno--);
|
|
|
return mq ? &mq->msg : NULL;
|
return mq ? &mq->msg : NULL;
|
}
|
}
|
|
|
/*
|
/*
|
* Function: int msgqueue_addmsg(MsgQueue_t *msgq, int length, ...)
|
* Function: int msgqueue_addmsg(MsgQueue_t *msgq, int length, ...)
|
* Purpose : add a message onto a message queue
|
* Purpose : add a message onto a message queue
|
* Params : msgq - queue to add message on
|
* Params : msgq - queue to add message on
|
* length - length of message
|
* length - length of message
|
* ... - message bytes
|
* ... - message bytes
|
* Returns : != 0 if successful
|
* Returns : != 0 if successful
|
*/
|
*/
|
int msgqueue_addmsg(MsgQueue_t *msgq, int length, ...)
|
int msgqueue_addmsg(MsgQueue_t *msgq, int length, ...)
|
{
|
{
|
struct msgqueue_entry *mq = mqe_alloc(msgq);
|
struct msgqueue_entry *mq = mqe_alloc(msgq);
|
va_list ap;
|
va_list ap;
|
|
|
if (mq) {
|
if (mq) {
|
struct msgqueue_entry **mqp;
|
struct msgqueue_entry **mqp;
|
int i;
|
int i;
|
|
|
va_start(ap, length);
|
va_start(ap, length);
|
for (i = 0; i < length; i++)
|
for (i = 0; i < length; i++)
|
mq->msg.msg[i] = va_arg(ap, unsigned char);
|
mq->msg.msg[i] = va_arg(ap, unsigned char);
|
va_end(ap);
|
va_end(ap);
|
|
|
mq->msg.length = length;
|
mq->msg.length = length;
|
mq->msg.fifo = 0;
|
mq->msg.fifo = 0;
|
mq->next = NULL;
|
mq->next = NULL;
|
|
|
mqp = &msgq->qe;
|
mqp = &msgq->qe;
|
while (*mqp)
|
while (*mqp)
|
mqp = &(*mqp)->next;
|
mqp = &(*mqp)->next;
|
|
|
*mqp = mq;
|
*mqp = mq;
|
}
|
}
|
|
|
return mq != NULL;
|
return mq != NULL;
|
}
|
}
|
|
|
/*
|
/*
|
* Function: void msgqueue_flush(MsgQueue_t *msgq)
|
* Function: void msgqueue_flush(MsgQueue_t *msgq)
|
* Purpose : flush all messages from message queue
|
* Purpose : flush all messages from message queue
|
* Params : msgq - queue to flush
|
* Params : msgq - queue to flush
|
*/
|
*/
|
void msgqueue_flush(MsgQueue_t *msgq)
|
void msgqueue_flush(MsgQueue_t *msgq)
|
{
|
{
|
struct msgqueue_entry *mq, *mqnext;
|
struct msgqueue_entry *mq, *mqnext;
|
|
|
for (mq = msgq->qe; mq; mq = mqnext) {
|
for (mq = msgq->qe; mq; mq = mqnext) {
|
mqnext = mq->next;
|
mqnext = mq->next;
|
mqe_free(msgq, mq);
|
mqe_free(msgq, mq);
|
}
|
}
|
msgq->qe = NULL;
|
msgq->qe = NULL;
|
}
|
}
|
|
|
