message.c

   1 /*****************************************************************************\
   2 **                                                                           **
   3 ** Linux Call Route                                                          **
   4 **                                                                           **
   5 **---------------------------------------------------------------------------**
   6 ** Copyright: Andreas Eversberg                                              **
   7 **                                                                           **
   8 ** message handling                                                          **
   9 **                                                                           **
  10 \*****************************************************************************/
  11
  12 #include "main.h"
  13
  14 MESSAGES
  15
  16 struct lcr_msg *message_first = NULL;
  17 struct lcr_msg **messagepointer_end = &message_first;
  18 struct lcr_work message_work;
  19
  20 static int work_message(struct lcr_work *work, void *instance, int index);
  21
  22 void init_message(void)
  23 {
  24         memset(&message_work, 0, sizeof(message_work));
  25         add_work(&message_work, work_message, NULL, 0);
  26 }
  27
  28 void cleanup_message(void)
  29 {
  30         del_work(&message_work);
  31 }
  32
  33 /* creates a new message with the given attributes. the message must be filled then. after filling, the message_put must be called */
  34 struct lcr_msg *message_create(int id_from, int id_to, int flow, int type)
  35 {
  36         struct lcr_msg *message;
  37
  38         message = (struct lcr_msg *)MALLOC(sizeof(struct lcr_msg));
  39         if (!message)
  40                 FATAL("No memory for message.\n");
  41         mmemuse++;
  42
  43         message->id_from = id_from;
  44         message->id_to = id_to;
  45         message->flow = flow;
  46         message->type = type;
  47
  48         return(message);
  49 }
  50
  51 /* attaches a message to the end of the message chain */
  52 void _message_put(struct lcr_msg *message, const char *file, int line)
  53 {
  54         if (message->id_to == 0) {
  55                 PDEBUG(DEBUG_MSG, "message %s not written, because destination is 0.\n", messages_txt[message->type]);
  56                 message_free(message);
  57                 return;
  58         }
  59
  60         if ((options.deb & DEBUG_MSG))
  61                 PDEBUG(DEBUG_MSG, "message %s written from %ld to %ld (memory %x at file %s, line %d)\n", messages_txt[message->type], message->id_from, message->id_to, message, file, line);
  62
  63         *messagepointer_end = message;
  64         messagepointer_end = &(message->next);
  65         /* Nullify next pointer if recycled messages */
  66         *messagepointer_end=NULL;
  67
  68         /* trigger work */
  69         trigger_work(&message_work);
  70 }
  71
  72 struct lcr_msg *message_forward(int id_from, int id_to, int flow, union parameter *param)
  73 {
  74         struct lcr_msg *message;
  75
  76         /* get point to message */
  77         message = (struct lcr_msg *)((unsigned long)param - ((unsigned long)(&message->param) - (unsigned long)message));
  78
  79         /* protect, so forwarded messages are not freed after handling */
  80         message->keep = 1;
  81
  82         message->id_from = id_from;
  83         message->id_to = id_to;
  84         message->flow = flow;
  85         message_put(message);
  86
  87         return(message);
  88 }
  89
  90 /* detaches the first messages from the message chain */
  91 struct lcr_msg *message_get(void)
  92 {
  93         struct lcr_msg *message;
  94
  95         if (!message_first)
  96                 return(0);
  97
  98         message = message_first;
  99         message_first = message->next;
 100         if (!message_first)
 101                 messagepointer_end = &message_first;
 102
 103         message->keep = 0;
 104
 105         if ((options.deb & DEBUG_MSG))
 106                 PDEBUG(DEBUG_MSG, "message %s reading from %ld to %ld (memory %x)\n", messages_txt[message->type], message->id_from, message->id_to, message);
 107
 108         return(message);
 109 }
 110
 111 /* free a message */
 112 void message_free(struct lcr_msg *message)
 113 {
 114         if (message->keep)
 115                 return;
 116         FREE(message, sizeof(struct lcr_msg));
 117         mmemuse--;
 118 }
 119
 120
 121 static int work_message(struct lcr_work *work, void *instance, int index)
 122 {
 123         struct lcr_msg          *message;
 124         class Port              *port;
 125         class Endpoint          *epoint;
 126         class Join              *join;
 127
 128         while ((message = message_get())) {
 129                 switch(message->flow) {
 130                         case PORT_TO_EPOINT:
 131                         epoint = find_epoint_id(message->id_to);
 132                         if (epoint) {
 133                                 if (epoint->ep_app) {
 134                                         epoint->ep_app->ea_message_port(message->id_from, message->type, &message->param);
 135                                 } else {
 136                                         PDEBUG(DEBUG_MSG, "Warning: message %s from port %d to endpoint %d. endpoint doesn't have an application.\n", messages_txt[message->type], message->id_from, message->id_to);
 137                                 }
 138                         } else {
 139                                 PDEBUG(DEBUG_MSG, "Warning: message %s from port %d to endpoint %d. endpoint doesn't exist anymore.\n", messages_txt[message->type], message->id_from, message->id_to);
 140                         }
 141                         break;
 142
 143                         case EPOINT_TO_JOIN:
 144                         join = find_join_id(message->id_to);
 145                         if (join) {
 146                                 join->message_epoint(message->id_from, message->type, &message->param);
 147                         } else {
 148                                 PDEBUG(DEBUG_MSG, "Warning: message %s from endpoint %d to join %d. join doesn't exist anymore\n", messages_txt[message->type], message->id_from, message->id_to);
 149                         }
 150                         break;
 151
 152                         case JOIN_TO_EPOINT:
 153                         epoint = find_epoint_id(message->id_to);
 154                         if (epoint) {
 155                                 if (epoint->ep_app) {
 156                                         epoint->ep_app->ea_message_join(message->id_from, message->type, &message->param);
 157                                 } else {
 158                                         PDEBUG(DEBUG_MSG, "Warning: message %s from join %d to endpoint %d. endpoint doesn't have an application.\n", messages_txt[message->type], message->id_from, message->id_to);
 159                                 }
 160                         } else {
 161                                 PDEBUG(DEBUG_MSG, "Warning: message %s from join %d to endpoint %d. endpoint doesn't exist anymore.\n", messages_txt[message->type], message->id_from, message->id_to);
 162                         }
 163                         break;
 164
 165                         case EPOINT_TO_PORT:
 166                         port = find_port_id(message->id_to);
 167                         if (port) {
 168                                 port->message_epoint(message->id_from, message->type, &message->param);
 169 BUDETECT
 170                         } else {
 171                                 PDEBUG(DEBUG_MSG, "Warning: message %s from endpoint %d to port %d. port doesn't exist anymore\n", messages_txt[message->type], message->id_from, message->id_to);
 172                         }
 173                         break;
 174
 175                         default:
 176                         PERROR("Message flow %d unknown.\n", message->flow);
 177                 }
 178                 message_free(message);
 179         }
 180
 181         return 0;
 182 }
 183