struct lcr_gsm *gsm_bs = NULL;
+// use holdMPTY to transfer call
+#define TRANSFER_HACK
+
#define PAYLOAD_TYPE_GSM 3
/*
}
end_trace();
+ SCPY(p_g_imsi, mncc->imsi);
+
new_state(PORT_STATE_OUT_PROCEEDING);
- /* get list of offered payload types
- * if list ist empty, the FR V1 is selected */
+ /* get list of offered payload types */
select_payload_type(mncc, payload_types, media_types, &payloads, sizeof(payload_types));
- /* if no given payload type is supported, we select from channel type */
+ /* if no given payload type is supported, we must release */
if (!payloads) {
- switch (mncc->lchan_type) {
- case GSM_LCHAN_TCH_F:
- media_types[0] = MEDIA_TYPE_GSM;
- payload_types[0] = PAYLOAD_TYPE_GSM;
- payloads = 1;
- break;
- case GSM_LCHAN_TCH_H:
- media_types[0] = MEDIA_TYPE_GSM_HR;
- payload_types[0] = 96; /* dynamic */
- payloads = 1;
- break;
- default:
- mncc = create_mncc(MNCC_REL_REQ, callref);
- gsm_trace_header(p_interface_name, this, MNCC_REL_REQ, DIRECTION_OUT);
- mncc->fields |= MNCC_F_CAUSE;
- mncc->cause.coding = 3;
- mncc->cause.location = 1;
- mncc->cause.value = 65;
- add_trace("cause", "coding", "%d", mncc->cause.coding);
- add_trace("cause", "location", "%d", mncc->cause.location);
- add_trace("cause", "value", "%d", mncc->cause.value);
- add_trace("reason", NULL, "Given lchan not supported");
- end_trace();
- send_and_free_mncc(p_g_lcr_gsm, mncc->msg_type, mncc);
- new_state(PORT_STATE_RELEASE);
- trigger_work(&p_g_delete);
- return;
- }
+ mncc = create_mncc(MNCC_REL_REQ, callref);
+ gsm_trace_header(p_interface_name, this, MNCC_REL_REQ, DIRECTION_OUT);
+ mncc->fields |= MNCC_F_CAUSE;
+ mncc->cause.coding = 3;
+ mncc->cause.location = 1;
+ mncc->cause.value = 65;
+ add_trace("cause", "coding", "%d", mncc->cause.coding);
+ add_trace("cause", "location", "%d", mncc->cause.location);
+ add_trace("cause", "value", "%d", mncc->cause.value);
+ add_trace("reason", NULL, "Given lchan not supported");
+ end_trace();
+ send_and_free_mncc(p_g_lcr_gsm, mncc->msg_type, mncc);
+ new_state(PORT_STATE_RELEASE);
+ trigger_work(&p_g_delete);
+ return;
}
/* select first payload type that matches the rtp list */
message->param.notifyinfo.local = 1; /* call is held by supplementary service */
message_put(message);
+ p_hold = 1;
+
/* acknowledge hold */
gsm_trace_header(p_interface_name, this, MNCC_HOLD_CNF, DIRECTION_OUT);
end_trace();
message->param.notifyinfo.local = 1; /* call is retrieved by supplementary service */
message_put(message);
+ p_hold = 0;
+
/* acknowledge retr */
gsm_trace_header(p_interface_name, this, MNCC_RETRIEVE_CNF, DIRECTION_OUT);
end_trace();
{
int media_type;
unsigned char payload_type;
- int half;
void *encoder, *decoder;
*payloads = 0;
add_trace("bearer", "capa", "given by MS");
for (i = 0; mncc->bearer_cap.speech_ver[i] >= 0; i++) {
- half = 0;
/* select payload type we support */
switch (mncc->bearer_cap.speech_ver[i]) {
case 0:
payload_type = dynamic_type++;
encoder = p_g_hr_encoder;
decoder = p_g_hr_decoder;
- half = 1;
break;
case 5:
add_trace("speech", "version", "AMR Half Rate given");
payload_type = dynamic_type++;
encoder = p_g_amr_encoder;
decoder = p_g_amr_decoder;
- half = 1;
break;
default:
add_trace("speech", "version", "%d given", mncc->bearer_cap.speech_ver[i]);
add_trace("speech", "ignored", "Not supported by LCR");
continue;
}
- if (!half && mncc->lchan_type != GSM_LCHAN_TCH_F) {
- add_trace("speech", "ignored", "Not TCH/F");
- continue;
- }
- if (half && mncc->lchan_type != GSM_LCHAN_TCH_H) {
- add_trace("speech", "ignored", "Not TCH/H");
- continue;
- }
if (!p_g_rtp_bridge) {
if (!encoder || !decoder) {
add_trace("speech", "ignored", "Codec not supported");
end_trace();
}
+void gsm_trace_facility(unsigned char *fac_ie, unsigned char fac_len)
+{
+ char debug[GSM_MAX_FACILITY * 3 + 1];
+ int i;
+
+ i = 0;
+ while(i < fac_len) {
+ UPRINT(debug+(i*3), " %02x", fac_ie[i]);
+ i++;
+ }
+ debug[i*3] = '\0';
+ add_trace("facility", NULL, "%s", debug[0]?debug+1:"<none>");
+}
+
+/* encode facility IE */
+void Pgsm_bs::enc_ie_facility(struct gsm_mncc *mncc, int operation_code, int error_code, unsigned char invoke_id)
+{
+ unsigned char *fac_ie, fac_len;
+
+ fac_ie = (unsigned char *)mncc->facility.info;
+
+ mncc->fields |= MNCC_F_FACILITY;
+ if (operation_code >= 0) {
+ fac_len = 8;
+ fac_ie[0] = 0xa2;
+ fac_ie[1] = 6;
+ fac_ie[2] = 0x02; /* invoke ID */
+ fac_ie[3] = 1;
+ fac_ie[4] = invoke_id;
+ fac_ie[5] = 0x02; /* Operation Code */
+ fac_ie[6] = 1;
+ fac_ie[7] = 124; /* buildMPTY */
+ fac_ie[7] = operation_code;
+ }
+ if (error_code >= 0) {
+ fac_len = 8;
+ fac_ie[0] = 0xa3;
+ fac_ie[1] = 6;
+ fac_ie[2] = 0x02; /* invoke ID */
+ fac_ie[3] = 1;
+ fac_ie[4] = invoke_id;
+ fac_ie[5] = 0x02; /* Error Code */
+ fac_ie[6] = 1;
+ fac_ie[7] = error_code;
+ }
+ mncc->facility.len = fac_len;
+}
+
+/* send facility request */
+void Pgsm_bs::facility_req(int operation_code, int error_code, unsigned char invoke_id)
+{
+ struct gsm_mncc *mncc;
+
+ gsm_trace_header(p_interface_name, this, MNCC_FACILITY_REQ, DIRECTION_OUT);
+ mncc = create_mncc(MNCC_FACILITY_REQ, p_g_callref);
+
+ enc_ie_facility(mncc, operation_code, error_code, invoke_id);
+
+ gsm_trace_facility((unsigned char *)mncc->facility.info, mncc->facility.len);
+ end_trace();
+ send_and_free_mncc(p_g_lcr_gsm, mncc->msg_type, mncc);
+}
+
+/* FACILITY INDICATION */
+void Pgsm_bs::facility_ind(unsigned int msg_type, unsigned int callref, struct gsm_mncc *mncc)
+{
+ unsigned char *fac_ie, fac_len;
+ unsigned char comp_type, comp_len, *comp_val;
+ unsigned char invoke = 0, invoke_id = 0;
+ unsigned char operation = 0, operation_code = 0;
+ struct lcr_msg *message;
+ int i;
+
+ if (mncc->fields & MNCC_F_FACILITY) {
+ fac_ie = (unsigned char *)mncc->facility.info;
+ fac_len = mncc->facility.len;
+
+ gsm_trace_header(p_interface_name, this, msg_type, DIRECTION_IN);
+ gsm_trace_facility(fac_ie, fac_len);
+ end_trace();
+ } else
+ return;
+
+ /* facility */
+ if (fac_len<=2)
+ return;
+ /* component tag */
+ if (fac_ie[1] > fac_len - 2) {
+ PDEBUG(DEBUG_GSM, "Component Tag in facility message greater than message length\n");
+ return;
+ }
+ comp_type = fac_ie[0];
+ comp_len = fac_ie[1];
+ comp_val = fac_ie + 2;
+ PDEBUG(DEBUG_GSM, "Component Tag type 0x%02x\n", comp_type);
+ /* tags inside component */
+ for (i = 0; i != comp_len;) {
+ if (comp_val[1 + i] > comp_len - i - 2) {
+ PDEBUG(DEBUG_GSM, "Tag inside Component TAG greater than Component length\n");
+ break;
+ }
+ PDEBUG(DEBUG_GSM, "Tag inside Component Tag (type 0x%02x)\n", comp_val[0 + i]);
+ if (comp_val[0 + i] == 0x02 && ! invoke) { /* Invoke ID Tag */
+ if (comp_val[1 + i] != 1) {
+ PDEBUG(DEBUG_GSM, "Invoke ID Tag has invalid length\n");
+ break;
+ }
+ invoke = 1;
+ invoke_id = comp_val[2 + i];
+ PDEBUG(DEBUG_GSM, "Invoke ID Tag inside Component TAG with ID=%d\n", invoke_id);
+ } else if (comp_val[0 + i] == 0x02 && !operation) { /* Operation Code Tag */
+ if (comp_val[1 + i] != 1) {
+ PDEBUG(DEBUG_GSM, "Operation Code Tag has invalid length\n");
+ break;
+ }
+ operation = 1;
+ operation_code = comp_val[2 + i];
+ PDEBUG(DEBUG_GSM, "Operation Code Tag inside Component TAG with Code=%d\n", operation_code);
+ } else
+ PDEBUG(DEBUG_GSM, "Unknown Tag (0x%02x) inside Component TAG, ignoring\n", comp_val[0 + i]);
+
+ i += comp_val[1 + i] + 2;
+ }
+
+ /* check component type */
+ switch (comp_type) {
+ case 0xa1: /* Invoke */
+ if (!invoke) {
+ PDEBUG(DEBUG_GSM, "error: Invoke without Invoke ID\n");
+ break;
+ }
+ if (!operation) {
+ PDEBUG(DEBUG_GSM, "error: Invoke without Operation Tag\n");
+ break;
+ }
+ switch(operation_code) {
+ case 124: /* buildMTPY */
+ message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_3PTY);
+ message->param.threepty.begin = 1;
+ message->param.threepty.invoke = 1;
+ message->param.threepty.invoke_id = invoke_id;
+ message_put(message);
+ return;
+
+ case 121: /* splitMTPY */
+ message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_3PTY);
+ message->param.threepty.end = 1;
+ message->param.threepty.invoke = 1;
+ message->param.threepty.invoke_id = invoke_id;
+ message_put(message);
+ return;
+
+ case 122: /* holdMTPY */
+#ifdef TRANSFER_HACK
+ facility_req(-1, 122, invoke_id); /* rejected by network */
+
+ message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_TRANSFER);
+ message->param.transfer.invoke = 1;
+ message->param.transfer.invoke_id = invoke_id;
+ message_put(message);
+#else
+ message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_3PTY);
+ message->param.threepty.hold = 1;
+ message->param.threepty.invoke = 1;
+ message->param.threepty.invoke_id = invoke_id;
+ message_put(message);
+#endif
+ return;
+
+ case 123: /* retrieveMTPY */
+#ifdef TRANSFER_HACK
+ facility_req(-1, 122, invoke_id); /* rejected by network */
+
+ message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_TRANSFER);
+ message->param.transfer.invoke = 1;
+ message->param.transfer.invoke_id = invoke_id;
+ message_put(message);
+#else
+ message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_3PTY);
+ message->param.threepty.retrieve = 1;
+ message->param.threepty.invoke = 1;
+ message->param.threepty.invoke_id = invoke_id;
+ message_put(message);
+#endif
+ return;
+
+ case 126: /* explicitCT */
+ message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_TRANSFER);
+ message->param.transfer.invoke = 1;
+ message->param.transfer.invoke_id = invoke_id;
+ message_put(message);
+ return;
+ default:
+ PDEBUG(DEBUG_GSM, "error: Unsupported Operation\n");
+ facility_req(-1, 122, invoke_id); /* rejected by network */
+ return;
+ }
+ break;
+ }
+}
+
+
+/* MESSAGE_3PTY */
+void Pgsm_bs::message_3pty(unsigned int epoint_id, int message_id, union parameter *param)
+{
+ if (param->threepty.result) {
+ if (param->threepty.begin)
+ facility_req(124, -1, param->threepty.invoke_id); /* buildMPTY */
+ if (param->threepty.end)
+ facility_req(121, -1, param->threepty.invoke_id); /* splitMPTY */
+ }
+ if (param->threepty.error) {
+ facility_req(-1, 122, param->threepty.invoke_id); /* rejected by network */
+ }
+}
+
+void Pgsm_bs::enc_ie_facility_ect(struct gsm_mncc *mncc, struct param_transfer *transfer)
+{
+ if (transfer->result) {
+ enc_ie_facility(mncc, 126, -1, transfer->invoke_id); /* explicitCT */
+ }
+ if (transfer->error) {
+ enc_ie_facility(mncc, -1, 122, transfer->invoke_id); /* rejected by network */
+ }
+}
+
+/* MESSAGE_TRANSFER */
+void Pgsm_bs::message_transfer(unsigned int epoint_id, int message_id, union parameter *param)
+{
+#ifdef TRANSFER_HACK
+ struct gsm_mncc *mncc;
+
+ /* sending facility */
+ gsm_trace_header(p_interface_name, this, MNCC_FACILITY_REQ, DIRECTION_OUT);
+ mncc = create_mncc(MNCC_FACILITY_REQ, p_g_callref);
+ enc_ie_facility_ect(mncc, ¶m->transfer);
+ gsm_trace_facility((unsigned char *)mncc->facility.info, mncc->facility.len);
+ end_trace();
+ send_and_free_mncc(p_g_lcr_gsm, mncc->msg_type, mncc);
+#endif
+}
+
/*
* handles all indications
*/
p_g_callref = callref;
end_trace();
+ SCPY(p_g_imsi, mncc->imsi);
+
/* caller info */
if (mncc->clir.inv)
p_callerinfo.present = INFO_PRESENT_RESTRICTED;
p_capainfo.source_mode = B_MODE_TRANSPARENT;
p_g_mode = p_capainfo.source_mode;
- /* get list of offered payload types
- * if list ist empty, the FR V1 is selected */
+ /* get list of offered payload types */
select_payload_type(mncc, payload_types, media_types, &payloads, sizeof(payload_types));
- /* if no given payload type is supported, we select from channel type */
+ /* if no given payload type is supported, we must release */
if (!payloads) {
- switch (mncc->lchan_type) {
- case GSM_LCHAN_TCH_F:
- media_types[0] = MEDIA_TYPE_GSM;
- payload_types[0] = PAYLOAD_TYPE_GSM;
- payloads = 1;
- break;
- case GSM_LCHAN_TCH_H:
- media_types[0] = MEDIA_TYPE_GSM_HR;
- payload_types[0] = 96; /* dynamic */
- payloads = 1;
- break;
- default:
- mncc = create_mncc(MNCC_REJ_REQ, callref);
- 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;
- mncc->cause.value = 65;
- add_trace("cause", "coding", "%d", mncc->cause.coding);
- add_trace("cause", "location", "%d", mncc->cause.location);
- add_trace("cause", "value", "%d", mncc->cause.value);
- add_trace("reason", NULL, "Given lchan not supported");
- end_trace();
- send_and_free_mncc(p_g_lcr_gsm, mncc->msg_type, mncc);
- new_state(PORT_STATE_RELEASE);
- trigger_work(&p_g_delete);
- return;
- }
+ mncc = create_mncc(MNCC_REJ_REQ, callref);
+ 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;
+ mncc->cause.value = 65;
+ add_trace("cause", "coding", "%d", mncc->cause.coding);
+ add_trace("cause", "location", "%d", mncc->cause.location);
+ add_trace("cause", "value", "%d", mncc->cause.value);
+ add_trace("reason", NULL, "Given lchan not supported");
+ end_trace();
+ send_and_free_mncc(p_g_lcr_gsm, mncc->msg_type, mncc);
+ new_state(PORT_STATE_RELEASE);
+ trigger_work(&p_g_delete);
+ return;
}
#if 0
/* if no given payload type is supported, we reject the call */
pgsm_bs->retr_ind(msg_type, callref, mncc);
break;
+ case MNCC_FACILITY_IND:
+ pgsm_bs->facility_ind(msg_type, callref, mncc);
+ break;
+
default:
PDEBUG(DEBUG_GSM, "Pgsm_bs(%s) gsm port with (caller id %s) received unhandled nessage: 0x%x\n", pgsm_bs->p_name, pgsm_bs->p_callerinfo.id, msg_type);
}
struct lcr_msg *message;
struct epoint_list *epointlist;
struct gsm_mncc *mncc;
+ struct interface *interface;
+ int page_with_tchh = 0;
+
+ interface = getinterfacebyname(p_interface_name);
+ if (!interface) {
+ PERROR("Cannot find interface %s.\n", p_interface_name);
+ return;
+ }
/* copy setup infos to port */
memcpy(&p_callerinfo, ¶m->setup.callerinfo, sizeof(p_callerinfo));
gsm_trace_header(p_interface_name, this, 1 /* codec negotioation */, DIRECTION_NONE);
for (i = 0; i < param->setup.rtpinfo.payloads; i++) {
switch (param->setup.rtpinfo.media_types[i]) {
- case MEDIA_TYPE_GSM:
- case MEDIA_TYPE_GSM_EFR:
case MEDIA_TYPE_AMR:
case MEDIA_TYPE_GSM_HR:
+ /* because offered codecs are compatible with half rate, we can page with tchh */
+ page_with_tchh = 1;
+ // Fall through!
+ case MEDIA_TYPE_GSM:
+ case MEDIA_TYPE_GSM_EFR:
add_trace("rtp", "payload", "%s:%d supported", media_type2name(param->setup.rtpinfo.media_types[i]), param->setup.rtpinfo.payload_types[i]);
if (p_g_rtp_payloads < (int)sizeof(p_g_rtp_payload_types)) {
p_g_rtp_media_types[p_g_rtp_payloads] = param->setup.rtpinfo.media_types[i];
trigger_work(&p_g_delete);
return;
}
+ } else {
+ /* since we support half rate compatible codecss, we can page with tchh */
+ if (p_g_hr_encoder || p_g_amr_encoder)
+ page_with_tchh = 1;
}
// SCPY(&p_m_tones_dir, param->setup.ext.tones_dir);
add_trace("redir", "number", "%s", mncc->redirecting.number);
}
+ /* if we support any half rate codec we page the mobile with TCH/H
+ * support indication. the mobile will reply paging with a channel
+ * request that indicates half rate support. if no SDCCH and TCH/F
+ * channel is available, BSC can assign a TCH/H channel, because it
+ * knows that the phone supports it. */
+ if (page_with_tchh) {
+ add_trace("lchan", "type", "TCH/H or TCH/F");
+ mncc->lchan_type = GSM_LCHAN_TCH_H;
+ } else {
+ add_trace("lchan", "type", "TCH/F");
+ mncc->lchan_type = GSM_LCHAN_TCH_F;
+ }
+
end_trace();
send_and_free_mncc(p_g_lcr_gsm, mncc->msg_type, mncc);
message_setup(epoint_id, message_id, param);
break;
+ case MESSAGE_3PTY:
+ message_3pty(epoint_id, message_id, param);
+ break;
+
+ case MESSAGE_TRANSFER:
+ message_transfer(epoint_id, message_id, param);
+ break;
+
default:
PDEBUG(DEBUG_GSM, "Pgsm_bs(%s) gsm port with (caller id %s) received unhandled nessage: %d\n", p_name, p_callerinfo.id, message_id);
}