projects
/
lcr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Added display of current active TEI values (L2) at lcradmin.
[lcr.git]
/
message.c
diff --git
a/message.c
b/message.c
index
7b8ce57
..
ff0d70c
100644
(file)
--- a/
message.c
+++ b/
message.c
@@
-9,22
+9,19
@@
** **
\*****************************************************************************/
** **
\*****************************************************************************/
-#include <stdio.h>
-#include <string.h>
-#include <stdlib.h>
#include "main.h"
MESSAGES
#include "main.h"
MESSAGES
-struct
message
*message_first = NULL;
-struct
message
**messagepointer_end = &message_first;
+struct
lcr_msg
*message_first = NULL;
+struct
lcr_msg
**messagepointer_end = &message_first;
/* creates a new message with the given attributes. the message must be filled then. after filling, the message_put must be called */
/* creates a new message with the given attributes. the message must be filled then. after filling, the message_put must be called */
-struct
message
*message_create(int id_from, int id_to, int flow, int type)
+struct
lcr_msg
*message_create(int id_from, int id_to, int flow, int type)
{
{
- struct
message
*message;
+ struct
lcr_msg
*message;
- message = (struct
message *)MALLOC(sizeof(struct message
));
+ message = (struct
lcr_msg *)MALLOC(sizeof(struct lcr_msg
));
if (!message)
FATAL("No memory for message.\n");
mmemuse++;
if (!message)
FATAL("No memory for message.\n");
mmemuse++;
@@
-38,7
+35,7
@@
struct message *message_create(int id_from, int id_to, int flow, int type)
}
/* attaches a message to the end of the message chain */
}
/* attaches a message to the end of the message chain */
-void message_put(struct
message
*message)
+void message_put(struct
lcr_msg
*message)
{
if (message->id_to == 0)
{
{
if (message->id_to == 0)
{
@@
-52,14
+49,16
@@
void message_put(struct message *message)
*messagepointer_end = message;
messagepointer_end = &(message->next);
*messagepointer_end = message;
messagepointer_end = &(message->next);
+ /* Nullify next pointer if recycled messages */
+ *messagepointer_end=NULL;
}
}
-
void
message_forward(int id_from, int id_to, int flow, union parameter *param)
+
struct lcr_msg *
message_forward(int id_from, int id_to, int flow, union parameter *param)
{
{
- struct
message
*message;
+ struct
lcr_msg
*message;
/* get point to message */
/* get point to message */
- message = (struct
message
*)((unsigned long)param - ((unsigned long)(&message->param) - (unsigned long)message));
+ message = (struct
lcr_msg
*)((unsigned long)param - ((unsigned long)(&message->param) - (unsigned long)message));
/* protect, so forwarded messages are not freed after handling */
message->keep = 1;
/* protect, so forwarded messages are not freed after handling */
message->keep = 1;
@@
-68,12
+67,14
@@
void message_forward(int id_from, int id_to, int flow, union parameter *param)
message->id_to = id_to;
message->flow = flow;
message_put(message);
message->id_to = id_to;
message->flow = flow;
message_put(message);
+
+ return(message);
}
/* detaches the first messages from the message chain */
}
/* detaches the first messages from the message chain */
-struct
message
*message_get(void)
+struct
lcr_msg
*message_get(void)
{
{
- struct
message
*message;
+ struct
lcr_msg
*message;
if (!message_first)
{
if (!message_first)
{
@@
-95,11
+96,11
@@
struct message *message_get(void)
}
/* free a message */
}
/* free a message */
-void message_free(struct
message
*message)
+void message_free(struct
lcr_msg
*message)
{
if (message->keep)
return;
{
if (message->keep)
return;
- FREE(message, sizeof(struct
message
));
+ FREE(message, sizeof(struct
lcr_msg
));
mmemuse--;
}
mmemuse--;
}