X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=action.cpp;h=db8e101018d7f9dcebda476de83e6d96fb50c749;hp=5819670d77d506c4a084d593fbfea268da48e787;hb=8a3a986487b4d8f2e2607ebeaf21a77d7222211d;hpb=efc550418c0b107c07818809a3d8e779e476dcd4 diff --git a/action.cpp b/action.cpp index 5819670..db8e101 100644 --- a/action.cpp +++ b/action.cpp @@ -15,59 +15,26 @@ extern char **environ; /* - * process init 'internal' / 'external' / 'remote' / 'vbox-record' / 'partyline'... + * process init 'internal' / 'external' / 'vbox-record' / 'partyline'... */ -int EndpointAppPBX::_action_init_call(char *remote) +void EndpointAppPBX::action_init_call(void) { class Join *join; - struct port_list *portlist = ea_endpoint->ep_portlist; - 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); + return; } /* create join */ PDEBUG(DEBUG_EPOINT, "EPOINT(%d): Creating new join instance.\n", ea_endpoint->ep_serial); - if (remote) - { - admin = admin_first; - while(admin) - { - if (admin->remote_name[0] && !strcmp(admin->remote_name, remote)) - break; - admin = admin->next; - } - if (!admin) - { - /* resource not available */ - trace_header("ACTION remote (not available)", DIRECTION_NONE); - add_trace("application", NULL, "%s", remote); - end_trace(); - message_disconnect_port(portlist, CAUSE_OUTOFORDER, LOCATION_PRIVATE_LOCAL, ""); - new_state(EPOINT_STATE_OUT_DISCONNECT); - set_tone(portlist,"cause_1b"); - return(0); - } - join = new JoinRemote(ea_endpoint->ep_serial, remote, admin->sock); - } - else - join = new JoinPBX(ea_endpoint); + join = new JoinPBX(ea_endpoint); if (!join) FATAL("No memoy for Join instance.\n"); ea_endpoint->ep_join_id = join->j_serial; - return(1); -} -void EndpointAppPBX::action_init_call(void) -{ - _action_init_call(NULL); -} -void EndpointAppPBX::action_init_remote(void) -{ + return; } /* @@ -78,6 +45,7 @@ void EndpointAppPBX::action_dialing_internal(void) struct capa_info capainfo; struct caller_info callerinfo; struct redir_info redirinfo; + struct rtp_info rtpinfo; struct dialing_info dialinginfo; struct port_list *portlist = ea_endpoint->ep_portlist; struct lcr_msg *message; @@ -95,6 +63,7 @@ void EndpointAppPBX::action_dialing_internal(void) memcpy(&capainfo, &e_capainfo, sizeof(capainfo)); memcpy(&callerinfo, &e_callerinfo, sizeof(callerinfo)); memcpy(&redirinfo, &e_redirinfo, sizeof(redirinfo)); + memcpy(&rtpinfo, &e_rtpinfo, sizeof(rtpinfo)); memset(&dialinginfo, 0, sizeof(dialinginfo)); dialinginfo.itype = INFO_ITYPE_ISDN_EXTENSION; SCPY(dialinginfo.id, e_dialinginfo.id); @@ -108,59 +77,52 @@ void EndpointAppPBX::action_dialing_internal(void) 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; + capainfo.hlc = INFO_HLC_NONE; + capainfo.exthlc = INFO_HLC_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 (!read_extension(&ext, dialinginfo.id) && !strchr(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(); - release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, 0, 0); + release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, 0, 0, 0); new_state(EPOINT_STATE_OUT_DISCONNECT); message_disconnect_port(portlist, CAUSE_UNALLOCATED, LOCATION_PRIVATE_LOCAL, ""); set_tone(portlist, "cause_86"); 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(); new_state(EPOINT_STATE_OUT_DISCONNECT); - release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, 0, 0); + release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, 0, 0, 0); message_disconnect_port(portlist, CAUSE_REJECTED, LOCATION_PRIVATE_LOCAL, ""); set_tone(portlist, "cause_81"); return; @@ -175,6 +137,7 @@ void EndpointAppPBX::action_dialing_internal(void) memcpy(&message->param.setup.redirinfo, &redirinfo, sizeof(struct redir_info)); memcpy(&message->param.setup.callerinfo, &callerinfo, sizeof(struct caller_info)); memcpy(&message->param.setup.capainfo, &capainfo, sizeof(struct capa_info)); + memcpy(&message->param.setup.rtpinfo, &rtpinfo, sizeof(struct rtp_info)); message_put(message); } @@ -185,6 +148,7 @@ void EndpointAppPBX::action_dialing_external(void) struct capa_info capainfo; struct caller_info callerinfo; struct redir_info redirinfo; + struct rtp_info rtpinfo; struct dialing_info dialinginfo; char *p; struct port_list *portlist = ea_endpoint->ep_portlist; @@ -192,23 +156,18 @@ void EndpointAppPBX::action_dialing_external(void) 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--; } @@ -222,19 +181,27 @@ void EndpointAppPBX::action_dialing_external(void) memcpy(&capainfo, &e_capainfo, sizeof(capainfo)); memcpy(&callerinfo, &e_callerinfo, sizeof(callerinfo)); memcpy(&redirinfo, &e_redirinfo, sizeof(redirinfo)); + memcpy(&rtpinfo, &e_rtpinfo, sizeof(rtpinfo)); memset(&dialinginfo, 0, sizeof(dialinginfo)); dialinginfo.itype = INFO_ITYPE_ISDN; - dialinginfo.sending_complete = 0; +// dialinginfo.sending_complete = 0; SCPY(dialinginfo.id, e_extdialing); /* process prefix */ if ((rparam = routeparam(e_action, PARAM_PREFIX))) SPRINT(dialinginfo.id, "%s%s", rparam->string_value, e_extdialing); + if ((rparam = routeparam(e_action, PARAM_CONTEXT))) + SCPY(dialinginfo.context, rparam->string_value); + + /* process keypad */ + if ((rparam = routeparam(e_action, PARAM_KEYPAD))) { + SCPY(dialinginfo.keypad, dialinginfo.id); + dialinginfo.id[0] = '\0'; + } + /* process number complete */ if ((rparam = routeparam(e_action, PARAM_COMPLETE))) - if ((rparam = routeparam(e_action, PARAM_PREFIX))) - SCPY(dialinginfo.id, rparam->string_value); dialinginfo.sending_complete = 1; /* process number type */ @@ -242,47 +209,40 @@ void EndpointAppPBX::action_dialing_external(void) 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; + capainfo.hlc = INFO_HLC_NONE; + capainfo.exthlc = INFO_HLC_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; } @@ -291,11 +251,10 @@ void EndpointAppPBX::action_dialing_external(void) 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); + release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_REJECTED, 0, 0, 0); set_tone(portlist, "cause_82"); denied: message_disconnect_port(portlist, CAUSE_REJECTED, LOCATION_PRIVATE_LOCAL, ""); @@ -305,28 +264,24 @@ void EndpointAppPBX::action_dialing_external(void) 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); + release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_REJECTED, 0, 0, 0); set_tone(portlist, "cause_83"); goto denied; } } 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); + release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_REJECTED, 0, 0, 0); set_tone(portlist, "cause_84"); goto denied; } @@ -335,6 +290,8 @@ void EndpointAppPBX::action_dialing_external(void) /* add or update outgoing call */ trace_header("ACTION extern (calling)", DIRECTION_NONE); add_trace("number", NULL, dialinginfo.id); + if (dialinginfo.sending_complete) + add_trace("number", "complete", "yes"); if (dialinginfo.interfaces[0]) add_trace("interfaces", NULL, dialinginfo.interfaces); end_trace(); @@ -343,89 +300,11 @@ void EndpointAppPBX::action_dialing_external(void) memcpy(&message->param.setup.redirinfo, &redirinfo, sizeof(struct redir_info)); memcpy(&message->param.setup.callerinfo, &callerinfo, sizeof(struct caller_info)); memcpy(&message->param.setup.capainfo, &capainfo, sizeof(struct capa_info)); + memcpy(&message->param.setup.rtpinfo, &rtpinfo, sizeof(struct rtp_info)); message_put(message); } -void EndpointAppPBX::action_dialing_remote(void) -{ - struct route_param *rparam; - struct port_list *portlist = ea_endpoint->ep_portlist; - struct lcr_msg *message; - struct capa_info capainfo; - struct caller_info callerinfo; - struct redir_info redirinfo; - struct dialing_info dialinginfo; - char context[128] = ""; - char remote[32]; - - if (!ea_endpoint->ep_join_id) - { - /* no join yet, sending setup */ - if (!(rparam = routeparam(e_action, PARAM_APPLICATION))) - { - trace_header("ACTION remote (no application given)", DIRECTION_NONE); - end_trace(); - new_state(EPOINT_STATE_OUT_DISCONNECT); - message_disconnect_port(portlist, CAUSE_SERVICEUNAVAIL, LOCATION_PRIVATE_LOCAL, ""); - set_tone(portlist, "cause_3f"); - return; - } - SCPY(remote, rparam->string_value); - if (!_action_init_call(remote)) - return; - - /* create bearer/caller/dialinginfo */ - memcpy(&capainfo, &e_capainfo, sizeof(capainfo)); - memcpy(&callerinfo, &e_callerinfo, sizeof(callerinfo)); - memcpy(&redirinfo, &e_redirinfo, sizeof(redirinfo)); - memset(&dialinginfo, 0, sizeof(dialinginfo)); - - if ((rparam = routeparam(e_action, PARAM_CONTEXT))) - { - SCPY(context, rparam->string_value); - } - if ((rparam = routeparam(e_action, PARAM_EXTEN))) - { - SCPY(dialinginfo.id, rparam->string_value); - dialinginfo.ntype = INFO_NTYPE_UNKNOWN; - } else - { - SCPY(dialinginfo.id, e_extdialing); - } - e_extdialing = e_dialinginfo.id + strlen(e_dialinginfo.id); - /* send setup to remote */ - trace_header("ACTION remote (setup)", DIRECTION_NONE); - add_trace("number", NULL, dialinginfo.id); - add_trace("remote", NULL, remote); - if (context[0]) - add_trace("context", NULL, context); - end_trace(); - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_SETUP); - memcpy(&message->param.setup.dialinginfo, &dialinginfo, sizeof(struct dialing_info)); - memcpy(&message->param.setup.redirinfo, &redirinfo, sizeof(struct redir_info)); - memcpy(&message->param.setup.callerinfo, &callerinfo, sizeof(struct caller_info)); - memcpy(&message->param.setup.capainfo, &capainfo, sizeof(struct capa_info)); - SCPY(message->param.setup.context, context); - message_put(message); - } else - { - /* send overlap digits */ - trace_header("ACTION remote (dialing)", DIRECTION_NONE); - add_trace("number", NULL, e_extdialing); - end_trace(); - 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); - e_extdialing = e_dialinginfo.id + strlen(e_dialinginfo.id); - message_put(message); - } - } -} - - /* * process dialing the "am" and record */ @@ -440,8 +319,7 @@ void EndpointAppPBX::action_dialing_vbox_record(void) 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(); @@ -452,8 +330,7 @@ void EndpointAppPBX::action_dialing_vbox_record(void) } /* 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(); @@ -464,8 +341,7 @@ void EndpointAppPBX::action_dialing_vbox_record(void) } /* 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); @@ -487,8 +363,7 @@ void EndpointAppPBX::action_dialing_vbox_record(void) /* 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); } @@ -522,8 +397,7 @@ void EndpointAppPBX::action_init_partyline(void) 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: @@ -532,8 +406,7 @@ void EndpointAppPBX::action_init_partyline(void) 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(); @@ -546,24 +419,20 @@ void EndpointAppPBX::action_init_partyline(void) /* 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())) @@ -620,14 +489,12 @@ void EndpointAppPBX::action_dialing_login(void) 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(); @@ -637,14 +504,12 @@ void EndpointAppPBX::action_dialing_login(void) 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(); @@ -682,8 +547,7 @@ void EndpointAppPBX::action_dialing_login(void) 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); @@ -692,18 +556,17 @@ void EndpointAppPBX::action_dialing_login(void) e_ruleset = NULL; e_rule = NULL; e_action = &action_password; - e_match_timeout = 0; + unsched_timer(&e_match_timeout); e_match_to_action = NULL; e_dialinginfo.id[0] = '\0'; e_extdialing = strchr(e_dialinginfo.id, '\0'); /* set timeout */ - e_password_timeout = now+20; + schedule_timer(&e_password_timeout, 20, 0); /* do dialing */ - process_dialing(); - } else - { + process_dialing(0); + } else { /* make call state */ new_state(EPOINT_STATE_IN_OVERLAP); e_ruleset = ruleset_main; @@ -724,8 +587,7 @@ void EndpointAppPBX::action_init_change_callerid(void) { 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(); @@ -746,15 +608,12 @@ void EndpointAppPBX::_action_callerid_calleridnext(int next) 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; } @@ -764,8 +623,7 @@ void EndpointAppPBX::_action_callerid_calleridnext(int next) /* 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; @@ -786,27 +644,22 @@ void EndpointAppPBX::_action_callerid_calleridnext(int next) /* 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; @@ -855,8 +708,7 @@ void EndpointAppPBX::action_init_change_forward(void) { 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 */ @@ -880,12 +732,10 @@ void EndpointAppPBX::action_dialing_forward(void) 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'; @@ -893,10 +743,8 @@ void EndpointAppPBX::action_dialing_forward(void) } 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); @@ -944,8 +792,7 @@ void EndpointAppPBX::action_init_redial_reply(void) 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); @@ -976,16 +823,14 @@ void EndpointAppPBX::_action_redial_reply(int in) 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) { @@ -1000,8 +845,7 @@ void EndpointAppPBX::_action_redial_reply(int in) } 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); @@ -1013,7 +857,7 @@ void EndpointAppPBX::_action_redial_reply(int in) SCPY(e_dialinginfo.id, last); e_extdialing = e_dialinginfo.id; e_action = NULL; - process_dialing(); + process_dialing(0); return; } e_extdialing[0] = '\0'; @@ -1062,8 +906,7 @@ void EndpointAppPBX::action_dialing_powerdial(void) 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); @@ -1073,20 +916,16 @@ void EndpointAppPBX::action_dialing_powerdial(void) } /* 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; @@ -1112,10 +951,10 @@ void EndpointAppPBX::action_dialing_powerdial(void) /* do dialing */ SCPY(e_dialinginfo.id, e_ext.last_out[0]); - e_powerdialing = -1; /* indicates the existence of powerdialing but no redial time given */ + e_powerdial_on = 1; /* indicates the existence of powerdialing but no redial time given */ e_powercount = 0; e_action = NULL; - process_dialing(); + process_dialing(0); } @@ -1130,8 +969,7 @@ void EndpointAppPBX::action_dialing_callback(void) 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(); @@ -1152,8 +990,7 @@ void EndpointAppPBX::action_dialing_callback(void) /* 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(); @@ -1161,8 +998,7 @@ void EndpointAppPBX::action_dialing_callback(void) } /* 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(); @@ -1172,8 +1008,7 @@ void EndpointAppPBX::action_dialing_callback(void) /* 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); @@ -1182,8 +1017,7 @@ void EndpointAppPBX::action_dialing_callback(void) 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(); @@ -1222,7 +1056,7 @@ void EndpointAppPBX::action_hangup_callback(void) end_trace(); /* set time to callback */ - e_callback = now_d + delay; + schedule_timer(&e_callback_timeout, delay, 0); } @@ -1238,8 +1072,7 @@ void EndpointAppPBX::action_dialing_abbrev(void) 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); @@ -1253,8 +1086,7 @@ void EndpointAppPBX::action_dialing_abbrev(void) 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(); @@ -1263,8 +1095,7 @@ void EndpointAppPBX::action_dialing_abbrev(void) 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; } @@ -1278,7 +1109,7 @@ void EndpointAppPBX::action_dialing_abbrev(void) SCPY(e_dialinginfo.id, phone); e_extdialing = e_dialinginfo.id; e_action = NULL; - process_dialing(); + process_dialing(0); } @@ -1299,8 +1130,7 @@ void EndpointAppPBX::action_dialing_test(void) 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"); @@ -1348,8 +1178,7 @@ void EndpointAppPBX::action_dialing_test(void) 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; @@ -1462,8 +1291,7 @@ void EndpointAppPBX::action_init_play(void) 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(); @@ -1476,8 +1304,7 @@ void EndpointAppPBX::action_init_play(void) } /* 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; @@ -1509,16 +1336,13 @@ void EndpointAppPBX::action_dialing_calculator(void) 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); } @@ -1533,31 +1357,24 @@ void EndpointAppPBX::action_dialing_calculator(void) 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--) @@ -1566,11 +1383,9 @@ void EndpointAppPBX::action_dialing_calculator(void) } break; case 1: /* second number */ - if (!komma2) - { + if (!komma2) { value2 = value2*10 + (*p-'0'); - } else - { + } else { k = komma2++; v = *p-'0'; while(k--) @@ -1580,17 +1395,14 @@ void EndpointAppPBX::action_dialing_calculator(void) 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); @@ -1598,8 +1410,7 @@ void EndpointAppPBX::action_dialing_calculator(void) break; } /* if there is a division, we change to + */ - if (p[-1] == '/') - { + if (p[-1] == '/') { mode = 2; p[-1] = '+'; UCPY(p, p+1); @@ -1607,8 +1418,7 @@ void EndpointAppPBX::action_dialing_calculator(void) break; } /* if there is a addition, we change to - */ - if (p[-1] == '+') - { + if (p[-1] == '+') { mode = 3; p[-1] = '-'; UCPY(p, p+1); @@ -1616,8 +1426,7 @@ void EndpointAppPBX::action_dialing_calculator(void) 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); @@ -1625,8 +1434,7 @@ void EndpointAppPBX::action_dialing_calculator(void) 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--; @@ -1634,8 +1442,7 @@ void EndpointAppPBX::action_dialing_calculator(void) 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); @@ -1644,14 +1451,12 @@ void EndpointAppPBX::action_dialing_calculator(void) 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; @@ -1664,14 +1469,12 @@ void EndpointAppPBX::action_dialing_calculator(void) 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; @@ -1686,8 +1489,7 @@ void EndpointAppPBX::action_dialing_calculator(void) 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] == '.') @@ -1715,8 +1517,7 @@ void EndpointAppPBX::action_dialing_calculator(void) break; case '-': - if (first) - { + if (first) { sign1=-1; break; } @@ -1761,8 +1562,7 @@ void EndpointAppPBX::_action_goto_menu(int mode) 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(); @@ -1777,8 +1577,7 @@ void EndpointAppPBX::_action_goto_menu(int mode) 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(); @@ -1786,15 +1585,12 @@ void EndpointAppPBX::_action_goto_menu(int mode) } /* 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; @@ -1804,23 +1600,20 @@ void EndpointAppPBX::_action_goto_menu(int mode) /* 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(); } /* do dialing with new ruleset */ e_action = NULL; - process_dialing(); + process_dialing(0); } /* process dialing goto @@ -1851,13 +1644,11 @@ void EndpointAppPBX::action_dialing_disconnect(void) 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); } @@ -1867,15 +1658,13 @@ void EndpointAppPBX::action_dialing_disconnect(void) 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); } @@ -1891,11 +1680,9 @@ void EndpointAppPBX::action_dialing_disconnect(void) 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); @@ -1906,6 +1693,48 @@ void EndpointAppPBX::action_dialing_disconnect(void) /* + * process dialing release + */ +void EndpointAppPBX::action_dialing_release(void) +{ + struct route_param *rparam; + int cause = CAUSE_NORMAL; /* normal call clearing */ + int location = LOCATION_PRIVATE_LOCAL; + char cause_string[256] = "", display[84] = ""; + + /* check cause parameter */ + 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))) { + location = rparam->integer_value; + PDEBUG(DEBUG_EPOINT, "EPOINT(%d): 'location' is given: %d\n", ea_endpoint->ep_serial, location); + } + + + /* use cause as sample, if not given later */ + SPRINT(cause_string, "cause_%02x", cause); + + /* check 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); + } + + /* disconnect only if connect parameter is not given */ + trace_header("ACTION release", DIRECTION_NONE); + add_trace("cause", "value", "%d", cause); + add_trace("cause", "location", "%d", location); + if (display[0]) + add_trace("display", NULL, "%s", display); + end_trace(); + e_action = NULL; + release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, location, cause, 1); + return; +} + +/* * process dialing help */ void EndpointAppPBX::action_dialing_help(void) @@ -1923,36 +1752,29 @@ void EndpointAppPBX::action_dialing_help(void) 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; @@ -1962,8 +1784,7 @@ void EndpointAppPBX::action_dialing_help(void) } /* 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 @@ -1972,7 +1793,7 @@ void EndpointAppPBX::action_dialing_help(void) e_extdialing = e_dialinginfo.id+strlen(numbering->prefix); PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal %s selected a new menu '%s' dialing: %s\n", ea_endpoint->ep_serial, e_ext.number, numb_actions[numbering->action], e_dialinginfo.id); nesting?: - process_dialing(); + process_dialing(0); return; } @@ -2001,34 +1822,75 @@ void EndpointAppPBX::action_dialing_setforward(void) { } +/* + * process init 'execute' + */ +void EndpointAppPBX::action_init_execute(void) +{ + struct route_param *rparam; + int executeon = INFO_ON_HANGUP; /* Use Hangup as a default for compatibility */ + + /* Get the execute on parameter */ + if ((rparam = routeparam(e_action, PARAM_ON))) + executeon = rparam->integer_value; + + /* Execute this action if init was specified */ + if (executeon == INFO_ON_INIT) { + trace_header("ACTION execute ON init", DIRECTION_NONE); + end_trace(); + action_execute(); + } +} /* * process hangup 'execute' - */ + */ void EndpointAppPBX::action_hangup_execute(void) { struct route_param *rparam; + int executeon = INFO_ON_HANGUP; /* Use Hangup as a default for compatibility */ + + /* Get the execute on parameter */ + if ((rparam = routeparam(e_action, PARAM_ON))) + executeon = rparam->integer_value; + + /* Execute this action if init was specified */ + if (executeon == INFO_ON_HANGUP) { + trace_header("ACTION execute ON hangup", DIRECTION_NONE); + end_trace(); + action_execute(); + } +} + +/* + * process 'execute' from action_init_execute or action_hangup_execute + */ +void EndpointAppPBX::action_execute(void) +{ + struct route_param *rparam; pid_t pid; + pid_t pid2; + int iWaitStatus; char *command = (char *)""; char isdn_port[10]; - char *argv[11]; /* check also number of args below */ + char *argv[12]; /* check also number of args below */ int i = 0; /* 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; } +#if 0 argv[i++] = (char *)"/bin/sh"; argv[i++] = (char *)"-c"; argv[i++] = command; +#endif 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; @@ -2037,6 +1899,7 @@ void EndpointAppPBX::action_hangup_execute(void) argv[i++] = e_callerinfo.name; SPRINT(isdn_port, "%d", e_callerinfo.isdn_port); argv[i++] = isdn_port; + argv[i++] = e_callerinfo.imsi; argv[i++] = NULL; /* check also number of args above */ switch (pid = fork ()) { case -1: @@ -2044,12 +1907,20 @@ void EndpointAppPBX::action_hangup_execute(void) end_trace(); break; case 0: - execve("/bin/sh", argv, environ); - break; + /* To be shure there are no zombies created double fork */ + if ((pid2 = fork()) == 0) { + execve(command, argv, environ); + } + /* Exit immediately and release the waiting parent. The subprocess falls to init because the parent died */ + exit(0); + break; default: trace_header("ACTION execute", DIRECTION_NONE); add_trace("command", NULL, "%s", command); end_trace(); + + /* Wait for the pid. The forked process will exit immediately so there is no problem waiting. */ + waitpid(pid, &iWaitStatus, 0); break; } } @@ -2077,14 +1948,12 @@ void EndpointAppPBX::action_hangup_file(void) 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"); @@ -2128,13 +1997,11 @@ void EndpointAppPBX::action_dialing_password(void) 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"); } @@ -2144,8 +2011,7 @@ void EndpointAppPBX::action_dialing_password(void) 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(); @@ -2159,8 +2025,7 @@ void EndpointAppPBX::action_dialing_password(void) /* 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); @@ -2184,68 +2049,454 @@ void EndpointAppPBX::action_dialing_password_wr(void) } +/* process pots-retrieve + */ +void EndpointAppPBX::action_init_pots_retrieve(void) +{ +#ifdef ISDN_P_FXS_POTS + struct route_param *rparam; + struct port_list *portlist = ea_endpoint->ep_portlist; + class Port *port; + class Pfxs *ourfxs, *fxs; + int count = 0; + class Endpoint *epoint; + + /* check given call */ + if (!(rparam = routeparam(e_action, PARAM_POTS_CALL))) { + trace_header("ACTION pots-retrieve (no call given)", DIRECTION_NONE); + end_trace(); + + disconnect: + new_state(EPOINT_STATE_OUT_DISCONNECT); + message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, ""); + set_tone(portlist, "cause_3f"); + e_action = NULL; + return; + } + + /* find call */ + port = find_port_id(portlist->port_id); + if (!port) + goto disconnect; + if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) { + trace_header("ACTION pots-retrieve (call not of FXS type)", DIRECTION_NONE); + end_trace(); + goto disconnect; + } + ourfxs = (class Pfxs *)port; + + port = port_first; + while(port) { + if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) { + fxs = (class Pfxs *)port; + if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) { + count++; + if (count == rparam->integer_value) + break; + } + } + port = port->next; + } + if (!port) { + trace_header("ACTION pots-retrieve (call # does not exist)", DIRECTION_NONE); + end_trace(); + goto disconnect; + } + + /* release our call */ + ourfxs->hangup_ind(0); + + /* retrieve selected call */ + fxs->retrieve_ind(0); + + /* split if selected call is member of a 3pty */ + epoint = find_epoint_id(ACTIVE_EPOINT(fxs->p_epointlist)); + if (epoint && epoint->ep_app_type == EAPP_TYPE_PBX) { + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) try spliting 3pty. this may fail because we don't have a 3pty.\n", epoint->ep_serial); + ((class EndpointAppPBX *)epoint->ep_app)->split_3pty(); + } +#endif +} + + +/* process pots-release + */ +void EndpointAppPBX::action_init_pots_release(void) +{ +#ifdef ISDN_P_FXS_POTS + struct route_param *rparam; + struct port_list *portlist = ea_endpoint->ep_portlist; + class Port *port; + class Pfxs *ourfxs, *fxs; + int count = 0; + + /* check given call */ + if (!(rparam = routeparam(e_action, PARAM_POTS_CALL))) { + trace_header("ACTION pots-release (no call given)", DIRECTION_NONE); + end_trace(); + + disconnect: + new_state(EPOINT_STATE_OUT_DISCONNECT); + message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, ""); + set_tone(portlist, "cause_3f"); + e_action = NULL; + return; + } + + /* find call */ + port = find_port_id(portlist->port_id); + if (!port) + goto disconnect; + if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) { + trace_header("ACTION pots-release (call not of FXS type)", DIRECTION_NONE); + end_trace(); + goto disconnect; + } + ourfxs = (class Pfxs *)port; + + port = port_first; + while(port) { + if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) { + fxs = (class Pfxs *)port; + if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) { + count++; + if (count == rparam->integer_value) + break; + } + } + port = port->next; + } + if (!port) { + trace_header("ACTION pots-release (call # does not exist)", DIRECTION_NONE); + end_trace(); + goto disconnect; + } + +#if 0 + /* disconnect our call */ + new_state(EPOINT_STATE_OUT_DISCONNECT); + message_disconnect_port(portlist, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, ""); + set_tone(portlist, "hangup"); + e_action = NULL; +#endif + + /* release selected call */ + fxs->hangup_ind(0); + + /* indicate timeout, so next action will be processed */ + process_dialing(1); +#endif +} + + +/* process pots-reject + */ +void EndpointAppPBX::action_init_pots_reject(void) +{ +#ifdef ISDN_P_FXS_POTS + struct port_list *portlist = ea_endpoint->ep_portlist; + class Port *port; + class Pfxs *ourfxs, *fxs; + + /* find call */ + port = find_port_id(portlist->port_id); + if (!port) + goto disconnect; + if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) { + trace_header("ACTION pots-reject (call not of FXS type)", DIRECTION_NONE); + end_trace(); + disconnect: + new_state(EPOINT_STATE_OUT_DISCONNECT); + message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, ""); + set_tone(portlist, "cause_3f"); + e_action = NULL; + return; + } + ourfxs = (class Pfxs *)port; + + port = port_first; + while(port) { + if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) { + fxs = (class Pfxs *)port; + if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) { + if (fxs->p_state == PORT_STATE_OUT_ALERTING) + break; + } + } + port = port->next; + } + if (!port) { + trace_header("ACTION pots-reject (no call waiting)", DIRECTION_NONE); + end_trace(); + goto disconnect; + } + + /* reject alerting call */ + fxs->reject_ind(0); + + /* indicate timeout, so next action will be processed */ + process_dialing(1); +#endif +} + + +/* process pots-answer + */ +void EndpointAppPBX::action_init_pots_answer(void) +{ +#ifdef ISDN_P_FXS_POTS + struct port_list *portlist = ea_endpoint->ep_portlist; + class Port *port; + class Pfxs *ourfxs, *fxs; + + /* find call */ + port = find_port_id(portlist->port_id); + if (!port) + goto disconnect; + if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) { + trace_header("ACTION pots-answer (call not of FXS type)", DIRECTION_NONE); + end_trace(); + disconnect: + new_state(EPOINT_STATE_OUT_DISCONNECT); + message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, ""); + set_tone(portlist, "cause_3f"); + e_action = NULL; + return; + } + ourfxs = (class Pfxs *)port; + + port = port_first; + while(port) { + if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) { + fxs = (class Pfxs *)port; + if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) { + if (fxs->p_state == PORT_STATE_OUT_ALERTING) + break; + } + } + port = port->next; + } + if (!port) { + trace_header("ACTION pots-answer (no call waiting)", DIRECTION_NONE); + end_trace(); + goto disconnect; + } + + /* release our call */ + ourfxs->hangup_ind(0); + + /* answer alerting call */ + fxs->answer_ind(0); +#endif +} + + +/* process pots-3pty + */ +void EndpointAppPBX::action_init_pots_3pty(void) +{ +#ifdef ISDN_P_FXS_POTS + struct port_list *portlist = ea_endpoint->ep_portlist; + class Port *port; + class Pfxs *ourfxs, *fxs, *fxs1 = NULL, *fxs2 = NULL; + class Endpoint *epoint; + int count = 0; + + /* find call */ + port = find_port_id(portlist->port_id); + if (!port) + goto disconnect; + if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) { + trace_header("ACTION pots-3pty (call not of FXS type)", DIRECTION_NONE); + end_trace(); + disconnect: + new_state(EPOINT_STATE_OUT_DISCONNECT); + message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, ""); + set_tone(portlist, "cause_3f"); + e_action = NULL; + return; + } + ourfxs = (class Pfxs *)port; + + port = port_first; + while(port) { + if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) { + fxs = (class Pfxs *)port; + if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) { + if (count == 0) + fxs1 = fxs; + if (count == 1) + fxs2 = fxs; + count++; + } + } + port = port->next; + } + if (count != 2) { + trace_header("ACTION pots-3pty (exactly two calls don't exist)", DIRECTION_NONE); + end_trace(); + goto disconnect; + } + + /* release our call */ + ourfxs->hangup_ind(0); + + /* retrieve latest active call */ + if (fxs2->p_m_fxs_age > fxs1->p_m_fxs_age) { + fxs2->retrieve_ind(0); + epoint = find_epoint_id(ACTIVE_EPOINT(fxs2->p_epointlist)); + } else { + fxs1->retrieve_ind(0); + epoint = find_epoint_id(ACTIVE_EPOINT(fxs2->p_epointlist)); + } + + if (!epoint) { + trace_header("ACTION pots-3pty (interal error: no endpoint)", DIRECTION_NONE); + end_trace(); + return; + } + + if (epoint->ep_app_type != EAPP_TYPE_PBX) { + trace_header("ACTION pots-3pty (interal error: endpoint not PBX type)", DIRECTION_NONE); + end_trace(); + return; + } + + /* bridge calls */ + if (((class EndpointAppPBX *)epoint->ep_app)->join_3pty_fxs()) { + trace_header("ACTION pots-3pty (interal error: join_3pty_fsx failed)", DIRECTION_NONE); + end_trace(); + return; + } +#endif +} + +/* process pots-transfer + */ +void EndpointAppPBX::action_init_pots_transfer(void) +{ +#ifdef ISDN_P_FXS_POTS + struct route_param *rparam; + struct port_list *portlist = ea_endpoint->ep_portlist; + class Port *port; + class Pfxs *ourfxs, *fxs, *fxs1 = NULL, *fxs2 = NULL; + int count = 0; + + /* check given call */ + if (!(rparam = routeparam(e_action, PARAM_POTS_CALL))) { + trace_header("ACTION pots-transfer (no call given)", DIRECTION_NONE); + end_trace(); + + disconnect: + new_state(EPOINT_STATE_OUT_DISCONNECT); + message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, ""); + set_tone(portlist, "cause_3f"); + e_action = NULL; + return; + } + + /* find call */ + port = find_port_id(portlist->port_id); + if (!port) + goto disconnect; + if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) { + trace_header("ACTION pots-transfer (call not of FXS type)", DIRECTION_NONE); + end_trace(); + goto disconnect; + } + ourfxs = (class Pfxs *)port; + + port = port_first; + while(port) { + if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) { + fxs = (class Pfxs *)port; + if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) { + if (count == 0) + fxs1 = fxs; + if (count == 1) + fxs2 = fxs; + count++; + } + } + port = port->next; + } + if (count != 2) { + trace_header("ACTION pots-transfer (exactly two calls don't exist)", DIRECTION_NONE); + end_trace(); + goto disconnect; + } + + /* retrieve call */ + if (fxs2->p_m_fxs_age > fxs1->p_m_fxs_age) + fxs2->retrieve_ind(0); + else + fxs1->retrieve_ind(0); + /* bridge calls */ + join_join_fxs(); +#endif +} + + /* general process dialing of incoming call * depending on the detected prefix, subfunctions above (action_*) will be * calles. */ -void EndpointAppPBX::process_dialing(void) +void EndpointAppPBX::process_dialing(int timeout) { struct port_list *portlist = ea_endpoint->ep_portlist; struct lcr_msg *message; struct route_param *rparam; + struct timeval current_time; + + /* set if timeout is active, or if timeout value was given due to timeout action */ + if (e_action_timeout.active) + timeout = 1; //#warning Due to HANG-BUG somewhere here, I added some HANG-BUG-DEBUGGING output that cannot be disabled. after bug has been found, this will be removed. //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; + unsched_timer(&e_action_timeout); + unsched_timer(&e_match_timeout); 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(); new_state(EPOINT_STATE_OUT_DISCONNECT); message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, ""); set_tone(portlist, "cause_3f"); - e_action_timeout = 0; - e_match_timeout = 0; + unsched_timer(&e_action_timeout); + unsched_timer(&e_match_timeout); goto end; } //PDEBUG(~0, "HANG-BUG-DEBUGGING: before action-timeout processing\n"); /* process timeout */ - if (e_action_timeout) - { - e_action_timeout = 0; - if (e_state == EPOINT_STATE_CONNECT) - { + if (e_action && timeout) { /* e_action may be NULL, but e_action_timeout may still be set and must be ignored */ + unsched_timer(&e_action_timeout); + 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); + release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, 0); goto end; } - release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, 0, 0); + release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, 0, 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); @@ -2258,10 +2509,9 @@ void EndpointAppPBX::process_dialing(void) //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; + unsched_timer(&e_match_timeout); goto end; } @@ -2269,15 +2519,13 @@ void EndpointAppPBX::process_dialing(void) /* 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; - process_dialing(); - e_match_timeout = 0; + process_dialing(0); + unsched_timer(&e_match_timeout); goto end; } /* invalid dialing */ @@ -2285,8 +2533,7 @@ void EndpointAppPBX::process_dialing(void) 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)); } @@ -2295,86 +2542,70 @@ void EndpointAppPBX::process_dialing(void) } new_state(EPOINT_STATE_OUT_DISCONNECT); set_tone(portlist,"cause_1c"); - e_match_timeout = 0; + unsched_timer(&e_match_timeout); goto end; } #endif //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)) - { - 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) - { + gettimeofday(¤t_time, NULL); + if (e_match_to_action && TIME_SMALLER(&e_match_timeout.timeout, ¤t_time)) { /* 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; + unsched_timer(&e_match_timeout); e_action = e_match_to_action; + e_match_to_action = NULL; e_extdialing = e_match_to_extdialing; trace_header("ROUTING (timeout)", 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 { //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; } @@ -2385,17 +2616,15 @@ void EndpointAppPBX::process_dialing(void) action_timeout: /* set timeout */ - e_action_timeout = 0; - if (e_action->timeout) - { - e_action_timeout = now_d + e_action->timeout; + unsched_timer(&e_action_timeout); + if (e_action->timeout) { + schedule_timer(&e_action_timeout, e_action->timeout, 0); 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)); @@ -2403,16 +2632,14 @@ void EndpointAppPBX::process_dialing(void) 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); @@ -2420,14 +2647,12 @@ void EndpointAppPBX::process_dialing(void) 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; } @@ -2436,16 +2661,14 @@ void EndpointAppPBX::process_dialing(void) /* 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 @@ -2458,15 +2681,12 @@ void EndpointAppPBX::process_dialing(void) 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); } @@ -2488,21 +2708,18 @@ void EndpointAppPBX::process_hangup(int cause, int location) 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; @@ -2530,17 +2747,14 @@ void EndpointAppPBX::process_hangup(int cause, int location) /* 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--; } @@ -2553,13 +2767,10 @@ void EndpointAppPBX::process_hangup(int cause, int location) /* 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--; } @@ -2574,10 +2785,8 @@ void EndpointAppPBX::process_hangup(int cause, int location) 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))(); }