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 unsigned int lcr_random = 0;
  34
  35 /* creates a new message with the given attributes. the message must be filled then. after filling, the message_put must be called */
  36 struct lcr_msg *message_create(int id_from, int id_to, int flow, int type)
  37 {
  38         struct lcr_msg *message;
  39         struct timeval now_tv;
  40         struct timezone now_tz;
  41
  42         gettimeofday(&now_tv, &now_tz);
  43         lcr_random = (lcr_random << 1) | (lcr_random >> 31);
  44         lcr_random ^= now_tv.tv_sec;
  45         lcr_random ^= now_tv.tv_usec;
  46
  47         message = (struct lcr_msg *)MALLOC(sizeof(struct lcr_msg));
  48         if (!message)
  49                 FATAL("No memory for message.\n");
  50         mmemuse++;
  51
  52         message->id_from = id_from;
  53         message->id_to = id_to;
  54         message->flow = flow;
  55         message->type = type;
  56
  57         return(message);
  58 }
  59
  60 /* attaches a message to the end of the message chain */
  61 void _message_put(struct lcr_msg *message, const char *file, int line)
  62 {
  63         if (message->id_to == 0) {
  64                 PDEBUG(DEBUG_MSG, "message %s not written, because destination is 0.\n", messages_txt[message->type]);
  65                 message_free(message);
  66                 return;
  67         }
  68
  69         if ((options.deb & DEBUG_MSG))
  70                 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);
  71
  72         *messagepointer_end = message;
  73         messagepointer_end = &(message->next);
  74         /* Nullify next pointer if recycled messages */
  75         *messagepointer_end=NULL;
  76
  77         /* trigger work */
  78         trigger_work(&message_work);
  79 }
  80
  81 struct lcr_msg *message_forward(int id_from, int id_to, int flow, union parameter *param)
  82 {
  83         struct lcr_msg *message;
  84
  85         /* get point to message */
  86         message = (struct lcr_msg *)((unsigned long)param - ((unsigned long)(&message->param) - (unsigned long)message));
  87
  88         /* protect, so forwarded messages are not freed after handling */
  89         message->keep = 1;
  90
  91         message->id_from = id_from;
  92         message->id_to = id_to;
  93         message->flow = flow;
  94         message_put(message);
  95
  96         return(message);
  97 }
  98
  99 /* detaches the first messages from the message chain */
 100 struct lcr_msg *message_get(void)
 101 {
 102         struct lcr_msg *message;
 103
 104         if (!message_first)
 105                 return(0);
 106
 107         message = message_first;
 108         message_first = message->next;
 109         if (!message_first)
 110                 messagepointer_end = &message_first;
 111
 112         message->keep = 0;
 113
 114         if ((options.deb & DEBUG_MSG))
 115                 PDEBUG(DEBUG_MSG, "message %s reading from %ld to %ld (memory %x)\n", messages_txt[message->type], message->id_from, message->id_to, message);
 116
 117         return(message);
 118 }
 119
 120 /* free a message */
 121 void message_free(struct lcr_msg *message)
 122 {
 123         if (message->keep)
 124                 return;
 125         FREE(message, sizeof(struct lcr_msg));
 126         mmemuse--;
 127 }
 128
 129
 130 static int work_message(struct lcr_work *work, void *instance, int index)
 131 {
 132         struct lcr_msg          *message;
 133         class Port              *port;
 134         class Endpoint          *epoint;
 135         class Join              *join;
 136
 137         while ((message = message_get())) {
 138                 switch(message->flow) {
 139                         case PORT_TO_EPOINT:
 140                         epoint = find_epoint_id(message->id_to);
 141                         if (epoint) {
 142                                 if (epoint->ep_app) {
 143                                         epoint->ep_app->ea_message_port(message->id_from, message->type, &message->param);
 144                                 } else {
 145                                         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);
 146                                 }
 147                         } else {
 148                                 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);
 149                         }
 150                         break;
 151
 152                         case EPOINT_TO_JOIN:
 153                         join = find_join_id(message->id_to);
 154                         if (join) {
 155                                 join->message_epoint(message->id_from, message->type, &message->param);
 156                         } else {
 157                                 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);
 158                         }
 159                         break;
 160
 161                         case JOIN_TO_EPOINT:
 162                         epoint = find_epoint_id(message->id_to);
 163                         if (epoint) {
 164                                 if (epoint->ep_app) {
 165                                         epoint->ep_app->ea_message_join(message->id_from, message->type, &message->param);
 166                                 } else {
 167                                         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);
 168                                 }
 169                         } else {
 170                                 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);
 171                         }
 172                         break;
 173
 174                         case EPOINT_TO_PORT:
 175                         port = find_port_id(message->id_to);
 176                         if (port) {
 177                                 port->message_epoint(message->id_from, message->type, &message->param);
 178 BUDETECT
 179                         } else {
 180                                 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);
 181                         }
 182                         break;
 183
 184                         default:
 185                         PERROR("Message flow %d unknown.\n", message->flow);
 186                 }
 187                 message_free(message);
 188         }
 189
 190         return 0;
 191 }
 192