X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=gsm_ms.cpp;h=b3eabc4292217074558c2465a3024c926df570b9;hp=ae99930b9a75ae88ecb1c8591ccc08c31abcefc8;hb=7f0d14c706328e1ff74fe8b8c16ae54407cc8055;hpb=74a7fe54a81bb7e996ea45203bbc8cc0ff6b8dda

diff --git a/gsm_ms.cpp b/gsm_ms.cpp
index ae99930..b3eabc4 100644
--- a/gsm_ms.cpp
+++ b/gsm_ms.cpp
@@ -23,6 +23,8 @@ static int dtmf_timeout(struct lcr_timer *timer, void *instance, int index);
 #define DTMF_ST_STOP		3	/* DTMF stopped, waiting for resp. */
 #define DTMF_ST_SPACE		4	/* wait space between tones */
 
+#define RTP_PT_GSM_FULL		3
+
 /*
  * constructor
  */
@@ -67,28 +69,24 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_
 {
 	class Endpoint *epoint;
 	struct lcr_msg *message;
-	struct gsm_mncc *mode, *proceeding, *frame;
-	struct interface *interface = interface_first;
+	struct gsm_mncc *proceeding, *frame;
+	struct interface *interface;
 
-	while (interface) {
-		if (!strcmp(interface->name, p_g_interface_name))
-			break;
-		interface = interface->next;
-	}
+	interface = getinterfacebyname(p_interface_name);
 	if (!interface) {
-		PERROR("Cannot find interface %s.\n", p_g_interface_name);
+		PERROR("Cannot find interface %s.\n", p_interface_name);
 		return;
 	}
 
 	/* process given callref */
-	gsm_trace_header(p_g_interface_name, this, 0, DIRECTION_IN);
+	gsm_trace_header(p_interface_name, this, 0, DIRECTION_IN);
 	add_trace("callref", "new", "0x%x", callref);
 	if (p_g_callref) {
 		/* release in case the ID is already in use */
 		add_trace("error", NULL, "callref already in use");
 		end_trace();
 		mncc = create_mncc(MNCC_REJ_REQ, callref);
-		gsm_trace_header(p_g_interface_name, this, MNCC_REJ_REQ, DIRECTION_OUT);
+		gsm_trace_header(p_interface_name, this, MNCC_REJ_REQ, DIRECTION_OUT);
 		mncc->fields |= MNCC_F_CAUSE;
 		mncc->cause.coding = 3;
 		mncc->cause.location = 1;
@@ -106,7 +104,7 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_
 	p_g_callref = callref;
 	end_trace();
 
-	gsm_trace_header(p_g_interface_name, this, MNCC_SETUP_IND, DIRECTION_IN);
+	gsm_trace_header(p_interface_name, this, MNCC_SETUP_IND, DIRECTION_IN);
 	/* caller information */
 	p_callerinfo.ntype = INFO_NTYPE_NOTPRESENT;
 	if (mncc->fields & MNCC_F_CALLING) {
@@ -159,7 +157,7 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_
 		add_trace("calling", "screen", "%d", mncc->calling.screen);
 		add_trace("calling", "number", "%s", mncc->calling.number);
 	}
-	SCPY(p_callerinfo.interface, p_g_interface_name);
+	SCPY(p_callerinfo.interface, p_interface_name);
 	/* dialing information */
 	if (mncc->fields & MNCC_F_CALLED) {
 		SCAT(p_dialinginfo.id, mncc->called.number);
@@ -279,18 +277,22 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_
 	epointlist_new(epoint->ep_serial);
 
 	/* modify lchan to GSM codec V1 */
-	gsm_trace_header(p_g_interface_name, this, MNCC_LCHAN_MODIFY, DIRECTION_OUT);
-	mode = create_mncc(MNCC_LCHAN_MODIFY, p_g_callref);
-	mode->lchan_mode = 0x01; /* GSM V1 */
-	mode->lchan_type = 0x02;
-	add_trace("mode", NULL, "0x%02x", mode->lchan_mode);
-	end_trace();
-	send_and_free_mncc(p_g_lcr_gsm, mode->msg_type, mode);
+	modify_lchan(RTP_PT_GSM_FULL);
 
 	/* send call proceeding */
-	gsm_trace_header(p_g_interface_name, this, MNCC_CALL_CONF_REQ, DIRECTION_OUT);
+	gsm_trace_header(p_interface_name, this, MNCC_CALL_CONF_REQ, DIRECTION_OUT);
 	proceeding = create_mncc(MNCC_CALL_CONF_REQ, p_g_callref);
-	// FIXME: bearer
+	/* bearer capability (mandatory, if not present in setup message) */
+	if (!(mncc->fields & MNCC_F_BEARER_CAP)) {
+		proceeding->fields |= MNCC_F_BEARER_CAP;
+		proceeding->bearer_cap.coding = 0;
+		proceeding->bearer_cap.radio = 1;
+		proceeding->bearer_cap.speech_ctm = 0;
+		proceeding->bearer_cap.speech_ver[0] = 0;
+		proceeding->bearer_cap.speech_ver[1] = -1; /* end of list */
+		proceeding->bearer_cap.transfer = 0;
+		proceeding->bearer_cap.mode = 0;
+	}
 	/* DTMF supported */
 	proceeding->fields |= MNCC_F_CCCAP;
 	proceeding->cccap.dtmf = 1;
@@ -300,7 +302,7 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_
 	new_state(PORT_STATE_IN_PROCEEDING);
 
 	if (p_g_tones && !p_g_tch_connected) { /* only if ... */
-		gsm_trace_header(p_g_interface_name, this, MNCC_FRAME_RECV, DIRECTION_OUT);
+		gsm_trace_header(p_interface_name, this, MNCC_FRAME_RECV, DIRECTION_OUT);
 		end_trace();
 		frame = create_mncc(MNCC_FRAME_RECV, p_g_callref);
 		send_and_free_mncc(p_g_lcr_gsm, frame->msg_type, frame);
@@ -325,7 +327,6 @@ void Pgsm_ms::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_
  */
 int message_ms(struct lcr_gsm *gsm_ms, int msg_type, void *arg)
 {
-	struct interface *interface = gsm_ms->interface;
 	struct gsm_mncc *mncc = (struct gsm_mncc *)arg;
 	unsigned int callref = mncc->callref;
 	class Port *port;
@@ -350,24 +351,21 @@ int message_ms(struct lcr_gsm *gsm_ms, int msg_type, void *arg)
 		port = port->next;
 	}
 
-	if (msg_type == GSM_TCHF_FRAME) {
+	if (msg_type == GSM_TCHF_FRAME
+	 || msg_type == GSM_BAD_FRAME) {
 		if (port)
 			pgsm_ms->frame_receive(arg);
 		return 0;
 	}
 
 	if (!port) {
+		struct interface *interface;
+
 		if (msg_type != MNCC_SETUP_IND)
 			return(0);
-#if 0
-		/* find gsm ms port */
-		mISDNport = mISDNport_first;
-		while(mISDNport) {
-			if (mISDNport->gsm_ms && !strcmp(mISDNport->ifport->gsm_ms_name, gsm_ms->name))
-				break;
-			mISDNport = mISDNport->next;
-		}
-		if (!mISDNport) {
+
+		interface = getinterfacebyname(gsm_ms->interface_name);
+		if (!interface) {
 			struct gsm_mncc *rej;
 
 			rej = create_mncc(MNCC_REJ_REQ, callref);
@@ -379,11 +377,11 @@ int message_ms(struct lcr_gsm *gsm_ms, int msg_type, void *arg)
 			add_trace("cause", "coding", "%d", rej->cause.coding);
 			add_trace("cause", "location", "%d", rej->cause.location);
 			add_trace("cause", "value", "%d", rej->cause.value);
+			add_trace("reason", NULL, "interface %s not found", gsm_ms->interface_name);
 			end_trace();
 			send_and_free_mncc(gsm_ms, rej->msg_type, rej);
 			return 0;
 		}
-#endif
 		/* creating port object, transparent until setup with hdlc */
 		SPRINT(name, "%s-%d-in", interface->name, 0);
 		if (!(pgsm_ms = new Pgsm_ms(PORT_TYPE_GSM_MS_IN, name, NULL, interface)))
@@ -452,7 +450,7 @@ void Pgsm_ms::message_setup(unsigned int epoint_id, int message_id, union parame
 
 	/* no instance */
 	if (!p_g_lcr_gsm || p_g_lcr_gsm->mncc_lfd.fd < 0) {
-		gsm_trace_header(p_g_interface_name, this, MNCC_SETUP_REQ, DIRECTION_OUT);
+		gsm_trace_header(p_interface_name, this, MNCC_SETUP_REQ, DIRECTION_OUT);
 		add_trace("failure", NULL, "MS %s instance is unavailable", p_g_ms_name);
 		end_trace();
 		message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE);
@@ -466,7 +464,7 @@ void Pgsm_ms::message_setup(unsigned int epoint_id, int message_id, union parame
 	
 	/* no number */
 	if (!p_dialinginfo.id[0]) {
-		gsm_trace_header(p_g_interface_name, this, MNCC_SETUP_REQ, DIRECTION_OUT);
+		gsm_trace_header(p_interface_name, this, MNCC_SETUP_REQ, DIRECTION_OUT);
 		add_trace("failure", NULL, "No dialed subscriber given.");
 		end_trace();
 		message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE);
@@ -489,12 +487,12 @@ void Pgsm_ms::message_setup(unsigned int epoint_id, int message_id, union parame
 		epointlist_new(epoint_id);
 
 	/* creating l3id */
-	gsm_trace_header(p_g_interface_name, this, 0, DIRECTION_OUT);
+	gsm_trace_header(p_interface_name, this, 0, DIRECTION_OUT);
 	p_g_callref = new_callref++;
 	add_trace("callref", "new", "0x%x", p_g_callref);
 	end_trace();
 
-	gsm_trace_header(p_g_interface_name, this, MNCC_SETUP_REQ, DIRECTION_OUT);
+	gsm_trace_header(p_interface_name, this, MNCC_SETUP_REQ, DIRECTION_OUT);
 	mncc = create_mncc(MNCC_SETUP_REQ, p_g_callref);
 	if (!strncasecmp(p_dialinginfo.id, "emerg", 5)) {
 		mncc->emergency = 1;
@@ -576,7 +574,7 @@ void Pgsm_ms::dtmf_statemachine(struct gsm_mncc *mncc)
 			p_g_dtmf_state = DTMF_ST_IDLE;
 			return;
 		}
-		gsm_trace_header(p_g_interface_name, this, MNCC_START_DTMF_REQ, DIRECTION_OUT);
+		gsm_trace_header(p_interface_name, this, MNCC_START_DTMF_REQ, DIRECTION_OUT);
 		dtmf = create_mncc(MNCC_START_DTMF_REQ, p_g_callref);
 		dtmf->keypad = p_g_dtmf[p_g_dtmf_index++];
 		p_g_dtmf_state = DTMF_ST_START;
@@ -595,7 +593,7 @@ void Pgsm_ms::dtmf_statemachine(struct gsm_mncc *mncc)
 		PDEBUG(DEBUG_GSM, "DTMF is on\n");
 		break;
 	case DTMF_ST_MARK:
-		gsm_trace_header(p_g_interface_name, this, MNCC_STOP_DTMF_REQ, DIRECTION_OUT);
+		gsm_trace_header(p_interface_name, this, MNCC_STOP_DTMF_REQ, DIRECTION_OUT);
 		dtmf = create_mncc(MNCC_STOP_DTMF_REQ, p_g_callref);
 		p_g_dtmf_state = DTMF_ST_STOP;
 		end_trace();
@@ -730,7 +728,7 @@ int gsm_ms_new(struct interface *interface)
 	/* create gsm instance */
 	gsm_ms = (struct lcr_gsm *)MALLOC(sizeof(struct lcr_gsm));
 
-	gsm_ms->interface = interface;
+	SCPY(gsm_ms->interface_name, interface->name);
 	gsm_ms->type = LCR_GSM_TYPE_MS;
 	SCPY(gsm_ms->name, interface->gsm_ms_name);
 	gsm_ms->sun.sun_family = AF_UNIX;