+static int work_message(struct lcr_work *work, void *instance, int index)
+{
+ struct lcr_msg *message;
+ class Port *port;
+ class Endpoint *epoint;
+ class Join *join;
+
+ while ((message = message_get())) {
+ switch(message->flow) {
+ case PORT_TO_EPOINT:
+ epoint = find_epoint_id(message->id_to);
+ if (epoint) {
+ if (epoint->ep_app) {
+ epoint->ep_app->ea_message_port(message->id_from, message->type, &message->param);
+ } else {
+ 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);
+ }
+ } else {
+ 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);
+ }
+ break;
+
+ case EPOINT_TO_JOIN:
+ join = find_join_id(message->id_to);
+ if (join) {
+ join->message_epoint(message->id_from, message->type, &message->param);
+ } else {
+ 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);
+ }
+ break;
+
+ case JOIN_TO_EPOINT:
+ epoint = find_epoint_id(message->id_to);
+ if (epoint) {
+ if (epoint->ep_app) {
+ epoint->ep_app->ea_message_join(message->id_from, message->type, &message->param);
+ } else {
+ 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);
+ }
+ } else {
+ 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);
+ }
+ break;
+
+ case EPOINT_TO_PORT:
+ port = find_port_id(message->id_to);
+ if (port) {
+ port->message_epoint(message->id_from, message->type, &message->param);
+BUDETECT
+ } else {
+ 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);
+ }
+ break;
+
+ default:
+ PERROR("Message flow %d unknown.\n", message->flow);
+ }
+ message_free(message);
+ }
+
+ return 0;
+}
+