- Fixed some GSM information elements.
- OpenBSC api changes.
- Fixed disabling of DTMF using 'n' option of chan_lcr.
+- Added GSM IMSI dialing by using dialing "imsi-<number>".
struct admin_list *admin;
/* a created call, this should never happen */
- if (ea_endpoint->ep_join_id)
- {
+ if (ea_endpoint->ep_join_id) {
if (options.deb & DEBUG_EPOINT)
PERROR("EPOINT(%d): We already have a call instance, this should never happen!\n", ea_endpoint->ep_serial);
return(0);
/* create join */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): Creating new join instance.\n", ea_endpoint->ep_serial);
- if (remote)
- {
+ if (remote) {
admin = admin_first;
- while(admin)
- {
+ while(admin) {
if (admin->remote_name[0] && !strcmp(admin->remote_name, remote))
break;
admin = admin->next;
}
- if (!admin)
- {
+ if (!admin) {
/* resource not available */
trace_header("ACTION remote (not available)", DIRECTION_NONE);
add_trace("application", NULL, "%s", remote);
dialinginfo.ntype = rparam->integer_value;
/* process service */
- if ((rparam = routeparam(e_action, PARAM_CAPA)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CAPA))) {
capainfo.bearer_capa = rparam->integer_value;
if (capainfo.bearer_capa != INFO_BC_SPEECH
- && capainfo.bearer_capa != INFO_BC_AUDIO)
- {
+ && capainfo.bearer_capa != INFO_BC_AUDIO) {
capainfo.bearer_mode = INFO_BMODE_PACKET;
}
capainfo.bearer_info1 = INFO_INFO1_NONE;
}
- if ((rparam = routeparam(e_action, PARAM_BMODE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_BMODE))) {
capainfo.bearer_mode = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_INFO1)))
- {
+ if ((rparam = routeparam(e_action, PARAM_INFO1))) {
capainfo.bearer_info1 = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_HLC)))
- {
+ if ((rparam = routeparam(e_action, PARAM_HLC))) {
capainfo.hlc = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_EXTHLC)))
- {
+ if ((rparam = routeparam(e_action, PARAM_EXTHLC))) {
capainfo.exthlc = rparam->integer_value;
}
/* process presentation */
- if ((rparam = routeparam(e_action, PARAM_PRESENT)))
- {
+ if ((rparam = routeparam(e_action, PARAM_PRESENT))) {
callerinfo.present = (rparam->integer_value)?INFO_PRESENT_ALLOWED:INFO_PRESENT_RESTRICTED;
}
/* check if extension exists AND only if not multiple extensions */
- if (!strchr(dialinginfo.id,',') && !read_extension(&ext, dialinginfo.id))
- {
+ if (!strchr(dialinginfo.id,',') && !read_extension(&ext, dialinginfo.id)) {
trace_header("ACTION extension (extension doesn't exist)", DIRECTION_NONE);
add_trace("extension", NULL, dialinginfo.id);
end_trace();
return;
}
/* check if internal calls are denied */
- if (e_ext.rights < 1)
- {
+ if (e_ext.rights < 1) {
trace_header("ACTION extension (dialing to extension denied)", DIRECTION_NONE);
add_trace("extension", NULL, dialinginfo.id);
end_trace();
struct route_param *rparam;
/* special processing of delete characters '*' and '#' */
- if (e_ext.delete_ext)
- {
+ if (e_ext.delete_ext) {
/* dialing a # causes a clearing of complete number */
- if (strchr(e_extdialing, '#'))
- {
+ if (strchr(e_extdialing, '#')) {
e_extdialing[0] = '\0';
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): '#' detected: terminal '%s' selected caller id '%s' and continues dialing: '%s'\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, e_extdialing);
}
/* eliminate digits before '*', which is a delete digit
*/
- if (strchr(e_extdialing, '*'))
- {
+ if (strchr(e_extdialing, '*')) {
/* remove digits */
- while((p=strchr(e_extdialing, '*')))
- {
- if (p > e_extdialing) /* only if there is a digit in front */
- {
+ while((p=strchr(e_extdialing, '*'))) {
+ if (p > e_extdialing) { /* only if there is a digit in front */
UCPY(p-1, p);
p--;
}
dialinginfo.ntype = rparam->integer_value;
/* process service */
- if ((rparam = routeparam(e_action, PARAM_CAPA)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CAPA))) {
capainfo.bearer_capa = rparam->integer_value;
if (capainfo.bearer_capa != INFO_BC_SPEECH
- && capainfo.bearer_capa != INFO_BC_AUDIO)
- {
+ && capainfo.bearer_capa != INFO_BC_AUDIO) {
capainfo.bearer_mode = INFO_BMODE_PACKET;
}
capainfo.bearer_info1 = INFO_INFO1_NONE;
}
- if ((rparam = routeparam(e_action, PARAM_BMODE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_BMODE))) {
capainfo.bearer_mode = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_INFO1)))
- {
+ if ((rparam = routeparam(e_action, PARAM_INFO1))) {
capainfo.bearer_info1 = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_HLC)))
- {
+ if ((rparam = routeparam(e_action, PARAM_HLC))) {
capainfo.hlc = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_EXTHLC)))
- {
+ if ((rparam = routeparam(e_action, PARAM_EXTHLC))) {
capainfo.exthlc = rparam->integer_value;
}
/* process callerid */
- if ((rparam = routeparam(e_action, PARAM_CALLERID)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CALLERID))) {
SCPY(callerinfo.id, rparam->string_value);
}
- if ((rparam = routeparam(e_action, PARAM_CALLERIDTYPE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CALLERIDTYPE))) {
callerinfo.ntype = rparam->integer_value;
}
/* process presentation */
- if ((rparam = routeparam(e_action, PARAM_PRESENT)))
- {
+ if ((rparam = routeparam(e_action, PARAM_PRESENT))) {
callerinfo.present = (rparam->integer_value)?INFO_PRESENT_ALLOWED:INFO_PRESENT_RESTRICTED;
}
SCPY(dialinginfo.interfaces, rparam->string_value);
/* check if local calls are denied */
- if (e_ext.rights < 2)
- {
+ if (e_ext.rights < 2) {
trace_header("ACTION extern (calling denied)", DIRECTION_NONE);
end_trace();
release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_REJECTED, 0, 0);
if (!strncmp(dialinginfo.id, options.national, strlen(options.national))
|| dialinginfo.ntype == INFO_NTYPE_NATIONAL
- || dialinginfo.ntype == INFO_NTYPE_INTERNATIONAL)
- {
+ || dialinginfo.ntype == INFO_NTYPE_INTERNATIONAL) {
/* check if national calls are denied */
- if (e_ext.rights < 3)
- {
+ if (e_ext.rights < 3) {
trace_header("ACTION extern (national calls denied)", DIRECTION_NONE);
end_trace();
release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_REJECTED, 0, 0);
}
if (!strncmp(dialinginfo.id, options.international, strlen(options.international))
- || dialinginfo.ntype == INFO_NTYPE_INTERNATIONAL)
- {
+ || dialinginfo.ntype == INFO_NTYPE_INTERNATIONAL) {
/* check if international calls are denied */
- if (e_ext.rights < 4)
- {
+ if (e_ext.rights < 4) {
trace_header("ACTION extern (international calls denied)", DIRECTION_NONE);
end_trace();
release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_REJECTED, 0, 0);
char context[128] = "";
char remote[32];
- if (!ea_endpoint->ep_join_id)
- {
+ if (!ea_endpoint->ep_join_id) {
/* no join yet, sending setup */
- if (!(rparam = routeparam(e_action, PARAM_APPLICATION)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_APPLICATION))) {
trace_header("ACTION remote (no application given)", DIRECTION_NONE);
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
memcpy(&redirinfo, &e_redirinfo, sizeof(redirinfo));
memset(&dialinginfo, 0, sizeof(dialinginfo));
- if ((rparam = routeparam(e_action, PARAM_CONTEXT)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CONTEXT))) {
SCPY(context, rparam->string_value);
}
- if ((rparam = routeparam(e_action, PARAM_EXTEN)))
- {
+ if ((rparam = routeparam(e_action, PARAM_EXTEN))) {
SCPY(dialinginfo.id, rparam->string_value);
dialinginfo.ntype = INFO_NTYPE_UNKNOWN;
- } else
- {
+ } else {
SCPY(dialinginfo.id, e_extdialing);
}
e_extdialing = e_dialinginfo.id + strlen(e_dialinginfo.id);
memcpy(&message->param.setup.capainfo, &capainfo, sizeof(struct capa_info));
SCPY(message->param.setup.context, context);
message_put(message);
- } else
- {
+ } else {
/* send overlap digits */
trace_header("ACTION remote (dialing)", DIRECTION_NONE);
add_trace("number", NULL, e_extdialing);
end_trace();
- if (e_extdialing[0])
- {
+ if (e_extdialing[0]) {
message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_INFORMATION);
memcpy(&message->param.information, &e_dialinginfo, sizeof(struct dialing_info));
SCPY(message->param.information.id, e_extdialing);
portlist = ea_endpoint->ep_portlist;
/* check for given extension */
- if (!(rparam = routeparam(e_action, PARAM_EXTENSION)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_EXTENSION))) {
trace_header("ACTION vbox-record (no extension given by parameter)", DIRECTION_NONE);
end_trace();
}
/* check if extension exists */
- if (!read_extension(&ext, rparam->string_value))
- {
+ if (!read_extension(&ext, rparam->string_value)) {
trace_header("ACTION vbox-record (given extension does not exists)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", rparam->string_value);
end_trace();
}
/* check if internal calls are denied */
- if (e_ext.rights < 1)
- {
+ if (e_ext.rights < 1) {
trace_header("ACTION vbox-record (internal calls are denied)", DIRECTION_NONE);
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
/* append special announcement (if given) */
if ((rparam = routeparam(e_action, PARAM_ANNOUNCEMENT)))
- if (rparam->string_value[0])
- {
+ if (rparam->string_value[0]) {
SCAT(dialinginfo.id, ",");
SCAT(dialinginfo.id, rparam->string_value);
}
portlist = ea_endpoint->ep_portlist;
/* check for given extension */
- if (!(rparam = routeparam(e_action, PARAM_ROOM)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_ROOM))) {
trace_header("ACTION partyline (no room parameter)", DIRECTION_NONE);
end_trace();
noroom:
set_tone(portlist, "cause_3f");
return;
}
- if (rparam->integer_value <= 0)
- {
+ if (rparam->integer_value <= 0) {
trace_header("ACTION partyline (illegal room parameter)", DIRECTION_NONE);
add_trace("room", NULL, "%d", rparam->integer_value);
end_trace();
/* don't create join if partyline exists */
join = join_first;
- while(join)
- {
- if (join->j_type == JOIN_TYPE_PBX)
- {
+ while(join) {
+ if (join->j_type == JOIN_TYPE_PBX) {
joinpbx = (class JoinPBX *)join;
if (joinpbx->j_partyline == partyline)
break;
}
join = join->next;
}
- if (!join)
- {
+ if (!join) {
/* create join */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): Creating new join instance.\n", ea_endpoint->ep_serial);
if (!(join = new JoinPBX(ea_endpoint)))
FATAL("No memory for join object\n");
- } else
- {
+ } else {
//NOTE: joinpbx must be set here
/* add relation to existing join */
if (!(relation=joinpbx->add_relation()))
struct route_param *rparam;
/* extension parameter */
- if ((rparam = routeparam(e_action, PARAM_EXTENSION)))
- {
+ if ((rparam = routeparam(e_action, PARAM_EXTENSION))) {
/* extension is given by parameter */
extension = rparam->string_value;
if (extension[0] == '\0')
return;
- if (!read_extension(&e_ext, extension))
- {
+ if (!read_extension(&e_ext, extension)) {
trace_header("ACTION login (extension doesn't exist)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", extension);
end_trace();
set_tone(portlist, "cause_86");
return;
}
- } else
- {
+ } else {
/* extension must be given by dialstring */
extension = e_extdialing;
if (extension[0] == '\0')
return;
- if (!read_extension(&e_ext, extension))
- {
+ if (!read_extension(&e_ext, extension)) {
trace_header("ACTION login (extension incomplete or does not exist)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", extension);
end_trace();
e_connectedmode = 1;
e_dtmf = 1;
- if (!(rparam = routeparam(e_action, PARAM_NOPASSWORD)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_NOPASSWORD))) {
/* make call state to enter password */
trace_header("ACTION login (ask for password)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", e_ext.number);
/* do dialing */
process_dialing();
- } else
- {
+ } else {
/* make call state */
new_state(EPOINT_STATE_IN_OVERLAP);
e_ruleset = ruleset_main;
{
struct port_list *portlist = ea_endpoint->ep_portlist;
- if (!e_ext.change_callerid)
- {
+ if (!e_ext.change_callerid) {
/* service not available */
trace_header("ACTION change-callerid (denied for this caller)", DIRECTION_NONE);
end_trace();
char old_id[64] = "", new_id[64] = "";
int old_type=0, new_type=0, old_present=0, new_present=0;
- if ((rparam = routeparam(e_action, PARAM_CALLERID)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CALLERID))) {
/* the caller ID is given by parameter */
callerid = rparam->string_value;
- } else
- {
+ } else {
/* caller ID is dialed */
- if (!strchr(e_extdialing, '#'))
- {
+ if (!strchr(e_extdialing, '#')) {
/* no complete ID yet */
return;
}
/* given callerid type */
if ((rparam = routeparam(e_action, PARAM_CALLERIDTYPE)))
- switch(rparam->integer_value)
- {
+ switch(rparam->integer_value) {
case INFO_NTYPE_SUBSCRIBER:
SPRINT(buffer, "s%s", callerid);
callerid = buffer;
/* caller id complete, dialing with new caller id */
/* write new parameters */
- if (read_extension(&e_ext, e_ext.number))
- {
+ if (read_extension(&e_ext, e_ext.number)) {
old_present = (!next)?e_ext.callerid_present:e_ext.id_next_call_present;
old_type = (!next)?e_ext.callerid_type:e_ext.id_next_call_type;
SCPY(old_id, (!next)?e_ext.callerid:e_ext.id_next_call);
- if (callerid[0] == '\0')
- {
+ if (callerid[0] == '\0') {
/* no caller id */
(!next)?e_ext.callerid_present:e_ext.id_next_call_present = INFO_PRESENT_RESTRICTED;
- } else
- {
+ } else {
/* new caller id */
(!next)?e_ext.callerid_present:e_ext.id_next_call_present = INFO_PRESENT_ALLOWED;
if ((rparam = routeparam(e_action, PARAM_PRESENT))) if (rparam->integer_value == 0)
(!next)?e_ext.callerid_present:e_ext.id_next_call_present = INFO_PRESENT_RESTRICTED;
- if (e_ext.callerid_type == INFO_NTYPE_UNKNOWN) /* if callerid is unknown, the given id is not nationalized */
- {
+ if (e_ext.callerid_type == INFO_NTYPE_UNKNOWN) /* if callerid is unknown, the given id is not nationalized */ {
SCPY((!next)?e_ext.callerid:e_ext.id_next_call, callerid);
(!next)?e_ext.callerid_type:e_ext.id_next_call_type = INFO_NTYPE_UNKNOWN;
- } else
- {
+ } else {
SCPY((!next)?e_ext.callerid:e_ext.id_next_call, nationalize_callerinfo(callerid,&((!next)?e_ext.callerid_type:e_ext.id_next_call_type), options.national, options.international));
}
if (!next) e_ext.id_next_call_type = -1;
{
struct port_list *portlist = ea_endpoint->ep_portlist;
- if (!e_ext.change_forward)
- {
+ if (!e_ext.change_forward) {
trace_header("ACTION change-forward (denied for this caller)", DIRECTION_NONE);
end_trace();
/* service not available */
if ((rparam = routeparam(e_action, PARAM_DIVERSION)))
diversion = rparam->integer_value;
- if ((rparam = routeparam(e_action, PARAM_DEST)))
- {
+ if ((rparam = routeparam(e_action, PARAM_DEST))) {
/* if destination is given */
dest = rparam->string_value;
- } else
- {
+ } else {
if (!strchr(e_extdialing, '#'))
return;
*strchr(e_extdialing, '#') = '\0';
}
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal %s: storing forwarding to '%s'.\n", ea_endpoint->ep_serial, e_ext.number, dest);
- if (read_extension(&e_ext, e_ext.number))
- {
- switch(diversion)
- {
+ if (read_extension(&e_ext, e_ext.number)) {
+ switch(diversion) {
case INFO_DIVERSION_CFU:
trace_header("ACTION change-forward (new CFU=unconditional)", DIRECTION_NONE);
add_trace("destin'", NULL, "%s", dest);
struct port_list *portlist = ea_endpoint->ep_portlist;
e_select = 0;
- if (!e_ext.last_out[0])
- {
+ if (!e_ext.last_out[0]) {
trace_header("ACTION redial/reply (no last number stored)", DIRECTION_NONE);
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
goto nodisplay;
/* scroll menu */
- if (e_extdialing[0]=='*' || e_extdialing[0]=='1')
- {
+ if (e_extdialing[0]=='*' || e_extdialing[0]=='1') {
/* find prev entry */
e_select--;
if (e_select < 0)
e_select = 0;
}
- if (e_extdialing[0]=='#' || e_extdialing[0]=='3')
- {
+ if (e_extdialing[0]=='#' || e_extdialing[0]=='3') {
/* find next entry */
e_select++;
if (e_select >= MAX_REMEMBER) {
}
last = (in)?e_ext.last_in[e_select]:e_ext.last_out[e_select];
- if (e_extdialing[0]=='0' || e_extdialing[0]=='2')
- {
+ if (e_extdialing[0]=='0' || e_extdialing[0]=='2') {
nodisplay:
if (in)
trace_header("ACTION reply (dialing)", DIRECTION_NONE);
struct route_param *rparam;
/* power dialing only possible if we have a last dialed number */
- if (!e_ext.last_out[0])
- {
+ if (!e_ext.last_out[0]) {
trace_header("ACTION powerdial (no last number stored)", DIRECTION_NONE);
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
}
/* limit */
- if ((rparam = routeparam(e_action, PARAM_LIMIT)))
- {
+ if ((rparam = routeparam(e_action, PARAM_LIMIT))) {
e_powerlimit = rparam->integer_value;
- } else
- {
+ } else {
e_powerlimit = 0;
}
/* delay */
- if ((rparam = routeparam(e_action, PARAM_DELAY)))
- {
+ if ((rparam = routeparam(e_action, PARAM_DELAY))) {
e_powerdelay = rparam->integer_value;
- } else
- {
+ } else {
/* delay incomplete */
if (!strchr(e_extdialing, '#'))
return;
portlist = ea_endpoint->ep_portlist;
/* check given extension */
- if (!(rparam = routeparam(e_action, PARAM_EXTENSION)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_EXTENSION))) {
noextension:
trace_header("ACTION callback (no extension defined)", DIRECTION_NONE);
end_trace();
/* read callback extension */
memset(&cbext, 0, sizeof(cbext));
- if (!read_extension(&cbext, e_cbcaller))
- {
+ if (!read_extension(&cbext, e_cbcaller)) {
trace_header("ACTION callback (extension doesn't exist)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", e_cbcaller);
end_trace();
}
/* if password is not given */
- if (cbext.password[0] == '\0')
- {
+ if (cbext.password[0] == '\0') {
trace_header("ACTION callback (no password set)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", e_cbcaller);
end_trace();
/* callback only possible if callerid exists OR it is given */
if ((rparam = routeparam(e_action, PARAM_CALLTO)))
SCPY(e_cbto, rparam->string_value);
- if (e_cbto[0])
- {
+ if (e_cbto[0]) {
trace_header("ACTION callback (alternative caller id)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", e_cbcaller);
add_trace("callerid", NULL, "%s", e_cbto);
e_callerinfo.ntype = INFO_NTYPE_UNKNOWN;
e_callerinfo.present = INFO_PRESENT_ALLOWED;
}
- if (e_callerinfo.id[0]=='\0' || e_callerinfo.present==INFO_PRESENT_NOTAVAIL)
- {
+ if (e_callerinfo.id[0]=='\0' || e_callerinfo.present==INFO_PRESENT_NOTAVAIL) {
trace_header("ACTION callback (no caller ID available)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", e_cbcaller);
end_trace();
portlist = ea_endpoint->ep_portlist;
/* abbrev dialing is only possible if we have a caller defined */
- if (!e_ext.number[0])
- {
+ if (!e_ext.number[0]) {
trace_header("ACTION abbreviation (only for extension)", DIRECTION_NONE);
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
phone = NULL;
name = NULL;
result = parse_phonebook(e_ext.number, &abbrev, &phone, &name);
- if (result == 0)
- {
+ if (result == 0) {
trace_header("ACTION abbreviation (not found)", DIRECTION_NONE);
add_trace("abbrev", NULL, "%s", abbrev);
end_trace();
set_tone(portlist, "cause_01");
return;
}
- if (result == -1) /* may match if more digits are dialed */
- {
+ if (result == -1) { /* may match if more digits are dialed */
return;
}
SCPY(testcode, rparam->string_value);
SCAT(testcode, e_extdialing);
- switch(testcode[0])
- {
+ switch(testcode[0]) {
case '1':
trace_header("ACTION test", DIRECTION_NONE);
add_trace("test", NULL, "proceeding");
logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT);
port = find_port_id(portlist->port_id);
- if (port)
- {
+ if (port) {
port->set_echotest(1);
}
break;
struct port_list *portlist = ea_endpoint->ep_portlist;
/* check given sample */
- if (!(rparam = routeparam(e_action, PARAM_SAMPLE)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_SAMPLE))) {
trace_header("ACTION play (no sample given)", DIRECTION_NONE);
end_trace();
}
/* if sample is given */
- if (rparam->string_value[0] == '\0')
- {
+ if (rparam->string_value[0] == '\0') {
trace_header("ACTION play (no sample given)", DIRECTION_NONE);
end_trace();
goto disconnect;
portlist = ea_endpoint->ep_portlist;
/* remove error message */
- if (!strncmp(e_extdialing, "Error", 5))
- {
+ if (!strncmp(e_extdialing, "Error", 5)) {
UCPY(e_extdialing, e_extdialing+5);
}
- if (!strncmp(e_extdialing, "inf", 3))
- {
+ if (!strncmp(e_extdialing, "inf", 3)) {
UCPY(e_extdialing, e_extdialing+3);
}
- if (!strncmp(e_extdialing, "-inf", 4))
- {
+ if (!strncmp(e_extdialing, "-inf", 4)) {
UCPY(e_extdialing, e_extdialing+4);
}
if (!p)
return;
first = 1;
- while(*p)
- {
- if (*p>='0' && *p<='9')
- {
+ while(*p) {
+ if (*p>='0' && *p<='9') {
#if 0
- if (first)
- {
+ if (first) {
UCPY(p, p+1);
continue;
}
- if ((p[-1]<'0' || p[-1]>'0') && p[-1]!='.')
- {
+ if ((p[-1]<'0' || p[-1]>'0') && p[-1]!='.') {
p--;
UCPY(p, p+1);
continue;
}
#endif
- switch(state)
- {
+ switch(state) {
case 0: /* first number */
- if (!komma1)
- {
+ if (!komma1) {
value1 = value1*10 + (*p-'0');
- } else
- {
+ } else {
k = komma1++;
v = *p-'0';
while(k--)
}
break;
case 1: /* second number */
- if (!komma2)
- {
+ if (!komma2) {
value2 = value2*10 + (*p-'0');
- } else
- {
+ } else {
k = komma2++;
v = *p-'0';
while(k--)
break;
}
} else
- switch(*p)
- {
+ switch(*p) {
case '*':
- if (first)
- {
+ if (first) {
UCPY(e_extdialing, "Error");
goto done;
}
/* if there is a multiplication, we change to / */
- if (p[-1] == '*')
- {
+ if (p[-1] == '*') {
mode = 1;
p[-1] = '/';
UCPY(p, p+1);
break;
}
/* if there is a division, we change to + */
- if (p[-1] == '/')
- {
+ if (p[-1] == '/') {
mode = 2;
p[-1] = '+';
UCPY(p, p+1);
break;
}
/* if there is a addition, we change to - */
- if (p[-1] == '+')
- {
+ if (p[-1] == '+') {
mode = 3;
p[-1] = '-';
UCPY(p, p+1);
break;
}
/* if there is a substraction and a comma, we change to * */
- if (p[-1]=='-' && komma1)
- {
+ if (p[-1]=='-' && komma1) {
mode = 0;
p[-1] = '*';
UCPY(p, p+1);
break;
}
/* if there is a substraction and no comma and the first or second value, we change to , */
- if (p[-1]=='-')
- {
+ if (p[-1]=='-') {
p[-1] = '.';
UCPY(p, p+1);
p--;
break;
}
/* if there is a komma and we are at the first value, we change to * */
- if (p[-1]=='.' && state==0)
- {
+ if (p[-1]=='.' && state==0) {
mode = 0;
p[-1] = '*';
UCPY(p, p+1);
break;
}
/* if there is a komma and we are at the second value, we display error */
- if (komma2 && state==1)
- {
+ if (komma2 && state==1) {
UCPY(e_extdialing, "Error");
goto done;
}
/* if we are at state 1, we write a comma */
- if (state == 1)
- {
+ if (state == 1) {
*p = '.';
komma2 = 1;
break;
case '#':
/* if just a number is displayed, the input is cleared */
- if (state==0)
- {
+ if (state==0) {
*e_extdialing = '\0';
break;
}
/* calculate the result */
- switch(mode)
- {
+ switch(mode) {
case 0: /* multiply */
UNPRINT(e_extdialing, sizeof(e_dialinginfo.id)-strlen(e_dialinginfo.id), "%.8f", sign1*value1*value2);
break;
break;
}
e_dialinginfo.id[sizeof(e_dialinginfo.id)-1] = '\0';
- if (strchr(e_extdialing, '.')) /* remove zeroes */
- {
+ if (strchr(e_extdialing, '.')) { /* remove zeroes */
while (e_extdialing[strlen(e_extdialing)-1] == '0')
e_extdialing[strlen(e_extdialing)-1] = '\0';
if (e_extdialing[strlen(e_extdialing)-1] == '.')
break;
case '-':
- if (first)
- {
+ if (first) {
sign1=-1;
break;
}
struct route_param *rparam;
/* check given ruleset */
- if (!(rparam = routeparam(e_action, PARAM_RULESET)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_RULESET))) {
no_ruleset:
trace_header("ACTION goto/menu (no ruleset given)", DIRECTION_NONE);
end_trace();
if (rparam->string_value[0] == '\0')
goto no_ruleset;
e_ruleset = getrulesetbyname(rparam->string_value);
- if (!e_ruleset)
- {
+ if (!e_ruleset) {
trace_header("ACTION goto/menu (ruleset not found)", DIRECTION_NONE);
add_trace("ruleset", NULL, "%s", rparam->string_value);
end_trace();
}
/* if the 'menu' was selected, we will flush all digits */
- if (mode)
- {
+ if (mode) {
e_dialinginfo.id[0] = 0;
e_extdialing = e_dialinginfo.id;
- } else
- {
+ } else {
/* remove digits that are required to match the rule */
- if ((rparam = routeparam(e_action, PARAM_STRIP)))
- {
+ if ((rparam = routeparam(e_action, PARAM_STRIP))) {
if (e_extdialing)
SCPY(e_dialinginfo.id, e_extdialing);
e_extdialing = e_dialinginfo.id;
/* play sample */
trace_header("ACTION goto/menu (change to)", DIRECTION_NONE);
add_trace("ruleset", NULL, "%s", e_ruleset->name);
- if (e_dialinginfo.id[0])
- {
+ if (e_dialinginfo.id[0]) {
add_trace("dialing", NULL, "%s", e_dialinginfo.id);
}
- if ((rparam = routeparam(e_action, PARAM_SAMPLE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_SAMPLE))) {
add_trace("sample", NULL, "%s", rparam->string_value);
end_trace();
set_tone(ea_endpoint->ep_portlist, rparam->string_value);
- } else
- {
+ } else {
end_trace();
}
char cause_string[256] = "", display[84] = "";
/* check cause parameter */
- if ((rparam = routeparam(e_action, PARAM_CAUSE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CAUSE))) {
cause = rparam->integer_value;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): 'cause' is given: %d\n", ea_endpoint->ep_serial, cause);
}
- if ((rparam = routeparam(e_action, PARAM_LOCATION)))
- {
+ if ((rparam = routeparam(e_action, PARAM_LOCATION))) {
location = rparam->integer_value;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): 'location' is given: %d\n", ea_endpoint->ep_serial, location);
}
SPRINT(cause_string, "cause_%02x", cause);
/* check sample parameter */
- if ((rparam = routeparam(e_action, PARAM_SAMPLE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_SAMPLE))) {
SCPY(cause_string, rparam->string_value);
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): 'sample' is given: %s\n", ea_endpoint->ep_serial, cause_string);
}
/* check display */
- if ((rparam = routeparam(e_action, PARAM_DISPLAY)))
- {
+ if ((rparam = routeparam(e_action, PARAM_DISPLAY))) {
SCPY(display, rparam->string_value);
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): 'display' is given: %s\n", ea_endpoint->ep_serial, display);
}
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
set_tone(portlist, cause_string);
- if (!(rparam = routeparam(e_action, PARAM_CONNECT)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_CONNECT))) {
message_disconnect_port(portlist, cause, location, display);
- } else
- {
+ } else {
message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_portlist->port_id, EPOINT_TO_PORT, MESSAGE_NOTIFY);
SCPY(message->param.notifyinfo.display, display);
message_put(message);
return;
/* scroll menu */
- if (strchr(e_dialinginfo.id,'*'))
- {
+ if (strchr(e_dialinginfo.id,'*')) {
e_menu--;
e_dialinginfo.id[0] = '\0';
}
- if (strchr(e_dialinginfo.id,'#'))
- {
+ if (strchr(e_dialinginfo.id,'#')) {
e_menu++;
e_dialinginfo.id[0] = '\0';
}
/* get position in menu */
- if (e_menu < 0)
- {
+ if (e_menu < 0) {
/* get last menu position */
e_menu = 0;
- while(numbering->next)
- {
+ while(numbering->next) {
e_menu++;
numbering = numbering->next;
}
- } else
- {
+ } else {
/* get menu position */
i = 0;
- while(i < e_menu)
- {
+ while(i < e_menu) {
numbering = numbering->next;
- if (!numbering)
- {
+ if (!numbering) {
e_menu = 0;
numbering = numbering_int;
break;
}
/* if we dial something else we need to add the prefix and change the action */
- if (e_dialinginfo.id[0])
- {
+ if (e_dialinginfo.id[0]) {
e_action = NUMB_ACTION_NONE;
SCPY(dialing, numbering->prefix);
//we ignore the first digit after selecting
executeon = rparam->integer_value;
/* Execute this action if init was specified */
- if (executeon == INFO_ON_INIT)
- {
+ if (executeon == INFO_ON_INIT) {
trace_header("ACTION execute ON init", DIRECTION_NONE);
end_trace();
action_execute();
executeon = rparam->integer_value;
/* Execute this action if init was specified */
- if (executeon == INFO_ON_HANGUP)
- {
+ if (executeon == INFO_ON_HANGUP) {
trace_header("ACTION execute ON hangup", DIRECTION_NONE);
end_trace();
action_execute();
/* get script / command */
if ((rparam = routeparam(e_action, PARAM_EXECUTE)))
command = rparam->string_value;
- if (command[0] == '\0')
- {
+ if (command[0] == '\0') {
trace_header("ACTION execute (no parameter given)", DIRECTION_NONE);
end_trace();
return;
argv[i++] = (char *)"-c";
argv[i++] = command;
argv[i++] = command;
- if ((rparam = routeparam(e_action, PARAM_PARAM)))
- {
+ if ((rparam = routeparam(e_action, PARAM_PARAM))) {
argv[i++] = rparam->string_value;
}
argv[i++] = e_extdialing;
break;
case 0:
/* To be shure there are no zombies created double fork */
- if ((pid2 = fork()) == 0)
- {
+ if ((pid2 = fork()) == 0) {
execve("/bin/sh", argv, environ);
}
- else
- {
+ else {
/* Exit immediately and release the waiting parent. The subprocess falls to init because the parent died */
exit(0);
}
mode = "a";
else
mode = "w";
- if (file[0] == '\0')
- {
+ if (file[0] == '\0') {
trace_header("ACTION file (no filename given)", DIRECTION_NONE);
end_trace();
return;
}
- if (!(fp = fopen(file, mode)))
- {
+ if (!(fp = fopen(file, mode))) {
trace_header("ACTION file (failed to open)", DIRECTION_NONE);
add_trace("file", "name", "%s", file);
add_trace("file", "mode", "%s", (mode[0]=='w')?"write":"append");
struct port_list *portlist = ea_endpoint->ep_portlist;
/* prompt for password */
- if (e_extdialing[0] == '\0')
- {
+ if (e_extdialing[0] == '\0') {
/* give password tone */
set_tone(portlist, "password");
} else // ELSE!!
- if (e_extdialing[1] == '\0')
- {
+ if (e_extdialing[1] == '\0') {
/* give password tone */
set_tone(portlist, "dialing");
}
return; /* more digits needed */
/* check the password */
- if (e_ext.password[0]=='\0' || (strlen(e_ext.password)==strlen(e_extdialing) && !!strcmp(e_ext.password,e_extdialing)))
- {
+ if (e_ext.password[0]=='\0' || (strlen(e_ext.password)==strlen(e_extdialing) && !!strcmp(e_ext.password,e_extdialing))) {
trace_header("ACTION password_write (wrong password)", DIRECTION_NONE);
add_trace("dialed", NULL, "%s", e_extdialing);
end_trace();
/* write caller id if ACTION_PASSWORD_WRITE was selected */
if (e_action)
- if (e_action->index == ACTION_PASSWORD_WRITE)
- {
+ if (e_action->index == ACTION_PASSWORD_WRITE) {
append_callbackauth(e_ext.number, &e_callbackinfo);
trace_header("ACTION password_write (written)", DIRECTION_NONE);
add_trace("dialed", NULL, "%s", e_extdialing);
//PDEBUG(~0, "HANG-BUG-DEBUGGING: entered porcess_dialing\n");
portlist = ea_endpoint->ep_portlist;
/* check if we have a port instance linked to our epoint */
- if (!portlist)
- {
+ if (!portlist) {
portlist_error:
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): note: dialing call requires exactly one port object to process dialing. this case could happen due to a parked call. we end dialing here.\n", ea_endpoint->ep_serial, e_ext.number);
e_action_timeout = 0;
e_match_timeout = 0;
return;
}
- if (portlist->next)
- {
+ if (portlist->next) {
goto portlist_error;
}
/* check nesting levels */
- if (++e_rule_nesting > RULE_NESTING)
- {
+ if (++e_rule_nesting > RULE_NESTING) {
trace_header("ACTION (nesting too deep)", DIRECTION_NONE);
add_trace("max-levels", NULL, "%d", RULE_NESTING);
end_trace();
//PDEBUG(~0, "HANG-BUG-DEBUGGING: before action-timeout processing\n");
/* process timeout */
- if (e_action && e_action_timeout) /* e_action may be NULL, but e_action_timeout may still be set and must be ignored */
- {
+ if (e_action && e_action_timeout) { /* e_action may be NULL, but e_action_timeout may still be set and must be ignored */
e_action_timeout = 0;
- if (e_state == EPOINT_STATE_CONNECT)
- {
+ if (e_state == EPOINT_STATE_CONNECT) {
PDEBUG(DEBUG_ROUTE|DEBUG_EPOINT, "EPOINT(%d): action timed out, but we already have connected, so we stop timer and continue.\n", ea_endpoint->ep_serial);
goto end;
}
if (e_action->index == ACTION_DISCONNECT
- || e_state == EPOINT_STATE_OUT_DISCONNECT)
- {
+ || e_state == EPOINT_STATE_OUT_DISCONNECT) {
/* release after disconnect */
release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL);
goto end;
}
release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, 0, 0);
e_action = e_action->next;
- if (!e_action)
- {
+ if (!e_action) {
/* nothing more, so we release */
PDEBUG(DEBUG_ROUTE|DEBUG_EPOINT, "EPOINT(%d): action timed out, and we have no next action, so we disconnect.\n", ea_endpoint->ep_serial);
new_state(EPOINT_STATE_OUT_DISCONNECT);
//PDEBUG(~0, "HANG-BUG-DEBUGGING: before setup/overlap state checking\n");
if (e_state!=EPOINT_STATE_IN_SETUP
- && e_state!=EPOINT_STATE_IN_OVERLAP)
- {
+ && e_state!=EPOINT_STATE_IN_OVERLAP) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): we are not in incoming setup/overlap state, so we ignore init/dialing process.\n", ea_endpoint->ep_serial, e_rule_nesting);
e_match_timeout = 0;
goto end;
/* check if we do menu selection */
if (e_action==NUMB_ACTION_NONE && (e_dialinginfo.id[0]=='*' || e_dialinginfo.id[0]=='#'))
/* do menu selection */
- if (e_ext.display_menu)
- {
- if (portlist->port_type==PORT_TYPE_DSS1_NT_IN || portlist->port_type==PORT_TYPE_DSS1_NT_OUT) /* only if the dialing terminal is an isdn telephone connected to an internal port */
- {
+ if (e_ext.display_menu) {
+ if (portlist->port_type==PORT_TYPE_DSS1_NT_IN || portlist->port_type==PORT_TYPE_DSS1_NT_OUT) { /* only if the dialing terminal is an isdn telephone connected to an internal port */
e_dialinginfo.id[0] = '\0';
e_action = NUMB_ACTION_MENU;
e_menu = 0;
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_DISCONNECT);
message->param.disconnectinfo.cause = CAUSE_INVALID;
message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
- } else
- {
+ } else {
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_NOTIFY);
SCPY(message->param.notifyinfo.display,get_isdn_cause(LOCATION_PRIVATE_LOCAL, epoint->e_ext.display_cause, param->disconnectinfo.location, param->disconnectinfo.cause));
}
//PDEBUG(~0, "HANG-BUG-DEBUGGING: before e_action==NULL\n");
/* if no action yet, we will call try to find a matching rule */
- if (!e_action)
- {
+ if (!e_action) {
/* be sure that all selectors are initialized */
e_select = 0;
/* check for external call */
- if (!strncmp(e_dialinginfo.id, "extern:", 7))
- {
+ if (!strncmp(e_dialinginfo.id, "extern:", 7)) {
e_extdialing = e_dialinginfo.id+7;
e_action = &action_external;
goto process_action;
}
/* check for internal call */
- if (!strncmp(e_dialinginfo.id, "intern:", 7))
- {
+ if (!strncmp(e_dialinginfo.id, "intern:", 7)) {
e_extdialing = e_dialinginfo.id+7;
e_action = &action_internal;
goto process_action;
}
/* check for chan call */
- if (!strncmp(e_dialinginfo.id, "remote:", 7))
- {
+ if (!strncmp(e_dialinginfo.id, "remote:", 7)) {
e_extdialing = e_dialinginfo.id+7;
e_action = &action_remote;
goto process_action;
}
/* check for vbox call */
- if (!strncmp(e_dialinginfo.id, "vbox:", 5))
- {
+ if (!strncmp(e_dialinginfo.id, "vbox:", 5)) {
e_extdialing = e_dialinginfo.id+5;
e_action = &action_vbox;
goto process_action;
}
- if (e_match_timeout && now_d>=e_match_timeout)
- {
+ if (e_match_timeout && now_d>=e_match_timeout) {
/* return timeout rule */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal '%s' dialing: '%s', timeout in ruleset '%s'\n", ea_endpoint->ep_serial, e_ext.number, e_dialinginfo.id, e_ruleset->name);
e_match_timeout = 0;
add_trace("action", NULL, "%s", action_defs[e_action->index].name);
add_trace("line", NULL, "%d", e_action->line);
end_trace();
- } else
- {
+ } else {
//PDEBUG(~0, "HANG-BUG-DEBUGGING: before routing\n");
/* check for matching rule */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal '%s' dialing: '%s', checking matching rule of ruleset '%s'\n", ea_endpoint->ep_serial, e_ext.number, e_dialinginfo.id, e_ruleset->name);
- if (e_ruleset)
- {
+ if (e_ruleset) {
e_action = route(e_ruleset);
- if (e_action)
- {
+ if (e_action) {
trace_header("ACTION (match)", DIRECTION_NONE);
add_trace("action", NULL, "%s", action_defs[e_action->index].name);
add_trace("line", NULL, "%d", e_action->line);
end_trace();
}
- } else
- {
+ } else {
e_action = &action_disconnect;
- if (e_action)
- {
+ if (e_action) {
trace_header("ACTION (no main ruleset, disconnecting)", DIRECTION_NONE);
end_trace();
}
}
//PDEBUG(~0, "HANG-BUG-DEBUGGING: after routing\n");
}
- if (!e_action)
- {
+ if (!e_action) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): no rule within the current ruleset matches yet.\n", ea_endpoint->ep_serial, e_ext.number);
goto display;
}
/* set timeout */
e_action_timeout = 0;
- if (e_action->timeout)
- {
+ if (e_action->timeout) {
e_action_timeout = now_d + e_action->timeout;
PDEBUG(DEBUG_ROUTE|DEBUG_EPOINT, "EPOINT(%d): action has a timeout of %d secods.\n", ea_endpoint->ep_serial, e_action->timeout);
}
process_action:
/* check param proceeding / alerting / connect */
- if ((rparam = routeparam(e_action, PARAM_CONNECT)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CONNECT))) {
/* NOTE: we may not change our state to connect, because dialing will then not possible */
e_dtmf = 1;
memset(&e_connectinfo, 0, sizeof(e_connectinfo));
message_put(message);
logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT);
} else
- if ((rparam = routeparam(e_action, PARAM_ALERTING)))
- {
+ if ((rparam = routeparam(e_action, PARAM_ALERTING))) {
/* NOTE: we may not change our state to alerting, because dialing will then not possible */
memset(&e_connectinfo, 0, sizeof(e_connectinfo));
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_ALERTING);
message_put(message);
logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT);
} else
- if ((rparam = routeparam(e_action, PARAM_PROCEEDING)))
- {
+ if ((rparam = routeparam(e_action, PARAM_PROCEEDING))) {
/* NOTE: we may not change our state to proceeding, because dialing will then not possible */
memset(&e_connectinfo, 0, sizeof(e_connectinfo));
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_PROCEEDING);
logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT);
}
- if (action_defs[e_action->index].init_func)
- {
+ if (action_defs[e_action->index].init_func) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal %s: current action '%s' has a init function, so we call it...\n", ea_endpoint->ep_serial, e_ext.number, action_defs[e_action->index].name);
(this->*(action_defs[e_action->index].init_func))();
}
if (e_state!=EPOINT_STATE_IN_SETUP
- && e_state!=EPOINT_STATE_IN_OVERLAP)
- {
+ && e_state!=EPOINT_STATE_IN_OVERLAP) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): AFTER init process: we are not in incoming setup/overlap state anymore, so we ignore further dialing process.\n", ea_endpoint->ep_serial, e_rule_nesting);
goto display_action;
}
/* show what we are doing */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal '%s' action: %s (dialing '%s')\n", ea_endpoint->ep_serial, e_ext.number, action_defs[e_action->index].name, e_extdialing);
/* go to action's dialing function */
- if (action_defs[e_action->index].dialing_func)
- {
+ if (action_defs[e_action->index].dialing_func) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal %s: current action '%s' has a dialing function, so we call it...\n", ea_endpoint->ep_serial, e_ext.number, action_defs[e_action->index].name);
(this->*(action_defs[e_action->index].dialing_func))();
}
/* display selected dialing action if enabled and still in setup state */
display_action:
- if (e_action)
- {
+ if (e_action) {
if (e_action->index==ACTION_MENU
|| e_action->index==ACTION_REDIAL
|| e_action->index==ACTION_REPLY
if (!e_ext.display_dialing)
goto end;
if (e_state==EPOINT_STATE_IN_OVERLAP || e_state==EPOINT_STATE_IN_PROCEEDING || e_state==EPOINT_STATE_IN_ALERTING || e_state==EPOINT_STATE_CONNECT/* || e_state==EPOINT_STATE_IN_DISCONNECT || e_state==EPOINT_STATE_OUT_DISCONNECT*/)
- if (portlist->port_type==PORT_TYPE_DSS1_NT_IN || portlist->port_type==PORT_TYPE_DSS1_NT_OUT) /* only if the dialing terminal is an isdn telephone connected to an internal port */
- {
+ if (portlist->port_type==PORT_TYPE_DSS1_NT_IN || portlist->port_type==PORT_TYPE_DSS1_NT_OUT) { /* only if the dialing terminal is an isdn telephone connected to an internal port */
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_NOTIFY);
- if (!e_action)
- {
+ if (!e_action) {
SPRINT(message->param.notifyinfo.display, "> %s", e_dialinginfo.id);
- } else
- {
+ } else {
SPRINT(message->param.notifyinfo.display, "%s%s%s", action_defs[e_action->index].name, (e_extdialing[0])?" ":"", e_extdialing);
}
int writeext = 0, i;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal '%s'\n", ea_endpoint->ep_serial, e_ext.number);
- if (e_ext.number[0])
- {
+ if (e_ext.number[0]) {
if (read_extension(&e_ext, e_ext.number))
writeext = 0x10;
- if (!e_start)
- {
+ if (!e_start) {
time(&e_start);
e_stop = 0;
} else
if (!e_stop)
time(&e_stop);
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): writing connect from %s to %s into logfile of %s\n", ea_endpoint->ep_serial, e_callerinfo.id, e_dialinginfo.id, e_ext.number);
- switch(e_dialinginfo.itype)
- {
+ switch(e_dialinginfo.itype) {
case INFO_ITYPE_CHAN:
SPRINT(dialingtext, "chan:%s", e_dialinginfo.id);
break;
/* store last received call for reply-list */
if (e_origin == 1) // outgoing to phone is incoming for user
if (e_callerinfo.id[0] || e_callerinfo.extension[0])
- if (e_ext.anon_ignore || e_callerinfo.present!=INFO_PRESENT_RESTRICTED)
- {
+ if (e_ext.anon_ignore || e_callerinfo.present!=INFO_PRESENT_RESTRICTED) {
if (e_callerinfo.extension[0])
SPRINT(callertext, "intern:%s", e_callerinfo.extension);
else
SPRINT(callertext, "extern:%s", numberrize_callerinfo(e_callerinfo.id, e_callerinfo.ntype, options.national, options.international));
- if (!!strcmp(callertext, e_ext.last_in[0]))
- {
+ if (!!strcmp(callertext, e_ext.last_in[0])) {
i = MAX_REMEMBER-1;
- while(i)
- {
+ while(i) {
UCPY(e_ext.last_in[i], e_ext.last_in[i-1]);
i--;
}
/* store last made call for reply-list */
if (e_origin == 0) // incoming from phone is outgoing for user
- if (e_dialinginfo.id[0])
- {
- if (!!strcmp(e_dialinginfo.id, e_ext.last_out[0]))
- {
+ if (e_dialinginfo.id[0]) {
+ if (!!strcmp(e_dialinginfo.id, e_ext.last_out[0])) {
i = MAX_REMEMBER-1;
- while(i)
- {
+ while(i) {
UCPY(e_ext.last_out[i], e_ext.last_out[i-1]);
i--;
}
if (writeext == 0x11)
write_extension(&e_ext, e_ext.number);
- if (e_action)
- {
- if (action_defs[e_action->index].hangup_func)
- {
+ if (e_action) {
+ if (action_defs[e_action->index].hangup_func) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal %s: current action '%s' has a hangup function, so we call it...\n", ea_endpoint->ep_serial, e_ext.number, action_defs[e_action->index].name);
(this->*(action_defs[e_action->index].hangup_func))();
}
struct port_list *portlist = ea_endpoint->ep_portlist;
/* if no caller id */
- if (e_callerinfo.id[0] == '\0')
- {
+ if (e_callerinfo.id[0] == '\0') {
/* facility rejected */
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_DISCONNECT);
message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) terminal %s end of file during state: %d\n", ea_endpoint->ep_serial, e_ext.number, e_vbox_state);
- switch(e_efi_state)
- {
+ switch(e_efi_state) {
case EFI_STATE_HELLO:
e_efi_state = EFI_STATE_DIE;
set_tone_efi("die");
break;
case EFI_STATE_DIE:
- if (e_callerinfo.screen==INFO_SCREEN_USER)
- {
+ if (e_callerinfo.screen==INFO_SCREEN_USER) {
e_efi_state = EFI_STATE_BENUTZERDEFINIERTE;
set_tone_efi("benutzerdefinierte");
break;
}
// fall through
case EFI_STATE_BENUTZERDEFINIERTE:
- if (e_callerinfo.present==INFO_PRESENT_RESTRICTED)
- {
+ if (e_callerinfo.present==INFO_PRESENT_RESTRICTED) {
e_efi_state = EFI_STATE_UNTERDRUECKTE;
set_tone_efi("unterdrueckte");
break;
// fall through
case EFI_STATE_DIGIT:
digit[8] = numberrize_callerinfo(e_callerinfo.id,e_callerinfo.ntype, options.national, options.international)[e_efi_digit];
- if (digit[8])
- {
+ if (digit[8]) {
set_tone_efi(digit);
e_efi_digit++;
- } else
- {
+ } else {
// e_efi_state = EFI_STATE_STOP;
e_efi_state = EFI_STATE_ICH_WIEDERHOLE;
// message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_DISCONNECT);
if (tone == NULL)
tone = "";
- if (!ea_endpoint->ep_portlist)
- {
+ if (!ea_endpoint->ep_portlist) {
PERROR("EPOINT(%d) no portlist\n", ea_endpoint->ep_serial);
}
message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_portlist->port_id, EPOINT_TO_PORT, MESSAGE_VBOX_TONE);
SCPY(e_vbox, e_ext.number);
if ((rparam = routeparam(e_action, PARAM_EXTENSION)))
SCPY(e_vbox, rparam->string_value);
- if (e_vbox[0] == '\0')
- {
+ if (e_vbox[0] == '\0') {
/* facility rejected */
message_disconnect_port(portlist, CAUSE_FACILITYREJECTED, LOCATION_PRIVATE_LOCAL, "");
new_state(EPOINT_STATE_OUT_DISCONNECT);
vbox_index_read(e_vbox_play);
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) number of calls: %d\n", ea_endpoint->ep_serial, e_vbox_index_num);
- if (e_vbox_index_num == 0)
- {
+ if (e_vbox_index_num == 0) {
e_vbox_state = VBOX_STATE_NOTHING;
SCPY(e_vbox_display, (char *)((language)?"keine Anrufe":"no calls"));
e_vbox_display_refresh = 1;
e_vbox_index_num = 0;
SPRINT(filename, "%s/%s/vbox/index", EXTENSION_DATA, e_vbox);
- if (!(fp = fopen(filename, "r")))
- {
+ if (!(fp = fopen(filename, "r"))) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) no files in index\n", ea_endpoint->ep_serial);
return;
}
fduse++;
i = 0;
- while((fgets(buffer,sizeof(buffer),fp)))
- {
+ while((fgets(buffer,sizeof(buffer),fp))) {
buffer[sizeof(buffer)-1] = '\0';
if (buffer[0]) buffer[strlen(buffer)-1] = '\0';
continue;
/* the selected entry */
- if (i == num)
- {
+ if (i == num) {
SCPY(e_vbox_index_file, name);
e_vbox_index_year = year;
e_vbox_index_mon = mon;
SPRINT(filename1, "%s/%s/vbox/index", EXTENSION_DATA, e_vbox);
SPRINT(filename2, "%s/%s/vbox/index-temp", EXTENSION_DATA, e_vbox);
- if (!(fpr = fopen(filename1, "r")))
- {
+ if (!(fpr = fopen(filename1, "r"))) {
return;
}
- if (!(fpw = fopen(filename2, "w")))
- {
+ if (!(fpw = fopen(filename2, "w"))) {
fclose(fpr);
return;
}
fduse += 2;
i = 0;
- while((fgets(buffer,sizeof(buffer),fpr)))
- {
+ while((fgets(buffer,sizeof(buffer),fpr))) {
buffer[sizeof(buffer)-1] = '\0';
if (buffer[0]) buffer[strlen(buffer)-1] = '\0';
- if (buffer[0]=='\0' || buffer[0]=='#')
- {
+ if (buffer[0]=='\0' || buffer[0]=='#') {
fprintf(fpw, "%s\n", buffer);
continue;
}
/* the selected entry will not be written */
- if (i != num)
- {
+ if (i != num) {
fprintf(fpw, "%s\n", buffer);
}
portlist = ea_endpoint->ep_portlist;
- if (e_extdialing[0] == '\0')
- {
+ if (e_extdialing[0] == '\0') {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) called with no digit\n", ea_endpoint->ep_serial);
return;
}
e_vbox_display_refresh = 1;
- if (e_vbox_state == VBOX_STATE_RECORD_RECORD)
- {
- if (e_extdialing[0] == '1' || e_extdialing[0] == '0')
- {
+ if (e_vbox_state == VBOX_STATE_RECORD_RECORD) {
+ if (e_extdialing[0] == '1' || e_extdialing[0] == '0') {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) stopping recording of announcement.\n", ea_endpoint->ep_serial);
port = find_port_id(portlist->port_id);
goto done;
}
- if (e_vbox_state == VBOX_STATE_RECORD_PLAY)
- {
- if (e_extdialing[0] == '1')
- {
+ if (e_vbox_state == VBOX_STATE_RECORD_PLAY) {
+ if (e_extdialing[0] == '1') {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) stopping playback of announcement.\n", ea_endpoint->ep_serial);
goto record_ask;
goto done;
}
- if (e_vbox_state == VBOX_STATE_RECORD_ASK)
- {
- switch(e_extdialing[0])
- {
+ if (e_vbox_state == VBOX_STATE_RECORD_ASK) {
+ switch(e_extdialing[0]) {
case '3':
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) quit recoding menu.\n", ea_endpoint->ep_serial);
ask_abort:
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) record announcement.\n", ea_endpoint->ep_serial);
/* close recording if already recording */
port = find_port_id(portlist->port_id);
- if (port)
- {
+ if (port) {
port->close_record(0,0);
port->open_record(CODEC_MONO, 1, 4000, e_ext.number, 0, "", 0); /* record announcement, skip the first 4000 samples */
}
goto done;
}
- if (e_vbox_state==VBOX_STATE_STORE_ASK || e_vbox_state==VBOX_STATE_DELETE_ASK)
- {
+ if (e_vbox_state==VBOX_STATE_STORE_ASK || e_vbox_state==VBOX_STATE_DELETE_ASK) {
char filename[256], filename2[256];
- switch(e_extdialing[0])
- {
+ switch(e_extdialing[0]) {
case '3':
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) quit store/delete menu.\n", ea_endpoint->ep_serial);
goto ask_abort;
SPRINT(filename, "%s/%s/vbox/%s", EXTENSION_DATA, e_vbox, e_vbox_index_file);
/* move file */
- if (e_vbox_state == VBOX_STATE_STORE_ASK)
- {
+ if (e_vbox_state == VBOX_STATE_STORE_ASK) {
SPRINT(filename, "%s/%s/recordings", EXTENSION_DATA, e_vbox);
- if (mkdir(filename, 0755) < 0)
- {
- if (errno != EEXIST)
- {
+ if (mkdir(filename, 0755) < 0) {
+ if (errno != EEXIST) {
PERROR("EPOINT(%d) cannot create directory '%s'\n", ea_endpoint->ep_serial, filename);
goto done;
}
}
/* remove file */
- if (e_vbox_state == VBOX_STATE_DELETE_ASK)
- {
+ if (e_vbox_state == VBOX_STATE_DELETE_ASK) {
remove(filename);
e_vbox_state = VBOX_STATE_DELETE_DONE;
if (e_ext.vbox_language)
vbox_index_remove(e_vbox_play);
vbox_index_read(e_vbox_play);
/* stay at the last message+1, so we always get "no messages" */
- if (e_vbox_play>e_vbox_index_num && e_vbox_play)
- {
+ if (e_vbox_play>e_vbox_index_num && e_vbox_play) {
e_vbox_play = e_vbox_index_num-1;
}
default:
}
/* dialing during menu */
- switch(e_extdialing[0])
- {
+ switch(e_extdialing[0]) {
/* process the vbox functions */
case '1': /* previous */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) previous call is selected.\n", ea_endpoint->ep_serial);
- if (e_vbox_index_num == 0) /* nothing to play */
- {
+ if (e_vbox_index_num == 0) { /* nothing to play */
no_calls:
e_vbox_state = VBOX_STATE_MENU;
SCPY(e_vbox_display, (char *)((language)?"keine Anrufe":"no calls"));
break;
}
e_vbox_play--;
- if (e_vbox_play < 0)
- {
+ if (e_vbox_play < 0) {
e_vbox_play = 0;
e_vbox_state = VBOX_STATE_MENU;
e_vbox_state = VBOX_STATE_CALLINFO_INTRO;
SPRINT(e_vbox_display, "#%d", e_vbox_play+1);
vbox_index_read(e_vbox_play);
- if (e_vbox_index_mon!=now_tm->tm_mon || e_vbox_index_year!=now_tm->tm_year)
- {
+ if (e_vbox_index_mon!=now_tm->tm_mon || e_vbox_index_year!=now_tm->tm_year) {
UPRINT(strchr(e_vbox_display,'\0'), " %s", (language)?months_german[e_vbox_index_mon]:months_english[e_vbox_index_mon]);
}
- if (e_vbox_index_mday!=now_tm->tm_mday || e_vbox_index_mon!=now_tm->tm_mon || e_vbox_index_year!=now_tm->tm_year)
- {
+ if (e_vbox_index_mday!=now_tm->tm_mday || e_vbox_index_mon!=now_tm->tm_mon || e_vbox_index_year!=now_tm->tm_year) {
UPRINT(strchr(e_vbox_display,'\0'), " %d", e_vbox_index_mday);
}
UPRINT(strchr(e_vbox_display,'\0'), " %02d:%02d", e_vbox_index_hour, e_vbox_index_min);
case '2': /* play */
if (e_vbox_play >= e_vbox_index_num)
goto no_messages;
- if (e_vbox_index_num == 0) /* nothing to play */
- {
+ if (e_vbox_index_num == 0) { /* nothing to play */
goto no_calls;
}
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) play call #%d.\n", ea_endpoint->ep_serial, e_vbox_play+1);
- if (e_vbox_state>VBOX_STATE_CALLINFO_BEGIN && e_vbox_state<VBOX_STATE_CALLINFO_END)
- {
+ if (e_vbox_state>VBOX_STATE_CALLINFO_BEGIN && e_vbox_state<VBOX_STATE_CALLINFO_END) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) play call #%d. abborting announcement and starting with playback\n", ea_endpoint->ep_serial, e_vbox_play+1);
/* the callinfo is played, so we start with the call */
e_vbox_counter = 0;
set_play_vbox(e_vbox_index_file, 0);
break;
} else
- if (e_vbox_state==VBOX_STATE_PLAY && e_vbox_speed!=1)
- {
+ if (e_vbox_state==VBOX_STATE_PLAY && e_vbox_speed!=1) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) play call #%d. play speed is different from 1, so we play now with normal speed\n", ea_endpoint->ep_serial, e_vbox_play+1);
/* we set play speed to normal */
e_vbox_speed = 1;
set_play_speed(e_vbox_speed);
} else
- if (e_vbox_state == VBOX_STATE_PLAY)
- {
+ if (e_vbox_state == VBOX_STATE_PLAY) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) play call #%d. play speed is equals 1, so we pause\n", ea_endpoint->ep_serial, e_vbox_play+1);
/* we pause the current play */
e_vbox_state = VBOX_STATE_PAUSE;
SCPY(e_vbox_display, (char *)((language)?"druecke 2 f. wiedergabe":"press 2 to play"));
set_tone_vbox("pause");
} else
- if (e_vbox_state == VBOX_STATE_PAUSE)
- {
+ if (e_vbox_state == VBOX_STATE_PAUSE) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) play call #%d. currently pause, so we continue play\n", ea_endpoint->ep_serial, e_vbox_play+1);
/* we continue the current play */
e_vbox_state = VBOX_STATE_PLAY;
if (e_ext.vbox_display == VBOX_DISPLAY_DETAILED)
UPRINT(strchr(e_vbox_display,'\0'), " (%s)", e_vbox_index_callerid);
set_play_vbox(e_vbox_index_file, e_vbox_counter);
- } else
- {
+ } else {
/* now we have something else going on, so we announce the call */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) play call #%d. announcing call during any other state\n", ea_endpoint->ep_serial, e_vbox_play+1);
goto announce_call;
case '3': /* next */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) next call is selected.\n", ea_endpoint->ep_serial);
- if (e_vbox_index_num == 0) /* nothing to play */
- {
+ if (e_vbox_index_num == 0) { /* nothing to play */
goto no_calls;
}
e_vbox_play++;
- if (e_vbox_play >= e_vbox_index_num)
- {
+ if (e_vbox_play >= e_vbox_index_num) {
no_messages:
e_vbox_play = e_vbox_index_num;
break;
case '4': /* rewind */
- if (e_vbox_state==VBOX_STATE_PLAY)
- {
+ if (e_vbox_state==VBOX_STATE_PLAY) {
if (e_vbox_speed >= -1)
e_vbox_speed = -1;
e_vbox_speed = e_vbox_speed * 2;
break;
case '6': /* wind */
- if (e_vbox_state==VBOX_STATE_PLAY)
- {
+ if (e_vbox_state==VBOX_STATE_PLAY) {
if (e_vbox_speed <= 1)
e_vbox_speed = 1;
e_vbox_speed = e_vbox_speed * 2;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) entering the store menu\n", ea_endpoint->ep_serial);
if (e_vbox_play >= e_vbox_index_num)
goto no_messages;
- if (e_vbox_index_num == 0) /* nothing to play */
- {
+ if (e_vbox_index_num == 0) { /* nothing to play */
goto no_calls;
}
e_vbox_state = VBOX_STATE_STORE_ASK;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) entering the delete menu\n", ea_endpoint->ep_serial);
if (e_vbox_play >= e_vbox_index_num)
goto no_messages;
- if (e_vbox_index_num == 0) /* nothing to play */
- {
+ if (e_vbox_index_num == 0) { /* nothing to play */
goto no_calls;
}
e_vbox_state = VBOX_STATE_DELETE_ASK;
break;
case '0':
- if (e_vbox_menu < 0) /* only if menu selection is pressed before*/
- {
+ if (e_vbox_menu < 0) { /* only if menu selection is pressed before*/
/* call if phonenumber is given */
if (e_vbox_index_num)
- if (e_vbox_index_callerid[0]!='\0' && !!strcmp(e_vbox_index_callerid,"anonymous") && !!strcmp(e_vbox_index_callerid,"unknown"))
- {
+ if (e_vbox_index_callerid[0]!='\0' && !!strcmp(e_vbox_index_callerid,"anonymous") && !!strcmp(e_vbox_index_callerid,"unknown")) {
set_tone(portlist, "dialing");
SPRINT(e_dialinginfo.id, "extern:%s", e_vbox_index_callerid);
e_extdialing = e_dialinginfo.id;
{
/* refresh if counter changes */
if (e_vbox_state==VBOX_STATE_PLAY || e_vbox_state==VBOX_STATE_RECORD_PLAY)
- if (e_vbox_counter != e_vbox_counter_last)
- {
+ if (e_vbox_counter != e_vbox_counter_last) {
e_vbox_counter_last = e_vbox_counter;
e_vbox_display_refresh = 1;
}
/* refresh display, if required (include counter) */
- if (e_vbox_display_refresh && e_ext.vbox_display!=VBOX_DISPLAY_OFF)
- {
+ if (e_vbox_display_refresh && e_ext.vbox_display!=VBOX_DISPLAY_OFF) {
char counter[32];
struct lcr_msg *message;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) terminal %s end of file during state: %d\n", ea_endpoint->ep_serial, e_ext.number, e_vbox_state);
- switch(e_vbox_state)
- {
+ switch(e_vbox_state) {
case VBOX_STATE_MENU:
case VBOX_STATE_NOTHING:
e_vbox_state = VBOX_STATE_MENU;
break;
case VBOX_STATE_PLAY:
- if (e_vbox_speed > 0)
- {
+ if (e_vbox_speed > 0) {
e_vbox_state = VBOX_STATE_MENU;
SCPY(e_vbox_display, (char *)((language)?"druecke 3 f. Naechste":"press 3 for next"));
e_vbox_display_refresh = 1;
set_tone_vbox("menu");
- } else
- {
+ } else {
/* if we have endoffile because we were playing backwards, we continue to play forward */
e_vbox_speed = 1;
e_vbox_counter = 1;
case VBOX_STATE_CALLINFO_MONTH:
e_vbox_state = VBOX_STATE_CALLINFO_DAY; //german month
- if (e_ext.vbox_language)
- {
+ if (e_ext.vbox_language) {
/* done with month, so we send the month*/
SPRINT(buffer, "month_%02d", e_vbox_index_mon+1);
- } else
- {
+ } else {
/* done with day, so we send the day */
SPRINT(buffer, "day_%02d", e_vbox_index_mday);
}
case VBOX_STATE_CALLINFO_DAY: //german month
skip_day_month:
e_vbox_state = VBOX_STATE_CALLINFO_HOUR;
- if (e_ext.vbox_language)
- {
+ if (e_ext.vbox_language) {
if (e_vbox_index_hour == 1)
SCPY(buffer, "number_ein");
else
SPRINT(buffer, "number_%02d", e_vbox_index_hour); /* 1-23 hours */
- } else
- {
+ } else {
SPRINT(buffer, "number_%02d", ((e_vbox_index_hour+11)%12)+1); /* 12 hours am/pm */
}
set_tone_vbox(buffer);
case VBOX_STATE_CALLINFO_HOUR:
e_vbox_state = VBOX_STATE_CALLINFO_OCLOCK;
- if (e_ext.vbox_language)
- {
+ if (e_ext.vbox_language) {
set_tone_vbox("oclock");
- } else
- {
+ } else {
if (e_vbox_index_hour >= 12)
set_tone_vbox("oclock_pm");
else
case VBOX_STATE_CALLINFO_OCLOCK:
e_vbox_state = VBOX_STATE_CALLINFO_MIN;
- if (e_ext.vbox_language)
- {
+ if (e_ext.vbox_language) {
// german says "zwölfuhr und eins"
// if (e_vbox_index_min == 1)
// SCPY(buffer, "number_eine");
// else
SPRINT(buffer, "number_%02d", e_vbox_index_min); /* 1-59 minutes */
- } else
- {
+ } else {
SPRINT(buffer, "number_%02d", e_vbox_index_min);
}
set_tone_vbox(buffer);
case VBOX_STATE_CALLINFO_MINUTES:
start_digits:
e_vbox_state = VBOX_STATE_CALLINFO_DIGIT;
- if (e_vbox_index_callerid[0]=='\0' || !strcmp(e_vbox_index_callerid,"anonymous") || !strcmp(e_vbox_index_callerid,"unknown"))
- {
+ if (e_vbox_index_callerid[0]=='\0' || !strcmp(e_vbox_index_callerid,"anonymous") || !strcmp(e_vbox_index_callerid,"unknown")) {
set_tone_vbox("call_anonymous");
e_vbox_index_callerid_index = strlen(e_vbox_index_callerid);
- } else
- {
+ } else {
set_tone_vbox("call_from");
e_vbox_index_callerid_index = 0;
}
case VBOX_STATE_CALLINFO_DIGIT:
while (e_vbox_index_callerid[e_vbox_index_callerid_index] && (e_vbox_index_callerid[e_vbox_index_callerid_index]<'0' || e_vbox_index_callerid[e_vbox_index_callerid_index]>'9'))
e_vbox_index_callerid_index++;
- if (e_vbox_index_callerid[e_vbox_index_callerid_index])
- {
+ if (e_vbox_index_callerid[e_vbox_index_callerid_index]) {
SPRINT(buffer, "number_%02d", e_vbox_index_callerid[e_vbox_index_callerid_index]-'0');
set_tone_vbox(buffer);
e_vbox_index_callerid_index ++;
- } else
- {
+ } else {
/* the callinfo is played, so we start with the call */
e_vbox_counter = 0;
e_vbox_counter_last = 0;
case VBOX_STATE_STORE_DONE:
case VBOX_STATE_DELETE_DONE:
- if (e_vbox_index_num == 0) /* nothing to play */
- {
+ if (e_vbox_index_num == 0) { /* nothing to play */
e_vbox_state = VBOX_STATE_MENU;
SCPY(e_vbox_display, (char *)((language)?"keine Anrufe":"no calls"));
e_vbox_display_refresh = 1;
set_tone_vbox("nothing");
- } else
- {
+ } else {
e_vbox_state = VBOX_STATE_MENU;
SCPY(e_vbox_display, (char *)((language)?"druecke 2 f. wiedergabe":"press 2 to play"));
e_vbox_display_refresh = 1;
if (tone == NULL)
tone = "";
- if (!ea_endpoint->ep_portlist)
- {
+ if (!ea_endpoint->ep_portlist) {
PERROR("EPOINT(%d) no portlist\n", ea_endpoint->ep_serial);
}
message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_portlist->port_id, EPOINT_TO_PORT, MESSAGE_VBOX_TONE);
if (!strcmp(filename+strlen(filename)-5, ".isdn")) /* filename is always more than 5 digits long */
filename[strlen(filename)-5] = '\0';
- if (!ea_endpoint->ep_portlist)
- {
+ if (!ea_endpoint->ep_portlist) {
PERROR("EPOINT(%d) no portlist\n", ea_endpoint->ep_serial);
}
message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_portlist->port_id, EPOINT_TO_PORT, MESSAGE_VBOX_PLAY);
{
struct lcr_msg *message;
- if (!ea_endpoint->ep_portlist)
- {
+ if (!ea_endpoint->ep_portlist) {
PERROR("EPOINT(%d) no portlist\n", ea_endpoint->ep_serial);
}
message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_portlist->port_id, EPOINT_TO_PORT, MESSAGE_VBOX_PLAY_SPEED);
{
int i, j;
- if (law == 'a')
- {
+ if (law == 'a') {
audio_law_to_s32=audio_alaw_to_s32;
/* generating alaw-table */
i = j = 0;
= audio_alaw_relations[(j<<1)|1];
i++;
}
- } else
- {
+ } else {
audio_law_to_s32=audio_ulaw_to_s32;
/* generating ulaw-table */
i = j = 0;
unsigned int on = 1;
struct sockaddr_mISDN addr;
- if (bchannel->b_sock > -1)
- {
+ if (bchannel->b_sock > -1) {
CERROR(bchannel->call, NULL, "Socket already created for handle 0x%x\n", bchannel->handle);
return(0);
}
/* open socket */
bchannel->b_mode = mode;
- switch(bchannel->b_mode)
- {
+ switch(bchannel->b_mode) {
case 0:
CDEBUG(bchannel->call, NULL, "Open DSP audio\n");
bchannel->b_sock = socket(PF_ISDN, SOCK_DGRAM, ISDN_P_B_L2DSP);
bchannel->b_sock = socket(PF_ISDN, SOCK_DGRAM, ISDN_P_B_HDLC);
break;
}
- if (bchannel->b_sock < 0)
- {
+ if (bchannel->b_sock < 0) {
CERROR(bchannel->call, NULL, "Failed to open bchannel-socket for handle 0x%x with mISDN-DSP layer. Did you load mISDN_dsp.ko?\n", bchannel->handle);
return(0);
}
/* set nonblocking io */
ret = ioctl(bchannel->b_sock, FIONBIO, &on);
- if (ret < 0)
- {
+ if (ret < 0) {
CERROR(bchannel->call, NULL, "Failed to set bchannel-socket handle 0x%x into nonblocking IO\n", bchannel->handle);
close(bchannel->b_sock);
bchannel->b_sock = -1;
addr.dev = (bchannel->handle>>8);
addr.channel = bchannel->handle & 0xff;
ret = bind(bchannel->b_sock, (struct sockaddr *)&addr, sizeof(addr));
- if (ret < 0)
- {
+ if (ret < 0) {
CERROR(bchannel->call, NULL, "Failed to bind bchannel-socket for handle 0x%x with mISDN-DSP layer. (port %d, channel %d) Did you load mISDN_dsp.ko?\n", bchannel->handle, addr.dev, addr.channel);
close(bchannel->b_sock);
bchannel->b_sock = -1;
/* activate bchannel */
CDEBUG(bchannel->call, NULL, "%sActivating B-channel.\n", activate?"":"De-");
- switch(bchannel->b_mode)
- {
+ switch(bchannel->b_mode) {
case 0:
case 2:
act.prim = (activate)?DL_ESTABLISH_REQ:DL_RELEASE_REQ;
*/
void bchannel_destroy(struct bchannel *bchannel)
{
- if (bchannel->b_sock > -1)
- {
+ if (bchannel->b_sock > -1) {
close(bchannel->b_sock);
bchannel->b_sock = -1;
}
struct bchannel *remote_bchannel;
int ret;
- if (hh->prim == PH_CONTROL_IND)
- {
+ if (hh->prim == PH_CONTROL_IND) {
/* non dsp -> ignore ph_control */
if (bchannel->b_mode == 1 || bchannel->b_mode == 3)
return;
- if (len < 4)
- {
+ if (len < 4) {
CERROR(bchannel->call, NULL, "SHORT READ OF PH_CONTROL INDICATION\n");
return;
}
- if ((cont&(~DTMF_TONE_MASK)) == DTMF_TONE_VAL)
- {
+ if ((cont&(~DTMF_TONE_MASK)) == DTMF_TONE_VAL) {
if (bchannel->call)
lcr_in_dtmf(bchannel->call, cont & DTMF_TONE_MASK);
return;
}
- switch(cont)
- {
+ switch(cont) {
case DSP_BF_REJECT:
CERROR(bchannel->call, NULL, "Blowfish crypt rejected.\n");
break;
}
return;
}
- if (hh->prim == PH_DATA_REQ)
- {
- if (!bchannel->b_txdata)
- {
+ if (hh->prim == PH_DATA_REQ) {
+ if (!bchannel->b_txdata) {
/* if tx is off, it may happen that fifos send us pending informations, we just ignore them */
CDEBUG(bchannel->call, NULL, "ignoring tx data, because 'txdata' is turned off\n");
return;
}
return;
}
- if (hh->prim != PH_DATA_IND && hh->prim != DL_DATA_IND)
- {
+ if (hh->prim != PH_DATA_IND && hh->prim != DL_DATA_IND) {
CERROR(bchannel->call, NULL, "Bchannel received unknown primitve: 0x%lx\n", hh->prim);
return;
}
*/
/* if rx is off, it may happen that fifos send us pending informations, we just ignore them */
- if (bchannel->b_rxoff)
- {
+ if (bchannel->b_rxoff) {
CDEBUG(bchannel->call, NULL, "ignoring data, because rx is turned off\n");
return;
}
- if (!bchannel->call)
- {
+ if (!bchannel->call) {
CDEBUG(bchannel->call, NULL, "ignoring data, because no call associated with bchannel\n");
return;
}
- if (!bchannel->call->audiopath)
- {
+ if (!bchannel->call->audiopath) {
/* return, because we have no audio from port */
return;
}
- if (bchannel->call->pipe[1] < 0)
- {
+ if (bchannel->call->pipe[1] < 0) {
/* nobody there */
return;
}
/* if no hdlc */
- if (bchannel->b_mode == 0 || bchannel->b_mode == 1)
- {
+ if (bchannel->b_mode == 0 || bchannel->b_mode == 1) {
d = data;
for (i = 0; i < len; i++) {
*d = flip_bits[*d];
return;
if (len > 1024 || len < 1)
return;
- switch(bchannel->b_mode)
- {
+ switch(bchannel->b_mode) {
case 0:
for (i = 0; i < len; i++)
*p++ = flip_bits[*data++];
bchannel->b_conf = 0;
bchannel->b_rxoff = 0;
}
- if (bchannel->b_state == BSTATE_ACTIVE)
- {
+ if (bchannel->b_state == BSTATE_ACTIVE) {
ph_control(sock, DSP_RECEIVE_OFF, bchannel->b_rxoff, "DSP-RX_OFF", bchannel->b_conf, bchannel->b_mode);
ph_control(sock, DSP_CONF_JOIN, bchannel->b_conf, "DSP-CONF", bchannel->b_conf, bchannel->b_mode);
}
/* process all bchannels */
bchannel = bchannel_first;
- while(bchannel)
- {
+ while(bchannel) {
/* handle message from bchannel */
- if (bchannel->b_sock > -1)
- {
+ if (bchannel->b_sock > -1) {
ret = recv(bchannel->b_sock, buffer, sizeof(buffer), 0);
- if (ret >= (int)MISDN_HEADER_LEN)
- {
+ if (ret >= (int)MISDN_HEADER_LEN) {
work = 1;
- switch(hh->prim)
- {
+ switch(hh->prim) {
/* we don't care about confirms, we use rx data to sync tx */
case PH_DATA_CNF:
break;
default:
CERROR(bchannel->call, NULL, "child message not handled: prim(0x%x) socket(%d) data len(%d)\n", hh->prim, bchannel->b_sock, ret - MISDN_HEADER_LEN);
}
- } else
- {
+ } else {
if (ret < 0 && errno != EWOULDBLOCK)
CERROR(bchannel->call, NULL, "Read from socket %d failed with return code %d\n", bchannel->b_sock, ret);
}
{
struct bchannel *bchannel = bchannel_first;
- while(bchannel)
- {
+ while(bchannel) {
if (bchannel->handle == handle)
break;
bchannel = bchannel->next;
{
struct bchannel *bchannel = bchannel_first;
- while(bchannel)
- {
+ while(bchannel) {
if (bchannel->ref == ref)
break;
bchannel = bchannel->next;
{
struct bchannel **temp = &bchannel_first;
- while(*temp)
- {
- if (*temp == bchannel)
- {
+ while(*temp) {
+ if (*temp == bchannel) {
*temp = (*temp)->next;
if (bchannel->b_sock > -1)
bchannel_destroy(bchannel);
- if (bchannel->call)
- {
+ if (bchannel->call) {
if (bchannel->call->bchannel)
bchannel->call->bchannel = NULL;
}
/* Connect signalling of bts0/trx0 to e1_0/ts1/64kbps */
abis_nm_conn_terr_sign(trx, 0, 1, 0xff);
- set_ts_e1link(&trx->ts[0], 0, 1, 0xff);
abis_nm_raw_msg(bts, sizeof(msg_6), msg_6); /* SET TRX ATTRIBUTES */
/* Use TEI 1 for signalling */
/* SET CHANNEL ATTRIBUTE TS1 */
abis_nm_set_channel_attr(&trx->ts[1], NM_CHANC_TCHFull);
/* Connect traffic of bts0/trx0/ts1 to e1_0/ts2/b */
- set_ts_e1link(&trx->ts[1], 0, 2, 1);
abis_nm_conn_terr_traf(&trx->ts[1], 0, 2, 1);
/* SET CHANNEL ATTRIBUTE TS2 */
abis_nm_set_channel_attr(&trx->ts[2], NM_CHANC_TCHFull);
/* Connect traffic of bts0/trx0/ts2 to e1_0/ts2/c */
- set_ts_e1link(&trx->ts[2], 0, 2, 2);
abis_nm_conn_terr_traf(&trx->ts[2], 0, 2, 2);
/* SET CHANNEL ATTRIBUTE TS3 */
abis_nm_set_channel_attr(&trx->ts[3], NM_CHANC_TCHFull);
/* Connect traffic of bts0/trx0/ts3 to e1_0/ts2/d */
- set_ts_e1link(&trx->ts[3], 0, 2, 3);
abis_nm_conn_terr_traf(&trx->ts[3], 0, 2, 3);
/* SET CHANNEL ATTRIBUTE TS4 */
abis_nm_set_channel_attr(&trx->ts[4], NM_CHANC_TCHFull);
/* Connect traffic of bts0/trx0/ts4 to e1_0/ts3/a */
- set_ts_e1link(&trx->ts[4], 0, 3, 0);
abis_nm_conn_terr_traf(&trx->ts[4], 0, 3, 0);
/* SET CHANNEL ATTRIBUTE TS5 */
abis_nm_set_channel_attr(&trx->ts[5], NM_CHANC_TCHFull);
/* Connect traffic of bts0/trx0/ts5 to e1_0/ts3/b */
- set_ts_e1link(&trx->ts[5], 0, 3, 1);
abis_nm_conn_terr_traf(&trx->ts[5], 0, 3, 1);
/* SET CHANNEL ATTRIBUTE TS6 */
abis_nm_set_channel_attr(&trx->ts[6], NM_CHANC_TCHFull);
/* Connect traffic of bts0/trx0/ts6 to e1_0/ts3/c */
- set_ts_e1link(&trx->ts[6], 0, 3, 2);
abis_nm_conn_terr_traf(&trx->ts[6], 0, 3, 2);
/* SET CHANNEL ATTRIBUTE TS7 */
abis_nm_set_channel_attr(&trx->ts[7], NM_CHANC_TCHFull);
/* Connect traffic of bts0/trx0/ts7 to e1_0/ts3/d */
- set_ts_e1link(&trx->ts[7], 0, 3, 3);
abis_nm_conn_terr_traf(&trx->ts[7], 0, 3, 3);
/* end DB transmission */
/* s1 reset*/0x2B
};
+static u_int8_t *gsm48_si1(u_int8_t *arfcn_list, int arfcn_len, int max_trans, int tx_integer, int cell_barr, int re, int ec, u_int8_t *ac_list, int ac_len)
+{
+ static u_int8_t si[23];
+ int i, bit, octet;
+
+ memset(&si, 0, sizeof(si));
+
+ /* header */
+ si[0] = 0x55;
+ si[1] = 0x06;
+ si[2] = 0x19;
+ /* ccdesc */
+ for (i = 0; i < arfcn_len; i++) {
+ if (arfcn_list[i] <= 124 && arfcn_list[i] > 0) {
+ bit = (arfcn_list[i] - 1) & 7;
+ octet = (arfcn_list[i] -1) / 8;
+ si[18 - octet] |= (1 << bit);
+ }
+ }
+ /* rach */
+ si[19] = (max_trans << 6);
+ si[19] |= (tx_integer << 2);
+ si[19] |= (cell_barr << 1);
+ si[19] |= re;
+ si[20] = (ec << 2);
+ for (i = 0; i < ac_len; i++) {
+ if (ac_list[i] <= 15 && ac_list[i] != 10) {
+ bit = ac_list[i] & 7;
+ octet = ac_list[i] / 8;
+ si[21 - octet] |= (1 << bit);
+ }
+ }
+ /* s1 rest */
+ si[22] = 0x2B;
+
+ /* testig */
+ if (memcmp(&si1, &si, sizeof(si)))
+ printf("SI1 does not match default template.\n");
+
+ return si;
+}
+
/*
SYSTEM INFORMATION TYPE 2
Neighbour Cells Description
/* rach*/0xD5, 0x00, 0x00
};
+static u_int8_t *gsm48_si2(int ba, u_int8_t *arfcn_list, int arfcn_len, u_int8_t ncc, int max_trans, int tx_integer, int cell_barr, int re, int ec, u_int8_t *ac_list, int ac_len)
+{
+ static u_int8_t si[23];
+ int i, bit, octet;
+
+ memset(&si, 0, sizeof(si));
+
+ /* header */
+ si[0] = 0x59;
+ si[1] = 0x06;
+ si[2] = 0x1A;
+ /* ncdesc */
+ si[3] = (ba << 4);
+ for (i = 0; i < arfcn_len; i++) {
+ if (arfcn_list[i] <= 124 && arfcn_list[i] > 0) {
+ bit = (arfcn_list[i] - 1) & 7;
+ octet = (arfcn_list[i] -1) / 8;
+ si[18 - octet] |= (1 << bit);
+ }
+ }
+ /* ncc */
+ si[19] = ncc;
+ /* rach */
+ si[20] = (max_trans << 6);
+ si[20] |= (tx_integer << 2);
+ si[20] |= (cell_barr << 1);
+ si[20] |= re;
+ si[21] = (ec << 2);
+ for (i = 0; i < ac_len; i++) {
+ if (ac_list[i] <= 15 && ac_list[i] != 10) {
+ bit = ac_list[i] & 7;
+ octet = ac_list[i] / 8;
+ si[22 - octet] |= (1 << bit);
+ }
+ }
+
+ /* testig */
+ if (memcmp(&si2, &si, sizeof(si)))
+ printf("SI2 does not match default template.\n");
+
+ return si;
+}
+
/*
SYSTEM INFORMATION TYPE 3
Cell identity = 00001 (1h)
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
};
+static u_int8_t *gsm48_si5(int ba, u_int8_t *arfcn_list, int arfcn_len)
+{
+ static u_int8_t si[18];
+ int i, bit, octet;
+
+ memset(&si, 0, sizeof(si));
+
+ /* header */
+ si[0] = 0x06;
+ si[1] = 0x1D;
+ /* ncdesc */
+ si[2] = (ba << 4);
+ for (i = 0; i < arfcn_len; i++) {
+ if (arfcn_list[i] <= 124 && arfcn_list[i] > 0) {
+ bit = (arfcn_list[i] - 1) & 7;
+ octet = (arfcn_list[i] -1) / 8;
+ si[17 - octet] |= (1 << bit);
+ }
+ }
+
+ /* testig */
+ if (memcmp(&si3, &si, sizeof(si)))
+ printf("SI3 does not match default template.\n");
+
+ return si;
+}
+
// SYSTEM INFORMATION TYPE 6
/*
static int set_system_infos(struct gsm_bts_trx *trx)
{
unsigned int i;
-
- for (i = 0; i < ARRAY_SIZE(bcch_infos); i++) {
+ u_int8_t *_si1;
+ u_int8_t *_si2;
+ u_int8_t *_si5;
+ u_int8_t arfcn_list[8];
+
+ arfcn_list[0] = trx->arfcn;
+ _si1 = gsm48_si1(arfcn_list, 1, 3, 5, 0, 1, 0, NULL, 0);
+
+ memset(arfcn_list, 0, sizeof(arfcn_list));
+ arfcn_list[0] = trx->arfcn;
+ arfcn_list[1] = 112;
+ arfcn_list[2] = 62;
+ arfcn_list[3] = 99;
+ arfcn_list[4] = 77;
+ arfcn_list[5] = 64;
+ arfcn_list[6] = 54;
+ arfcn_list[7] = 51;
+ _si2 = gsm48_si2(0, arfcn_list, 8, 0xff, 3, 5, 0, 1, 0, NULL, 0);
+ _si5 = gsm48_si5(0, arfcn_list, 8);
+
+ rsl_bcch_info(trx, RSL_SYSTEM_INFO_1, _si1, 23);
+ rsl_bcch_info(trx, RSL_SYSTEM_INFO_2, _si2, 23);
+// rsl_bcch_info(trx, RSL_SYSTEM_INFO_3, _si3, );
+// rsl_bcch_info(trx, RSL_SYSTEM_INFO_4, _si4, );
+
+ for (i = 2; i < ARRAY_SIZE(bcch_infos); i++) {
rsl_bcch_info(trx, bcch_infos[i].type,
bcch_infos[i].data,
bcch_infos[i].len);
}
- rsl_sacch_filling(trx, RSL_SYSTEM_INFO_5, si5, sizeof(si5));
+ rsl_sacch_filling(trx, RSL_SYSTEM_INFO_5, _si5, 18);
rsl_sacch_filling(trx, RSL_SYSTEM_INFO_6, si6, sizeof(si6));
return 0;
*/
static void patch_tables(struct gsm_bts *bts)
{
+#warning todo
u_int8_t arfcn_low = bts->trx[0].arfcn & 0xff;
u_int8_t arfcn_high = (bts->trx[0].arfcn >> 8) & 0x0f;
/* covert the raw packet to the struct */
paging_init(bts);
+ if (bts->type == GSM_BTS_TYPE_BS11) {
+ struct gsm_bts_trx *trx = &bts->trx[0];
+ set_ts_e1link(&trx->ts[0], 0, 1, 0xff);
+ set_ts_e1link(&trx->ts[1], 0, 2, 1);
+ set_ts_e1link(&trx->ts[2], 0, 2, 2);
+ set_ts_e1link(&trx->ts[3], 0, 2, 3);
+ set_ts_e1link(&trx->ts[4], 0, 3, 0);
+ set_ts_e1link(&trx->ts[5], 0, 3, 1);
+ set_ts_e1link(&trx->ts[6], 0, 3, 2);
+ set_ts_e1link(&trx->ts[7], 0, 3, 3);
+#ifdef HAVE_TRX1
+ /* TRX 1 */
+ trx = &bts->trx[1];
+ set_ts_e1link(&trx->ts[0], 0, 1, 0xff);
+ set_ts_e1link(&trx->ts[1], 0, 2, 1);
+ set_ts_e1link(&trx->ts[2], 0, 2, 2);
+ set_ts_e1link(&trx->ts[3], 0, 2, 3);
+ set_ts_e1link(&trx->ts[4], 0, 3, 0);
+ set_ts_e1link(&trx->ts[5], 0, 3, 1);
+ set_ts_e1link(&trx->ts[6], 0, 3, 2);
+ set_ts_e1link(&trx->ts[7], 0, 3, 3);
+#endif
+ }
+
return 0;
}
*/
const char *nationalize_callerinfo(const char *string, int *ntype, const char *national, const char *international)
{
- if (!strncmp(international, string, strlen(international)))
- {
+ if (!strncmp(international, string, strlen(international))) {
*ntype = INFO_NTYPE_INTERNATIONAL;
return(string+strlen(international));
}
- if (!strncmp(national, string, strlen(national)))
- {
+ if (!strncmp(national, string, strlen(national))) {
*ntype = INFO_NTYPE_NATIONAL;
return(string+strlen(national));
}
{
static char result[256];
- switch(ntype)
- {
+ switch(ntype) {
case INFO_NTYPE_NOTPRESENT:
return("");
*/
void collect_cause(int *multicause, int *multilocation, int newcause, int newlocation)
{
- if (newcause == CAUSE_REJECTED) /* call rejected */
- {
+ if (newcause == CAUSE_REJECTED) { /* call rejected */
*multicause = newcause;
*multilocation = newlocation;
} else
- if (newcause==CAUSE_NORMAL && *multicause!=CAUSE_REJECTED) /* reject via hangup */
- {
+ if (newcause==CAUSE_NORMAL && *multicause!=CAUSE_REJECTED) { /* reject via hangup */
*multicause = newcause;
*multilocation = newlocation;
} else
- if (newcause==CAUSE_BUSY && *multicause!=CAUSE_REJECTED && *multicause!=CAUSE_NORMAL) /* busy */
- {
+ if (newcause==CAUSE_BUSY && *multicause!=CAUSE_REJECTED && *multicause!=CAUSE_NORMAL) { /* busy */
*multicause = newcause;
*multilocation = newlocation;
} else
- if (newcause==CAUSE_OUTOFORDER && *multicause!=CAUSE_BUSY && *multicause!=CAUSE_REJECTED && *multicause!=CAUSE_NORMAL) /* no L1 */
- {
+ if (newcause==CAUSE_OUTOFORDER && *multicause!=CAUSE_BUSY && *multicause!=CAUSE_REJECTED && *multicause!=CAUSE_NORMAL) { /* no L1 */
*multicause = newcause;
*multilocation = newlocation;
} else
- if (newcause!=CAUSE_NOUSER && *multicause!=CAUSE_OUTOFORDER && *multicause!=CAUSE_BUSY && *multicause!=CAUSE_REJECTED && *multicause!=CAUSE_NORMAL) /* anything but not 18 */
- {
+ if (newcause!=CAUSE_NOUSER && *multicause!=CAUSE_OUTOFORDER && *multicause!=CAUSE_BUSY && *multicause!=CAUSE_REJECTED && *multicause!=CAUSE_NORMAL) { /* anything but not 18 */
*multicause = newcause;
*multilocation = newlocation;
} else
- if (newcause==CAUSE_NOUSER && *multicause==CAUSE_NOUSER) /* cause 18, use the location */
- {
+ if (newcause==CAUSE_NOUSER && *multicause==CAUSE_NOUSER) { /* cause 18, use the location */
*multilocation = newlocation;
} else
- if (*multicause==0) /* no cause yet, use newcause (should be 18) */
- {
+ if (*multicause==0) { /* no cause yet, use newcause (should be 18) */
*multicause = newcause;
*multilocation = newlocation;
}
struct chan_call *call = call_first;
int assigned = (ref > 0);
- while(call)
- {
+ while(call) {
if (call->ref == ref && call->ref_was_assigned == assigned)
break;
call = call->next;
{
struct chan_call **temp = &call_first;
- while(*temp)
- {
- if (*temp == call)
- {
+ while(*temp) {
+ if (*temp == call) {
*temp = (*temp)->next;
if (call->pipe[0] > -1)
close(call->pipe[0]);
if (call->pipe[1] > -1)
close(call->pipe[1]);
- if (call->bchannel)
- {
+ if (call->bchannel) {
if (call->bchannel->call != call)
CERROR(call, NULL, "Linked bchannel structure has no link to us.\n");
call->bchannel->call = NULL;
}
- if (call->bridge_call)
- {
+ if (call->bridge_call) {
if (call->bridge_call->bridge_call != call)
CERROR(call, NULL, "Linked call structure has no link to us.\n");
call->bridge_call->bridge_call = NULL;
unsigned short id = 1;
/* search for lowest bridge id that is not in use and not 0 */
- while(id)
- {
+ while(id) {
call = call_first;
- while(call)
- {
+ while(call) {
if (call->bridge_id == id)
break;
call = call->next;
string[sizeof(string)-1] = '\0';
/* parse options */
- while((opt = strsep(&p, ":")))
- {
+ while((opt = strsep(&p, ":"))) {
switch(opt[0]) {
case 'd':
if (opt[1] == '\0') {
break;
}
i = 0;
- while(*key)
- {
+ while(*key) {
if (*key>='0' && *key<='9')
call->bf_key[i] = (*key-'0') << 8;
else if (*key>='a' && *key<='f')
strncpy(newparam.setup.callerinfo.id, call->cid_num, sizeof(newparam.setup.callerinfo.id)-1);
if (call->cid_name[0])
strncpy(newparam.setup.callerinfo.name, call->cid_name, sizeof(newparam.setup.callerinfo.name)-1);
- if (call->cid_rdnis[0])
- {
+ if (call->cid_rdnis[0]) {
strncpy(newparam.setup.redirinfo.id, call->cid_rdnis, sizeof(newparam.setup.redirinfo.id)-1);
newparam.setup.redirinfo.itype = INFO_ITYPE_CHAN;
newparam.setup.redirinfo.ntype = INFO_NTYPE_UNKNOWN;
}
- switch(ast->cid.cid_pres & AST_PRES_RESTRICTION)
- {
+ switch(ast->cid.cid_pres & AST_PRES_RESTRICTION) {
case AST_PRES_RESTRICTED:
newparam.setup.callerinfo.present = INFO_PRESENT_RESTRICTED;
break;
default:
newparam.setup.callerinfo.present = INFO_PRESENT_ALLOWED;
}
- switch(ast->cid.cid_ton)
- {
+ switch(ast->cid.cid_ton) {
case 4:
newparam.setup.callerinfo.ntype = INFO_NTYPE_SUBSCRIBER;
break;
CDEBUG(call, ast, "Try to start pbx. (exten=%s context=%s complete=%s)\n", exten, ast->context, complete?"yes":"no");
- if (complete)
- {
+ if (complete) {
/* if not match */
- if (!ast_canmatch_extension(ast, ast->context, exten, 1, call->oad))
- {
+ if (!ast_canmatch_extension(ast, ast->context, exten, 1, call->oad)) {
CDEBUG(call, ast, "Got 'sending complete', but extension '%s' will not match at context '%s' - releasing.\n", exten, ast->context);
cause = 1;
goto release;
}
- if (!ast_exists_extension(ast, ast->context, exten, 1, call->oad))
- {
+ if (!ast_exists_extension(ast, ast->context, exten, 1, call->oad)) {
CDEBUG(call, ast, "Got 'sending complete', but extension '%s' would match at context '%s', if more digits would be dialed - releasing.\n", exten, ast->context);
cause = 28;
goto release;
goto start;
}
- if (ast_canmatch_extension(ast, ast->context, exten, 1, call->oad))
- {
+ if (ast_canmatch_extension(ast, ast->context, exten, 1, call->oad)) {
/* send setup acknowledge to lcr */
if (call->state != CHAN_LCR_STATE_IN_DIALING) {
memset(&newparam, 0, sizeof(union parameter));
#endif
ret = ast_pbx_start(ast);
- if (ret < 0)
- {
+ if (ret < 0) {
cause = (ret==-2)?34:27;
goto release;
}
ast = ast_channel_alloc(1, AST_STATE_RESERVED, NULL, NULL, "", NULL, "", 0, "%s/%d", lcr_type, ++glob_channel);
#endif
- if (!ast)
- {
+ if (!ast) {
/* release */
CERROR(call, NULL, "Failed to create Asterisk channel - releasing.\n");
send_release_and_import(call, CAUSE_RESSOURCEUNAVAIL, LOCATION_PRIVATE_LOCAL);
ast->cid.cid_name = strdup(param->setup.callerinfo.name);
if (param->setup.redirinfo.id[0])
ast->cid.cid_name = strdup(numberrize_callerinfo(param->setup.callerinfo.id, param->setup.callerinfo.ntype, options.national, options.international));
- switch (param->setup.callerinfo.present)
- {
+ switch (param->setup.callerinfo.present) {
case INFO_PRESENT_ALLOWED:
ast->cid.cid_pres = AST_PRES_ALLOWED;
break;
default:
ast->cid.cid_pres = AST_PRES_UNAVAILABLE;
}
- switch (param->setup.callerinfo.ntype)
- {
+ switch (param->setup.callerinfo.ntype) {
case INFO_NTYPE_SUBSCRIBER:
ast->cid.cid_ton = 4;
break;
/* if bridge, forward disconnect and return */
#ifdef TODO
feature flag
- if (call->bridge_call)
- {
+ if (call->bridge_call) {
CDEBUG(call, call->ast, "Only signal disconnect via bridge.\n");
bridge_message_if_bridged(call, message_type, param);
return;
/* change to release state */
call->state = CHAN_LCR_STATE_RELEASE;
/* queue release asterisk */
- if (ast)
- {
+ if (ast) {
ast->hangupcause = call->cause;
if (call->pbx_started)
strcpy(call->queue_string, "H"); // overwrite other indications
/* change to release state */
call->state = CHAN_LCR_STATE_RELEASE;
/* copy release info */
- if (!call->cause)
- {
+ if (!call->cause) {
call->cause = param->disconnectinfo.cause;
call->location = param->disconnectinfo.location;
}
/* if we have an asterisk instance, queue hangup, else we are done */
- if (ast)
- {
+ if (ast) {
ast->hangupcause = call->cause;
if (call->pbx_started)
strcpy(call->queue_string, "H");
else {
ast_hangup(ast); // call will be destroyed here
}
- } else
- {
+ } else {
free_call(call);
}
if (!ast) return;
/* pbx not started */
- if (!call->pbx_started)
- {
+ if (!call->pbx_started) {
CDEBUG(call, call->ast, "Asterisk not started, adding digits to number.\n");
strncat(ast->exten, param->information.id, AST_MAX_EXTENSION-1);
lcr_start_pbx(call, ast, param->information.sending_complete);
memset(&newparam, 0, sizeof(union parameter));
/* handle bchannel message*/
- if (message_type == MESSAGE_BCHANNEL)
- {
- switch(param->bchannel.type)
- {
+ if (message_type == MESSAGE_BCHANNEL) {
+ switch(param->bchannel.type) {
case BCHANNEL_ASSIGN:
CDEBUG(NULL, NULL, "Received BCHANNEL_ASSIGN message. (handle=%08lx) for ref %d\n", param->bchannel.handle, ref);
- if ((bchannel = find_bchannel_handle(param->bchannel.handle)))
- {
+ if ((bchannel = find_bchannel_handle(param->bchannel.handle))) {
CERROR(NULL, NULL, "bchannel handle %x already assigned.\n", (int)param->bchannel.handle);
return(-1);
}
/* create bchannel */
bchannel = alloc_bchannel(param->bchannel.handle);
- if (!bchannel)
- {
+ if (!bchannel) {
CERROR(NULL, NULL, "alloc bchannel handle %x failed.\n", (int)param->bchannel.handle);
return(-1);
}
bchannel->b_tx_gain = param->bchannel.tx_gain;
bchannel->b_rx_gain = param->bchannel.rx_gain;
strncpy(bchannel->b_pipeline, param->bchannel.pipeline, sizeof(bchannel->b_pipeline)-1);
- if (param->bchannel.crypt_len && param->bchannel.crypt_len <= sizeof(bchannel->b_bf_key))
- {
+ if (param->bchannel.crypt_len && param->bchannel.crypt_len <= sizeof(bchannel->b_bf_key)) {
bchannel->b_bf_len = param->bchannel.crypt_len;
memcpy(bchannel->b_bf_key, param->bchannel.crypt, param->bchannel.crypt_len);
}
* be created until it is removed again by LCR */
/* link to call */
call = find_call_ref(ref);
- if (call)
- {
+ if (call) {
bchannel->call = call;
call->bchannel = bchannel;
if (call->dsp_dtmf)
case BCHANNEL_REMOVE:
CDEBUG(NULL, NULL, "Received BCHANNEL_REMOVE message. (handle=%08lx)\n", param->bchannel.handle);
- if (!(bchannel = find_bchannel_handle(param->bchannel.handle)))
- {
+ if (!(bchannel = find_bchannel_handle(param->bchannel.handle))) {
CERROR(NULL, NULL, "Bchannel handle %x not assigned.\n", (int)param->bchannel.handle);
return(-1);
}
}
/* handle new ref */
- if (message_type == MESSAGE_NEWREF)
- {
- if (param->direction)
- {
+ if (message_type == MESSAGE_NEWREF) {
+ if (param->direction) {
/* new ref from lcr */
CDEBUG(NULL, NULL, "Received new ref by LCR, due to incomming call. (ref=%ld)\n", ref);
- if (!ref || find_call_ref(ref))
- {
+ if (!ref || find_call_ref(ref)) {
CERROR(NULL, NULL, "Illegal new ref %ld received.\n", ref);
return(-1);
}
/* set dtmf (default, use option 'n' to disable */
call->dsp_dtmf = 1;
/* wait for setup (or release from asterisk) */
- } else
- {
+ } else {
/* new ref, as requested from this remote application */
CDEBUG(NULL, NULL, "Received new ref by LCR, as requested from chan_lcr. (ref=%ld)\n", ref);
call = find_call_ref(0);
- if (!call)
- {
+ if (!call) {
/* send release, if ref does not exist */
CDEBUG(NULL, NULL, "No call found, that requests a ref.\n");
send_release_and_import(call, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL);
if (call->state == CHAN_LCR_STATE_OUT_PREPARE)
send_setup_to_lcr(call);
/* release if asterisk has signed off */
- else if (call->state == CHAN_LCR_STATE_RELEASE)
- {
+ else if (call->state == CHAN_LCR_STATE_RELEASE) {
/* send release */
if (call->cause)
send_release_and_import(call, call->cause, call->location);
}
/* check ref */
- if (!ref)
- {
+ if (!ref) {
CERROR(NULL, NULL, "Received message %d without ref.\n", message_type);
return(-1);
}
call = find_call_ref(ref);
- if (!call)
- {
+ if (!call) {
/* ignore ref that is not used (anymore) */
CDEBUG(NULL, NULL, "Message %d from LCR ignored, because no call instance found.\n", message_type);
return(0);
}
/* handle messages */
- switch(message_type)
- {
+ switch(message_type) {
case MESSAGE_SETUP:
lcr_in_setup(call, message_type, param);
break;
/* read from socket */
len = read(lcr_sock, &msg, sizeof(msg));
- if (len == 0)
- {
+ if (len == 0) {
CERROR(NULL, NULL, "Socket closed.\n");
return(-1); // socket closed
}
- if (len > 0)
- {
- if (len != sizeof(msg))
- {
+ if (len > 0) {
+ if (len != sizeof(msg)) {
CERROR(NULL, NULL, "Socket short read. (len %d)\n", len);
return(-1); // socket error
}
- if (msg.message != ADMIN_MESSAGE)
- {
+ if (msg.message != ADMIN_MESSAGE) {
CERROR(NULL, NULL, "Socket received illegal message %d.\n", msg.message);
return(-1);
}
receive_message(msg.u.msg.type, msg.u.msg.ref, &msg.u.msg.param);
work = 1;
- } else
- {
- if (errno != EWOULDBLOCK)
- {
+ } else {
+ if (errno != EWOULDBLOCK) {
CERROR(NULL, NULL, "Socket failed (errno %d).\n", errno);
return(-1);
}
return(work);
admin = admin_first;
len = write(lcr_sock, &admin->msg, sizeof(msg));
- if (len == 0)
- {
+ if (len == 0) {
CERROR(NULL, NULL, "Socket closed.\n");
return(-1); // socket closed
}
- if (len > 0)
- {
- if (len != sizeof(msg))
- {
+ if (len > 0) {
+ if (len != sizeof(msg)) {
CERROR(NULL, NULL, "Socket short write. (len %d)\n", len);
return(-1); // socket error
}
free(admin);
work = 1;
- } else
- {
- if (errno != EWOULDBLOCK)
- {
+ } else {
+ if (errno != EWOULDBLOCK) {
CERROR(NULL, NULL, "Socket failed (errno %d).\n", errno);
return(-1);
}
union parameter param;
/* open socket */
- if ((lcr_sock = socket(PF_UNIX, SOCK_STREAM, 0)) < 0)
- {
+ if ((lcr_sock = socket(PF_UNIX, SOCK_STREAM, 0)) < 0) {
CERROR(NULL, NULL, "Failed to create socket.\n");
return(lcr_sock);
}
sprintf(sock_address.sun_path, SOCKET_NAME, options.lock);
/* connect socket */
- if ((conn = connect(lcr_sock, (struct sockaddr *)&sock_address, SUN_LEN(&sock_address))) < 0)
- {
+ if ((conn = connect(lcr_sock, (struct sockaddr *)&sock_address, SUN_LEN(&sock_address))) < 0) {
close(lcr_sock);
lcr_sock = -1;
CDEBUG(NULL, NULL, "Failed to connect to socket '%s'. Is LCR running?\n", sock_address.sun_path);
}
/* set non-blocking io */
- if ((ret = ioctl(lcr_sock, FIONBIO, (unsigned char *)(&on))) < 0)
- {
+ if ((ret = ioctl(lcr_sock, FIONBIO, (unsigned char *)(&on))) < 0) {
close(lcr_sock);
lcr_sock = -1;
CERROR(NULL, NULL, "Failed to set socket into non-blocking IO.\n");
CDEBUG(NULL, NULL, "Received request from Asterisk. (data=%s)\n", (char *)data);
/* if socket is closed */
- if (lcr_sock < 0)
- {
+ if (lcr_sock < 0) {
CERROR(NULL, NULL, "Rejecting call from Asterisk, because LCR not running.\n");
ast_mutex_unlock(&chan_lock);
return NULL;
/* create call instance */
call = alloc_call();
- if (!call)
- {
+ if (!call) {
/* failed to create instance */
ast_mutex_unlock(&chan_lock);
return NULL;
ast = ast_channel_alloc(1);
#endif
- if (!ast)
- {
+ if (!ast) {
CERROR(NULL, NULL, "Failed to create Asterisk channel.\n");
free_call(call);
/* failed to create instance */
CDEBUG(call, ast, "Received digit '%c' from Asterisk.\n", digit);
/* send information or queue them */
- if (call->ref && call->state == CHAN_LCR_STATE_OUT_DIALING)
- {
+ if (call->ref && call->state == CHAN_LCR_STATE_OUT_DIALING) {
CDEBUG(call, ast, "Sending digit to LCR, because we are in dialing state.\n");
memset(&newparam, 0, sizeof(union parameter));
newparam.information.id[0] = digit;
send_message(MESSAGE_INFORMATION, call->ref, &newparam);
} else
if (!call->ref
- && (call->state == CHAN_LCR_STATE_OUT_PREPARE || call->state == CHAN_LCR_STATE_OUT_SETUP))
- {
+ && (call->state == CHAN_LCR_STATE_OUT_PREPARE || call->state == CHAN_LCR_STATE_OUT_SETUP)) {
CDEBUG(call, ast, "Queue digits, because we are in setup/dialing state and have no ref yet.\n");
*buf = digit;
strncat(call->dialque, buf, strlen(call->dialque)-1);
/* disconnect asterisk, maybe not required */
ast->tech_pvt = NULL;
ast->fds[0] = -1;
- if (call->ref)
- {
+ if (call->ref) {
/* release */
CDEBUG(call, ast, "Releasing ref and freeing call instance.\n");
if (ast->hangupcause > 0)
if (!pthread_equal(tid, chan_tid))
ast_mutex_unlock(&chan_lock);
return 0;
- } else
- {
+ } else {
/* ref is not set, due to prepare setup or release */
- if (call->state == CHAN_LCR_STATE_RELEASE)
- {
+ if (call->state == CHAN_LCR_STATE_RELEASE) {
/* we get the response to our release */
CDEBUG(call, ast, "Freeing call instance, because we have no ref AND we are requesting no ref.\n");
free_call(call);
- } else
- {
+ } else {
/* during prepare, we change to release state */
CDEBUG(call, ast, "We must wait until we received our ref, until we can free call instance.\n");
call->state = CHAN_LCR_STATE_RELEASE;
ast_mutex_lock(&chan_lock);
call1 = ast1->tech_pvt;
call2 = ast2->tech_pvt;
- if (call1 && call1->bridge_id)
- {
+ if (call1 && call1->bridge_id) {
call1->bridge_id = 0;
if (call1->bchannel)
bchannel_join(call1->bchannel, 0);
if (call1->bridge_call)
call1->bridge_call->bridge_call = NULL;
}
- if (call2 && call1->bridge_id)
- {
+ if (call2 && call1->bridge_id) {
call2->bridge_id = 0;
if (call2->bchannel)
bchannel_join(call2->bchannel, 0);
#endif
quit = 0;
- if ((pthread_create(&chan_tid, NULL, chan_thread, NULL)<0))
- {
+ if ((pthread_create(&chan_tid, NULL, chan_thread, NULL)<0)) {
/* failed to create thread */
bchannel_deinitialize();
close_socket();
# Enable debugging of OpenBSC library.
# Refer to OpenBSC project for debugging options.
# By default, debugging is turned off.
-#debug DRLL:DCC:DNM:DRR:DRSL:DNM:DSMS:DMNCC:DPAG:DMUX
+#debug DRLL:DCC:DMM:DRR:DRSL:DNM:DSMS:DMNCC:DMNSMS:DPAG:DMUX
# Two Loopback interfaces for audio transfer between OpenBSC and mISDN.
# The first interface must provide B-channelis for each call mobile call.
# To keep layer 2 connection to BS11 when quitting, use this option.
# It is only usefull for developing. TRX will stay on.
+# Also changes in frequency, mcc, mnc, lac while keeping layer 2 will cause
+# malefunction of BSC.
# Warning: Keeping layer 2 link may prevent emergency calls. (See below)
-# Layer 2 will only be kept, if lcr was killed manually.
#keep-l2
# You must define a list of your BTS'.
# emergency facility. If you can't do that, don't touch it!
#no-emergency-shutdown
-
+# Write BTS-Link traffic to PCAP file.
+#pcapfile pcap
dec_ie_display(l3m, (unsigned char *)display, sizeof(display));
end_trace();
- if (cause < 0)
+ if (cause < 0) {
cause = 16;
+ location = LOCATION_PRIVATE_LOCAL;
+ }
/* release if remote sends us no tones */
if (!p_m_mISDNport->earlyb) {
dec_ie_display(l3m, (unsigned char *)display, sizeof(display));
end_trace();
- if (cause < 0)
+ if (cause < 0) {
cause = 16;
+ location = LOCATION_PRIVATE_LOCAL;
+ }
/* sending release to endpoint */
if (location == LOCATION_PRIVATE_LOCAL)
if (location == LOCATION_PRIVATE_LOCAL)
location = LOCATION_PRIVATE_REMOTE;
- if (cause < 0)
+ if (cause < 0) {
cause = 16;
+ location = LOCATION_PRIVATE_LOCAL;
+ }
/* sending release to endpoint */
while(p_epointlist) {
#include "openbsc/trau_frame.h"
#include "openbsc/select.h"
#include "openbsc/debug.h"
+#include "openbsc/e1_input.h"
#include "bootstrap.h"
#include "gsm_audio.h"
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;
/* what infos did we got ... */
gsm_trace_header(p_m_mISDNport, this, msg_type, DIRECTION_IN);
- add_trace("subscr", "number", "%s", p_callerinfo.id);
+ 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();
gsm_trace_header(p_m_mISDNport, this, msg_type, DIRECTION_IN);
end_trace();
+ SCPY(p_connectinfo.id, mncc->calling_number);
+ SCPY(p_connectinfo.imsi, mncc->imsi);
+ p_connectinfo.present = INFO_PRESENT_ALLOWED;
+ p_connectinfo.screen = INFO_SCREEN_NETWORK;
+ p_connectinfo.ntype = INFO_NTYPE_UNKNOWN;
+ p_connectinfo.isdn_port = p_m_portnum;
+ SCPY(p_connectinfo.interface, p_m_mISDNport->ifport->interface->name);
/* send resp */
gsm_trace_header(p_m_mISDNport, this, MNCC_SETUP_COMPL_REQ, DIRECTION_OUT);
+ if (p_connectinfo.id[0])
+ add_trace("connect", "number", "%s", p_connectinfo.id);
+ else
+ SPRINT(p_connectinfo.id, "imsi-%s", p_connectinfo.imsi);
+ add_trace("connect", "imsi", "%s", p_connectinfo.imsi);
resp = create_mncc(MNCC_SETUP_COMPL_REQ, p_m_g_callref);
end_trace();
send_and_free_mncc((struct gsm_network *)gsm->network, resp->msg_type, resp);
message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_CONNECT);
+ memcpy(&message->param.connectinfo, &p_connectinfo, sizeof(struct connect_info));
message_put(message);
new_state(PORT_STATE_CONNECT);
}
/* dialing information */
mncc->called = 1;
- SCPY(mncc->called_number, p_dialinginfo.id);
- add_trace("dialing", "number", "%s", mncc->called_number);
+ 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 */
int gsm_init(void)
{
- char hlr[128];
+ char hlr[128], filename[128];
+ mode_t mode = S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH;
+ int pcapfd;
/* create gsm instance */
gsm = (struct lcr_gsm *)MALLOC(sizeof(struct lcr_gsm));
PERROR("Expecting exactly one BTS. You defined %d.\n", gsm->conf.numbts);
return gsm_exit(-1);
}
+
/* bootstrap network */
gsm->network = bootstrap_network(&message_bcs, gsm->conf.bts[0].type, gsm->conf.mcc, gsm->conf.mnc, gsm->conf.lac, gsm->conf.bts[0].frequency[0], gsm->conf.bts[0].card, !gsm->conf.keep_l2, gsm->conf.short_name, gsm->conf.long_name, hlr, gsm->conf.allow_all);
if (!gsm->network) {
PERROR("Failed to bootstrap GSM network.\n");
return gsm_exit(-1);
}
+
/* open gsm loop interface */
if (gsm_sock_open(gsm->conf.interface_bsc)) {
return gsm_exit(-1);
}
+ /* open pcap file */
+ if (gsm->conf.pcapfile[0]) {
+ if (gsm->conf.pcapfile[0] == '/')
+ SCPY(filename, gsm->conf.pcapfile);
+ else
+ SPRINT(filename, "%s/%s", CONFIG_DATA, gsm->conf.pcapfile);
+ pcapfd = open(filename, O_WRONLY|O_TRUNC|O_CREAT, mode);
+ if (pcapfd < 0) {
+ PERROR("Failed to open file for pcap\n");
+ return gsm_exit(-1);
+ }
+ e1_set_pcap_fd(pcapfd);
+ }
+
return 0;
}
int numbts; /* number of BTS' */
struct bts_conf bts[8]; /* configure BTS' */
int noemergshut; /* don't shut down on emergency */
+ char pcapfile[128]; /* open capture file for BS11 links */
};
struct lcr_gsm {
SPRINT(filename, "%s/gsm.conf", CONFIG_DATA);
- if (!(fp=fopen(filename,"r")))
- {
+ if (!(fp=fopen(filename,"r"))) {
SPRINT(gsm_conf_error, "Cannot open %s\n",filename);
return(0);
}
line=0;
- while((fgets(buffer,sizeof(buffer),fp)))
- {
+ while((fgets(buffer,sizeof(buffer),fp))) {
line++;
buffer[sizeof(buffer)-1]=0;
if (buffer[0]) buffer[strlen(buffer)-1]=0;
p=buffer;
- while(*p <= 32) /* skip spaces */
- {
+ while(*p <= 32) { /* skip spaces */
if (*p == 0)
break;
p++;
option[0]=0;
i=0; /* read option */
- while(*p > 32)
- {
- if (i+1 >= sizeof(option))
- {
+ while(*p > 32) {
+ if (i+1 >= sizeof(option)) {
SPRINT(gsm_conf_error, "Error in %s (line %d): option too long.\n",filename,line);
goto error;
}
option[i++] = *p++;
}
- while(*p <= 32) /* skip spaces */
- {
+ while(*p <= 32) { /* skip spaces */
if (*p == 0)
break;
p++;
params[0][0] = 0;
pnum = 0;
- while(*p!=0 && *p!='#' && pnum < 10) /* param */
- {
+ while(*p!=0 && *p!='#' && pnum < 10) { /* param */
i=0; /* read param */
- while(*p > 32)
- {
- if (i+1 >= sizeof(params[pnum]))
- {
+ while(*p > 32) {
+ if (i+1 >= sizeof(params[pnum])) {
SPRINT(gsm_conf_error, "Error in %s (line %d): param too long.\n",filename,line);
goto error;
}
params[pnum][i+1] = '\0';
params[pnum][i++] = *p++;
}
- while(*p <= 32) /* skip spaces */
- {
+ while(*p <= 32) { /* skip spaces */
if (*p == 0)
break;
p++;
/* at this point we have option and param */
/* check option */
- if (!strcmp(option,"debug"))
- {
- if (params[0][0]==0)
- {
+ if (!strcmp(option,"debug")) {
+ if (params[0][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter for option %s missing.\n",filename,line,option);
goto error;
}
SCPY(gsm_conf->debug, params[0]);
} else
- if (!strcmp(option,"interface-bsc"))
- {
- if (params[0][0]==0)
- {
+ if (!strcmp(option,"interface-bsc")) {
+ if (params[0][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter for option %s missing.\n",filename,line, option);
goto error;
}
SCPY(gsm_conf->interface_bsc, params[0]);
} else
- if (!strcmp(option,"interface-lcr"))
- {
- if (params[0][0]==0)
- {
+ if (!strcmp(option,"interface-lcr")) {
+ if (params[0][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter for option %s missing.\n",filename,line, option);
goto error;
}
SCPY(gsm_conf->interface_lcr, params[0]);
} else
- if (!strcmp(option,"short-name"))
- {
- if (params[0][0]==0)
- {
+ if (!strcmp(option,"short-name")) {
+ if (params[0][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter for option %s missing.\n",filename,line, option);
goto error;
}
SCPY(gsm_conf->short_name, params[0]);
} else
- if (!strcmp(option,"long-name"))
- {
- if (params[0][0]==0)
- {
+ if (!strcmp(option,"long-name")) {
+ if (params[0][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter for option %s missing.\n",filename,line, option);
goto error;
}
SCPY(gsm_conf->long_name, params[0]);
} else
- if (!strcmp(option,"mcc"))
- {
- if (params[0][0]==0)
- {
+ if (!strcmp(option,"mcc")) {
+ if (params[0][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter for option %s missing.\n",filename,line, option);
goto error;
}
gsm_conf->mcc = atoi(params[0]);
} else
- if (!strcmp(option,"mnc"))
- {
- if (params[0][0]==0)
- {
+ if (!strcmp(option,"mnc")) {
+ if (params[0][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter for option %s missing.\n",filename,line, option);
goto error;
}
gsm_conf->mnc = atoi(params[0]);
} else
- if (!strcmp(option,"lac"))
- {
- if (params[0][0]==0)
- {
+ if (!strcmp(option,"lac")) {
+ if (params[0][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter for option %s missing.\n",filename,line, option);
goto error;
}
gsm_conf->lac = atoi(params[0]);
} else
- if (!strcmp(option,"hlr"))
- {
- if (params[0][0]==0)
- {
+ if (!strcmp(option,"hlr")) {
+ if (params[0][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter for option %s missing.\n",filename,line, option);
goto error;
}
SCPY(gsm_conf->hlr, params[0]);
} else
- if (!strcmp(option,"allow-all"))
- {
+ if (!strcmp(option,"allow-all")) {
gsm_conf->allow_all = 1;
} else
- if (!strcmp(option,"keep-l2"))
- {
+ if (!strcmp(option,"keep-l2")) {
gsm_conf->keep_l2 = 1;
} else
- if (!strcmp(option,"no-mergency-shutdown"))
- {
+ if (!strcmp(option,"no-mergency-shutdown")) {
gsm_conf->noemergshut = 1;
} else
- if (!strcmp(option,"bts"))
- {
- if (gsm_conf->numbts == 8)
- {
+ if (!strcmp(option,"pcapfile")) {
+ if (params[0][0]==0) {
+ SPRINT(gsm_conf_error, "Error in %s (line %d): parameter for option %s missing.\n",filename,line, option);
+ goto error;
+ }
+ SCPY(gsm_conf->pcapfile, params[0]);
+ } else
+ if (!strcmp(option,"bts")) {
+ if (gsm_conf->numbts == 8) {
SPRINT(gsm_conf_error, "Error in %s (line %d): too many BTS defined.\n",filename,line);
goto error;
}
- if (params[0][0]==0)
- {
+ if (params[0][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter <bts-type> for option %s missing.\n",filename,line,option);
goto error;
}
- if (params[1][0]==0)
- {
+ if (params[1][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter <card number> for option %s missing.\n",filename,line,option);
goto error;
}
- if (params[2][0]==0)
- {
+ if (params[2][0]==0) {
SPRINT(gsm_conf_error, "Error in %s (line %d): parameter <frequency> for option %s missing.\n",filename,line,option);
goto error;
}
- if (!strcmp(params[0], "bs11"))
- {
+ if (!strcmp(params[0], "bs11")) {
gsm_conf->bts[gsm_conf->numbts].type = GSM_BTS_TYPE_BS11;
} else {
SPRINT(gsm_conf_error, "Error in %s (line %d): unknown BTS type '%s'.\n",filename,line,params[0]);
}
gsm_conf->bts[gsm_conf->numbts].card = atoi(params[1]);
gsm_conf->bts[gsm_conf->numbts].numtrx = 0;
- while (params[gsm_conf->bts[gsm_conf->numbts].numtrx+2][0])
- {
- if (gsm_conf->bts[gsm_conf->numbts].numtrx == 8)
- {
+ while (params[gsm_conf->bts[gsm_conf->numbts].numtrx+2][0]) {
+ if (gsm_conf->bts[gsm_conf->numbts].numtrx == 8) {
SPRINT(gsm_conf_error, "Error in %s (line %d): too many frequencies defined.\n",filename,line);
goto error;
}
gsm_conf->bts[gsm_conf->numbts].frequency[gsm_conf->bts[gsm_conf->numbts].numtrx++] = atoi(params[gsm_conf->bts[gsm_conf->numbts].numtrx+2]);
}
gsm_conf->numbts++;
- } else
- {
+ } else {
SPRINT(gsm_conf_error, "Error in %s (line %d): wrong option keyword %s.\n", filename,line,option);
goto error;
}
int ntype2; /* second type of number */
int present2; /* second presentation */
int screen2; /* second who provided the number */
+ char imsi[16]; /* IMSI for gsm originated calls */
};
/* call-info structure DIALING */
int present; /* presentation */
int screen; /* who provided the number */
char display[84]; /* display information */
+ char imsi[16]; /* IMSI for gsm terminated calls */
};
/* call-info structure DISCONNECT */
projects / lcr.git / commitdiff