X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=asterisk_client.c;fp=asterisk_client.c;h=f15564b7ae24d5af0862aba98026b97490561569;hp=13ab261f0d1feff3fc37844cedb1ad70a8907103;hb=6552bc36271c4926a8ac5615f4f84f7391034732;hpb=b88911b990a009db4ed8956fd8a0a0ed1fef8f9f

diff --git a/asterisk_client.c b/asterisk_client.c
index 13ab261..f15564b 100644
--- a/asterisk_client.c
+++ b/asterisk_client.c
@@ -25,7 +25,7 @@ Make a MESSAGE_SETUP or receive a MESSAGE_SETUP with the reference.
 To release call and reference, send or receive MESSAGE_RELEASE.
 From that point on, the ref is not valid, so no other message may be sent
 with that reference.
-   
+
 */
 
 #include <stdio.h>
@@ -44,6 +44,7 @@ with that reference.
 #include "extension.h"
 #include "message.h"
 #include "admin.h"
+#include "aserisk_client.h"
 
 int sock;
 
@@ -55,7 +56,7 @@ struct admin_list {
 /*
  * enque message from asterisk
  */
-int admin_asterisk(int message_type, union parameter *param)
+int send_message(int message_type, unsigned long ref, union parameter *param)
 {
 	struct admin_list *admin, **adminp;
 
@@ -66,11 +67,81 @@ int admin_asterisk(int message_type, union parameter *param)
 	*adminp = admin;
 
 	admin->msg.type = message_type;
+	admin->msg.ref = ref;
 	memcpy(&admin->msg.param, param, sizeof(union parameter));
 
 	return(0);
 }
 
+/*
+ * message received from LCR
+ */
+int receive_message(int message_type, unsigned long ref, union parameter *param)
+{
+	union parameter newparam;
+
+	memset(&newparam, 0, sizeof(union parameter));
+
+	/* handle bchannel message*/
+	if (message_type == MESSAGE_BCHANNEL)
+	{
+		switch(param.bchannel.type)
+		{
+			case BCHANNEL_ASSIGN:
+			if (find_channel_addr(param->bchannel.addr))
+			{
+				fprintf(stderr, "error: bchannel addr %x already assigned.\n", param->bchannel.addr);
+				return(-1);
+			}
+			/* create channel */
+			channel = alloc_channel();
+			channel.addr = param->bchannel.addr;
+			/* in case, ref is not set, this channel instance must
+			 * be created until it is removed again by LCR */
+			channel.ref = param->bchannel.ref;
+			/* link to call */
+			if ((call = find_call_ref(param->bchannel.ref)))
+			{
+				call.addr = param->bchannel.addr;
+			}
+
+#warning open stack
+			/* acknowledge */
+			newparam.bchannel.type = BCHANNEL_ASSIGN_ACK;
+			newparam.bchannel.addr = param->bchannel.addr;
+			send_message(MESSAGE_BCHANNEL, 0, &newparam);
+			break;
+
+			case BCHANNEL_REMOVE:
+			if (!(channel = find_channel_addr(param->bchannel.addr)))
+			{
+				fprintf(stderr, "error: bchannel addr %x already assigned.\n", param->bchannel.addr);
+				return(-1);
+			}
+			/* unlink from call */
+			if ((call = find_call_ref(channel->ref)))
+			{
+				call.addr = 0;
+			}
+			/* remove channel */
+			free_channel(channel);
+#warning close stack
+			/* acknowledge */
+			newparam.bchannel.type = BCHANNEL_REMOVE_ACK;
+			newparam.bchannel.addr = param->bchannel.addr;
+			send_message(MESSAGE_BCHANNEL, 0, &newparam);
+			
+			break;
+
+			default:
+			fprintf(stderr, "received unknown bchannel message %d\n", param.bchannel.type);
+		}
+		return(0);
+	}
+	switch(message_type)
+	return(0);
+}
+
 
 /* asterisk handler
  * warning! not thread safe
@@ -102,6 +173,7 @@ int handle_socket(void)
 			fprintf(stderr, "Socket received illegal message %d\n", msg.message);
 			return(-1); // socket error
 		}
+		receive_message(msg.type, msg.ref, &msg.param);
 		printf("message received %d\n", msg.u.msg.type);
 		work = 1;
 	} else