2010-05-31 16:45:02 +00:00
|
|
|
/*****************************************************************************\
|
|
|
|
** **
|
|
|
|
** LCR **
|
|
|
|
** **
|
|
|
|
**---------------------------------------------------------------------------**
|
|
|
|
** Copyright: Andreas Eversberg **
|
|
|
|
** **
|
|
|
|
** mISDN gsm (BS mode) **
|
|
|
|
** **
|
|
|
|
\*****************************************************************************/
|
|
|
|
|
|
|
|
#include "main.h"
|
2010-10-30 15:21:54 +00:00
|
|
|
#include "config.h"
|
2010-05-31 16:45:02 +00:00
|
|
|
|
|
|
|
#ifndef _GNU_SOURCE
|
|
|
|
#define _GNU_SOURCE
|
|
|
|
#endif
|
|
|
|
extern "C" {
|
2010-12-22 18:35:28 +00:00
|
|
|
#include <assert.h>
|
2010-05-31 16:45:02 +00:00
|
|
|
#include <getopt.h>
|
|
|
|
|
2010-12-22 18:35:28 +00:00
|
|
|
#include <sys/socket.h>
|
|
|
|
#include <sys/un.h>
|
|
|
|
|
2010-05-31 16:45:02 +00:00
|
|
|
#include <openbsc/mncc.h>
|
|
|
|
#include <openbsc/trau_frame.h>
|
|
|
|
}
|
|
|
|
|
2010-12-23 15:46:54 +00:00
|
|
|
#define SOCKET_RETRY_TIMER 5
|
|
|
|
|
2011-02-20 09:35:40 +00:00
|
|
|
/*
|
|
|
|
* DTMF stuff
|
|
|
|
*/
|
|
|
|
unsigned char dtmf_samples[16][8000];
|
|
|
|
static int dtmf_x[4] = { 1209, 1336, 1477, 1633 };
|
|
|
|
static int dtmf_y[4] = { 697, 770, 852, 941 };
|
2010-05-31 16:45:02 +00:00
|
|
|
|
2011-02-20 09:35:40 +00:00
|
|
|
void generate_dtmf(void)
|
2010-05-31 16:45:02 +00:00
|
|
|
{
|
2011-02-20 09:35:40 +00:00
|
|
|
double fx, fy, sample;
|
|
|
|
int i, x, y;
|
|
|
|
unsigned char *law;
|
|
|
|
|
|
|
|
for (y = 0; y < 4; y++) {
|
|
|
|
fy = 2 * 3.1415927 * ((double)dtmf_y[y]) / 8000.0;
|
|
|
|
for (x = 0; x < 4; x++) {
|
|
|
|
fx = 2 * 3.1415927 * ((double)dtmf_x[x]) / 8000.0;
|
|
|
|
law = dtmf_samples[y << 2 | x];
|
|
|
|
for (i = 0; i < 8000; i++) {
|
|
|
|
sample = sin(fy * ((double)i)) * 0.251 * 32767.0; /* -6 dB */
|
|
|
|
sample += sin(fx * ((double)i)) * 0.158 * 32767.0; /* -8 dB */
|
|
|
|
*law++ = audio_s16_to_law[(int)sample & 0xffff];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2010-05-31 16:45:02 +00:00
|
|
|
}
|
|
|
|
|
2011-02-20 09:35:40 +00:00
|
|
|
|
2010-05-31 16:45:02 +00:00
|
|
|
/*
|
|
|
|
* constructor
|
|
|
|
*/
|
|
|
|
Pgsm_bs::Pgsm_bs(int type, struct mISDNport *mISDNport, char *portname, struct port_settings *settings, int channel, int exclusive, int mode) : Pgsm(type, mISDNport, portname, settings, channel, exclusive, mode)
|
|
|
|
{
|
|
|
|
p_m_g_instance = gsm->network;
|
2011-02-20 09:35:40 +00:00
|
|
|
p_m_g_dtmf = NULL;
|
|
|
|
p_m_g_dtmf_index = 0;
|
|
|
|
|
2010-05-31 16:45:02 +00:00
|
|
|
PDEBUG(DEBUG_GSM, "Created new GSMBSPort(%s).\n", portname);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* destructor
|
|
|
|
*/
|
|
|
|
Pgsm_bs::~Pgsm_bs()
|
|
|
|
{
|
|
|
|
PDEBUG(DEBUG_GSM, "Destroyed GSM BS process(%s).\n", p_name);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* DTMF INDICATION */
|
|
|
|
void Pgsm_bs::start_dtmf_ind(unsigned int msg_type, unsigned int callref, struct gsm_mncc *mncc)
|
|
|
|
{
|
2011-02-20 09:35:40 +00:00
|
|
|
// struct lcr_msg *message;
|
2010-05-31 16:45:02 +00:00
|
|
|
struct gsm_mncc *resp;
|
|
|
|
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, msg_type, DIRECTION_IN);
|
|
|
|
add_trace("keypad", NULL, "%c", mncc->keypad);
|
|
|
|
end_trace();
|
|
|
|
SPRINT(p_dialinginfo.id, "%c", mncc->keypad);
|
|
|
|
p_dialinginfo.ntype = INFO_NTYPE_UNKNOWN;
|
|
|
|
|
|
|
|
/* send resp */
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_START_DTMF_RSP, DIRECTION_OUT);
|
|
|
|
add_trace("keypad", NULL, "%c", mncc->keypad);
|
|
|
|
end_trace();
|
|
|
|
resp = create_mncc(MNCC_START_DTMF_RSP, p_m_g_callref);
|
2010-12-23 18:03:47 +00:00
|
|
|
resp->fields |= MNCC_F_KEYPAD;
|
2010-05-31 16:45:02 +00:00
|
|
|
resp->keypad = mncc->keypad;
|
|
|
|
send_and_free_mncc(p_m_g_instance, resp->msg_type, resp);
|
|
|
|
|
2011-02-20 09:35:40 +00:00
|
|
|
#if 0
|
2010-05-31 16:45:02 +00:00
|
|
|
/* send dialing information */
|
|
|
|
message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_INFORMATION);
|
|
|
|
memcpy(&message->param.information, &p_dialinginfo, sizeof(struct dialing_info));
|
|
|
|
message_put(message);
|
2011-02-20 09:35:40 +00:00
|
|
|
#endif
|
|
|
|
|
|
|
|
/* generate DTMF tones */
|
|
|
|
switch (mncc->keypad) {
|
|
|
|
case '1': p_m_g_dtmf = dtmf_samples[0]; break;
|
|
|
|
case '2': p_m_g_dtmf = dtmf_samples[1]; break;
|
|
|
|
case '3': p_m_g_dtmf = dtmf_samples[2]; break;
|
|
|
|
case 'a':
|
|
|
|
case 'A': p_m_g_dtmf = dtmf_samples[3]; break;
|
|
|
|
case '4': p_m_g_dtmf = dtmf_samples[4]; break;
|
|
|
|
case '5': p_m_g_dtmf = dtmf_samples[5]; break;
|
|
|
|
case '6': p_m_g_dtmf = dtmf_samples[6]; break;
|
|
|
|
case 'b':
|
|
|
|
case 'B': p_m_g_dtmf = dtmf_samples[7]; break;
|
|
|
|
case '7': p_m_g_dtmf = dtmf_samples[8]; break;
|
|
|
|
case '8': p_m_g_dtmf = dtmf_samples[9]; break;
|
|
|
|
case '9': p_m_g_dtmf = dtmf_samples[10]; break;
|
|
|
|
case 'c':
|
|
|
|
case 'C': p_m_g_dtmf = dtmf_samples[11]; break;
|
|
|
|
case '*': p_m_g_dtmf = dtmf_samples[12]; break;
|
|
|
|
case '0': p_m_g_dtmf = dtmf_samples[13]; break;
|
|
|
|
case '#': p_m_g_dtmf = dtmf_samples[14]; break;
|
|
|
|
case 'd':
|
|
|
|
case 'D': p_m_g_dtmf = dtmf_samples[15]; break;
|
|
|
|
}
|
|
|
|
p_m_g_dtmf_index = 0;
|
2010-05-31 16:45:02 +00:00
|
|
|
}
|
|
|
|
void Pgsm_bs::stop_dtmf_ind(unsigned int msg_type, unsigned int callref, struct gsm_mncc *mncc)
|
|
|
|
{
|
|
|
|
struct gsm_mncc *resp;
|
|
|
|
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, msg_type, DIRECTION_IN);
|
|
|
|
add_trace("keypad", NULL, "%c", mncc->keypad);
|
|
|
|
end_trace();
|
|
|
|
|
|
|
|
/* send resp */
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_STOP_DTMF_RSP, DIRECTION_OUT);
|
|
|
|
add_trace("keypad", NULL, "%c", mncc->keypad);
|
|
|
|
end_trace();
|
|
|
|
resp = create_mncc(MNCC_STOP_DTMF_RSP, p_m_g_callref);
|
|
|
|
resp->keypad = mncc->keypad;
|
|
|
|
send_and_free_mncc(p_m_g_instance, resp->msg_type, resp);
|
2011-02-20 09:35:40 +00:00
|
|
|
|
|
|
|
/* stop DTMF */
|
|
|
|
p_m_g_dtmf = NULL;
|
2010-05-31 16:45:02 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/* HOLD INDICATION */
|
|
|
|
void Pgsm_bs::hold_ind(unsigned int msg_type, unsigned int callref, struct gsm_mncc *mncc)
|
|
|
|
{
|
|
|
|
struct lcr_msg *message;
|
|
|
|
struct gsm_mncc *resp, *frame;
|
|
|
|
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, msg_type, DIRECTION_IN);
|
|
|
|
end_trace();
|
|
|
|
|
|
|
|
/* notify the hold of call */
|
|
|
|
message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_NOTIFY);
|
|
|
|
message->param.notifyinfo.notify = INFO_NOTIFY_REMOTE_HOLD;
|
|
|
|
message->param.notifyinfo.local = 1; /* call is held by supplementary service */
|
|
|
|
message_put(message);
|
|
|
|
|
|
|
|
/* acknowledge hold */
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_HOLD_CNF, DIRECTION_OUT);
|
|
|
|
end_trace();
|
|
|
|
resp = create_mncc(MNCC_HOLD_CNF, p_m_g_callref);
|
|
|
|
send_and_free_mncc(p_m_g_instance, resp->msg_type, resp);
|
|
|
|
|
|
|
|
/* disable audio */
|
|
|
|
if (p_m_g_tch_connected) { /* it should be true */
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_FRAME_DROP, DIRECTION_OUT);
|
|
|
|
end_trace();
|
|
|
|
frame = create_mncc(MNCC_FRAME_DROP, p_m_g_callref);
|
|
|
|
send_and_free_mncc(p_m_g_instance, frame->msg_type, frame);
|
|
|
|
p_m_g_tch_connected = 0;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/* RETRIEVE INDICATION */
|
|
|
|
void Pgsm_bs::retr_ind(unsigned int msg_type, unsigned int callref, struct gsm_mncc *mncc)
|
|
|
|
{
|
|
|
|
struct lcr_msg *message;
|
|
|
|
struct gsm_mncc *resp, *frame;
|
|
|
|
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, msg_type, DIRECTION_IN);
|
|
|
|
end_trace();
|
|
|
|
|
|
|
|
/* notify the retrieve of call */
|
|
|
|
message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_NOTIFY);
|
|
|
|
message->param.notifyinfo.notify = INFO_NOTIFY_REMOTE_RETRIEVAL;
|
|
|
|
message->param.notifyinfo.local = 1; /* call is retrieved by supplementary service */
|
|
|
|
message_put(message);
|
|
|
|
|
|
|
|
/* acknowledge retr */
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_RETRIEVE_CNF, DIRECTION_OUT);
|
|
|
|
end_trace();
|
|
|
|
resp = create_mncc(MNCC_RETRIEVE_CNF, p_m_g_callref);
|
|
|
|
send_and_free_mncc(p_m_g_instance, resp->msg_type, resp);
|
|
|
|
|
|
|
|
/* enable audio */
|
|
|
|
if (!p_m_g_tch_connected) { /* it should be true */
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_FRAME_RECV, DIRECTION_OUT);
|
|
|
|
end_trace();
|
|
|
|
frame = create_mncc(MNCC_FRAME_RECV, p_m_g_callref);
|
|
|
|
send_and_free_mncc(p_m_g_instance, frame->msg_type, frame);
|
|
|
|
p_m_g_tch_connected = 1;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* handles all indications
|
|
|
|
*/
|
|
|
|
/* SETUP INDICATION */
|
|
|
|
void Pgsm_bs::setup_ind(unsigned int msg_type, unsigned int callref, struct gsm_mncc *mncc)
|
|
|
|
{
|
|
|
|
int ret;
|
|
|
|
class Endpoint *epoint;
|
|
|
|
struct lcr_msg *message;
|
|
|
|
int channel;
|
|
|
|
struct gsm_mncc *mode, *proceeding, *frame;
|
|
|
|
|
|
|
|
/* process given callref */
|
|
|
|
l1l2l3_trace_header(p_m_mISDNport, this, L3_NEW_L3ID_IND, DIRECTION_IN);
|
|
|
|
add_trace("callref", "new", "0x%x", callref);
|
|
|
|
if (p_m_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_m_mISDNport, this, MNCC_REJ_REQ, DIRECTION_OUT);
|
|
|
|
mncc->fields |= MNCC_F_CAUSE;
|
|
|
|
mncc->cause.coding = 3;
|
|
|
|
mncc->cause.location = 1;
|
|
|
|
mncc->cause.value = 47;
|
|
|
|
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, "callref already in use");
|
|
|
|
end_trace();
|
|
|
|
send_and_free_mncc(p_m_g_instance, mncc->msg_type, mncc);
|
|
|
|
new_state(PORT_STATE_RELEASE);
|
|
|
|
trigger_work(&p_m_g_delete);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
p_m_g_callref = callref;
|
|
|
|
end_trace();
|
|
|
|
|
|
|
|
/* if blocked, release call with MT_RELEASE_COMPLETE */
|
|
|
|
if (p_m_mISDNport->ifport->block) {
|
|
|
|
mncc = create_mncc(MNCC_REJ_REQ, p_m_g_callref);
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_REJ_REQ, DIRECTION_OUT);
|
|
|
|
mncc->fields |= MNCC_F_CAUSE;
|
|
|
|
mncc->cause.coding = 3;
|
|
|
|
mncc->cause.location = 1;
|
|
|
|
mncc->cause.value = 27;
|
|
|
|
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, "port is blocked");
|
|
|
|
end_trace();
|
|
|
|
send_and_free_mncc(p_m_g_instance, mncc->msg_type, mncc);
|
|
|
|
new_state(PORT_STATE_RELEASE);
|
|
|
|
trigger_work(&p_m_g_delete);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* caller info */
|
|
|
|
if (mncc->clir.inv)
|
|
|
|
p_callerinfo.present = INFO_PRESENT_RESTRICTED;
|
|
|
|
else
|
|
|
|
p_callerinfo.present = INFO_PRESENT_ALLOWED;
|
|
|
|
if (mncc->calling.number[0])
|
|
|
|
SCPY(p_callerinfo.id, mncc->calling.number);
|
|
|
|
else
|
|
|
|
p_callerinfo.present = INFO_PRESENT_NOTAVAIL;
|
|
|
|
SCPY(p_callerinfo.imsi, mncc->imsi);
|
|
|
|
p_callerinfo.screen = INFO_SCREEN_NETWORK;
|
|
|
|
p_callerinfo.ntype = INFO_NTYPE_UNKNOWN;
|
|
|
|
p_callerinfo.isdn_port = p_m_portnum;
|
|
|
|
SCPY(p_callerinfo.interface, p_m_mISDNport->ifport->interface->name);
|
|
|
|
|
|
|
|
/* dialing information */
|
|
|
|
SCAT(p_dialinginfo.id, mncc->called.number);
|
|
|
|
switch (mncc->called.type) {
|
|
|
|
case 0x1:
|
|
|
|
p_dialinginfo.ntype = INFO_NTYPE_INTERNATIONAL;
|
|
|
|
break;
|
|
|
|
case 0x2:
|
|
|
|
p_dialinginfo.ntype = INFO_NTYPE_NATIONAL;
|
|
|
|
break;
|
|
|
|
case 0x4:
|
|
|
|
p_dialinginfo.ntype = INFO_NTYPE_SUBSCRIBER;
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
p_dialinginfo.ntype = INFO_NTYPE_UNKNOWN;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
if (mncc->emergency) {
|
|
|
|
SCPY(p_dialinginfo.id, "emergency");
|
|
|
|
}
|
|
|
|
p_dialinginfo.sending_complete = 1;
|
|
|
|
|
|
|
|
/* bearer capability */
|
|
|
|
// todo
|
|
|
|
p_capainfo.bearer_capa = INFO_BC_SPEECH;
|
|
|
|
p_capainfo.bearer_info1 = (options.law=='a')?3:2;
|
|
|
|
p_capainfo.bearer_mode = INFO_BMODE_CIRCUIT;
|
|
|
|
p_capainfo.source_mode = B_MODE_TRANSPARENT;
|
|
|
|
p_m_g_mode = p_capainfo.source_mode;
|
|
|
|
|
|
|
|
/* useruser */
|
|
|
|
|
|
|
|
/* hunt channel */
|
|
|
|
ret = channel = hunt_bchannel();
|
|
|
|
if (ret < 0)
|
|
|
|
goto no_channel;
|
|
|
|
|
|
|
|
/* open channel */
|
|
|
|
ret = seize_bchannel(channel, 1);
|
|
|
|
if (ret < 0) {
|
|
|
|
no_channel:
|
|
|
|
mncc = create_mncc(MNCC_REJ_REQ, p_m_g_callref);
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_REJ_REQ, DIRECTION_OUT);
|
|
|
|
mncc->fields |= MNCC_F_CAUSE;
|
|
|
|
mncc->cause.coding = 3;
|
|
|
|
mncc->cause.location = 1;
|
|
|
|
mncc->cause.value = 34;
|
|
|
|
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, "no channel");
|
|
|
|
end_trace();
|
|
|
|
send_and_free_mncc(p_m_g_instance, mncc->msg_type, mncc);
|
|
|
|
new_state(PORT_STATE_RELEASE);
|
|
|
|
trigger_work(&p_m_g_delete);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
bchannel_event(p_m_mISDNport, p_m_b_index, B_EVENT_USE);
|
|
|
|
if (bchannel_open(p_m_b_index))
|
|
|
|
goto no_channel;
|
|
|
|
|
|
|
|
/* what infos did we got ... */
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, msg_type, DIRECTION_IN);
|
|
|
|
if (p_callerinfo.id[0])
|
|
|
|
add_trace("calling", "number", "%s", p_callerinfo.id);
|
|
|
|
else
|
|
|
|
SPRINT(p_callerinfo.id, "imsi-%s", p_callerinfo.imsi);
|
|
|
|
add_trace("calling", "imsi", "%s", p_callerinfo.imsi);
|
|
|
|
add_trace("dialing", "number", "%s", p_dialinginfo.id);
|
|
|
|
end_trace();
|
|
|
|
|
|
|
|
/* create endpoint */
|
|
|
|
if (p_epointlist)
|
|
|
|
FATAL("Incoming call but already got an endpoint.\n");
|
|
|
|
if (!(epoint = new Endpoint(p_serial, 0)))
|
|
|
|
FATAL("No memory for Endpoint instance\n");
|
|
|
|
if (!(epoint->ep_app = new DEFAULT_ENDPOINT_APP(epoint, 0))) //incoming
|
|
|
|
FATAL("No memory for Endpoint Application instance\n");
|
|
|
|
epointlist_new(epoint->ep_serial);
|
|
|
|
|
|
|
|
/* modify lchan to GSM codec V1 */
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_LCHAN_MODIFY, DIRECTION_OUT);
|
|
|
|
mode = create_mncc(MNCC_LCHAN_MODIFY, p_m_g_callref);
|
|
|
|
mode->lchan_mode = 0x01; /* GSM V1 */
|
|
|
|
add_trace("mode", NULL, "0x%02x", mode->lchan_mode);
|
|
|
|
end_trace();
|
|
|
|
send_and_free_mncc(p_m_g_instance, mode->msg_type, mode);
|
|
|
|
|
|
|
|
/* send call proceeding */
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_CALL_PROC_REQ, DIRECTION_OUT);
|
|
|
|
proceeding = create_mncc(MNCC_CALL_PROC_REQ, p_m_g_callref);
|
|
|
|
if (p_m_mISDNport->tones) {
|
|
|
|
proceeding->fields |= MNCC_F_PROGRESS;
|
|
|
|
proceeding->progress.coding = 3; /* GSM */
|
|
|
|
proceeding->progress.location = 1;
|
|
|
|
proceeding->progress.descr = 8;
|
|
|
|
add_trace("progress", "coding", "%d", proceeding->progress.coding);
|
|
|
|
add_trace("progress", "location", "%d", proceeding->progress.location);
|
|
|
|
add_trace("progress", "descr", "%d", proceeding->progress.descr);
|
|
|
|
}
|
|
|
|
end_trace();
|
|
|
|
send_and_free_mncc(p_m_g_instance, proceeding->msg_type, proceeding);
|
|
|
|
|
|
|
|
new_state(PORT_STATE_IN_PROCEEDING);
|
|
|
|
|
|
|
|
if (p_m_mISDNport->tones && !p_m_g_tch_connected) { /* only if ... */
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_FRAME_RECV, DIRECTION_OUT);
|
|
|
|
end_trace();
|
|
|
|
frame = create_mncc(MNCC_FRAME_RECV, p_m_g_callref);
|
|
|
|
send_and_free_mncc(p_m_g_instance, frame->msg_type, frame);
|
|
|
|
p_m_g_tch_connected = 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* send setup message to endpoit */
|
|
|
|
message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_SETUP);
|
|
|
|
message->param.setup.isdn_port = p_m_portnum;
|
|
|
|
message->param.setup.port_type = p_type;
|
|
|
|
// message->param.setup.dtmf = 0;
|
|
|
|
memcpy(&message->param.setup.dialinginfo, &p_dialinginfo, sizeof(struct dialing_info));
|
|
|
|
memcpy(&message->param.setup.callerinfo, &p_callerinfo, sizeof(struct caller_info));
|
|
|
|
memcpy(&message->param.setup.capainfo, &p_capainfo, sizeof(struct capa_info));
|
|
|
|
SCPY((char *)message->param.setup.useruser.data, (char *)mncc->useruser.info);
|
|
|
|
message->param.setup.useruser.len = strlen(mncc->useruser.info);
|
|
|
|
message->param.setup.useruser.protocol = mncc->useruser.proto;
|
|
|
|
message_put(message);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* BSC sends message to port
|
|
|
|
*/
|
|
|
|
static int message_bsc(struct gsm_network *net, int msg_type, void *arg)
|
|
|
|
{
|
|
|
|
struct gsm_mncc *mncc = (struct gsm_mncc *)arg;
|
|
|
|
unsigned int callref = mncc->callref;
|
|
|
|
class Port *port;
|
|
|
|
class Pgsm_bs *pgsm_bs = NULL;
|
|
|
|
char name[64];
|
|
|
|
struct mISDNport *mISDNport;
|
|
|
|
|
|
|
|
/* Special messages */
|
|
|
|
switch(msg_type) {
|
|
|
|
}
|
|
|
|
|
|
|
|
/* find callref */
|
|
|
|
callref = mncc->callref;
|
|
|
|
port = port_first;
|
|
|
|
while(port) {
|
|
|
|
if ((port->p_type & PORT_CLASS_GSM_MASK) == PORT_CLASS_GSM_BS) {
|
|
|
|
pgsm_bs = (class Pgsm_bs *)port;
|
|
|
|
if (pgsm_bs->p_m_g_callref == callref) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
port = port->next;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (msg_type == GSM_TCHF_FRAME) {
|
2011-02-20 09:35:40 +00:00
|
|
|
if (port) {
|
|
|
|
/* inject DTMF, if enabled */
|
|
|
|
if (pgsm_bs->p_m_g_dtmf) {
|
|
|
|
unsigned char data[160];
|
|
|
|
int i;
|
|
|
|
|
|
|
|
for (i = 0; i < 160; i++) {
|
|
|
|
data[i] = pgsm_bs->p_m_g_dtmf[pgsm_bs->p_m_g_dtmf_index++];
|
|
|
|
if (pgsm_bs->p_m_g_dtmf_index == 8000)
|
|
|
|
pgsm_bs->p_m_g_dtmf_index = 0;
|
|
|
|
}
|
|
|
|
/* send */
|
|
|
|
pgsm_bs->bchannel_send(PH_DATA_REQ, 0, data, 160);
|
|
|
|
} else
|
|
|
|
pgsm_bs->frame_receive(arg);
|
|
|
|
}
|
2010-05-31 16:45:02 +00:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!port) {
|
|
|
|
if (msg_type != MNCC_SETUP_IND)
|
|
|
|
return(0);
|
|
|
|
/* find gsm port */
|
|
|
|
mISDNport = mISDNport_first;
|
|
|
|
while(mISDNport) {
|
|
|
|
if (mISDNport->gsm_bs)
|
|
|
|
break;
|
|
|
|
mISDNport = mISDNport->next;
|
|
|
|
}
|
|
|
|
if (!mISDNport) {
|
|
|
|
struct gsm_mncc *rej;
|
|
|
|
|
|
|
|
rej = create_mncc(MNCC_REJ_REQ, callref);
|
|
|
|
rej->fields |= MNCC_F_CAUSE;
|
|
|
|
rej->cause.coding = 3;
|
|
|
|
rej->cause.location = 1;
|
|
|
|
rej->cause.value = 27;
|
|
|
|
gsm_trace_header(NULL, NULL, MNCC_REJ_REQ, DIRECTION_OUT);
|
|
|
|
add_trace("cause", "coding", "%d", rej->cause.coding);
|
|
|
|
add_trace("cause", "location", "%d", rej->cause.location);
|
|
|
|
add_trace("cause", "value", "%d", rej->cause.value);
|
|
|
|
end_trace();
|
|
|
|
send_and_free_mncc(gsm->network, rej->msg_type, rej);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
/* creating port object, transparent until setup with hdlc */
|
|
|
|
SPRINT(name, "%s-%d-in", mISDNport->ifport->interface->name, mISDNport->portnum);
|
|
|
|
if (!(pgsm_bs = new Pgsm_bs(PORT_TYPE_GSM_BS_IN, mISDNport, name, NULL, 0, 0, B_MODE_TRANSPARENT)))
|
|
|
|
|
|
|
|
FATAL("Cannot create Port instance.\n");
|
|
|
|
}
|
|
|
|
|
|
|
|
switch(msg_type) {
|
|
|
|
case MNCC_SETUP_IND:
|
|
|
|
pgsm_bs->setup_ind(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_START_DTMF_IND:
|
|
|
|
pgsm_bs->start_dtmf_ind(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_STOP_DTMF_IND:
|
|
|
|
pgsm_bs->stop_dtmf_ind(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_CALL_CONF_IND:
|
|
|
|
pgsm_bs->call_conf_ind(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_ALERT_IND:
|
|
|
|
pgsm_bs->alert_ind(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_SETUP_CNF:
|
|
|
|
pgsm_bs->setup_cnf(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_SETUP_COMPL_IND:
|
|
|
|
pgsm_bs->setup_compl_ind(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_DISC_IND:
|
|
|
|
pgsm_bs->disc_ind(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_REL_IND:
|
|
|
|
case MNCC_REL_CNF:
|
|
|
|
case MNCC_REJ_IND:
|
|
|
|
pgsm_bs->rel_ind(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_NOTIFY_IND:
|
|
|
|
pgsm_bs->notify_ind(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_HOLD_IND:
|
|
|
|
pgsm_bs->hold_ind(msg_type, callref, mncc);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case MNCC_RETRIEVE_IND:
|
|
|
|
pgsm_bs->retr_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);
|
|
|
|
}
|
|
|
|
return(0);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* MESSAGE_SETUP */
|
|
|
|
void Pgsm_bs::message_setup(unsigned int epoint_id, int message_id, union parameter *param)
|
|
|
|
{
|
|
|
|
struct lcr_msg *message;
|
|
|
|
int ret;
|
|
|
|
struct epoint_list *epointlist;
|
|
|
|
struct gsm_mncc *mncc;
|
|
|
|
int channel;
|
|
|
|
|
|
|
|
/* copy setup infos to port */
|
|
|
|
memcpy(&p_callerinfo, ¶m->setup.callerinfo, sizeof(p_callerinfo));
|
|
|
|
memcpy(&p_dialinginfo, ¶m->setup.dialinginfo, sizeof(p_dialinginfo));
|
|
|
|
memcpy(&p_capainfo, ¶m->setup.capainfo, sizeof(p_capainfo));
|
|
|
|
memcpy(&p_redirinfo, ¶m->setup.redirinfo, sizeof(p_redirinfo));
|
|
|
|
|
2010-12-23 16:05:20 +00:00
|
|
|
/* no GSM MNCC connection */
|
|
|
|
if (gsm->mncc_lfd.fd < 0) {
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_SETUP_REQ, DIRECTION_OUT);
|
|
|
|
add_trace("failure", NULL, "No MNCC connection.");
|
|
|
|
end_trace();
|
|
|
|
message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE);
|
|
|
|
message->param.disconnectinfo.cause = 27; // temp. unavail.
|
|
|
|
message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
|
|
|
|
message_put(message);
|
|
|
|
new_state(PORT_STATE_RELEASE);
|
|
|
|
trigger_work(&p_m_g_delete);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2010-05-31 16:45:02 +00:00
|
|
|
/* no number */
|
|
|
|
if (!p_dialinginfo.id[0]) {
|
|
|
|
gsm_trace_header(p_m_mISDNport, 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);
|
|
|
|
message->param.disconnectinfo.cause = 28;
|
|
|
|
message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
|
|
|
|
message_put(message);
|
|
|
|
new_state(PORT_STATE_RELEASE);
|
|
|
|
trigger_work(&p_m_g_delete);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* release if port is blocked */
|
|
|
|
if (p_m_mISDNport->ifport->block) {
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_SETUP_REQ, DIRECTION_OUT);
|
|
|
|
add_trace("failure", NULL, "Port blocked.");
|
|
|
|
end_trace();
|
|
|
|
message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE);
|
|
|
|
message->param.disconnectinfo.cause = 27; // temp. unavail.
|
|
|
|
message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
|
|
|
|
message_put(message);
|
|
|
|
new_state(PORT_STATE_RELEASE);
|
|
|
|
trigger_work(&p_m_g_delete);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* hunt channel */
|
|
|
|
ret = channel = hunt_bchannel();
|
|
|
|
if (ret < 0)
|
|
|
|
goto no_channel;
|
|
|
|
/* open channel */
|
|
|
|
ret = seize_bchannel(channel, 1);
|
|
|
|
if (ret < 0) {
|
|
|
|
no_channel:
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_SETUP_REQ, DIRECTION_OUT);
|
|
|
|
add_trace("failure", NULL, "No internal audio channel available.");
|
|
|
|
end_trace();
|
|
|
|
message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE);
|
|
|
|
message->param.disconnectinfo.cause = 34;
|
|
|
|
message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
|
|
|
|
message_put(message);
|
|
|
|
new_state(PORT_STATE_RELEASE);
|
|
|
|
trigger_work(&p_m_g_delete);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
bchannel_event(p_m_mISDNport, p_m_b_index, B_EVENT_USE);
|
|
|
|
if (bchannel_open(p_m_b_index))
|
|
|
|
goto no_channel;
|
|
|
|
|
|
|
|
// SCPY(&p_m_tones_dir, param->setup.ext.tones_dir);
|
|
|
|
/* screen outgoing caller id */
|
|
|
|
do_screen(1, p_callerinfo.id, sizeof(p_callerinfo.id), &p_callerinfo.ntype, &p_callerinfo.present, p_m_mISDNport->ifport->interface);
|
|
|
|
|
|
|
|
/* attach only if not already */
|
|
|
|
epointlist = p_epointlist;
|
|
|
|
while(epointlist) {
|
|
|
|
if (epointlist->epoint_id == epoint_id)
|
|
|
|
break;
|
|
|
|
epointlist = epointlist->next;
|
|
|
|
}
|
|
|
|
if (!epointlist)
|
|
|
|
epointlist_new(epoint_id);
|
|
|
|
|
|
|
|
/* creating l3id */
|
|
|
|
l1l2l3_trace_header(p_m_mISDNport, this, L3_NEW_L3ID_REQ, DIRECTION_OUT);
|
|
|
|
p_m_g_callref = new_callref++;
|
|
|
|
add_trace("callref", "new", "0x%x", p_m_g_callref);
|
|
|
|
end_trace();
|
|
|
|
|
|
|
|
gsm_trace_header(p_m_mISDNport, this, MNCC_SETUP_REQ, DIRECTION_OUT);
|
|
|
|
mncc = create_mncc(MNCC_SETUP_REQ, p_m_g_callref);
|
|
|
|
/* caller information */
|
|
|
|
mncc->fields |= MNCC_F_CALLING;
|
|
|
|
mncc->calling.plan = 1;
|
|
|
|
switch (p_callerinfo.ntype) {
|
|
|
|
case INFO_NTYPE_UNKNOWN:
|
|
|
|
mncc->calling.type = 0x0;
|
|
|
|
break;
|
|
|
|
case INFO_NTYPE_INTERNATIONAL:
|
|
|
|
mncc->calling.type = 0x1;
|
|
|
|
break;
|
|
|
|
case INFO_NTYPE_NATIONAL:
|
|
|
|
mncc->calling.type = 0x2;
|
|
|
|
break;
|
|
|
|
case INFO_NTYPE_SUBSCRIBER:
|
|
|
|
mncc->calling.type = 0x4;
|
|
|
|
break;
|
|
|
|
default: /* INFO_NTYPE_NOTPRESENT */
|
|
|
|
mncc->fields &= ~MNCC_F_CALLING;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
switch (p_callerinfo.screen) {
|
|
|
|
case INFO_SCREEN_USER:
|
|
|
|
mncc->calling.screen = 0;
|
|
|
|
break;
|
|
|
|
default: /* INFO_SCREEN_NETWORK */
|
|
|
|
mncc->calling.screen = 3;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
switch (p_callerinfo.present) {
|
|
|
|
case INFO_PRESENT_ALLOWED:
|
|
|
|
mncc->calling.present = 0;
|
|
|
|
break;
|
|
|
|
case INFO_PRESENT_RESTRICTED:
|
|
|
|
mncc->calling.present = 1;
|
|
|
|
break;
|
|
|
|
default: /* INFO_PRESENT_NOTAVAIL */
|
|
|
|
mncc->calling.present = 2;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
if (mncc->fields & MNCC_F_CALLING) {
|
|
|
|
SCPY(mncc->calling.number, p_callerinfo.id);
|
|
|
|
add_trace("calling", "type", "%d", mncc->calling.type);
|
|
|
|
add_trace("calling", "plan", "%d", mncc->calling.plan);
|
|
|
|
add_trace("calling", "present", "%d", mncc->calling.present);
|
|
|
|
add_trace("calling", "screen", "%d", mncc->calling.screen);
|
|
|
|
add_trace("calling", "number", "%s", mncc->calling.number);
|
|
|
|
}
|
|
|
|
/* dialing information */
|
|
|
|
mncc->fields |= MNCC_F_CALLED;
|
|
|
|
if (!strncmp(p_dialinginfo.id, "imsi-", 5)) {
|
|
|
|
SCPY(mncc->imsi, p_dialinginfo.id+5);
|
|
|
|
add_trace("dialing", "imsi", "%s", mncc->imsi);
|
|
|
|
} else {
|
|
|
|
SCPY(mncc->called.number, p_dialinginfo.id);
|
|
|
|
add_trace("dialing", "number", "%s", mncc->called.number);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* sending user-user */
|
|
|
|
|
|
|
|
/* redirecting number */
|
|
|
|
mncc->fields |= MNCC_F_REDIRECTING;
|
|
|
|
mncc->redirecting.plan = 1;
|
|
|
|
switch (p_redirinfo.ntype) {
|
|
|
|
case INFO_NTYPE_UNKNOWN:
|
|
|
|
mncc->redirecting.type = 0x0;
|
|
|
|
break;
|
|
|
|
case INFO_NTYPE_INTERNATIONAL:
|
|
|
|
mncc->redirecting.type = 0x1;
|
|
|
|
break;
|
|
|
|
case INFO_NTYPE_NATIONAL:
|
|
|
|
mncc->redirecting.type = 0x2;
|
|
|
|
break;
|
|
|
|
case INFO_NTYPE_SUBSCRIBER:
|
|
|
|
mncc->redirecting.type = 0x4;
|
|
|
|
break;
|
|
|
|
default: /* INFO_NTYPE_NOTPRESENT */
|
|
|
|
mncc->fields &= ~MNCC_F_REDIRECTING;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
switch (p_redirinfo.screen) {
|
|
|
|
case INFO_SCREEN_USER:
|
|
|
|
mncc->redirecting.screen = 0;
|
|
|
|
break;
|
|
|
|
default: /* INFO_SCREE_NETWORK */
|
|
|
|
mncc->redirecting.screen = 3;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
switch (p_redirinfo.present) {
|
|
|
|
case INFO_PRESENT_ALLOWED:
|
|
|
|
mncc->redirecting.present = 0;
|
|
|
|
break;
|
|
|
|
case INFO_PRESENT_RESTRICTED:
|
|
|
|
mncc->redirecting.present = 1;
|
|
|
|
break;
|
|
|
|
default: /* INFO_PRESENT_NOTAVAIL */
|
|
|
|
mncc->redirecting.present = 2;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
/* sending redirecting number only in ntmode */
|
|
|
|
if (mncc->fields & MNCC_F_REDIRECTING) {
|
|
|
|
SCPY(mncc->redirecting.number, p_redirinfo.id);
|
|
|
|
add_trace("redir", "type", "%d", mncc->redirecting.type);
|
|
|
|
add_trace("redir", "plan", "%d", mncc->redirecting.plan);
|
|
|
|
add_trace("redir", "present", "%d", mncc->redirecting.present);
|
|
|
|
add_trace("redir", "screen", "%d", mncc->redirecting.screen);
|
|
|
|
add_trace("redir", "number", "%s", mncc->redirecting.number);
|
|
|
|
}
|
|
|
|
/* bearer capability */
|
|
|
|
//todo
|
|
|
|
|
|
|
|
end_trace();
|
|
|
|
send_and_free_mncc(p_m_g_instance, mncc->msg_type, mncc);
|
|
|
|
|
|
|
|
new_state(PORT_STATE_OUT_SETUP);
|
|
|
|
|
|
|
|
message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_PROCEEDING);
|
|
|
|
message_put(message);
|
|
|
|
|
|
|
|
new_state(PORT_STATE_OUT_PROCEEDING);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* endpoint sends messages to the port
|
|
|
|
*/
|
|
|
|
int Pgsm_bs::message_epoint(unsigned int epoint_id, int message_id, union parameter *param)
|
|
|
|
{
|
|
|
|
if (Pgsm::message_epoint(epoint_id, message_id, param))
|
|
|
|
return(1);
|
|
|
|
|
|
|
|
switch(message_id) {
|
|
|
|
case MESSAGE_SETUP: /* dial-out command received from epoint */
|
|
|
|
if (p_state!=PORT_STATE_IDLE)
|
|
|
|
break;
|
|
|
|
message_setup(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);
|
|
|
|
}
|
|
|
|
|
|
|
|
return(1);
|
|
|
|
}
|
|
|
|
|
|
|
|
int gsm_bs_exit(int rc)
|
|
|
|
{
|
2011-07-25 09:38:50 +00:00
|
|
|
gsm->network = NULL;
|
|
|
|
|
2010-05-31 16:45:02 +00:00
|
|
|
return(rc);
|
|
|
|
}
|
|
|
|
|
2010-12-22 18:35:28 +00:00
|
|
|
extern "C" {
|
|
|
|
|
|
|
|
static int mncc_q_enqueue(struct gsm_mncc *mncc, unsigned int len)
|
2010-05-31 16:45:02 +00:00
|
|
|
{
|
2010-12-22 18:35:28 +00:00
|
|
|
struct mncc_q_entry *qe;
|
2010-05-31 16:45:02 +00:00
|
|
|
|
2010-12-22 18:35:28 +00:00
|
|
|
qe = (struct mncc_q_entry *) MALLOC(sizeof(*qe)+sizeof(*mncc)+len);
|
|
|
|
if (!qe)
|
|
|
|
return -ENOMEM;
|
2010-05-31 16:45:02 +00:00
|
|
|
|
2010-12-22 18:35:28 +00:00
|
|
|
qe->next = NULL;
|
|
|
|
qe->len = len;
|
|
|
|
memcpy(qe->data, mncc, len);
|
|
|
|
|
|
|
|
/* in case of empty list ... */
|
|
|
|
if (!gsm->mncc_q_hd && !gsm->mncc_q_tail) {
|
|
|
|
/* the list head and tail both point to the new qe */
|
|
|
|
gsm->mncc_q_hd = gsm->mncc_q_tail = qe;
|
|
|
|
} else {
|
|
|
|
/* append to tail of list */
|
|
|
|
gsm->mncc_q_tail->next = qe;
|
2010-12-22 21:55:30 +00:00
|
|
|
gsm->mncc_q_tail = qe;
|
2010-10-30 15:21:54 +00:00
|
|
|
}
|
|
|
|
|
2010-12-22 18:35:28 +00:00
|
|
|
gsm->mncc_lfd.when |= LCR_FD_WRITE;
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static struct mncc_q_entry *mncc_q_dequeue(void)
|
|
|
|
{
|
|
|
|
struct mncc_q_entry *qe = gsm->mncc_q_hd;
|
|
|
|
if (!qe)
|
|
|
|
return NULL;
|
|
|
|
|
|
|
|
/* dequeue the successfully sent message */
|
|
|
|
gsm->mncc_q_hd = qe->next;
|
|
|
|
if (!qe)
|
|
|
|
return NULL;
|
|
|
|
if (qe == gsm->mncc_q_tail)
|
|
|
|
gsm->mncc_q_tail = NULL;
|
|
|
|
|
|
|
|
return qe;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* routine called by LCR code if it wants to send a message to OpenBSC */
|
|
|
|
int mncc_send(struct gsm_network *instance, int msg_type, void *data)
|
|
|
|
{
|
|
|
|
int len = 0;
|
|
|
|
|
|
|
|
/* FIXME: the caller should provide this */
|
|
|
|
switch (msg_type) {
|
|
|
|
case GSM_TCHF_FRAME:
|
2010-12-22 20:40:08 +00:00
|
|
|
len = sizeof(struct gsm_data_frame) + 33;
|
2010-12-22 18:35:28 +00:00
|
|
|
break;
|
|
|
|
default:
|
|
|
|
len = sizeof(struct gsm_mncc);
|
|
|
|
break;
|
2010-05-31 16:45:02 +00:00
|
|
|
}
|
2010-12-22 18:35:28 +00:00
|
|
|
|
|
|
|
return mncc_q_enqueue((struct gsm_mncc *)data, len);
|
|
|
|
}
|
|
|
|
|
|
|
|
} // extern "C"
|
|
|
|
|
|
|
|
/* close MNCC socket */
|
|
|
|
static int mncc_fd_close(struct lcr_fd *lfd)
|
|
|
|
{
|
2010-12-23 14:32:10 +00:00
|
|
|
class Port *port;
|
|
|
|
class Pgsm_bs *pgsm_bs = NULL;
|
|
|
|
struct lcr_msg *message;
|
|
|
|
|
2010-12-23 15:46:54 +00:00
|
|
|
PERROR("Lost MNCC socket, retrying in %u seconds\n", SOCKET_RETRY_TIMER);
|
2010-12-22 18:35:28 +00:00
|
|
|
close(lfd->fd);
|
|
|
|
unregister_fd(lfd);
|
|
|
|
lfd->fd = -1;
|
|
|
|
|
2010-12-23 14:32:10 +00:00
|
|
|
/* free all the calls that were running through the MNCC interface */
|
|
|
|
port = port_first;
|
|
|
|
while(port) {
|
|
|
|
if ((port->p_type & PORT_CLASS_GSM_MASK) == PORT_CLASS_GSM_BS) {
|
|
|
|
pgsm_bs = (class Pgsm_bs *)port;
|
|
|
|
message = message_create(pgsm_bs->p_serial, ACTIVE_EPOINT(pgsm_bs->p_epointlist), PORT_TO_EPOINT, MESSAGE_RELEASE);
|
|
|
|
message->param.disconnectinfo.cause = 27; // temp. unavail.
|
|
|
|
message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
|
|
|
|
message_put(message);
|
|
|
|
pgsm_bs->new_state(PORT_STATE_RELEASE);
|
|
|
|
trigger_work(&pgsm_bs->p_m_g_delete);
|
|
|
|
}
|
|
|
|
port = port->next;
|
2010-05-31 16:45:02 +00:00
|
|
|
}
|
|
|
|
|
2010-12-23 15:46:54 +00:00
|
|
|
/* flush the queue */
|
|
|
|
while (mncc_q_dequeue())
|
|
|
|
;
|
|
|
|
|
|
|
|
/* start the re-connect timer */
|
|
|
|
schedule_timer(&gsm->socket_retry, SOCKET_RETRY_TIMER, 0);
|
2010-05-31 16:45:02 +00:00
|
|
|
|
2011-02-20 09:35:40 +00:00
|
|
|
generate_dtmf();
|
|
|
|
|
2010-05-31 16:45:02 +00:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2010-12-22 18:35:28 +00:00
|
|
|
/* read from OpenBSC via MNCC socket */
|
|
|
|
static int mncc_fd_write(struct lcr_fd *lfd, void *inst, int idx)
|
2010-05-31 16:45:02 +00:00
|
|
|
{
|
2010-12-22 18:35:28 +00:00
|
|
|
struct mncc_q_entry *qe, *qe2;
|
|
|
|
int rc;
|
2010-05-31 16:45:02 +00:00
|
|
|
|
2010-12-22 18:35:28 +00:00
|
|
|
while (1) {
|
|
|
|
qe = gsm->mncc_q_hd;
|
|
|
|
if (!qe) {
|
|
|
|
lfd->when &= ~LCR_FD_WRITE;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
rc = write(lfd->fd, qe->data, qe->len);
|
|
|
|
if (rc == 0)
|
|
|
|
return mncc_fd_close(lfd);
|
|
|
|
if (rc < 0)
|
|
|
|
return rc;
|
2011-02-20 16:34:24 +00:00
|
|
|
if (rc < (int)qe->len)
|
2010-12-22 18:35:28 +00:00
|
|
|
return -1;
|
|
|
|
/* dequeue the successfully sent message */
|
|
|
|
qe2 = mncc_q_dequeue();
|
|
|
|
assert(qe == qe2);
|
|
|
|
free(qe);
|
|
|
|
}
|
2010-05-31 16:45:02 +00:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2010-12-22 18:35:28 +00:00
|
|
|
/* read from OpenBSC via MNCC socket */
|
|
|
|
static int mncc_fd_read(struct lcr_fd *lfd, void *inst, int idx)
|
|
|
|
{
|
|
|
|
int rc;
|
|
|
|
static char buf[sizeof(struct gsm_mncc)+1024];
|
|
|
|
struct gsm_mncc *mncc_prim = (struct gsm_mncc *) buf;
|
|
|
|
|
|
|
|
memset(buf, 0, sizeof(buf));
|
|
|
|
rc = recv(lfd->fd, buf, sizeof(buf), 0);
|
|
|
|
if (rc == 0)
|
|
|
|
return mncc_fd_close(lfd);
|
|
|
|
if (rc < 0)
|
|
|
|
return rc;
|
|
|
|
|
|
|
|
/* Hand the MNCC message into LCR */
|
|
|
|
return message_bsc(NULL, mncc_prim->msg_type, mncc_prim);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* file descriptor callback if we can read or write form MNCC socket */
|
|
|
|
static int mncc_fd_cb(struct lcr_fd *lfd, unsigned int what, void *instance, int idx)
|
|
|
|
{
|
|
|
|
int rc = 0;
|
|
|
|
|
|
|
|
if (what & LCR_FD_READ)
|
|
|
|
rc = mncc_fd_read(lfd, instance, idx);
|
|
|
|
if (rc < 0)
|
|
|
|
return rc;
|
|
|
|
|
|
|
|
if (what & LCR_FD_WRITE)
|
|
|
|
rc = mncc_fd_write(lfd, instance, idx);
|
|
|
|
|
|
|
|
return rc;
|
|
|
|
}
|
|
|
|
|
2010-12-23 15:46:54 +00:00
|
|
|
static int socket_retry_cb(struct lcr_timer *timer, void *instance, int index)
|
2010-05-31 16:45:02 +00:00
|
|
|
{
|
2010-12-23 15:46:54 +00:00
|
|
|
int fd, rc;
|
2010-12-22 18:35:28 +00:00
|
|
|
|
2010-12-23 15:46:54 +00:00
|
|
|
fd = socket(PF_UNIX, SOCK_SEQPACKET, 0);
|
|
|
|
if (fd < 0) {
|
|
|
|
PERROR("Cannot create SEQPACKET socket, giving up!\n");
|
|
|
|
return fd;
|
|
|
|
}
|
2010-12-22 18:35:28 +00:00
|
|
|
|
2010-12-23 15:46:54 +00:00
|
|
|
rc = connect(fd, (struct sockaddr *) &gsm->sun,
|
|
|
|
sizeof(gsm->sun));
|
|
|
|
if (rc < 0) {
|
|
|
|
PERROR("Could not connect to MNCC socket, "
|
|
|
|
"retrying in %u seconds\n", SOCKET_RETRY_TIMER);
|
|
|
|
close(fd);
|
|
|
|
schedule_timer(&gsm->socket_retry, SOCKET_RETRY_TIMER, 0);
|
|
|
|
} else {
|
|
|
|
PDEBUG(DEBUG_GSM, "Connected to MNCC socket!\n");
|
|
|
|
gsm->mncc_lfd.fd = fd;
|
|
|
|
register_fd(&gsm->mncc_lfd, LCR_FD_READ, &mncc_fd_cb, NULL, 0);
|
|
|
|
}
|
2010-05-31 16:45:02 +00:00
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2010-12-23 15:46:54 +00:00
|
|
|
int gsm_bs_init(void)
|
|
|
|
{
|
|
|
|
gsm->sun.sun_family = AF_UNIX;
|
2011-07-10 17:52:08 +00:00
|
|
|
SCPY(gsm->sun.sun_path, "/tmp/bsc_mncc");
|
2010-12-22 18:35:28 +00:00
|
|
|
|
2010-12-23 15:46:54 +00:00
|
|
|
memset(&gsm->socket_retry, 0, sizeof(gsm->socket_retry));
|
|
|
|
add_timer(&gsm->socket_retry, socket_retry_cb, NULL, 0);
|
|
|
|
|
|
|
|
/* do the initial connect */
|
|
|
|
socket_retry_cb(&gsm->socket_retry, NULL, 0);
|
|
|
|
|
2011-07-25 09:38:50 +00:00
|
|
|
/* dummy instance */
|
|
|
|
gsm->network = (void *)1;
|
|
|
|
|
2010-12-23 15:46:54 +00:00
|
|
|
return 0;
|
2010-12-22 18:35:28 +00:00
|
|
|
}
|