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)
  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) && message->type != MESSAGE_DATA)
  61                 PDEBUG(DEBUG_MSG, "message %s written from %ld to %ld (memory %x)\n", messages_txt[message->type], message->id_from, message->id_to, message);
  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) && message->type != MESSAGE_DATA)
 106
 107                 PDEBUG(DEBUG_MSG, "message %s reading from %ld to %ld (memory %x)\n", messages_txt[message->type], message->id_from, message->id_to, message);
 108
 109         return(message);
 110 }
 111
 112 /* free a message */
 113 void message_free(struct lcr_msg *message)
 114 {
 115         if (message->keep)
 116                 return;
 117         FREE(message, sizeof(struct lcr_msg));
 118         mmemuse--;
 119 }
 120
 121
 122 static int work_message(struct lcr_work *work, void *instance, int index)
 123 {
 124         struct lcr_msg          *message;
 125         class Port              *port;
 126         class Endpoint          *epoint;
 127         class Join              *join;
 128
 129         while ((message = message_get())) {
 130                 switch(message->flow) {
 131                         case PORT_TO_EPOINT:
 132                         epoint = find_epoint_id(message->id_to);
 133                         if (epoint) {
 134                                 if (epoint->ep_app) {
 135                                         epoint->ep_app->ea_message_port(message->id_from, message->type, &message->param);
 136                                 } else {
 137                                         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);
 138                                 }
 139                         } else {
 140                                 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);
 141                         }
 142                         break;
 143
 144                         case EPOINT_TO_JOIN:
 145                         join = find_join_id(message->id_to);
 146                         if (join) {
 147                                 join->message_epoint(message->id_from, message->type, &message->param);
 148                         } else {
 149                                 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);
 150                         }
 151                         break;
 152
 153                         case JOIN_TO_EPOINT:
 154                         epoint = find_epoint_id(message->id_to);
 155                         if (epoint) {
 156                                 if (epoint->ep_app) {
 157                                         epoint->ep_app->ea_message_join(message->id_from, message->type, &message->param);
 158                                 } else {
 159                                         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);
 160                                 }
 161                         } else {
 162                                 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);
 163                         }
 164                         break;
 165
 166                         case EPOINT_TO_PORT:
 167                         port = find_port_id(message->id_to);
 168                         if (port) {
 169                                 port->message_epoint(message->id_from, message->type, &message->param);
 170 BUDETECT
 171                         } else {
 172                                 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);
 173                         }
 174                         break;
 175
 176                         default:
 177                         PERROR("Message flow %d unknown.\n", message->flow);
 178                 }
 179                 message_free(message);
 180         }
 181
 182         return 0;
 183 }
 184