X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=apppbx.cpp;h=e491a5731e5de115611882ea7d0c5803bafa77c2;hp=ddfb2b08ccecbb4813ff87a878723aed466eb7dc;hb=d2b113f2c4f11acfaee1b2e0fd2f03744a89f6d4;hpb=7dc10dcae129d2ef7f40a455aba45179eb68d1d8 diff --git a/apppbx.cpp b/apppbx.cpp index ddfb2b0..e491a57 100644 --- a/apppbx.cpp +++ b/apppbx.cpp @@ -1,6 +1,6 @@ /*****************************************************************************\ ** ** -** PBX4Linux ** +** Linux Call Router ** ** ** **---------------------------------------------------------------------------** ** Copyright: Andreas Eversberg ** @@ -10,23 +10,14 @@ \*****************************************************************************/ -#include -#include -#include -#include -#include -#include -#include -#include #include "main.h" - class EndpointAppPBX *apppbx_first = NULL; /* * EndpointAppPBX constructor */ -EndpointAppPBX::EndpointAppPBX(class Endpoint *epoint) : EndpointApp(epoint) +EndpointAppPBX::EndpointAppPBX(class Endpoint *epoint, int origin) : EndpointApp(epoint, origin) { class EndpointAppPBX **apppointer; @@ -39,8 +30,9 @@ EndpointAppPBX::EndpointAppPBX(class Endpoint *epoint) : EndpointApp(epoint) /* initialize */ memset(&e_ext, 0, sizeof(struct extension)); + // *************** NOTE: also change value in read_extension() ************** e_ext.rights = 4; /* international */ - e_ext.rxvol = e_ext.txvol = 256; + e_ext.rx_gain = e_ext.tx_gain = 0; e_state = EPOINT_STATE_IDLE; e_ext.number[0] = '\0'; e_extension_interface[0] = '\0'; @@ -50,7 +42,7 @@ EndpointAppPBX::EndpointAppPBX(class Endpoint *epoint) : EndpointApp(epoint) memset(&e_redirinfo, 0, sizeof(struct redir_info)); memset(&e_capainfo, 0, sizeof(struct capa_info)); e_start = e_stop = 0; -// e_origin = 0; + e_origin = origin; e_ruleset = ruleset_main; if (e_ruleset) e_rule = e_ruleset->rule_first; @@ -60,12 +52,12 @@ EndpointAppPBX::EndpointAppPBX(class Endpoint *epoint) : EndpointApp(epoint) e_match_timeout = 0; e_match_to_action = NULL; e_select = 0; - e_extdialing = e_dialinginfo.number; + e_extdialing = e_dialinginfo.id; // e_knocking = 0; // e_knocktime = 0; e_hold = 0; -// e_call_tone[0] = e_hold_tone[0] = '\0'; - e_call_pattern /*= e_hold_pattern*/ = 0; +// e_join_tone[0] = e_hold_tone[0] = '\0'; + e_join_pattern /*= e_hold_pattern*/ = 0; e_redial = 0; e_tone[0] = '\0'; e_adminid = 0; // will be set, if call was initiated via admin socket @@ -81,11 +73,12 @@ EndpointAppPBX::EndpointAppPBX(class Endpoint *epoint) : EndpointApp(epoint) e_dtmf = 0; e_dtmf_time = 0; e_dtmf_last = 0; + e_enablekeypad = 0; e_cfnr_release = 0; e_cfnr_call = 0; e_password_timeout = 0; - e_multipoint_cause = CAUSE_NOUSER; - e_multipoint_location = LOCATION_PRIVATE_LOCAL; + e_multipoint_cause = 0; + e_multipoint_location = 0; e_dialing_queue[0] = '\0'; e_crypt = CRYPT_OFF; e_crypt_state = CM_ST_NULL; @@ -95,7 +88,7 @@ EndpointAppPBX::EndpointAppPBX(class Endpoint *epoint) : EndpointApp(epoint) e_vbox[0] = '\0'; e_tx_state = NOTIFY_STATE_ACTIVE; e_rx_state = NOTIFY_STATE_ACTIVE; - e_call_cause = e_call_location = 0; + e_join_cause = e_join_location = 0; /********************************* ********************************* ********* ATTENTION ************* @@ -126,10 +119,7 @@ EndpointAppPBX::~EndpointAppPBX(void) temp = temp->next; } if (temp == 0) - { - PERROR("error: endpoint not in endpoint's list, exitting.\n"); - exit(-1); - } + FATAL("Endpoint not in endpoint's list.\n"); *tempp = next; } @@ -140,18 +130,20 @@ EndpointAppPBX::~EndpointAppPBX(void) */ void EndpointAppPBX::trace_header(char *name, int direction) { - char msgtext[sizeof(trace.name)]; + struct trace _trace; + + char msgtext[sizeof(_trace.name)]; SCPY(msgtext, name); /* init trace with given values */ - start_trace(e_serial, + start_trace(0, NULL, - nationalize(e_callerinfo.id, e_callerinfo.ntype), - e_dialinginfo.number, + numberrize_callerinfo(e_callerinfo.id, e_callerinfo.ntype, options.national, options.international), + e_dialinginfo.id, direction, CATEGORY_EP, - e_serial, + ea_endpoint->ep_serial, msgtext); } @@ -175,128 +167,40 @@ void EndpointAppPBX::new_state(int state) } -/* screen caller id - * out==0: incomming caller id, out==1: outgoing caller id - */ -void EndpointAppPBX::screen(int out, char *id, int idsize, int *type, int *present) -{ - struct interface *interface; - - interface = interface_first; - while(interface) - { - if (!strcmp(e_callerinfo.interface, interface->name)) - { - break; - } - interface = interface->next; - } -add logging - if (interface) - { - /* screen incoming caller id */ - if (!out) - { - /* check for MSN numbers, use first MSN if no match */ - msn1 = NULL; - ifmsn = interface->ifmsn; - while(ifmns) - { - if (!msn1) - msn1 = ifmns->msn; - if (!strcmp(ifmns->mns, id)) - { - break; - } - ifmsn = ifmsn->next; - } - if (!ifmns && mns1) // not in list, first msn given - UNCPY(id, msn1, idsize); - id[idsize-1] = '\0'; - } - - /* check screen list */ - if (out) - iscreen = interface->ifscreen_out; - else - iscreen = interface->ifscreen_in; - while (ifscreen) - { - if (ifcreen->match_type==-1 || ifscreen->match_type==*type) - if (ifcreen->match_present==-1 || ifscreen->match_present==*present) - { - if (strchr(ifcreen->match_id,'%')) - { - if (!strncmp(ifscreen->match_id, id, strchr(ifscreen->match_id,'%')-ifscreen->match_id)) - break; - } else - { - if (!strcmp(ifscreen->match_id, id)) - break; - } - } - ifscreen = ifscreen->next; - } - if (ifscreen) // match - { - if (ifscren->result_type != -1) - *type = ifscreen->result_type; - if (ifscren->result_present != -1) - *present = ifscreen->result_present; - if (strchr(ifscreen->match_id,'%')) - { - SCPY(suffix, strchr(ifscreen->match_id,'%') - ifscreen->match_id + id); - UNCPY(id, ifscreen->result_id); - id[idsize-1] = '\0'; - if (strchr(ifscreen->result_id,'%')) - { - *strchr(ifscreen->result_id,'%') = '\0'; - UNCAT(id, suffix, idsize); - id[idsize-1] = '\0'; - } - } else - { - UNCPY(id, ifscreen->result_id, idsize); - id[idsize-1] = '\0'; - } - } - } -} - -/* release call and port (as specified) +/* release join and port (as specified) */ -void EndpointAppPBX::release(int release, int calllocation, int callcause, int portlocation, int portcause) +void EndpointAppPBX::release(int release, int joinlocation, int joincause, int portlocation, int portcause) { struct port_list *portlist; - struct message *message; + struct lcr_msg *message; char cause[16]; - class Call *call; /* message to test call */ - admin_call_response(e_adminid, ADMIN_CALL_RELEASE, "", callcause, calllocation, 0); + admin_call_response(e_adminid, ADMIN_CALL_RELEASE, "", joincause, joinlocation, 0); /* if a release is pending */ - if (release==RELEASE_CALL || release==RELEASE_ALL || release==RELEASE_PORT_CALLONLY) + if (release==RELEASE_JOIN || release==RELEASE_ALL || release==RELEASE_PORT_JOINONLY) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d): do pending release (callcause %d location %d)\n", ea_endpoint->ep_serial, callcause, calllocation); - if (ea_endpoint->ep_call_id) + PDEBUG(DEBUG_EPOINT, "EPOINT(%d): do pending release (joincause %d location %d)\n", ea_endpoint->ep_serial, joincause, joinlocation); + if (ea_endpoint->ep_join_id) { - call = find_call_id(ea_endpoint->ep_call_id); - if (call) - call->release(ea_endpoint->ep_serial, 0, calllocation, callcause); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_RELEASE); + message->param.disconnectinfo.cause = joincause; + message->param.disconnectinfo.location = joinlocation; + message_put(message); + ea_endpoint->ep_join_id = 0; } - ea_endpoint->ep_call_id = 0; - e_call_pattern = 0; + e_join_pattern = 0; #if 0 - if (release != RELEASE_PORT_CALLONLY) + if (release != RELEASE_PORT_JOINONLY) { if (e_hold_id) - call_release(e_hold_id, ea_endpoint->ep_serial, 1, calllocation, callcause); + join_release(e_hold_id, ea_endpoint->ep_serial, 1, joinlocation, joincause); e_hold_id = 0; } #endif } - if (release==RELEASE_ALL || release==RELEASE_PORT_CALLONLY) + if (release==RELEASE_ALL || release==RELEASE_PORT_JOINONLY) { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) do pending release (portcause %d portlocation)\n", ea_endpoint->ep_serial, portcause, portlocation); while((portlist = ea_endpoint->ep_portlist)) @@ -309,7 +213,7 @@ void EndpointAppPBX::release(int release, int calllocation, int callcause, int p message->param.disconnectinfo.cause = portcause; message->param.disconnectinfo.location = portlocation; message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); } ea_endpoint->free_portlist(portlist); } @@ -330,15 +234,16 @@ void EndpointAppPBX::release(int release, int calllocation, int callcause, int p e_match_timeout = 0; e_match_to_action = NULL; //e_select = 0; - e_extdialing = e_dialinginfo.number; + e_extdialing = e_dialinginfo.id; e_connectedmode = 0; e_dtmf = 0; e_dtmf_time = 0; e_dtmf_last = 0; + e_enablekeypad = 0; e_cfnr_release = 0; e_cfnr_call = 0; - e_multipoint_cause = CAUSE_NOUSER; - e_multipoint_location = LOCATION_PRIVATE_LOCAL; + e_multipoint_cause = 0; + e_multipoint_location = 0; e_dialing_queue[0] = '\0'; e_crypt = 0; e_crypt_state = CM_ST_NULL; @@ -349,7 +254,7 @@ void EndpointAppPBX::release(int release, int calllocation, int callcause, int p e_vbox[0] = '\0'; e_tx_state = NOTIFY_STATE_ACTIVE; e_rx_state = NOTIFY_STATE_ACTIVE; - e_call_cause = e_call_location = 0; + e_join_cause = e_join_location = 0; e_rule_nesting = 0; /* the caller info of the callback user */ memcpy(&e_callbackinfo, &e_callerinfo, sizeof(e_callbackinfo)); @@ -359,7 +264,7 @@ void EndpointAppPBX::release(int release, int calllocation, int callcause, int p { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) preparing callback to internal: %s interface %s\n", ea_endpoint->ep_serial, e_ext.number, e_extension_interface); /* create callback to the current terminal */ - SCPY(e_dialinginfo.number, e_ext.number); + SCPY(e_dialinginfo.id, e_ext.number); SCPY(e_dialinginfo.interfaces, e_extension_interface); e_dialinginfo.itype = INFO_ITYPE_ISDN_EXTENSION; e_dialinginfo.ntype = INFO_NTYPE_UNKNOWN; @@ -367,15 +272,15 @@ void EndpointAppPBX::release(int release, int calllocation, int callcause, int p { if (e_cbto[0]) { - SCPY(e_dialinginfo.number, e_cbto); + SCPY(e_dialinginfo.id, e_cbto); } else { /* numberrize caller id and use it to dial to the callback */ - SCPY(e_dialinginfo.number, numberrize_callerinfo(e_callerinfo.id,e_callerinfo.ntype)); + SCPY(e_dialinginfo.id, numberrize_callerinfo(e_callerinfo.id,e_callerinfo.ntype, options.national, options.international)); } e_dialinginfo.itype = INFO_ITYPE_ISDN; e_dialinginfo.ntype = INFO_NTYPE_UNKNOWN; - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) preparing callback to external: %s\n", ea_endpoint->ep_serial, e_dialinginfo.number); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) preparing callback to external: %s\n", ea_endpoint->ep_serial, e_dialinginfo.id); } return; } @@ -388,22 +293,20 @@ void EndpointAppPBX::release(int release, int calllocation, int callcause, int p /* cancel callerid if restricted, unless anon-ignore is enabled at extension or port is of type external (so called police gets caller id :)*/ -void apply_callerid_restriction(int anon_ignore, int port_type, char *id, int *ntype, int *present, int *screen, char *voip, char *intern, char *name) +void apply_callerid_restriction(struct extension *ext, char *id, int *ntype, int *present, int *screen, char *extension, char *name) { - PDEBUG(DEBUG_EPOINT, "id='%s' ntype=%d present=%d screen=%d voip='%s' intern='%s' name='%s'\n", (id)?id:"NULL", (ntype)?*ntype:-1, (present)?*present:-1, (screen)?*screen:-1, (voip)?voip:"NULL", (intern)?intern:"NULL", (name)?name:"NULL"); + PDEBUG(DEBUG_EPOINT, "id='%s' ntype=%d present=%d screen=%d extension='%s' name='%s'\n", (id)?id:"NULL", (ntype)?*ntype:-1, (present)?*present:-1, (screen)?*screen:-1, (extension)?extension:"NULL", (name)?name:"NULL"); /* caller id is not restricted, so we do nothing */ if (*present != INFO_PRESENT_RESTRICTED) return; /* only extensions are restricted */ - if (!intern) - return; - if (!intern[0]) + if (!ext->number[0]) return; /* if we enabled anonymouse ignore */ - if (anon_ignore) + if (ext->anon_ignore) return; /* else we remove the caller id */ @@ -416,39 +319,37 @@ void apply_callerid_restriction(int anon_ignore, int port_type, char *id, int *n // maybe we should not make voip address anonymous // if (voip) // voip[0] = '\0'; -// maybe it's no fraud to present internal id -// if (intern) -// intern[0] = '\0'; +// maybe it's no fraud to present extension id +// if (extension) +// extension[0] = '\0'; if (name) name[0] = '\0'; } /* used display message to display callerid as available */ -char *EndpointAppPBX::apply_callerid_display(char *id, int itype, int ntype, int present, int screen, char *voip, char *intern, char *name) +char *EndpointAppPBX::apply_callerid_display(char *id, int itype, int ntype, int present, int screen, char *extension, char *name) { static char display[81]; display[0] = '\0'; - char *cid = numberrize_callerinfo(id, ntype); + char *cid = numberrize_callerinfo(id, ntype, options.national, options.international); - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) id='%s' itype=%d ntype=%d present=%d screen=%d voip='%s' intern='%s' name='%s'\n", ea_endpoint->ep_serial, (id)?id:"NULL", itype, ntype, present, screen, (voip)?voip:"NULL", (intern)?intern:"NULL", (name)?name:"NULL"); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) id='%s' itype=%d ntype=%d present=%d screen=%d extension='%s' name='%s'\n", ea_endpoint->ep_serial, (id)?id:"NULL", itype, ntype, present, screen, (extension)?extension:"NULL", (name)?name:"NULL"); if (!id) id = ""; - if (!voip) - voip = ""; - if (!intern) - intern = ""; + if (!extension) + extension = ""; if (!name) name = ""; /* NOTE: is caller is is not available for this extesion, it has been removed by apply_callerid_restriction already */ /* internal extension's caller id */ - if (intern[0] && e_ext.display_int) + if (extension[0] && e_ext.display_int) { if (!display[0]) - SCAT(display, intern); + SCAT(display, extension); if (display[0]) SCAT(display, " "); if (itype == INFO_ITYPE_VBOX) @@ -458,7 +359,7 @@ char *EndpointAppPBX::apply_callerid_display(char *id, int itype, int ntype, int } /* external caller id */ - if (!intern[0] && !voip[0] && e_ext.display_ext) + if (!extension[0] && e_ext.display_ext) { if (!display[0]) { @@ -474,16 +375,6 @@ char *EndpointAppPBX::apply_callerid_display(char *id, int itype, int ntype, int } } - /* voip caller id */ - if (voip[0] && e_ext.display_voip) - { - if (!display[0] && cid[0]) - SCAT(display, cid); - if (display[0]) - SCAT(display, " "); - SCAT(display, voip); - } - /* display if callerid is anonymouse but available due anon-ignore */ if (e_ext.display_anon && present==INFO_PRESENT_RESTRICTED) { @@ -531,7 +422,7 @@ char *EndpointAppPBX::apply_callerid_display(char *id, int itype, int ntype, int void EndpointAppPBX::notify_active(void) { struct port_list *portlist = ea_endpoint->ep_portlist; - struct message *message; + struct lcr_msg *message; int notify = 0; switch(e_tx_state) @@ -580,7 +471,7 @@ void EndpointAppPBX::notify_active(void) message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_NOTIFY); message->param.notifyinfo.notify = notify; message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); portlist = portlist->next; } } @@ -603,13 +494,13 @@ void EndpointAppPBX::keypad_function(char digit) { /* join conference */ case '3': - if (ea_endpoint->ep_call_id == 0) + if (ea_endpoint->ep_join_id == 0) { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) keypad received during connect but not during a call.\n", ea_endpoint->ep_serial); break; } PDEBUG(DEBUG_EPOINT, "EPOINT(%d) join call with call on hold\n", ea_endpoint->ep_serial); - join_call(); + join_join(); break; /* crypt shared */ @@ -639,7 +530,7 @@ void EndpointAppPBX::keypad_function(char digit) /* set tone pattern for port */ void EndpointAppPBX::set_tone(struct port_list *portlist, char *tone) { - struct message *message; + struct lcr_msg *message; if (!tone) tone = ""; @@ -647,13 +538,8 @@ void EndpointAppPBX::set_tone(struct port_list *portlist, char *tone) /* store for suspended processes */ SCPY(e_tone, tone); - if (!portlist) - { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) no endpoint to notify tone.\n", ea_endpoint->ep_serial); - return; - } - if (e_call_pattern /* pattern are provided */ + if (e_join_pattern /* pattern are provided */ && !(e_ext.own_setup && e_state == EPOINT_STATE_IN_SETUP) && !(e_ext.own_setup && e_state == EPOINT_STATE_IN_OVERLAP) && !(e_ext.own_proceeding && e_state == EPOINT_STATE_IN_PROCEEDING) @@ -676,7 +562,11 @@ void EndpointAppPBX::set_tone(struct port_list *portlist, char *tone) SCPY(message->param.tone.dir, e_ext.tones_dir[0]?e_ext.tones_dir:options.tones_dir); SCPY(message->param.tone.name, tone); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); + } else + { + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) no port to notify tone.\n", ea_endpoint->ep_serial); + return; } } @@ -686,17 +576,20 @@ void EndpointAppPBX::set_tone(struct port_list *portlist, char *tone) * if no ifname was given, any interface that is not an extension * will be searched. */ -static struct mISDNport *EndpointAppPBX::hunt_port(char *ifname, int *channel) +struct mISDNport *EndpointAppPBX::hunt_port(char *ifname, int *channel) { struct interface *interface; + struct interface_port *ifport, *ifport_start; + struct select_channel *selchannel; struct mISDNport *mISDNport; + int index, i; interface = interface_first; /* first find the given interface or, if not given, one with no extension */ checknext: if (!interface) - return(null); + return(NULL); /* check for given interface */ if (ifname) @@ -707,7 +600,7 @@ static struct mISDNport *EndpointAppPBX::hunt_port(char *ifname, int *channel) trace_header("CHANNEL SELECTION (found interface)", DIRECTION_NONE); add_trace("interface", NULL, "%s", ifname); end_trace(); - goto found; + goto foundif; } } else @@ -718,18 +611,19 @@ static struct mISDNport *EndpointAppPBX::hunt_port(char *ifname, int *channel) trace_header("CHANNEL SELECTION (found non extension interface)", DIRECTION_NONE); add_trace("interface", NULL, "%s", interface->name); end_trace(); - goto found; + goto foundif; } } interface = interface->next; goto checknext; +foundif: /* see if interface has ports */ if (!interface->ifport) { /* no ports */ - trace_header("CHANNEL SELECTION (interface has no active ports, skipping)", DIRECTION_NONE); + trace_header("CHANNEL SELECTION (active ports, skipping)", DIRECTION_NONE); add_trace("interface", NULL, "%s", interface->name); end_trace(); interface = interface->next; @@ -737,14 +631,14 @@ static struct mISDNport *EndpointAppPBX::hunt_port(char *ifname, int *channel) } /* select port by algorithm */ - ifport_start = interface->port; + ifport_start = interface->ifport; index = 0; if (interface->hunt == HUNT_ROUNDROBIN) { while(ifport_start->next && indexhunt_next) { ifport_start = ifport_start->next; - i++; + index++; } trace_header("CHANNEL SELECTION (starting round-robin)", DIRECTION_NONE); add_trace("port", NULL, "%d", ifport_start->portnum); @@ -767,8 +661,6 @@ static struct mISDNport *EndpointAppPBX::hunt_port(char *ifname, int *channel) } mISDNport = ifport->mISDNport; -#warning admin block auch bei incomming calls -#warning calls releasen, wenn port entfernt wird, geblockt wird /* see if port is administratively blocked */ if (ifport->block) { @@ -779,10 +671,10 @@ static struct mISDNport *EndpointAppPBX::hunt_port(char *ifname, int *channel) goto portbusy; } - /* see if link is up */ - if (mISDNport->ptp && !mISDNport->l2link) + /* see if link is up on PTP*/ + if (mISDNport->l2hold && !mISDNport->l2link) { - trace_header("CHANNEL SELECTION (port is ptp with layer 2 down, skipping)", DIRECTION_NONE); + trace_header("CHANNEL SELECTION (port's layer 2 is down, skipping)", DIRECTION_NONE); add_trace("port", NULL, "%d", ifport->portnum); add_trace("position", NULL, "%d", index); end_trace(); @@ -791,13 +683,13 @@ static struct mISDNport *EndpointAppPBX::hunt_port(char *ifname, int *channel) /* check for channel form selection list */ *channel = 0; - selchannel = ifport->selchannel; + selchannel = ifport->out_channel; while(selchannel) { switch(selchannel->channel) { case CHANNEL_FREE: /* free channel */ - if (mISDNport->b_inuse >= mISDNport->b_num) + if (mISDNport->b_reserved >= mISDNport->b_num) break; /* all channel in use or reserverd */ /* find channel */ i = 0; @@ -815,34 +707,61 @@ static struct mISDNport *EndpointAppPBX::hunt_port(char *ifname, int *channel) } i++; } + if (*channel) + break; + trace_header("CHANNEL SELECTION (no channel is 'free')", DIRECTION_NONE); + add_trace("port", NULL, "%d", ifport->portnum); + add_trace("position", NULL, "%d", index); + end_trace(); break; case CHANNEL_ANY: /* don't ask for channel */ - if (mISDNport->b_inuse >= mISDNport->b_num) + if (mISDNport->b_reserved >= mISDNport->b_num) { + trace_header("CHANNEL SELECTION (cannot ask for 'any' channel, all reserved)", DIRECTION_NONE); + add_trace("port", NULL, "%d", ifport->portnum); + add_trace("position", NULL, "%d", index); + add_trace("total", NULL, "%d", mISDNport->b_num); + add_trace("reserved", NULL, "%d", mISDNport->b_reserved); + end_trace(); break; /* all channel in use or reserverd */ } - trace_header("CHANNEL SELECTION (using 'any channel')", DIRECTION_NONE); + trace_header("CHANNEL SELECTION (using 'any' channel)", DIRECTION_NONE); add_trace("port", NULL, "%d", ifport->portnum); add_trace("position", NULL, "%d", index); end_trace(); - *channel = SEL_CHANNEL_ANY; + *channel = CHANNEL_ANY; break; case CHANNEL_NO: /* call waiting */ - trace_header("CHANNEL SELECTION (using 'no channel', call-waiting)", DIRECTION_NONE); + trace_header("CHANNEL SELECTION (using 'no' channel, call-waiting)", DIRECTION_NONE); add_trace("port", NULL, "%d", ifport->portnum); add_trace("position", NULL, "%d", index); end_trace(); - *channel = SEL_CHANNEL_NO; + *channel = CHANNEL_NO; break; default: if (selchannel->channel<1 || selchannel->channel==16) + { + trace_header("CHANNEL SELECTION (channel out of range)", DIRECTION_NONE); + add_trace("port", NULL, "%d", ifport->portnum); + add_trace("position", NULL, "%d", index); + add_trace("channel", NULL, "%d", selchannel->channel); + end_trace(); break; /* invalid channels */ + } i = selchannel->channel-1-(selchannel->channel>=17); if (i >= mISDNport->b_num) + { + trace_header("CHANNEL SELECTION (channel out of range)", DIRECTION_NONE); + add_trace("port", NULL, "%d", ifport->portnum); + add_trace("position", NULL, "%d", index); + add_trace("channel", NULL, "%d", selchannel->channel); + add_trace("channels", NULL, "%d", mISDNport->b_num); + end_trace(); break; /* channel not in port */ + } if (mISDNport->b_port[i] == NULL) { *channel = selchannel->channel; @@ -892,6 +811,11 @@ static struct mISDNport *EndpointAppPBX::hunt_port(char *ifname, int *channel) if (ifport != ifport_start) goto nextport; + if (!ifname) { + interface = interface->next; + goto checknext; + } + return(NULL); /* no port found */ } @@ -905,7 +829,7 @@ void EndpointAppPBX::out_setup(void) class Port *port; // class pdss1 *pdss1; struct port_list *portlist; - struct message *message; + struct lcr_msg *message; int anycall = 0; int cause = CAUSE_RESSOURCEUNAVAIL; char *p; @@ -916,12 +840,11 @@ void EndpointAppPBX::out_setup(void) class EndpointAppPBX *atemp; // char allowed_ports[256]; // char exten[256]; - int i, ii; - int use; char ifname[sizeof(e_ext.interfaces)], number[256]; struct port_settings port_settings; int channel = 0; + int earlyb; /* create settings for creating port */ memset(&port_settings, 0, sizeof(port_settings)); @@ -929,13 +852,6 @@ void EndpointAppPBX::out_setup(void) SCPY(port_settings.tones_dir, e_ext.tones_dir); else SCPY(port_settings.tones_dir, options.tones_dir); - port_settings.tout_setup = e_ext.tout_setup; - port_settings.tout_dialing = e_ext.tout_dialing; - port_settings.tout_proceeding = e_ext.tout_proceeding; - port_settings.tout_alerting = e_ext.tout_alerting; - port_settings.tout_disconnect = e_ext.tout_disconnect; -// port_settings.tout_hold = e_ext.tout_hold; -// port_settings.tout_park = e_ext.tout_park; port_settings.no_seconds = e_ext.no_seconds; /* NOTE: currently the try_card feature is not supported. it should be used later to try another card, if the outgoing call fails on one port */ @@ -959,21 +875,21 @@ void EndpointAppPBX::out_setup(void) if (atemp) { PERROR("EPOINT(%d) noknocking and currently a call\n", ea_endpoint->ep_serial); - release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_BUSY, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYSPE_ call, port */ + release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_BUSY, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYSPE_ join, port */ return; /* must exit here */ } } /* FALL THROUGH !!!! */ case INFO_ITYPE_VBOX: /* get dialed extension's info */ -// SCPY(exten, e_dialinginfo.number); +// SCPY(exten, e_dialinginfo.id); // if (strchr(exten, ',')) // *strchr(exten, ',') = '\0'; // if (!read_extension(&e_ext, exten)) - if (!read_extension(&e_ext, e_dialinginfo.number)) + if (!read_extension(&e_ext, e_dialinginfo.id)) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) extension %s not configured\n", ea_endpoint->ep_serial, e_dialinginfo.number); - release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_OUTOFORDER, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, call, port */ + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) extension %s not configured\n", ea_endpoint->ep_serial, e_dialinginfo.id); + release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_OUTOFORDER, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, join, port */ return; /* must exit here */ } @@ -1045,7 +961,7 @@ void EndpointAppPBX::out_setup(void) /* call to all internal interfaces */ p = e_ext.interfaces; - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) generating multiple calls for extension %s to interfaces %s\n", ea_endpoint->ep_serial, e_dialinginfo.number, p); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) generating multiple joins for extension %s to interfaces %s\n", ea_endpoint->ep_serial, e_dialinginfo.id, p); while(*p) { ifname[0] = '\0'; @@ -1066,20 +982,17 @@ void EndpointAppPBX::out_setup(void) continue; } /* creating INTERNAL port */ - SPRINT(portname, "%s-%d-out", mISDNport->interface_name, mISDNport->portnum); - port = new Pdss1((mISDNport->ntmode)?PORT_TYPE_DSS1_NT_OUT:PORT_TYPE_DSS1_TE_OUT, mISDNport, portname, &port_settings, channel, mISDNport->ifport.channel_force); + SPRINT(portname, "%s-%d-out", mISDNport->ifport->interface->name, mISDNport->portnum); + port = new Pdss1((mISDNport->ntmode)?PORT_TYPE_DSS1_NT_OUT:PORT_TYPE_DSS1_TE_OUT, mISDNport, portname, &port_settings, channel, mISDNport->ifport->channel_force); if (!port) - { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) port '%s' failed to create\n", ea_endpoint->ep_serial, mISDNport->interface_name); - goto check_anycall_intern; - } + FATAL("No memory for DSS1 Port instance\n"); PDEBUG(DEBUG_EPOINT, "EPOINT(%d) got port %s\n", ea_endpoint->ep_serial, port->p_name); memset(&dialinginfo, 0, sizeof(dialinginfo)); - SCPY(dialinginfo.number, e_dialinginfo.number); + SCPY(dialinginfo.id, e_dialinginfo.id); dialinginfo.itype = INFO_ITYPE_ISDN_EXTENSION; dialinginfo.ntype = e_dialinginfo.ntype; /* create port_list relation */ - portlist = ea_endpoint->portlist_new(port->p_serial, port->p_type, mISDNport->is_earlyb); + portlist = ea_endpoint->portlist_new(port->p_serial, port->p_type, mISDNport->earlyb); if (!portlist) { PERROR("EPOINT(%d) cannot allocate port_list relation\n", ea_endpoint->ep_serial); @@ -1087,7 +1000,7 @@ void EndpointAppPBX::out_setup(void) goto check_anycall_intern; } /* directory.list */ - if (e_callerinfo.id[0] && (e_ext.centrex || e_ext.display_name)) + if (e_callerinfo.id[0] && e_ext.display_name) { dirname = parse_directory(e_callerinfo.id, e_callerinfo.ntype); if (dirname) @@ -1095,39 +1008,39 @@ void EndpointAppPBX::out_setup(void) } // dss1 = (class Pdss1 *)port; /* message */ -//printf("INTERNAL caller=%s,id=%s,dial=%s\n", param.setup.networkid, param.setup.callerinfo.id, param.setup.dialinginfo.number); +//printf("INTERNAL caller=%s,id=%s,dial=%s\n", param.setup.networkid, param.setup.callerinfo.id, param.setup.dialinginfo.id); message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_SETUP); memcpy(&message->param.setup.dialinginfo, &dialinginfo, sizeof(struct dialing_info)); memcpy(&message->param.setup.redirinfo, &e_redirinfo, sizeof(struct redir_info)); memcpy(&message->param.setup.callerinfo, &e_callerinfo, sizeof(struct caller_info)); memcpy(&message->param.setup.capainfo, &e_capainfo, sizeof(struct capa_info)); //terminal SCPY(message->param.setup.from_terminal, e_ext.number); -//terminal if (e_dialinginfo.number) -//terminal SCPY(message->param.setup.to_terminal, e_dialinginfo.number); +//terminal if (e_dialinginfo.id) +//terminal SCPY(message->param.setup.to_terminal, e_dialinginfo.id); /* handle restricted caller ids */ - apply_callerid_restriction(e_ext.anon_ignore, port->p_type, message->param.setup.callerinfo.id, &message->param.setup.callerinfo.ntype, &message->param.setup.callerinfo.present, &message->param.setup.callerinfo.screen, message->param.setup.callerinfo.voip, message->param.setup.callerinfo.intern, message->param.setup.callerinfo.name); - apply_callerid_restriction(e_ext.anon_ignore, port->p_type, message->param.setup.redirinfo.id, &message->param.setup.redirinfo.ntype, &message->param.setup.redirinfo.present, NULL, message->param.setup.redirinfo.voip, message->param.setup.redirinfo.intern, 0); + apply_callerid_restriction(&e_ext, message->param.setup.callerinfo.id, &message->param.setup.callerinfo.ntype, &message->param.setup.callerinfo.present, &message->param.setup.callerinfo.screen, message->param.setup.callerinfo.extension, message->param.setup.callerinfo.name); + apply_callerid_restriction(&e_ext, message->param.setup.redirinfo.id, &message->param.setup.redirinfo.ntype, &message->param.setup.redirinfo.present, 0, message->param.setup.redirinfo.extension, NULL); /* display callerid if desired for extension */ - SCPY(message->param.setup.callerinfo.display, apply_callerid_display(message->param.setup.callerinfo.id, message->param.setup.callerinfo.itype, message->param.setup.callerinfo.ntype, message->param.setup.callerinfo.present, message->param.setup.callerinfo.screen, message->param.setup.callerinfo.voip, message->param.setup.callerinfo.intern, message->param.setup.callerinfo.name)); + SCPY(message->param.setup.callerinfo.display, apply_callerid_display(message->param.setup.callerinfo.id, message->param.setup.callerinfo.itype, message->param.setup.callerinfo.ntype, message->param.setup.callerinfo.present, message->param.setup.callerinfo.screen, message->param.setup.callerinfo.extension, message->param.setup.callerinfo.name)); //printf("\n\ndisplay = %s\n\n\n",message->param.setup.callerinfo.display); /* use cnip, if enabld */ - if (!e_ext.centrex) - message->param.setup.callerinfo.name[0] = '\0'; + // if (!e_ext.centrex) + // message->param.setup.callerinfo.name[0] = '\0'; /* screen clip if prefix is required */ if (message->param.setup.callerinfo.id[0] && e_ext.clip_prefix[0]) { SCPY(message->param.setup.callerinfo.id, e_ext.clip_prefix); - SCAT(message->param.setup.callerinfo.id, numberrize_callerinfo(e_callerinfo.id,e_callerinfo.ntype)); + SCAT(message->param.setup.callerinfo.id, numberrize_callerinfo(e_callerinfo.id,e_callerinfo.ntype, options.national, options.international)); message->param.setup.callerinfo.ntype = INFO_NTYPE_UNKNOWN; } /* use internal caller id */ - if (e_callerinfo.intern[0] && (message->param.setup.callerinfo.present!=INFO_PRESENT_RESTRICTED || e_ext.anon_ignore)) + if (e_callerinfo.extension[0] && (message->param.setup.callerinfo.present!=INFO_PRESENT_RESTRICTED || e_ext.anon_ignore)) { - SCPY(message->param.setup.callerinfo.id, e_callerinfo.intern); + SCPY(message->param.setup.callerinfo.id, e_callerinfo.extension); message->param.setup.callerinfo.ntype = INFO_NTYPE_UNKNOWN; } message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); anycall = 1; } @@ -1145,12 +1058,12 @@ void EndpointAppPBX::out_setup(void) cfu_only: /* entry point for cfu */ cfb_only: /* entry point for cfb */ cfnr_only: /* entry point for cfnr */ - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) call extension %s for external destiantion(s) '%s'\n", ea_endpoint->ep_serial, e_dialinginfo.number, p); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) call extension %s for external destiantion(s) '%s'\n", ea_endpoint->ep_serial, e_dialinginfo.id, p); // i=0; while(*p) { - /* only if vbox should be dialed, and terminal is given */ earlyb = 0; + /* only if vbox should be dialed, and terminal is given */ if (!strcmp(p, "vbox") && e_ext.number[0]) { /* go to the end of p */ @@ -1160,10 +1073,7 @@ void EndpointAppPBX::out_setup(void) PDEBUG(DEBUG_EPOINT, "EPOINT(%d) answering machine\n", ea_endpoint->ep_serial); /* alloc port */ if (!(port = new VBoxPort(PORT_TYPE_VBOX_OUT, &port_settings))) - { - PERROR("EPOINT(%d) no mem for port\n", ea_endpoint->ep_serial); - break; - } + FATAL("No memory for VBOX Port instance\n"); PDEBUG(DEBUG_EPOINT, "EPOINT(%d) allocated port %s\n", ea_endpoint->ep_serial, port->p_name); UCPY(cfp, e_ext.number); /* cfp or any other direct forward/vbox */ } else @@ -1173,63 +1083,17 @@ void EndpointAppPBX::out_setup(void) SCCAT(cfp, *p++); if (*p == ',') p++; - hier auch wie oben /* external call */ PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cfp external %s\n", ea_endpoint->ep_serial, cfp); /* hunt for mISDNport and create Port */ - mISDNport = mISDNport_first; - port = NULL; - while(mISDNport) - { - /* check for external or given interface */ - if (((!e_dialinginfo.interfaces[0])&&mISDNport->iftype==IF_EXTERN) || !strcmp(mISDNport->interface_name, e_dialinginfo.interfaces)) - { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) interface '%s' found\n", ea_endpoint->ep_serial, mISDNport->interface_name); - cause = CAUSE_NOCHANNEL; /* when failing: out of channels */ - /* if PTP, skip all down links */ - if (mISDNport->ptp && !mISDNport->l2link) - { - trace_header("INTERFACE (layer 2 is down)", DIRECTION_NONE); - add_trace("interface", NULL, "%s", mISDNport->interface_name); - end_trace(); - mISDNport = mISDNport->next; - continue; - } - /* if no channel is available */ - if (mISDNport->multilink || !mISDNport->ntmode || mISDNport->ptp) - { - use = 0; - i = 0; - ii = mISDNport->b_num; - while(i < ii) - { - if (mISDNport->b_state[i]) - use++; - i++; - } - if (use >= mISDNport->b_num) - { - trace_header("INTERFACE (no free channel)", DIRECTION_NONE); - add_trace("interface", NULL, "%s", mISDNport->interface_name); - end_trace(); - mISDNport = mISDNport->next; - continue; - } - } - /* found interface */ - trace_header("INTERFACE (found)", DIRECTION_NONE); - add_trace("interface", NULL, "%s", mISDNport->interface_name); - end_trace(); - break; - } - mISDNport = mISDNport->next; - } + mISDNport = hunt_port(e_dialinginfo.interfaces[0]?e_dialinginfo.interfaces:NULL, &channel); if (mISDNport) { /* creating EXTERNAL port*/ - SPRINT(portname, "%s-%d-out", mISDNport->interface_name, mISDNport->portnum); - port = new Pdss1((mISDNport->ntmode)?PORT_TYPE_DSS1_NT_OUT:PORT_TYPE_DSS1_TE_OUT, mISDNport, portname, &port_settings); - earlyb = mISDNport->is_earlyb; + SPRINT(portname, "%s-%d-out", mISDNport->ifport->interface->name, mISDNport->portnum); + if (!(port = new Pdss1((mISDNport->ntmode)?PORT_TYPE_DSS1_NT_OUT:PORT_TYPE_DSS1_TE_OUT, mISDNport, portname, &port_settings, channel, mISDNport->ifport->channel_force))) + FATAL("No memory for DSS1 Port instance\n"); + earlyb = mISDNport->earlyb; } else { port = NULL; @@ -1245,8 +1109,8 @@ void EndpointAppPBX::out_setup(void) } PDEBUG(DEBUG_EPOINT, "EPOINT(%d) found or created port %s\n", ea_endpoint->ep_serial, port->p_name); memset(&dialinginfo, 0, sizeof(dialinginfo)); - SCPY(dialinginfo.number, cfp); - dialinginfo.itype = INFO_ITYPE_EXTERN; + SCPY(dialinginfo.id, cfp); + dialinginfo.itype = INFO_ITYPE_ISDN; dialinginfo.ntype = e_dialinginfo.ntype; portlist = ea_endpoint->portlist_new(port->p_serial, port->p_type, earlyb); if (!portlist) @@ -1255,7 +1119,7 @@ void EndpointAppPBX::out_setup(void) delete port; goto check_anycall_intern; } -//printf("EXTERNAL caller=%s,id=%s,dial=%s\n", param.setup.networkid, param.setup.callerinfo.id, param.setup.dialinginfo.number); +//printf("EXTERNAL caller=%s,id=%s,dial=%s\n", param.setup.networkid, param.setup.callerinfo.id, param.setup.dialinginfo.id); message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_SETUP); memcpy(&message->param.setup.dialinginfo, &dialinginfo, sizeof(struct dialing_info)); memcpy(&message->param.setup.redirinfo, &e_redirinfo, sizeof(struct redir_info)); @@ -1264,21 +1128,21 @@ void EndpointAppPBX::out_setup(void) if (e_ext.clip==CLIP_HIDE && port->p_type!=PORT_TYPE_VBOX_OUT) { SCPY(message->param.setup.callerinfo.id, e_ext.callerid); - SCPY(message->param.setup.callerinfo.intern, e_ext.number); + SCPY(message->param.setup.callerinfo.extension, e_ext.number); message->param.setup.callerinfo.ntype = e_ext.callerid_type; message->param.setup.callerinfo.present = e_ext.callerid_present; } memcpy(&message->param.setup.capainfo, &e_capainfo, sizeof(struct capa_info)); //terminal SCPY(message->param.setup.from_terminal, e_ext.number); -//terminal if (e_dialinginfo.number) -//terminal SCPY(message->param.setup.to_terminal, e_dialinginfo.number); +//terminal if (e_dialinginfo.id) +//terminal SCPY(message->param.setup.to_terminal, e_dialinginfo.id); /* handle restricted caller ids */ - apply_callerid_restriction(e_ext.anon_ignore, port->p_type, message->param.setup.callerinfo.id, &message->param.setup.callerinfo.ntype, &message->param.setup.callerinfo.present, &message->param.setup.callerinfo.screen, message->param.setup.callerinfo.voip, message->param.setup.callerinfo.intern, message->param.setup.callerinfo.name); - apply_callerid_restriction(e_ext.anon_ignore, port->p_type, message->param.setup.redirinfo.id, &message->param.setup.redirinfo.ntype, &message->param.setup.redirinfo.present, NULL, message->param.setup.redirinfo.voip, message->param.setup.redirinfo.intern, 0); + apply_callerid_restriction(&e_ext, message->param.setup.callerinfo.id, &message->param.setup.callerinfo.ntype, &message->param.setup.callerinfo.present, &message->param.setup.callerinfo.screen, message->param.setup.callerinfo.extension, message->param.setup.callerinfo.name); + apply_callerid_restriction(&e_ext, message->param.setup.redirinfo.id, &message->param.setup.redirinfo.ntype, &message->param.setup.redirinfo.present, 0, message->param.setup.redirinfo.extension, NULL); /* display callerid if desired for extension */ - SCPY(message->param.setup.callerinfo.display, apply_callerid_display(message->param.setup.callerinfo.id, message->param.setup.callerinfo.itype, message->param.setup.callerinfo.ntype, message->param.setup.callerinfo.present, message->param.setup.callerinfo.screen, message->param.setup.callerinfo.voip, message->param.setup.callerinfo.intern, message->param.setup.callerinfo.name)); + SCPY(message->param.setup.callerinfo.display, apply_callerid_display(message->param.setup.callerinfo.id, message->param.setup.callerinfo.itype, message->param.setup.callerinfo.ntype, message->param.setup.callerinfo.present, message->param.setup.callerinfo.screen, message->param.setup.callerinfo.extension, message->param.setup.callerinfo.name)); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); anycall = 1; } @@ -1288,18 +1152,18 @@ void EndpointAppPBX::out_setup(void) { trace_header("INTERFACE (no extension's interface)", DIRECTION_NONE); end_trace(); - if (!ea_endpoint->ep_call_id) + if (!ea_endpoint->ep_join_id) break; - release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, cause, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, call, port */ + release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, cause, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, join, port */ return; /* must exit here */ } break; /* *********************** external call */ default: - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) dialing external: '%s'\n", ea_endpoint->ep_serial, e_dialinginfo.number); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) dialing external: '%s'\n", ea_endpoint->ep_serial, e_dialinginfo.id); /* call to extenal interfaces */ - p = e_dialinginfo.number; + p = e_dialinginfo.id; do { number[0] = '\0'; @@ -1310,53 +1174,8 @@ void EndpointAppPBX::out_setup(void) /* found number */ PDEBUG(DEBUG_EPOINT, "EPOINT(%d) calling to number '%s' interface '%s'\n", ea_endpoint->ep_serial, number, e_dialinginfo.interfaces[0]?e_dialinginfo.interfaces:"any interface"); /* hunt for mISDNport and create Port */ - mISDNport = mISDNport_first; - port = NULL; - while(mISDNport) - { - /* check for external or given interface */ - if ((!e_dialinginfo.interfaces[0]&&mISDNport->iftype==IF_EXTERN) || !strcmp(mISDNport->interface_name, e_dialinginfo.interfaces)) - { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) interface '%s' found\n", ea_endpoint->ep_serial, mISDNport->interface_name); - cause = CAUSE_NOCHANNEL; /* when failing: out of channels */ - /* if PTP, skip all down links */ - if (mISDNport->ptp && !mISDNport->l2link) - { - trace_header("INTERFACE (layer 2 is down)", DIRECTION_NONE); - add_trace("interface", NULL, "%s", mISDNport->interface_name); - end_trace(); - mISDNport = mISDNport->next; - continue; - } - /* if no channel is available */ - if (mISDNport->multilink || !mISDNport->ntmode || mISDNport->ptp) - { - use = 0; - i = 0; - ii = mISDNport->b_num; - while(i < ii) - { - if (mISDNport->b_state[i]) - use++; - i++; - } - if (use >= mISDNport->b_num) - { - trace_header("INTERFACE (no free channel)", DIRECTION_NONE); - add_trace("interface", NULL, "%s", mISDNport->interface_name); - end_trace(); - mISDNport = mISDNport->next; - continue; - } - } - /* found interface */ - trace_header("INTERFACE (found)", DIRECTION_NONE); - add_trace("interface", NULL, "%s", mISDNport->interface_name); - end_trace(); - break; - } - mISDNport = mISDNport->next; - } + /* hunt for mISDNport and create Port */ + mISDNport = hunt_port(e_dialinginfo.interfaces[0]?e_dialinginfo.interfaces:NULL, &channel); if (!mISDNport) { trace_header("INTERFACE (too busy)", DIRECTION_NONE); @@ -1365,19 +1184,16 @@ void EndpointAppPBX::out_setup(void) goto check_anycall_extern; } /* creating EXTERNAL port*/ - SPRINT(portname, "%s-%d-out", mISDNport->interface_name, mISDNport->portnum); - port = new Pdss1((mISDNport->ntmode)?PORT_TYPE_DSS1_NT_OUT:PORT_TYPE_DSS1_TE_OUT, mISDNport, portname, &port_settings); - if (!port) - { - PERROR("EPOINT(%d) no memory for external port, exitting\n", ea_endpoint->ep_serial); - exit(-1); - } + SPRINT(portname, "%s-%d-out", mISDNport->ifport->interface->name, mISDNport->portnum); + if (!(port = new Pdss1((mISDNport->ntmode)?PORT_TYPE_DSS1_NT_OUT:PORT_TYPE_DSS1_TE_OUT, mISDNport, portname, &port_settings, channel, mISDNport->ifport->channel_force))) + FATAL("No memory for DSS1 Port instance\n"); + earlyb = mISDNport->earlyb; PDEBUG(DEBUG_EPOINT, "EPOINT(%d) created port %s\n", ea_endpoint->ep_serial, port->p_name); memset(&dialinginfo, 0, sizeof(dialinginfo)); - SCPY(dialinginfo.number, number); - dialinginfo.itype = INFO_ITYPE_EXTERN; + SCPY(dialinginfo.id, number); + dialinginfo.itype = INFO_ITYPE_ISDN; dialinginfo.ntype = e_dialinginfo.ntype; - portlist = ea_endpoint->portlist_new(port->p_serial, port->p_type, mISDNport->is_earlyb); + portlist = ea_endpoint->portlist_new(port->p_serial, port->p_type, mISDNport->earlyb); if (!portlist) { PERROR("EPOINT(%d) cannot allocate port_list relation\n", ea_endpoint->ep_serial); @@ -1385,23 +1201,23 @@ void EndpointAppPBX::out_setup(void) goto check_anycall_extern; } // dss1 = (class Pdss1 *)port; -//printf("EXTERNAL caller=%s,id=%s,dial=%s\n", param.setup.networkid, param.setup.callerinfo.id, param.setup.dialinginfo.number); +//printf("EXTERNAL caller=%s,id=%s,dial=%s\n", param.setup.networkid, param.setup.callerinfo.id, param.setup.dialinginfo.id); message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_SETUP); memcpy(&message->param.setup.dialinginfo, &dialinginfo, sizeof(struct dialing_info)); - SCPY(message->param.setup.dialinginfo.number, number); + SCPY(message->param.setup.dialinginfo.id, number); memcpy(&message->param.setup.redirinfo, &e_redirinfo, sizeof(struct redir_info)); memcpy(&message->param.setup.callerinfo, &e_callerinfo, sizeof(struct caller_info)); memcpy(&message->param.setup.capainfo, &e_capainfo, sizeof(struct capa_info)); //terminal SCPY(message->param.setup.from_terminal, e_ext.number); -//terminal if (e_dialinginfo.number) -//terminal SCPY(message->param.setup.to_terminal, e_dialinginfo.number); +//terminal if (e_dialinginfo.id) +//terminal SCPY(message->param.setup.to_terminal, e_dialinginfo.id); /* handle restricted caller ids */ - apply_callerid_restriction(e_ext.anon_ignore, port->p_type, message->param.setup.callerinfo.id, &message->param.setup.callerinfo.ntype, &message->param.setup.callerinfo.present, &message->param.setup.callerinfo.screen, message->param.setup.callerinfo.voip, message->param.setup.callerinfo.intern, message->param.setup.callerinfo.name); - apply_callerid_restriction(e_ext.anon_ignore, port->p_type, message->param.setup.redirinfo.id, &message->param.setup.redirinfo.ntype, &message->param.setup.redirinfo.present, NULL, message->param.setup.redirinfo.voip, message->param.setup.redirinfo.intern, 0); + apply_callerid_restriction(&e_ext, message->param.setup.callerinfo.id, &message->param.setup.callerinfo.ntype, &message->param.setup.callerinfo.present, &message->param.setup.callerinfo.screen, message->param.setup.callerinfo.extension, message->param.setup.callerinfo.name); + apply_callerid_restriction(&e_ext, message->param.setup.redirinfo.id, &message->param.setup.redirinfo.ntype, &message->param.setup.redirinfo.present, 0, message->param.setup.redirinfo.extension, NULL); /* display callerid if desired for extension */ - SCPY(message->param.setup.callerinfo.display, apply_callerid_display(message->param.setup.callerinfo.id, message->param.setup.callerinfo.itype, message->param.setup.callerinfo.ntype, message->param.setup.callerinfo.present, message->param.setup.callerinfo.screen, message->param.setup.callerinfo.voip, message->param.setup.callerinfo.intern, message->param.setup.callerinfo.name)); + SCPY(message->param.setup.callerinfo.display, apply_callerid_display(message->param.setup.callerinfo.id, message->param.setup.callerinfo.itype, message->param.setup.callerinfo.ntype, message->param.setup.callerinfo.present, message->param.setup.callerinfo.screen, message->param.setup.callerinfo.extension, message->param.setup.callerinfo.name)); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); anycall = 1; } while(*p); @@ -1411,9 +1227,9 @@ void EndpointAppPBX::out_setup(void) { trace_header("INTERFACE (no free ports found)", DIRECTION_NONE); end_trace(); - if (!ea_endpoint->ep_call_id) + if (!ea_endpoint->ep_join_id) break; - release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_NOCHANNEL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, call, port */ + release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_NOCHANNEL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, join, port */ return; /* must exit here */ } break; @@ -1447,10 +1263,10 @@ int EndpointAppPBX::handler(void) { e_redial = 0; PDEBUG(DEBUG_EPOINT, "EPOINT(%d) current action timed out.\n", ea_endpoint->ep_serial); - e_multipoint_cause = CAUSE_NOUSER; - e_multipoint_location = LOCATION_PRIVATE_LOCAL; + e_multipoint_cause = 0; + e_multipoint_location = 0; new_state(EPOINT_STATE_IN_OVERLAP); - e_call_pattern = 0; + e_join_pattern = 0; process_dialing(); return(1); /* we must exit, because our endpoint might be gone */ } else @@ -1508,7 +1324,7 @@ int EndpointAppPBX::handler(void) if (e_cfnr_release) { struct port_list *portlist; - struct message *message; + struct lcr_msg *message; if (now >= e_cfnr_release) { @@ -1522,17 +1338,17 @@ int EndpointAppPBX::handler(void) message->param.disconnectinfo.cause = CAUSE_NORMAL; /* normal clearing */ message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL; message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); ea_endpoint->free_portlist(portlist); } /* put on hold */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_HOLD; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 0; message_put(message); /* indicate no patterns */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_NOPATTERN); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_NOPATTERN); message_put(message); - /* set setup state, since we have no response from the new call */ + /* set setup state, since we have no response from the new join */ new_state(EPOINT_STATE_OUT_SETUP); } } else @@ -1610,17 +1426,17 @@ void EndpointAppPBX::hookflash(void) return; } /* dialtone after pressing the hash key */ - process_hangup(e_call_cause, e_call_location); - e_multipoint_cause = CAUSE_NOUSER; - e_multipoint_location = LOCATION_PRIVATE_LOCAL; + process_hangup(e_join_cause, e_join_location); + e_multipoint_cause = 0; + e_multipoint_location = 0; port = find_port_id(ea_endpoint->ep_portlist->port_id); if (port) { port->set_echotest(0); } - if (ea_endpoint->ep_call_id) + if (ea_endpoint->ep_join_id) { - release(RELEASE_CALL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, call, port */ + release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, join, port */ } e_ruleset = ruleset_main; if (e_ruleset) @@ -1628,10 +1444,10 @@ void EndpointAppPBX::hookflash(void) e_action = NULL; new_state(EPOINT_STATE_IN_OVERLAP); e_connectedmode = 1; - SCPY(e_dialinginfo.number, e_ext.prefix); - e_extdialing = e_dialinginfo.number; - e_call_pattern = 0; - if (e_dialinginfo.number[0]) + SCPY(e_dialinginfo.id, e_ext.prefix); + e_extdialing = e_dialinginfo.id; + e_join_pattern = 0; + if (e_dialinginfo.id[0]) { set_tone(ea_endpoint->ep_portlist, "dialing"); process_dialing(); @@ -1649,58 +1465,47 @@ void EndpointAppPBX::hookflash(void) /* port MESSAGE_SETUP */ void EndpointAppPBX::port_setup(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; char buffer[256]; - char extension[32]; - char extension1[32]; - char *p; int writeext; /* flags need to write extension after modification */ class Port *port; + struct interface *interface; + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); + portlist->port_type = param->setup.port_type; memcpy(&e_callerinfo, ¶m->setup.callerinfo, sizeof(e_callerinfo)); memcpy(&e_dialinginfo, ¶m->setup.dialinginfo, sizeof(e_dialinginfo)); memcpy(&e_redirinfo, ¶m->setup.redirinfo, sizeof(e_redirinfo)); memcpy(&e_capainfo, ¶m->setup.capainfo, sizeof(e_capainfo)); - e_dtmf = param->setup.dtmf; - - /* screen by interface */ - if (e_callerinfo.interface[0]) +// e_dtmf = param->setup.dtmf; + /* screen incoming caller id */ + interface = interface_first; + while(interface) { - /* screen incoming caller id */ - screen(0, e_callerinfo.id, sizeof(e_callerinfo.id), &e_callerinfo.ntype, &e_callerinfo.present); + if (!strcmp(e_callerinfo.interface, interface->name)) + { + break; + } + interface = interface->next; } -colp, outclip, outcolp + if (interface) + do_screen(0, e_callerinfo.id, sizeof(e_callerinfo.id), &e_callerinfo.ntype, &e_callerinfo.present, interface); /* process extension */ - if (e_callerinfo.itype == INFO_ITYPE_INTERN) + if (e_callerinfo.itype == INFO_ITYPE_ISDN_EXTENSION) { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) incoming call is extension\n", ea_endpoint->ep_serial); /* port makes call from extension */ - SCPY(e_callerinfo.intern, e_callerinfo.id); - SCPY(e_ext.number, e_callerinfo.intern); + SCPY(e_callerinfo.extension, e_callerinfo.id); + SCPY(e_ext.number, e_callerinfo.extension); SCPY(e_extension_interface, e_callerinfo.interface); } else { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) incoming call is external or voip\n", ea_endpoint->ep_serial); } - trace_header("SETUP", DIRECTION_IN); - if (e_callerinfo.intern[0]) - add_trace("extension", NULL, "%s", e_callerinfo.intern); - add_trace("caller id", "number", "%s", numberrize_callerinfo(e_callerinfo.id, e_callerinfo.ntype)); - if (e_callerinfo.present == INFO_PRESENT_RESTRICTED) - add_trace("caller id", "present", "restricted"); - if (e_redirinfo.id[0]) - { - add_trace("redir'ing", "number", "%s", numberrize_callerinfo(e_redirinfo.id, e_redirinfo.ntype)); - if (e_redirinfo.present == INFO_PRESENT_RESTRICTED) - add_trace("redir'ing", "present", "restricted"); - } - if (e_dialinginfo.number) - add_trace("dialing", "number", "%s", e_dialinginfo.number)); - end_trace(); - if (e_callerinfo.itype == INFO_ITYPE_INTERN) + if (e_callerinfo.itype == INFO_ITYPE_ISDN_EXTENSION) { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) call from extension '%s'\n", ea_endpoint->ep_serial, e_ext.number); @@ -1719,20 +1524,20 @@ colp, outclip, outcolp } writeext = 0; - /* put prefix (next) in front of e_dialinginfo.number */ + /* put prefix (next) in front of e_dialinginfo.id */ if (e_ext.next[0]) { - SPRINT(buffer, "%s%s", e_ext.next, e_dialinginfo.number); - SCPY(e_dialinginfo.number, buffer); + SPRINT(buffer, "%s%s", e_ext.next, e_dialinginfo.id); + SCPY(e_dialinginfo.id, buffer); e_ext.next[0] = '\0'; writeext = 1; } else if (e_ext.prefix[0]) { - SPRINT(buffer, "%s%s", e_ext.prefix, e_dialinginfo.number); - SCPY(e_dialinginfo.number, buffer); + SPRINT(buffer, "%s%s", e_ext.prefix, e_dialinginfo.id); + SCPY(e_dialinginfo.id, buffer); } - /* screen caller id */ + /* screen caller id by extension's config */ e_callerinfo.screen = INFO_SCREEN_NETWORK; if (e_ext.name[0]) SCPY(e_callerinfo.name, e_ext.name); @@ -1762,13 +1567,13 @@ colp, outclip, outcolp write_extension(&e_ext, e_ext.number); /* set volume of rx and tx */ - if (param->setup.callerinfo.itype == INFO_ITYPE_INTERN) - if (e_ext.txvol!=256 || e_ext.rxvol!=256) + if (param->setup.callerinfo.itype == INFO_ITYPE_ISDN_EXTENSION) + if (e_ext.tx_gain!=0 || e_ext.rx_gain!=0) { message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_mISDNSIGNAL); message->param.mISDNsignal.message = mISDNSIGNAL_VOLUME; - message->param.mISDNsignal.rxvol = e_ext.txvol; - message->param.mISDNsignal.txvol = e_ext.rxvol; + message->param.mISDNsignal.rx_gain = e_ext.tx_gain; + message->param.mISDNsignal.tx_gain = e_ext.rx_gain; message_put(message); } @@ -1800,9 +1605,9 @@ colp, outclip, outcolp if (e_ruleset) e_rule = e_ruleset->rule_first; e_action = NULL; - e_extdialing = e_dialinginfo.number; + e_extdialing = e_dialinginfo.id; new_state(EPOINT_STATE_IN_SETUP); - if (e_dialinginfo.number[0]) + if (e_dialinginfo.id[0]) { set_tone(portlist, "dialing"); } else @@ -1819,24 +1624,22 @@ colp, outclip, outcolp new_state(EPOINT_STATE_IN_OVERLAP); message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_OVERLAP); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); } } /* port MESSAGE_INFORMATION */ void EndpointAppPBX::port_information(struct port_list *portlist, int message_type, union parameter *param) { - trace_header("INFORMATION", DIRECTION_IN); - add_trace("dialing", NULL, "%s", param->information.number); - if (param->information.sending_complete) - add_trace("complete", NULL, NULL); - end_trace(); + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); + e_overlap = 1; /* turn off dtmf detection, in case dtmf is sent with keypad information */ if (e_dtmf) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) received dialing information, so dtmf is now disabled, to prevent double detection by keypad+dtmf.\n", ea_endpoint->ep_serial, param->information.number, e_ext.number, e_callerinfo.id); + trace_header("DTMF (disabling due to keypad)", DIRECTION_IN); + end_trace(); e_dtmf = 0; } @@ -1845,7 +1648,7 @@ void EndpointAppPBX::port_information(struct port_list *portlist, int message_ty if (e_action->index == ACTION_VBOX_PLAY) { /* concat dialing string */ - SCAT(e_dialinginfo.number, param->information.number); + SCAT(e_dialinginfo.id, param->information.id); process_dialing(); return; } @@ -1853,9 +1656,9 @@ void EndpointAppPBX::port_information(struct port_list *portlist, int message_ty /* keypad when disconnect but in connected mode */ if (e_state==EPOINT_STATE_OUT_DISCONNECT && e_connectedmode) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) keypad information received after disconnect: %s.\n", ea_endpoint->ep_serial, param->information.number); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) keypad information received after disconnect: %s.\n", ea_endpoint->ep_serial, param->information.id); /* processing keypad function */ - if (param->information.number[0] == '0') + if (param->information.id[0] == '0') { hookflash(); } @@ -1863,26 +1666,40 @@ void EndpointAppPBX::port_information(struct port_list *portlist, int message_ty } /* keypad when connected */ - if (e_state == EPOINT_STATE_CONNECT && e_ext.keypad) + if (e_state == EPOINT_STATE_CONNECT) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) keypad information received during connect: %s.\n", ea_endpoint->ep_serial, param->information.number); - /* processing keypad function */ - if (param->information.number[0] == '0') + if (e_ext.keypad || e_enablekeypad) { - hookflash(); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) keypad information received during connect: %s.\n", ea_endpoint->ep_serial, param->information.id); + /* processing keypad function */ + if (param->information.id[0] == '0') + { + hookflash(); + } + if (param->information.id[0]) + keypad_function(param->information.id[0]); + } else + { + if (e_ext.number[0]) + trace_header("KEYPAD (not enabled by extension's settings)", DIRECTION_IN); + else + trace_header("KEYPAD (not enabled for external interfaces)", DIRECTION_IN); + end_trace(); } - if (param->information.number[0]) - keypad_function(param->information.number[0]); return; } if (e_state != EPOINT_STATE_IN_OVERLAP) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) ignored because we are not in overlap, or connect state.\n", ea_endpoint->ep_serial); + if (e_ext.number[0]) + trace_header("KEYPAD (ignored, not connected and not dialing)", DIRECTION_IN); + else + trace_header("KEYPAD (not enabled for external interfaces)", DIRECTION_IN); + end_trace(); return; } - if (!param->information.number[0]) + if (!param->information.id[0]) return; - if (e_dialinginfo.number[0]=='\0' && !e_action) + if (e_dialinginfo.id[0]=='\0' && !e_action) { set_tone(portlist, "dialing"); } @@ -1896,22 +1713,23 @@ void EndpointAppPBX::port_information(struct port_list *portlist, int message_ty set_tone(portlist, "dialing"); } /* concat dialing string */ - SCAT(e_dialinginfo.number, param->information.number); + SCAT(e_dialinginfo.id, param->information.id); process_dialing(); } /* port MESSAGE_DTMF */ void EndpointAppPBX::port_dtmf(struct port_list *portlist, int message_type, union parameter *param) { - trace_header("DTMF", DIRECTION_IN); - add_trace("digit", NULL, "%c", param->dtmf); - end_trace(); /* only if dtmf detection is enabled */ if (!e_dtmf) { - PDEBUG(DEBUG_EPOINT, "dtmf detection is disabled\n"); + trace_header("DTMF (disabled)", DIRECTION_IN); + end_trace(); return; } + trace_header("DTMF", DIRECTION_IN); + add_trace("digit", NULL, "%c", param->dtmf); + end_trace(); #if 0 NOTE: vbox is now handled due to overlap state @@ -1920,10 +1738,10 @@ NOTE: vbox is now handled due to overlap state if (e_action->index == ACTION_VBOX_PLAY) { /* concat dialing string */ - if (strlen(e_dialinginfo.number)+1 < sizeof(e_dialinginfo.number)) + if (strlen(e_dialinginfo.id)+1 < sizeof(e_dialinginfo.id)) { - e_dialinginfo.number[strlen(e_dialinginfo.number)+1] = '\0'; - e_dialinginfo.number[strlen(e_dialinginfo.number)] = param->dtmf; + e_dialinginfo.id[strlen(e_dialinginfo.id)+1] = '\0'; + e_dialinginfo.id[strlen(e_dialinginfo.id)] = param->dtmf; process_dialing(); } /* continue to process *X# sequences */ @@ -2003,15 +1821,15 @@ NOTE: vbox is now handled due to overlap state /* dialing using dtmf digit */ if (e_state==EPOINT_STATE_IN_OVERLAP)// && e_state==e_connectedmode) { - if (e_dialinginfo.number[0]=='\0' && !e_action) + if (e_dialinginfo.id[0]=='\0' && !e_action) { set_tone(portlist, "dialing"); } /* concat dialing string */ - if (strlen(e_dialinginfo.number)+1 < sizeof(e_dialinginfo.number)) + if (strlen(e_dialinginfo.id)+1 < sizeof(e_dialinginfo.id)) { - e_dialinginfo.number[strlen(e_dialinginfo.number)+1] = '\0'; - e_dialinginfo.number[strlen(e_dialinginfo.number)] = param->dtmf; + e_dialinginfo.id[strlen(e_dialinginfo.id)+1] = '\0'; + e_dialinginfo.id[strlen(e_dialinginfo.id)] = param->dtmf; process_dialing(); } } @@ -2030,51 +1848,51 @@ void EndpointAppPBX::port_crypt(struct port_list *portlist, int message_type, un /* port MESSAGE_OVERLAP */ void EndpointAppPBX::port_overlap(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; + + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); /* signal to call tool */ admin_call_response(e_adminid, ADMIN_CALL_SETUP_ACK, "", 0, 0, 0); - trace_header("SETUP ACKNOWLEDGE", DIRECTION_IN); - end_trace(); if (e_dialing_queue[0] && portlist) { /* send what we have not dialed yet, because we had no setup complete */ PDEBUG(DEBUG_EPOINT, "EPOINT(%d) dialing pending digits: '%s'\n", ea_endpoint->ep_serial, e_dialing_queue); message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_portlist->port_id, EPOINT_TO_PORT, MESSAGE_INFORMATION); - SCPY(message->param.information.number, e_dialing_queue); + SCPY(message->param.information.id, e_dialing_queue); message->param.information.ntype = INFO_NTYPE_UNKNOWN; message_put(message); - logmessage(message); + logmessage(message->type, &message->param, ea_endpoint->ep_portlist->port_id, DIRECTION_OUT); e_dialing_queue[0] = '\0'; } /* check if pattern is available */ - if (!ea_endpoint->ep_portlist->next && portlist->earlyb) /* one port_list relation and tones available */ + if (!ea_endpoint->ep_portlist->next && portlist->early_b) /* one port_list relation and tones available */ { /* indicate patterns */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_PATTERN); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_PATTERN); message_put(message); /* connect audio, if not already */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_CONNECT; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 1; message_put(message); } else { /* indicate no patterns */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_NOPATTERN); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_NOPATTERN); message_put(message); /* disconnect audio, if not already */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_HOLD; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 0; message_put(message); } new_state(EPOINT_STATE_OUT_OVERLAP); - /* if we are in a call */ - if (ea_endpoint->ep_call_id) + /* if we are in a join */ + if (ea_endpoint->ep_join_id) { - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, message_type); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, message_type); memcpy(&message->param, param, sizeof(union parameter)); message_put(message); } @@ -2083,40 +1901,40 @@ void EndpointAppPBX::port_overlap(struct port_list *portlist, int message_type, /* port MESSAGE_PROCEEDING */ void EndpointAppPBX::port_proceeding(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; + + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); /* signal to call tool */ admin_call_response(e_adminid, ADMIN_CALL_PROCEEDING, "", 0, 0, 0); - trace_header("PROCEEDING", DIRECTION_IN); - end_trace(); e_state = EPOINT_STATE_OUT_PROCEEDING; /* check if pattern is availatle */ - if (!ea_endpoint->ep_portlist->next && (portlist->earlyb || portlist->port_type==PORT_TYPE_VBOX_OUT)) /* one port_list relation and tones available */ + if (!ea_endpoint->ep_portlist->next && (portlist->early_b || portlist->port_type==PORT_TYPE_VBOX_OUT)) /* one port_list relation and tones available */ { /* indicate patterns */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_PATTERN); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_PATTERN); message_put(message); /* connect audio, if not already */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_CONNECT; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 1; message_put(message); } else { /* indicate no patterns */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_NOPATTERN); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_NOPATTERN); message_put(message); /* disconnect audio, if not already */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_HOLD; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 0; message_put(message); } /* if we are in a call */ - if (ea_endpoint->ep_call_id) + if (ea_endpoint->ep_join_id) { - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, message_type); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, message_type); memcpy(&message->param, param, sizeof(union parameter)); message_put(message); } @@ -2125,40 +1943,43 @@ void EndpointAppPBX::port_proceeding(struct port_list *portlist, int message_typ /* port MESSAGE_ALERTING */ void EndpointAppPBX::port_alerting(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; + + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); /* signal to call tool */ admin_call_response(e_adminid, ADMIN_CALL_ALERTING, "", 0, 0, 0); +//#warning hack!! +// if (e_adminid) +// set_tone(portlist, "hold"); - trace_header("ALERTING", DIRECTION_IN); - end_trace(); new_state(EPOINT_STATE_OUT_ALERTING); /* check if pattern is available */ - if (!ea_endpoint->ep_portlist->next && (portlist->earlyb || portlist->port_type==PORT_TYPE_VBOX_OUT)) /* one port_list relation and tones available */ + if (!ea_endpoint->ep_portlist->next && (portlist->early_b || portlist->port_type==PORT_TYPE_VBOX_OUT)) /* one port_list relation and tones available */ { /* indicate patterns */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_PATTERN); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_PATTERN); message_put(message); /* connect audio, if not already */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_CONNECT; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 1; message_put(message); } else { /* indicate no patterns */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_NOPATTERN); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_NOPATTERN); message_put(message); /* disconnect audio, if not already */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_HOLD; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 0; message_put(message); } /* if we are in a call */ - if (ea_endpoint->ep_call_id) + if (ea_endpoint->ep_join_id) { - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, message_type); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, message_type); memcpy(&message->param, param, sizeof(union parameter)); message_put(message); } @@ -2167,23 +1988,19 @@ void EndpointAppPBX::port_alerting(struct port_list *portlist, int message_type, /* port MESSAGE_CONNECT */ void EndpointAppPBX::port_connect(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; char buffer[256]; - unsigned long port_id = portlist->port_id; + unsigned int port_id = portlist->port_id; struct port_list *tportlist; class Port *port; + struct interface *interface; + + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); /* signal to call tool */ - admin_call_response(e_adminid, ADMIN_CALL_CONNECT, numberrize_callerinfo(param->connectinfo.id,param->connectinfo.ntype), 0, 0, 0); + admin_call_response(e_adminid, ADMIN_CALL_CONNECT, numberrize_callerinfo(param->connectinfo.id,param->connectinfo.ntype, options.national, options.international), 0, 0, 0); memcpy(&e_connectinfo, ¶m->connectinfo, sizeof(e_connectinfo)); - trace_header("CONNECT", DIRECTION_IN); - if (e_connectinfo.intern[0]) - add_trace("extension", NULL, "%s", e_connectinfo.intern); - add_trace("connect id", "number", "%s", numberrize_callerinfo(e_connectinfo.id, e_connectinfo.ntype)); - if (e_connectinfo.present == INFO_PRESENT_RESTRICTED) - add_trace("connect id", "present", "restricted"); - end_trace(); PDEBUG(DEBUG_EPOINT, "EPOINT(%d) removing all other ports (start)\n", ea_endpoint->ep_serial); while(ea_endpoint->ep_portlist->next) /* as long as we have at least two ports */ { @@ -2191,44 +2008,47 @@ void EndpointAppPBX::port_connect(struct port_list *portlist, int message_type, if (tportlist->port_id == port_id) /* if the first portlist is the calling one, the second must be a different one */ tportlist = tportlist->next; if (tportlist->port_id == port_id) - { - PERROR("EPOINT(%d) software error: this should not happen since the portlist list must not have two links to the same port - exitting.\n"); - exit(-1); - } + FATAL("EPOINT(%d) this should not happen since the portlist list must not have two links to the same port - exitting.\n"); message = message_create(ea_endpoint->ep_serial, tportlist->port_id, EPOINT_TO_PORT, MESSAGE_RELEASE); - message->param.disconnectinfo.cause = 26; /* non selected user clearing */ + message->param.disconnectinfo.cause = CAUSE_NONSELECTED; /* non selected user clearing */ message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL; message_put(message); - logmessage(message); + logmessage(message->type, &message->param, tportlist->port_id, DIRECTION_OUT); ea_endpoint->free_portlist(tportlist); } PDEBUG(DEBUG_EPOINT, "EPOINT(%d) removing all other ports (end)\n", ea_endpoint->ep_serial); e_start = now; - /* screen by interface */ - if (e_callerinfo.interface[0]) + /* screen incoming connected id */ + interface = interface_first; + while(interface) { - /* screen incoming caller id */ - screen(0, e_connectinfo.id, sizeof(e_connectinfo.id), &e_connectinfo.ntype, &e_connectinfo.present); + if (!strcmp(e_connectinfo.interface, interface->name)) + { + break; + } + interface = interface->next; } + if (interface) + do_screen(0, e_connectinfo.id, sizeof(e_connectinfo.id), &e_connectinfo.ntype, &e_connectinfo.present, interface); /* screen connected name */ if (e_ext.name[0]) SCPY(e_connectinfo.name, e_ext.name); /* add internal id to colp */ - SCPY(e_connectinfo.intern, e_ext.number); + SCPY(e_connectinfo.extension, e_ext.number); /* we store the connected port number */ - SCPY(e_extension_interface, e_connectinfo.interfaces); + SCPY(e_extension_interface, e_connectinfo.interface); /* for internal and am calls, we get the extension's id */ if (portlist->port_type==PORT_TYPE_VBOX_OUT || e_ext.colp==COLP_HIDE) { SCPY(e_connectinfo.id, e_ext.callerid); - SCPY(e_connectinfo.intern, e_ext.number); - e_connectinfo.itype = INFO_ITYPE_INTERN; + SCPY(e_connectinfo.extension, e_ext.number); + e_connectinfo.itype = INFO_ITYPE_ISDN_EXTENSION; e_connectinfo.ntype = e_ext.callerid_type; e_connectinfo.present = e_ext.callerid_present; } @@ -2241,43 +2061,44 @@ void EndpointAppPBX::port_connect(struct port_list *portlist, int message_type, new_state(EPOINT_STATE_CONNECT); /* set volume of rx and tx */ - if (e_ext.txvol!=256 || e_ext.rxvol!=256) + if (e_ext.tx_gain!=0 || e_ext.rx_gain!=0) { message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_mISDNSIGNAL); message->param.mISDNsignal.message = mISDNSIGNAL_VOLUME; - message->param.mISDNsignal.rxvol = e_ext.txvol; - message->param.mISDNsignal.txvol = e_ext.rxvol; + message->param.mISDNsignal.rx_gain = e_ext.tx_gain; + message->param.mISDNsignal.tx_gain = e_ext.rx_gain; message_put(message); } e_cfnr_call = e_cfnr_release = 0; if (e_ext.number[0]) e_dtmf = 1; /* allow dtmf */ -// if (call_countrelations(ea_endpoint->ep_call_id) == 2) + + /* modify colp */ + /* other calls with no caller id (or not available for the extension) and force colp */ + if ((e_connectinfo.id[0]=='\0' || (e_connectinfo.present==INFO_PRESENT_RESTRICTED && !e_ext.anon_ignore))&& e_ext.colp==COLP_FORCE) { - /* modify colp */ - /* other calls with no caller id (or not available for the extension) and force colp */ - if ((e_connectinfo.id[0]=='\0' || (e_connectinfo.present==INFO_PRESENT_RESTRICTED && !e_ext.anon_ignore))&& e_ext.colp==COLP_FORCE) + e_connectinfo.present = INFO_PRESENT_NOTAVAIL; + if (portlist->port_type==PORT_TYPE_DSS1_TE_OUT || portlist->port_type==PORT_TYPE_DSS1_NT_OUT) /* external extension answered */ { - e_connectinfo.present = INFO_PRESENT_NOTAVAIL; - if (portlist->port_type==PORT_TYPE_DSS1_TE_OUT || portlist->port_type==PORT_TYPE_DSS1_NT_OUT) /* external extension answered */ + port = find_port_id(portlist->port_id); + if (port) { - port = find_port_id(portlist->port_id); - if (port) - { - SCPY(e_connectinfo.id, nationalize_callerinfo(port->p_dialinginfo.number, &e_connectinfo.ntype)); - e_connectinfo.present = INFO_PRESENT_ALLOWED; - } + SCPY(e_connectinfo.id, nationalize_callerinfo(port->p_dialinginfo.id, &e_connectinfo.ntype, options.national, options.international)); + e_connectinfo.present = INFO_PRESENT_ALLOWED; } } - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, message_type); - memcpy(&message->param.connectinfo, &e_connectinfo, sizeof(struct connect_info)); - message_put(message); } - if (ea_endpoint->ep_call_id) + + /* send connect to join */ + if (ea_endpoint->ep_join_id) { - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_CONNECT; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, message_type); + memcpy(&message->param.connectinfo, &e_connectinfo, sizeof(struct connect_info)); + message_put(message); + + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 1; message_put(message); } else if (!e_adminid) { @@ -2300,13 +2121,13 @@ void EndpointAppPBX::port_connect(struct port_list *portlist, int message_type, /* put prefix in front of e_cbdialing */ SPRINT(buffer, "%s%s", e_ext.prefix, e_cbdialing); - SCPY(e_dialinginfo.number, buffer); - e_dialinginfo.itype = INFO_ITYPE_EXTERN; + SCPY(e_dialinginfo.id, buffer); + e_dialinginfo.itype = INFO_ITYPE_ISDN; e_dialinginfo.ntype = INFO_NTYPE_UNKNOWN; /* use caller id (or if exist: id_next_call) for this call */ e_callerinfo.screen = INFO_SCREEN_NETWORK; - SCPY(e_callerinfo.intern, e_ext.number); + SCPY(e_callerinfo.extension, e_ext.number); if (e_ext.id_next_call_present >= 0) { SCPY(e_callerinfo.id, e_ext.id_next_call); @@ -2333,8 +2154,8 @@ void EndpointAppPBX::port_connect(struct port_list *portlist, int message_type, e_action = &action_password_write; e_match_timeout = 0; e_match_to_action = NULL; - e_dialinginfo.number[0] = '\0'; - e_extdialing = strchr(e_dialinginfo.number, '\0'); + e_dialinginfo.id[0] = '\0'; + e_extdialing = strchr(e_dialinginfo.id, '\0'); e_password_timeout = now+20; process_dialing(); } else @@ -2344,8 +2165,8 @@ void EndpointAppPBX::port_connect(struct port_list *portlist, int message_type, if (e_ruleset) e_rule = e_ruleset->rule_first; e_action = NULL; - e_extdialing = e_dialinginfo.number; - if (e_dialinginfo.number[0]) + e_extdialing = e_dialinginfo.id; + if (e_dialinginfo.id[0]) { set_tone(portlist, "dialing"); process_dialing(); @@ -2377,20 +2198,17 @@ void EndpointAppPBX::port_connect(struct port_list *portlist, int message_type, /* port MESSAGE_DISCONNECT MESSAGE_RELEASE */ void EndpointAppPBX::port_disconnect_release(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; char buffer[256]; - unsigned long port_id = portlist->port_id; + unsigned int port_id = portlist->port_id; int cause, location; + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); + /* signal to call tool */ admin_call_response(e_adminid, (message_type==MESSAGE_DISCONNECT)?ADMIN_CALL_DISCONNECT:ADMIN_CALL_RELEASE, "", param->disconnectinfo.cause, param->disconnectinfo.location, 0); - trace_header((message_type==MESSAGE_DISCONNECT)?"DISCONNECT":"RELEASE", DIRECTION_IN); - add_trace("cause", "value", "%d", param->disconnectinfo.cause); - add_trace("cause", "location", "%d", param->disconnectinfo.location); - end_trace(); - //#warning does this work? only disconnect when incoming port hat not already disconnected yet? if (e_state==EPOINT_STATE_IN_DISCONNECT && message_type!=MESSAGE_RELEASE)// || e_state==EPOINT_STATE_OUT_DISCONNECT || e_state==EPOINT_STATE_IDLE) { @@ -2400,31 +2218,7 @@ void EndpointAppPBX::port_disconnect_release(struct port_list *portlist, int mes /* collect cause */ PDEBUG(DEBUG_EPOINT, "EPOINT(%d) current multipoint cause %d location %d, received cause %d location %d.\n", ea_endpoint->ep_serial, e_multipoint_cause, e_multipoint_location, param->disconnectinfo.cause, param->disconnectinfo.location); - if (param->disconnectinfo.cause == CAUSE_REJECTED) /* call rejected */ - { - e_multipoint_cause = CAUSE_REJECTED; - e_multipoint_location = param->disconnectinfo.location; - } else - if (param->disconnectinfo.cause==CAUSE_NORMAL && e_multipoint_cause!=CAUSE_REJECTED) /* reject via hangup */ - { - e_multipoint_cause = CAUSE_NORMAL; - e_multipoint_location = param->disconnectinfo.location; - } else - if (param->disconnectinfo.cause==CAUSE_BUSY && e_multipoint_cause!=CAUSE_REJECTED && e_multipoint_cause!=CAUSE_NORMAL) /* busy */ - { - e_multipoint_cause = CAUSE_BUSY; - e_multipoint_location = param->disconnectinfo.location; - } else - if (param->disconnectinfo.cause==CAUSE_OUTOFORDER && e_multipoint_cause!=CAUSE_BUSY && e_multipoint_cause!=CAUSE_REJECTED && e_multipoint_cause!=CAUSE_NORMAL) /* no L1 */ - { - e_multipoint_cause = CAUSE_OUTOFORDER; - e_multipoint_location = param->disconnectinfo.location; - } else - if (param->disconnectinfo.cause!=CAUSE_NOUSER && e_multipoint_cause!=CAUSE_OUTOFORDER && e_multipoint_cause!=CAUSE_BUSY && e_multipoint_cause!=CAUSE_REJECTED && e_multipoint_cause!=CAUSE_NORMAL) /* anything but not 18 */ - { - e_multipoint_cause = param->disconnectinfo.cause; - e_multipoint_location = param->disconnectinfo.location; - } + collect_cause(&e_multipoint_cause, &e_multipoint_location, param->disconnectinfo.cause, param->disconnectinfo.location); PDEBUG(DEBUG_EPOINT, "EPOINT(%d) new multipoint cause %d location %d.\n", ea_endpoint->ep_serial, e_multipoint_cause, e_multipoint_location); /* check if we have more than one portlist relation and we just ignore the disconnect */ @@ -2439,66 +2233,75 @@ void EndpointAppPBX::port_disconnect_release(struct port_list *portlist, int mes portlist = portlist->next; } if (!portlist) - { - PERROR("EPOINT(%d) software error: no portlist related to the calling port.\n", ea_endpoint->ep_serial); - exit(-1); - } + FATAL("EPOINT(%d) no portlist related to the calling port.\n", ea_endpoint->ep_serial); if (message_type != MESSAGE_RELEASE) { message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_RELEASE); message->param.disconnectinfo.cause = CAUSE_NORMAL; /* normal clearing */ message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL; message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); } ea_endpoint->free_portlist(portlist); return; /* one relation removed */ } - if (e_multipoint_cause) - { - cause = e_multipoint_cause; - location = e_multipoint_location; - } else + if (e_state == EPOINT_STATE_CONNECT) { + /* use cause from port after connect */ cause = param->disconnectinfo.cause; location = param->disconnectinfo.location; + } else + { + /* use multipoint cause if no connect yet */ + if (e_multipoint_cause) + { + cause = e_multipoint_cause; + location = e_multipoint_location; + } else + { + cause = CAUSE_NOUSER; + location = LOCATION_PRIVATE_LOCAL; + } } e_cfnr_call = e_cfnr_release = 0; /* process hangup */ - process_hangup(e_call_cause, e_call_location); + process_hangup(e_join_cause, e_join_location); e_multipoint_cause = 0; - e_multipoint_location = LOCATION_PRIVATE_LOCAL; + e_multipoint_location = 0; + + if (message_type == MESSAGE_DISCONNECT) + { + /* tone to disconnected end */ + SPRINT(buffer, "cause_%02x", cause); + if (ea_endpoint->ep_portlist) + set_tone(ea_endpoint->ep_portlist, buffer); - /* tone to disconnected end */ - SPRINT(buffer, "cause_%02x", cause); - if (ea_endpoint->ep_portlist) - set_tone(ea_endpoint->ep_portlist, buffer); + new_state(EPOINT_STATE_IN_DISCONNECT); + } - new_state(EPOINT_STATE_IN_DISCONNECT); - if (ea_endpoint->ep_call_id) + if (ea_endpoint->ep_join_id) { int haspatterns = 0; /* check if pattern is available */ if (ea_endpoint->ep_portlist) - if (!ea_endpoint->ep_portlist->next && ea_endpoint->ep_portlist->earlyb) -#warning wie ist das bei einem asterisk, gibts auch tones? - if (callpbx_countrelations(ea_endpoint->ep_call_id)==2 // we must count relations, in order not to disturb the conference ; NOTE: + if (!ea_endpoint->ep_portlist->next && ea_endpoint->ep_portlist->early_b) + if (joinpbx_countrelations(ea_endpoint->ep_join_id)==2 // we must count relations, in order not to disturb the conference ; NOTE: asterisk always counts two, since it is a point to point call && message_type != MESSAGE_RELEASE) // if we release, we are done haspatterns = 1; if (haspatterns) { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) the port has patterns.\n", ea_endpoint->ep_serial); /* indicate patterns */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_PATTERN); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_PATTERN); message_put(message); /* connect audio, if not already */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_CONNECT; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 1; message_put(message); /* send disconnect */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, message_type); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, message_type); memcpy(&message->param, param, sizeof(union parameter)); message_put(message); /* disable encryption if disconnected */ @@ -2511,6 +2314,8 @@ void EndpointAppPBX::port_disconnect_release(struct port_list *portlist, int mes PDEBUG(DEBUG_EPOINT, "EPOINT(%d) the port has no patterns.\n", ea_endpoint->ep_serial); } } + if (message_type == MESSAGE_RELEASE) + ea_endpoint->free_portlist(portlist); release(RELEASE_ALL, location, cause, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, callcause, portcause */ return; /* must exit here */ } @@ -2561,6 +2366,14 @@ void EndpointAppPBX::port_timeout(struct port_list *portlist, int message_type, release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_NOANSWER, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); return; /* must exit here */ + case PORT_STATE_CONNECT: + add_trace("state", NULL, "connect"); + end_trace(); + param->disconnectinfo.cause = CAUSE_NORMAL; /* normal */ + param->disconnectinfo.location = LOCATION_PRIVATE_LOCAL; + release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); + return; /* must exit here */ + case PORT_STATE_IN_ALERTING: add_trace("state", NULL, "incoming alerting"); param->disconnectinfo.cause = CAUSE_NOANSWER; @@ -2581,7 +2394,7 @@ void EndpointAppPBX::port_timeout(struct port_list *portlist, int message_type, } end_trace(); /* release call, disconnect isdn */ - e_call_pattern = 0; + e_join_pattern = 0; new_state(EPOINT_STATE_OUT_DISCONNECT); SPRINT(cause, "cause_%02x", param->disconnectinfo.cause); SCPY(e_tone, cause); @@ -2591,18 +2404,20 @@ void EndpointAppPBX::port_timeout(struct port_list *portlist, int message_type, message_disconnect_port(portlist, param->disconnectinfo.cause, param->disconnectinfo.location, ""); portlist = portlist->next; } - release(RELEASE_CALL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, call, port */ + release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, join, port */ } /* port MESSAGE_NOTIFY */ void EndpointAppPBX::port_notify(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); + + struct lcr_msg *message; char *logtext = ""; char buffer[64]; /* signal to call tool */ - admin_call_response(e_adminid, ADMIN_CALL_NOTIFY, numberrize_callerinfo(param->notifyinfo.id,param->notifyinfo.ntype), 0, 0, param->notifyinfo.notify); + admin_call_response(e_adminid, ADMIN_CALL_NOTIFY, numberrize_callerinfo(param->notifyinfo.id,param->notifyinfo.ntype, options.national, options.international), 0, 0, param->notifyinfo.notify); if (param->notifyinfo.notify) { e_rx_state = track_notify(e_rx_state, param->notifyinfo.notify); @@ -2614,10 +2429,10 @@ void EndpointAppPBX::port_notify(struct port_list *portlist, int message_type, u case INFO_NOTIFY_REMOTE_HOLD: case INFO_NOTIFY_USER_SUSPENDED: /* tell call about it */ - if (ea_endpoint->ep_call_id) + if (ea_endpoint->ep_join_id) { - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_HOLD; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 0; message_put(message); } break; @@ -2625,24 +2440,24 @@ void EndpointAppPBX::port_notify(struct port_list *portlist, int message_type, u case INFO_NOTIFY_REMOTE_RETRIEVAL: case INFO_NOTIFY_USER_RESUMED: /* set volume of rx and tx */ - if (param->setup.callerinfo.itype == INFO_ITYPE_INTERN) - if (e_ext.txvol!=256 || e_ext.rxvol!=256) + if (param->setup.callerinfo.itype == INFO_ITYPE_ISDN_EXTENSION) + if (e_ext.tx_gain!=0 || e_ext.rx_gain!=0) if (portlist) { message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_mISDNSIGNAL); message->param.mISDNsignal.message = mISDNSIGNAL_VOLUME; - message->param.mISDNsignal.rxvol = e_ext.txvol; - message->param.mISDNsignal.txvol = e_ext.rxvol; + message->param.mISDNsignal.rx_gain = e_ext.tx_gain; + message->param.mISDNsignal.tx_gain = e_ext.rx_gain; message_put(message); } /* set current tone */ if (portlist) set_tone(portlist, e_tone); /* tell call about it */ - if (ea_endpoint->ep_call_id) + if (ea_endpoint->ep_join_id) { - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_CONNECT; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 1; message_put(message); } break; @@ -2728,23 +2543,11 @@ void EndpointAppPBX::port_notify(struct port_list *portlist, int message_type, u logtext = buffer; } - trace_header("NOTIFY", DIRECTION_IN); - if (param->notifyinfo.notify) - add_trace("indicator", NULL, "%s", logtext); - if (param->notifyinfo.id) - { - add_trace("redir'on", "number", "%s", numberrize_callerinfo(param->notifyinfo.id, param->notifyinfo.ntype)); - if (param->notifyinfo.present == INFO_PRESENT_RESTRICTED) - add_trace("redir'on", "present", "restricted"); - } - if (param->notifyinfo.display[0]) - add_trace("display", NULL, "%s", param->notifyinfo.display); - end_trace(); /* notify call if available */ - if (ea_endpoint->ep_call_id) + if (ea_endpoint->ep_join_id) { - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_NOTIFY); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_NOTIFY); memcpy(&message->param.notifyinfo, ¶m->notifyinfo, sizeof(struct notify_info)); message_put(message); } @@ -2754,12 +2557,11 @@ void EndpointAppPBX::port_notify(struct port_list *portlist, int message_type, u /* port MESSAGE_FACILITY */ void EndpointAppPBX::port_facility(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); - trace_header("FACILITY", DIRECTION_IN); - end_trace(); + struct lcr_msg *message; - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_FACILITY); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_FACILITY); memcpy(&message->param.facilityinfo, ¶m->facilityinfo, sizeof(struct facility_info)); message_put(message); } @@ -2768,8 +2570,8 @@ void EndpointAppPBX::port_facility(struct port_list *portlist, int message_type, /* NOTE: before supending, the inactive-notification must be done in order to set call mixer */ void EndpointAppPBX::port_suspend(struct port_list *portlist, int message_type, union parameter *param) { - trace_header("SUSPEND", DIRECTION_IN); - end_trace(); + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); + /* epoint is now parked */ ea_endpoint->ep_park = 1; memcpy(ea_endpoint->ep_park_callid, param->parkinfo.callid, sizeof(ea_endpoint->ep_park_callid)); @@ -2783,8 +2585,8 @@ void EndpointAppPBX::port_suspend(struct port_list *portlist, int message_type, /* NOTE: before resume, the active-notification must be done in order to set call mixer */ void EndpointAppPBX::port_resume(struct port_list *portlist, int message_type, union parameter *param) { - trace_header("RESUME", DIRECTION_IN); - end_trace(); + logmessage(message_type, param, portlist->port_id, DIRECTION_IN); + /* epoint is now resumed */ ea_endpoint->ep_park = 0; @@ -2793,11 +2595,10 @@ void EndpointAppPBX::port_resume(struct port_list *portlist, int message_type, u /* port sends message to the endpoint */ -void EndpointAppPBX::ea_message_port(unsigned long port_id, int message_type, union parameter *param) +void EndpointAppPBX::ea_message_port(unsigned int port_id, int message_type, union parameter *param) { struct port_list *portlist; - struct message *message; - class Port *port; + struct lcr_msg *message; portlist = ea_endpoint->ep_portlist; while(portlist) @@ -2816,23 +2617,14 @@ void EndpointAppPBX::ea_message_port(unsigned long port_id, int message_type, un switch(message_type) { case MESSAGE_DATA: /* data from port */ - /* send back to source for recording */ - if (port_id) - { - message = message_create(ea_endpoint->ep_serial, port_id, EPOINT_TO_PORT, message_type); - memcpy(&message->param, param, sizeof(union parameter)); - message_put(message); - } - /* check if there is a call */ - if (!ea_endpoint->ep_call_id) + if (!ea_endpoint->ep_join_id) break; /* continue if only one portlist */ if (ea_endpoint->ep_portlist->next != NULL) break; - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, message_type); - memcpy(&message->param, param, sizeof(union parameter)); - message_put(message); + /* forward message */ + message_forward(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, param); break; case MESSAGE_TONE_EOF: /* tone is end of file */ @@ -2863,7 +2655,7 @@ void EndpointAppPBX::ea_message_port(unsigned long port_id, int message_type, un /* PORT sends SETUP message */ case MESSAGE_SETUP: - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) incoming call from callerid=%s, dialing=%s\n", ea_endpoint->ep_serial, param->setup.callerinfo.id, param->setup.dialinginfo.number); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) incoming call from callerid=%s, dialing=%s\n", ea_endpoint->ep_serial, param->setup.callerinfo.id, param->setup.dialinginfo.id); if (e_state!=EPOINT_STATE_IDLE) { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) ignored because we are not in idle state.\n", ea_endpoint->ep_serial); @@ -2874,7 +2666,7 @@ void EndpointAppPBX::ea_message_port(unsigned long port_id, int message_type, un /* PORT sends INFORMATION message */ case MESSAGE_INFORMATION: /* additional digits received */ - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) incoming call dialing more=%s (terminal '%s', caller id '%s')\n", ea_endpoint->ep_serial, param->information.number, e_ext.number, e_callerinfo.id); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) incoming call dialing more=%s (terminal '%s', caller id '%s')\n", ea_endpoint->ep_serial, param->information.id, e_ext.number, e_callerinfo.id); port_information(portlist, message_type, param); break; @@ -2983,6 +2775,18 @@ void EndpointAppPBX::ea_message_port(unsigned long port_id, int message_type, un port_resume(portlist, message_type, param); break; +#if 0 + kann nach dem test gelöscht werden, da eine direkte funktion im join und im mISDN zum austausch der message existiert + /* port assigns bchannel */ + case MESSAGE_BCHANNEL: /* bchannel assignment messafe */ + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received bchannel message %d from port.\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, param->bchannel.type); + /* only one port is expected to be connected to bchannel */ + message = message_forward(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, param); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_IN); + break; +#endif + + default: PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received a wrong message: %d\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, message); } @@ -2991,10 +2795,10 @@ void EndpointAppPBX::ea_message_port(unsigned long port_id, int message_type, un } -/* messages from port +/* messages from join */ -/* call MESSAGE_CRYPT */ -void EndpointAppPBX::call_crypt(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_CRYPT */ +void EndpointAppPBX::join_crypt(struct port_list *portlist, int message_type, union parameter *param) { switch(param->crypt.type) { @@ -3022,10 +2826,10 @@ void EndpointAppPBX::call_crypt(struct port_list *portlist, int message_type, un } } -/* call MESSAGE_INFORMATION */ -void EndpointAppPBX::call_information(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_INFORMATION */ +void EndpointAppPBX::join_information(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; e_overlap = 1; @@ -3034,17 +2838,17 @@ void EndpointAppPBX::call_information(struct port_list *portlist, int message_ty message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_INFORMATION); memcpy(&message->param.information, ¶m->information, sizeof(struct dialing_info)); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); portlist = portlist->next; } } -/* call MESSAGE_FACILITY */ -void EndpointAppPBX::call_facility(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_FACILITY */ +void EndpointAppPBX::join_facility(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; - if (!e_ext.facility) + if (!e_ext.facility && e_ext.number[0]) { return; } @@ -3054,29 +2858,32 @@ void EndpointAppPBX::call_facility(struct port_list *portlist, int message_type, message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_FACILITY); memcpy(&message->param.facilityinfo, ¶m->facilityinfo, sizeof(struct facility_info)); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); portlist = portlist->next; } } -/* call MESSAGE_MORE */ -void EndpointAppPBX::call_overlap(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_MORE */ +void EndpointAppPBX::join_overlap(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; new_state(EPOINT_STATE_IN_OVERLAP); /* own dialtone */ - if (e_call_pattern && e_ext.own_setup) + if (e_join_pattern && e_ext.own_setup) { /* disconnect audio */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_HOLD; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 0; message_put(message); } if (e_action) if (e_action->index == ACTION_OUTDIAL || e_action->index == ACTION_EXTERNAL) { - set_tone(portlist, "dialtone"); + if (e_dialinginfo.id[0]) + set_tone(portlist, "dialing"); + else + set_tone(portlist, "dialtone"); return; } if (e_ext.number[0]) @@ -3085,57 +2892,57 @@ void EndpointAppPBX::call_overlap(struct port_list *portlist, int message_type, set_tone(portlist, "dialtone"); } -/* call MESSAGE_PROCEEDING */ -void EndpointAppPBX::call_proceeding(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_PROCEEDING */ +void EndpointAppPBX::join_proceeding(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; new_state(EPOINT_STATE_IN_PROCEEDING); /* own proceeding tone */ - if (e_call_pattern) + if (e_join_pattern) { /* connect / disconnect audio */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); if (e_ext.own_proceeding) - message->param.channel = CHANNEL_STATE_HOLD; + message->param.audiopath = 0; else - message->param.channel = CHANNEL_STATE_CONNECT; + message->param.audiopath = 1; message_put(message); } -// UCPY(e_call_tone, "proceeding"); +// UCPY(e_join_tone, "proceeding"); if (portlist) { message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_PROCEEDING); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); } set_tone(portlist, "proceeding"); } -/* call MESSAGE_ALERTING */ -void EndpointAppPBX::call_alerting(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_ALERTING */ +void EndpointAppPBX::join_alerting(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; new_state(EPOINT_STATE_IN_ALERTING); /* own alerting tone */ - if (e_call_pattern) + if (e_join_pattern) { /* connect / disconnect audio */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); if (e_ext.own_alerting) - message->param.channel = CHANNEL_STATE_HOLD; + message->param.audiopath = 0; else - message->param.channel = CHANNEL_STATE_CONNECT; + message->param.audiopath = 1; message_put(message); } if (portlist) { message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_ALERTING); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); } if (e_action) if (e_action->index == ACTION_OUTDIAL || e_action->index == ACTION_EXTERNAL) { @@ -3148,70 +2955,66 @@ void EndpointAppPBX::call_alerting(struct port_list *portlist, int message_type, set_tone(portlist, "ringing"); } -/* call MESSAGE_CONNECT */ -void EndpointAppPBX::call_connect(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_CONNECT */ +void EndpointAppPBX::join_connect(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; new_state(EPOINT_STATE_CONNECT); -// UCPY(e_call_tone, ""); +// UCPY(e_join_tone, ""); +// if (e_ext.number[0]) e_dtmf = 1; /* allow dtmf */ + e_powerdialing = 0; memcpy(&e_connectinfo, ¶m->connectinfo, sizeof(e_callerinfo)); if(portlist) { message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_CONNECT); memcpy(&message->param, param, sizeof(union parameter)); - /* screen by interface */ - if (e_connectinfo.interface[0]) - { - /* screen incoming caller id */ - screen(1, e_connectinfo.id, sizeof(e_connectinfo.id), &e_connectinfo.ntype, &e_connectinfo.present); - } - memcpy(&message->param.connnectinfo, e_connectinfo); /* screen clip if prefix is required */ if (e_ext.number[0] && message->param.connectinfo.id[0] && e_ext.clip_prefix[0]) { SCPY(message->param.connectinfo.id, e_ext.clip_prefix); - SCAT(message->param.connectinfo.id, numberrize_callerinfo(e_connectinfo.id,e_connectinfo.ntype)); + SCAT(message->param.connectinfo.id, numberrize_callerinfo(e_connectinfo.id,e_connectinfo.ntype, options.national, options.international)); message->param.connectinfo.ntype = INFO_NTYPE_UNKNOWN; } /* use internal caller id */ - if (e_ext.number[0] && e_connectinfo.intern[0] && (message->param.connectinfo.present!=INFO_PRESENT_RESTRICTED || e_ext.anon_ignore)) + if (e_ext.number[0] && e_connectinfo.extension[0] && (message->param.connectinfo.present!=INFO_PRESENT_RESTRICTED || e_ext.anon_ignore)) { - SCPY(message->param.connectinfo.id, e_connectinfo.intern); + SCPY(message->param.connectinfo.id, e_connectinfo.extension); message->param.connectinfo.ntype = INFO_NTYPE_UNKNOWN; } /* handle restricted caller ids */ - apply_callerid_restriction(e_ext.anon_ignore, portlist->port_type, message->param.connectinfo.id, &message->param.connectinfo.ntype, &message->param.connectinfo.present, &message->param.connectinfo.screen, message->param.connectinfo.voip, message->param.connectinfo.intern, message->param.connectinfo.name); + apply_callerid_restriction(&e_ext, message->param.connectinfo.id, &message->param.connectinfo.ntype, &message->param.connectinfo.present, &message->param.connectinfo.screen, message->param.connectinfo.extension, message->param.connectinfo.name); /* display callerid if desired for extension */ - SCPY(message->param.connectinfo.display, apply_callerid_display(message->param.connectinfo.id, message->param.connectinfo.itype, message->param.connectinfo.ntype, message->param.connectinfo.present, message->param.connectinfo.screen, message->param.connectinfo.voip, message->param.connectinfo.intern, message->param.connectinfo.name)); + SCPY(message->param.connectinfo.display, apply_callerid_display(message->param.connectinfo.id, message->param.connectinfo.itype, message->param.connectinfo.ntype, message->param.connectinfo.present, message->param.connectinfo.screen, message->param.connectinfo.extension, message->param.connectinfo.name)); /* use conp, if enabld */ - if (!e_ext.centrex) - message->param.connectinfo.name[0] = '\0'; +// if (!e_ext.centrex) +// message->param.connectinfo.name[0] = '\0'; /* send connect */ message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); } set_tone(portlist, NULL); - e_call_pattern = 0; - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_CONNECT; + e_join_pattern = 0; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 1; message_put(message); e_start = now; } -/* call MESSAGE_DISCONNECT MESSAGE_RELEASE */ -void EndpointAppPBX::call_disconnect_release(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_DISCONNECT MESSAGE_RELEASE */ +void EndpointAppPBX::join_disconnect_release(int message_type, union parameter *param) { char cause[16]; - struct message *message; + struct lcr_msg *message; + struct port_list *portlist = NULL; /* be sure that we are active */ @@ -3221,7 +3024,7 @@ void EndpointAppPBX::call_disconnect_release(struct port_list *portlist, int mes /* we are powerdialing, if e_powerdialing is set and limit is not exceeded if given */ if (e_powerdialing && ((e_powercount+1)ep_portlist) { - e_call_pattern = 0; + e_join_pattern = 0; } set_tone(ea_endpoint->ep_portlist, "redial"); PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') redialing in %d seconds\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, (int)e_powerdelay); @@ -3238,11 +3041,11 @@ void EndpointAppPBX::call_disconnect_release(struct port_list *portlist, int mes if (e_state==EPOINT_STATE_IN_OVERLAP) { new_state(EPOINT_STATE_IN_PROCEEDING); - if (portlist) + if (ea_endpoint->ep_portlist) { - message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_PROCEEDING); + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_portlist->port_id, EPOINT_TO_PORT, MESSAGE_PROCEEDING); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, ea_endpoint->ep_portlist->port_id, DIRECTION_OUT); } /* caused the error, that the first knock sound was not there */ /* set_tone(portlist, "proceeding"); */ @@ -3250,6 +3053,7 @@ void EndpointAppPBX::call_disconnect_release(struct port_list *portlist, int mes /* send display of powerdialing */ if (e_ext.display_dialing) { + portlist = ea_endpoint->ep_portlist; while (portlist) { message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_NOTIFY); @@ -3258,7 +3062,7 @@ void EndpointAppPBX::call_disconnect_release(struct port_list *portlist, int mes else SPRINT(message->param.notifyinfo.display, "Retry %d", e_powercount); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); portlist = portlist->next; } } @@ -3276,41 +3080,42 @@ void EndpointAppPBX::call_disconnect_release(struct port_list *portlist, int mes || !ea_endpoint->ep_portlist) /* or no port */ { process_hangup(param->disconnectinfo.cause, param->disconnectinfo.location); - release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, param->disconnectinfo.cause); /* RELEASE_TYPE, call, port */ + release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, param->disconnectinfo.cause); /* RELEASE_TYPE, join, port */ return; /* must exit here */ } /* save cause */ - if (!e_call_cause) + if (!e_join_cause) { - e_call_cause = param->disconnectinfo.cause; - e_call_location = param->disconnectinfo.location; + e_join_cause = param->disconnectinfo.cause; + e_join_location = param->disconnectinfo.location; } /* on release we need the audio again! */ if (message_type == MESSAGE_RELEASE) { - e_call_pattern = 0; - ea_endpoint->ep_call_id = 0; + e_join_pattern = 0; + ea_endpoint->ep_join_id = 0; } /* disconnect and select tone */ new_state(EPOINT_STATE_OUT_DISCONNECT); SPRINT(cause, "cause_%02x", param->disconnectinfo.cause); - /* if own_cause, we must release the call */ + /* if own_cause, we must release the join */ if (e_ext.own_cause /* own cause */ - || !e_call_pattern) /* no patterns */ + || !e_join_pattern) /* no patterns */ { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) we have own cause or we have no patterns. (own_cause=%d pattern=%d)\n", ea_endpoint->ep_serial, e_ext.own_cause, e_call_pattern); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) we have own cause or we have no patterns. (own_cause=%d pattern=%d)\n", ea_endpoint->ep_serial, e_ext.own_cause, e_join_pattern); if (message_type != MESSAGE_RELEASE) - release(RELEASE_CALL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, call, port */ - e_call_pattern = 0; + release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL); /* RELEASE_TYPE, join, port */ + e_join_pattern = 0; } else /* else we enable audio */ { - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_CONNECT; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 1; message_put(message); } /* send disconnect message */ SCPY(e_tone, cause); + portlist = ea_endpoint->ep_portlist; while(portlist) { set_tone(portlist, cause); @@ -3319,10 +3124,11 @@ void EndpointAppPBX::call_disconnect_release(struct port_list *portlist, int mes } } -/* call MESSAGE_SETUP */ -void EndpointAppPBX::call_setup(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_SETUP */ +void EndpointAppPBX::join_setup(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; +// struct interface *interface; /* if we already in setup state, we just update the dialing with new digits */ if (e_state == EPOINT_STATE_OUT_SETUP @@ -3330,7 +3136,7 @@ void EndpointAppPBX::call_setup(struct port_list *portlist, int message_type, un { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) we are in setup state, so we do overlap dialing.\n", ea_endpoint->ep_serial); /* if digits changed, what we have already dialed */ - if (!!strncmp(e_dialinginfo.number,param->setup.dialinginfo.number,strlen(e_dialinginfo.number))) + if (!!strncmp(e_dialinginfo.id,param->setup.dialinginfo.id,strlen(e_dialinginfo.id))) { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) we have dialed digits which have been changed or we have a new multidial, so we must redial.\n", ea_endpoint->ep_serial); /* release all ports */ @@ -3340,13 +3146,13 @@ void EndpointAppPBX::call_setup(struct port_list *portlist, int message_type, un message->param.disconnectinfo.cause = CAUSE_NORMAL; /* normal clearing */ message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL; message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); ea_endpoint->free_portlist(portlist); } /* disconnect audio */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_HOLD; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 0; message_put(message); /* get dialing info */ @@ -3363,7 +3169,7 @@ void EndpointAppPBX::call_setup(struct port_list *portlist, int message_type, un /* if we have a pending redial, so we just adjust the dialing number */ if (e_redial) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) redial in progress, so we update the dialing number to %s.\n", ea_endpoint->ep_serial, param->setup.dialinginfo.number); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) redial in progress, so we update the dialing number to %s.\n", ea_endpoint->ep_serial, param->setup.dialinginfo.id); memcpy(&e_dialinginfo, ¶m->setup.dialinginfo, sizeof(e_dialinginfo)); return; } @@ -3378,18 +3184,18 @@ void EndpointAppPBX::call_setup(struct port_list *portlist, int message_type, un if (e_state == EPOINT_STATE_OUT_SETUP) { /* queue digits */ - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) digits '%s' are queued because we didn't receive a setup acknowledge.\n", ea_endpoint->ep_serial, param->setup.dialinginfo.number); - SCAT(e_dialing_queue, param->setup.dialinginfo.number + strlen(e_dialinginfo.number)); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) digits '%s' are queued because we didn't receive a setup acknowledge.\n", ea_endpoint->ep_serial, param->setup.dialinginfo.id); + SCAT(e_dialing_queue, param->setup.dialinginfo.id + strlen(e_dialinginfo.id)); } else { /* get what we have not dialed yet */ - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) we have already dialed '%s', we received '%s', what's left '%s'.\n", ea_endpoint->ep_serial, e_dialinginfo.number, param->setup.dialinginfo.number, param->setup.dialinginfo.number+strlen(e_dialinginfo.number)); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) we have already dialed '%s', we received '%s', what's left '%s'.\n", ea_endpoint->ep_serial, e_dialinginfo.id, param->setup.dialinginfo.id, param->setup.dialinginfo.id+strlen(e_dialinginfo.id)); message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_portlist->port_id, EPOINT_TO_PORT, MESSAGE_INFORMATION); - SCPY(message->param.information.number, param->setup.dialinginfo.number + strlen(e_dialinginfo.number)); + SCPY(message->param.information.id, param->setup.dialinginfo.id + strlen(e_dialinginfo.id)); message->param.information.ntype = INFO_NTYPE_UNKNOWN; message_put(message); - logmessage(message); + logmessage(message->type, &message->param, ea_endpoint->ep_portlist->port_id, DIRECTION_OUT); } /* always store what we have dialed or queued */ memcpy(&e_dialinginfo, ¶m->setup.dialinginfo, sizeof(e_dialinginfo)); @@ -3402,8 +3208,8 @@ void EndpointAppPBX::call_setup(struct port_list *portlist, int message_type, un return; } /* if an internal extension is dialed, copy that number */ - if (param->setup.dialinginfo.itype==INFO_ITYPE_INTERN || param->setup.dialinginfo.itype==INFO_ITYPE_VBOX) - SCPY(e_ext.number, param->setup.dialinginfo.number); + if (param->setup.dialinginfo.itype==INFO_ITYPE_ISDN_EXTENSION || param->setup.dialinginfo.itype==INFO_ITYPE_VBOX) + SCPY(e_ext.number, param->setup.dialinginfo.id); /* if an internal extension is dialed, get extension's info about caller */ if (e_ext.number[0]) { @@ -3419,13 +3225,6 @@ void EndpointAppPBX::call_setup(struct port_list *portlist, int message_type, un memcpy(&e_redirinfo, ¶m->setup.redirinfo, sizeof(e_redirinfo)); memcpy(&e_capainfo, ¶m->setup.capainfo, sizeof(e_capainfo)); - /* screen by interface */ - if (e_callerinfo.interface[0]) - { - /* screen incoming caller id */ - screen(1, e_callerinfo.id, sizeof(e_callerinfo.id), &e_callerinfo.ntype, &e_callerinfo.present); - } - /* process (voice over) data calls */ if (e_ext.datacall && e_capainfo.bearer_capa!=INFO_BC_SPEECH && e_capainfo.bearer_capa!=INFO_BC_AUDIO) { @@ -3441,10 +3240,10 @@ void EndpointAppPBX::call_setup(struct port_list *portlist, int message_type, un out_setup(); } -/* call MESSAGE_mISDNSIGNAL */ -void EndpointAppPBX::call_mISDNsignal(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_mISDNSIGNAL */ +void EndpointAppPBX::join_mISDNsignal(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; while(portlist) { @@ -3455,10 +3254,10 @@ void EndpointAppPBX::call_mISDNsignal(struct port_list *portlist, int message_ty } } -/* call MESSAGE_NOTIFY */ -void EndpointAppPBX::call_notify(struct port_list *portlist, int message_type, union parameter *param) +/* join MESSAGE_NOTIFY */ +void EndpointAppPBX::join_notify(struct port_list *portlist, int message_type, union parameter *param) { - struct message *message; + struct lcr_msg *message; int new_state; if (param->notifyinfo.notify) @@ -3473,10 +3272,13 @@ void EndpointAppPBX::call_notify(struct port_list *portlist, int message_type, u /* unhold if */ if (new_state!=NOTIFY_STATE_HOLD && new_state!=NOTIFY_STATE_SUSPEND) { - while(portlist) + if (!strcmp(e_tone, "hold")) // don't interrupt other tones { - set_tone(portlist, ""); - portlist = portlist->next; + while(portlist) + { + set_tone(portlist, ""); + portlist = portlist->next; + } } portlist = ea_endpoint->ep_portlist; e_hold = 0; @@ -3505,34 +3307,34 @@ void EndpointAppPBX::call_notify(struct port_list *portlist, int message_type, u message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_NOTIFY); memcpy(&message->param.notifyinfo, ¶m->notifyinfo, sizeof(struct notify_info)); /* handle restricted caller ids */ - apply_callerid_restriction(e_ext.anon_ignore, portlist->port_type, message->param.notifyinfo.id, &message->param.notifyinfo.ntype, &message->param.notifyinfo.present, NULL, message->param.notifyinfo.voip, message->param.notifyinfo.intern, 0); + apply_callerid_restriction(&e_ext, message->param.notifyinfo.id, &message->param.notifyinfo.ntype, &message->param.notifyinfo.present, 0, message->param.notifyinfo.extension, NULL); /* display callerid if desired for extension */ - SCPY(message->param.notifyinfo.display, apply_callerid_display(message->param.notifyinfo.id, message->param.notifyinfo.itype, message->param.notifyinfo.ntype, message->param.notifyinfo.present, 0, message->param.notifyinfo.voip, message->param.notifyinfo.intern, NULL)); + SCPY(message->param.notifyinfo.display, apply_callerid_display(message->param.notifyinfo.id, message->param.notifyinfo.itype, message->param.notifyinfo.ntype, message->param.notifyinfo.present, 0, message->param.notifyinfo.extension, NULL)); message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); portlist = portlist->next; } } -/* call sends messages to the endpoint +/* JOIN sends messages to the endpoint */ -void EndpointAppPBX::ea_message_call(unsigned long call_id, int message_type, union parameter *param) +void EndpointAppPBX::ea_message_join(unsigned int join_id, int message_type, union parameter *param) { struct port_list *portlist; - struct message *message; + struct lcr_msg *message; - if (!call_id) + if (!join_id) { - PERROR("EPOINT(%d) error: call == NULL.\n", ea_endpoint->ep_serial); + PERROR("EPOINT(%d) error: JOIN == NULL.\n", ea_endpoint->ep_serial); return; } portlist = ea_endpoint->ep_portlist; /* send MESSAGE_DATA to port */ - if (call_id == ea_endpoint->ep_call_id) + if (message_type == MESSAGE_DATA) { - if (message_type == MESSAGE_DATA) + if (join_id == ea_endpoint->ep_join_id) // still linked with JOIN { /* skip if no port relation */ if (!portlist) @@ -3540,36 +3342,40 @@ void EndpointAppPBX::ea_message_call(unsigned long call_id, int message_type, un /* skip if more than one port relation */ if (portlist->next) return; - /* send audio data to port */ - message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_DATA); - memcpy(&message->param, param, sizeof(union parameter)); - message_put(message); + /* forward audio data to port */ + message_forward(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, param); return; } } -// PDEBUG(DEBUG_EPOINT, "EPOINT(%d) received message %d for active call (terminal %s, caller id %s state=%d)\n", ea_endpoint->ep_serial, message, e_ext.number, e_callerinfo.id, e_state); +// PDEBUG(DEBUG_EPOINT, "EPOINT(%d) received message %d for active JOIN (terminal %s, caller id %s state=%d)\n", ea_endpoint->ep_serial, message, e_ext.number, e_callerinfo.id, e_state); switch(message_type) { - /* CALL SENDS CRYPT message */ + /* JOIN SENDS TONE message */ + case MESSAGE_TONE: + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received tone message: '%d'\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, param->tone.name); + set_tone(portlist, param->tone.name); + break; + + /* JOIN SENDS CRYPT message */ case MESSAGE_CRYPT: PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received crypt message: '%d'\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, param->crypt.type); - call_crypt(portlist, message_type, param); + join_crypt(portlist, message_type, param); break; - /* CALL sends INFORMATION message */ + /* JOIN sends INFORMATION message */ case MESSAGE_INFORMATION: - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received more digits: '%s'\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, param->information.number); - call_information(portlist, message_type, param); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received more digits: '%s'\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, param->information.id); + join_information(portlist, message_type, param); break; - /* CALL sends FACILITY message */ + /* JOIN sends FACILITY message */ case MESSAGE_FACILITY: PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received facility\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); - call_facility(portlist, message_type, param); + join_facility(portlist, message_type, param); break; - /* CALL sends OVERLAP message */ + /* JOIN sends OVERLAP message */ case MESSAGE_OVERLAP: PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received 'more info available'\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); if (e_state!=EPOINT_STATE_IN_SETUP @@ -3578,10 +3384,10 @@ void EndpointAppPBX::ea_message_call(unsigned long call_id, int message_type, un PDEBUG(DEBUG_EPOINT, "EPOINT(%d) ignored because we are not in setup state.\n", ea_endpoint->ep_serial); break; } - call_overlap(portlist, message_type, param); + join_overlap(portlist, message_type, param); break; - /* CALL sends PROCEEDING message */ + /* JOIN sends PROCEEDING message */ case MESSAGE_PROCEEDING: PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s (caller id '%s') received proceeding\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); if(e_state!=EPOINT_STATE_IN_OVERLAP) @@ -3589,10 +3395,10 @@ void EndpointAppPBX::ea_message_call(unsigned long call_id, int message_type, un PDEBUG(DEBUG_EPOINT, "EPOINT(%d) ignored because we are not in setup state.\n", ea_endpoint->ep_serial); break; } - call_proceeding(portlist, message_type, param); + join_proceeding(portlist, message_type, param); break; - /* CALL sends ALERTING message */ + /* JOIN sends ALERTING message */ case MESSAGE_ALERTING: PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received alerting\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); if (e_state!=EPOINT_STATE_IN_OVERLAP @@ -3601,10 +3407,10 @@ void EndpointAppPBX::ea_message_call(unsigned long call_id, int message_type, un PDEBUG(DEBUG_EPOINT, "EPOINT(%d) ignored because we are not in setup or proceeding state.\n", ea_endpoint->ep_serial); break; } - call_alerting(portlist, message_type, param); + join_alerting(portlist, message_type, param); break; - /* CALL sends CONNECT message */ + /* JOIN sends CONNECT message */ case MESSAGE_CONNECT: PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received connect\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); if (e_state!=EPOINT_STATE_IN_OVERLAP @@ -3614,36 +3420,53 @@ void EndpointAppPBX::ea_message_call(unsigned long call_id, int message_type, un PDEBUG(DEBUG_EPOINT, "EPOINT(%d) ignored because we are not in setup, proceeding or alerting state.\n", ea_endpoint->ep_serial); break; } - call_connect(portlist, message_type, param); + join_connect(portlist, message_type, param); break; - /* CALL sends DISCONNECT/RELEASE message */ - case MESSAGE_DISCONNECT: /* call disconnect */ - case MESSAGE_RELEASE: /* call releases */ + /* JOIN sends DISCONNECT/RELEASE message */ + case MESSAGE_DISCONNECT: /* JOIN disconnect */ + case MESSAGE_RELEASE: /* JOIN releases */ PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received %s with cause %d location %d\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, (message_type==MESSAGE_DISCONNECT)?"disconnect":"release", param->disconnectinfo.cause, param->disconnectinfo.location); - call_disconnect_release(portlist, message_type, param); + join_disconnect_release(message_type, param); break; - /* CALL sends SETUP message */ + /* JOIN sends SETUP message */ case MESSAGE_SETUP: - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint received setup from terminal='%s',id='%s' to id='%s' (dialing itype=%d)\n", ea_endpoint->ep_serial, param->setup.callerinfo.intern, param->setup.callerinfo.id, param->setup.dialinginfo.number, param->setup.dialinginfo.itype); - call_setup(portlist, message_type, param); - return; + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint received setup from terminal='%s',id='%s' to id='%s' (dialing itype=%d)\n", ea_endpoint->ep_serial, param->setup.callerinfo.extension, param->setup.callerinfo.id, param->setup.dialinginfo.id, param->setup.dialinginfo.itype); + join_setup(portlist, message_type, param); break; - /* CALL sends special mISDNSIGNAL message */ + /* JOIN sends special mISDNSIGNAL message */ case MESSAGE_mISDNSIGNAL: /* isdn message to port */ PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received mISDNsignal message.\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); - call_mISDNsignal(portlist, message_type, param); + join_mISDNsignal(portlist, message_type, param); break; - /* CALL has pattern available */ +#if 0 + kann nach dem test gelöscht werden, da eine direkte funktion im join und im mISDN zum austausch der message existiert + /* JOIN requests bchannel */ + case MESSAGE_BCHANNEL: /* indicates the need of own bchannel access */ + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received bchannel assignment %d from join.\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, param->bchannel.type); + /* only one port is expected to be connected to bchannel */ + if (!portlist) + break; + if (portlist->next) + break; + e_join_pattern = 1; + SCPY(e_tone, ""); + set_tone(portlist, NULL); + message = message_forward(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, param); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); + break; +#endif + + /* JOIN has pattern available */ case MESSAGE_PATTERN: /* indicating pattern available */ PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received pattern availability.\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); - if (!e_call_pattern) + if (!e_join_pattern) { PDEBUG(DEBUG_EPOINT, "-> pattern becomes available\n"); - e_call_pattern = 1; + e_join_pattern = 1; SCPY(e_tone, ""); while(portlist) { @@ -3651,45 +3474,49 @@ void EndpointAppPBX::ea_message_call(unsigned long call_id, int message_type, un portlist = portlist->next; } /* connect our audio tx and rx (blueboxing should be possibe before connect :)*/ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_CONNECT; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 1; message_put(message); -// /* tell remote epoint to connect audio also, because we like to hear the patterns */ -// message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_REMOTE_AUDIO); -// message->param.channel = CHANNEL_STATE_CONNECT; -// message_put(message); -// patterns are available, remote already connected audio } break; - /* CALL has no pattern available */ + /* JOIN has no pattern available */ case MESSAGE_NOPATTERN: /* indicating no pattern available */ PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received pattern NOT available.\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); - if (e_call_pattern) + if (e_join_pattern) { PDEBUG(DEBUG_EPOINT, "-> pattern becomes unavailable\n"); - e_call_pattern = 0; + e_join_pattern = 0; /* disconnect our audio tx and rx */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_HOLD; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 0; message_put(message); } break; #if 0 - /* CALL (dunno at the moment) */ + /* JOIN (dunno at the moment) */ case MESSAGE_REMOTE_AUDIO: PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received audio remote request.\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = param->channel; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = param->channel; message_put(message); break; #endif - /* CALL sends a notify message */ + /* JOIN sends a notify message */ case MESSAGE_NOTIFY: PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received notify.\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); - call_notify(portlist, message_type, param); + join_notify(portlist, message_type, param); + break; + + /* JOIN wants keypad / dtml */ + case MESSAGE_ENABLEKEYPAD: + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint with terminal '%s' (caller id '%s') received keypad enable request.\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id); + e_enablekeypad = 1; + e_dtmf = 1; + trace_header("ENABLE KEYPAD", DIRECTION_NONE); + end_trace(); break; default: @@ -3698,7 +3525,7 @@ void EndpointAppPBX::ea_message_call(unsigned long call_id, int message_type, un } -/* pick_call will connect the first incoming call found. the endpoint +/* pick_join will connect the first incoming call found. the endpoint * will receivce a MESSAGE_CONNECT. */ int match_list(char *list, char *item) @@ -3736,15 +3563,15 @@ int match_list(char *list, char *item) } } -void EndpointAppPBX::pick_call(char *extensions) +void EndpointAppPBX::pick_join(char *extensions) { - struct message *message; + struct lcr_msg *message; struct port_list *portlist; class Port *port; class EndpointAppPBX *eapp, *found; - class Call *call; - class CallPBX *callpbx; - struct call_relation *relation; + class Join *join; + class JoinPBX *joinpbx; + struct join_relation *relation; int vbox; /* find an endpoint that is ringing internally or vbox with higher priority */ @@ -3796,32 +3623,32 @@ reject: } eapp = found; - if (ea_endpoint->ep_call_id) + if (ea_endpoint->ep_join_id) { - PERROR("EPOINT(%d) we already have a call. SOFTWARE ERROR.\n", ea_endpoint->ep_serial); + PERROR("EPOINT(%d) we already have a join. SOFTWARE ERROR.\n", ea_endpoint->ep_serial); goto reject; } - if (!eapp->ea_endpoint->ep_call_id) + if (!eapp->ea_endpoint->ep_join_id) { - PERROR("EPOINT(%d) ringing endpoint has no call.\n", ea_endpoint->ep_serial); + PERROR("EPOINT(%d) ringing endpoint has no join.\n", ea_endpoint->ep_serial); goto reject; } - call = find_call_id(eapp->ea_endpoint->ep_call_id); - if (!call) + join = find_join_id(eapp->ea_endpoint->ep_join_id); + if (!join) { - PERROR("EPOINT(%d) ringing endpoint's call not found.\n", ea_endpoint->ep_serial); + PERROR("EPOINT(%d) ringing endpoint's join not found.\n", ea_endpoint->ep_serial); goto reject; } - if (callpbx->c_type != CALL_TYPE_PBX) + if (join->j_type != JOIN_TYPE_PBX) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) ringing endpoint's call is not a PBX call, so we must reject.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) ringing endpoint's join is not a PBX join, so we must reject.\n", ea_endpoint->ep_serial); goto reject; } - callpbx = (class CallPBX *)call; - relation = callpbx->c_relation; + joinpbx = (class JoinPBX *)join; + relation = joinpbx->j_relation; if (!relation) { - PERROR("EPOINT(%d) ringing endpoint's call has no relation. SOFTWARE ERROR.\n", ea_endpoint->ep_serial); + PERROR("EPOINT(%d) ringing endpoint's join has no relation. SOFTWARE ERROR.\n", ea_endpoint->ep_serial); goto reject; } while (relation->epoint_id != eapp->ea_endpoint->ep_serial) @@ -3829,7 +3656,7 @@ reject: relation = relation->next; if (!relation) { - PERROR("EPOINT(%d) ringing endpoint's call has no relation to that call. SOFTWARE ERROR.\n", ea_endpoint->ep_serial); + PERROR("EPOINT(%d) ringing endpoint's join has no relation to that join. SOFTWARE ERROR.\n", ea_endpoint->ep_serial); goto reject; } } @@ -3838,22 +3665,22 @@ reject: if (options.deb & DEBUG_EPOINT) { - class Call *debug_c = call_first; + class Join *debug_c = join_first; class Endpoint *debug_e = epoint_first; class Port *debug_p = port_first; - callpbx_debug(callpbx, "EndpointAppPBX::pick_call(before)"); + joinpbx_debug(joinpbx, "EndpointAppPBX::pick_join(before)"); - PDEBUG(DEBUG_EPOINT, "showing all calls:\n"); + PDEBUG(DEBUG_EPOINT, "showing all joins:\n"); while(debug_c) { - PDEBUG(DEBUG_EPOINT, "call=%ld\n", debug_c->c_serial); + PDEBUG(DEBUG_EPOINT, "join=%ld\n", debug_c->j_serial); debug_c = debug_c->next; } PDEBUG(DEBUG_EPOINT, "showing all endpoints:\n"); while(debug_e) { - PDEBUG(DEBUG_EPOINT, "ep=%ld, call=%ld\n", debug_e->ep_serial, debug_e->ep_call_id); + PDEBUG(DEBUG_EPOINT, "ep=%ld, join=%ld\n", debug_e->ep_serial, debug_e->ep_join_id); debug_e = debug_e->next; } PDEBUG(DEBUG_EPOINT, "showing all ports:\n"); @@ -3864,24 +3691,25 @@ reject: } } - /* relink call */ - ea_endpoint->ep_call_id = eapp->ea_endpoint->ep_call_id; /* we get the call */ - relation->epoint_id = ea_endpoint->ep_serial; /* the call gets us */ - eapp->ea_endpoint->ep_call_id = 0; /* the ringing endpoint will get disconnected */ + /* relink join */ + ea_endpoint->ep_join_id = eapp->ea_endpoint->ep_join_id; /* we get the join */ + relation->epoint_id = ea_endpoint->ep_serial; /* the join gets us */ + eapp->ea_endpoint->ep_join_id = 0; /* the ringing endpoint will get disconnected */ /* connnecting our endpoint */ new_state(EPOINT_STATE_CONNECT); - e_dtmf = 1; + if (e_ext.number[0]) + e_dtmf = 1; set_tone(ea_endpoint->ep_portlist, NULL); /* now we send a release to the ringing endpoint */ - message = message_create(ea_endpoint->ep_call_id, eapp->ea_endpoint->ep_serial, CALL_TO_EPOINT, MESSAGE_RELEASE); - message->param.disconnectinfo.cause = 26; /* non selected user clearing */ + message = message_create(ea_endpoint->ep_join_id, eapp->ea_endpoint->ep_serial, JOIN_TO_EPOINT, MESSAGE_RELEASE); + message->param.disconnectinfo.cause = CAUSE_NONSELECTED; /* non selected user clearing */ message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL; message_put(message); - /* we send a connect to the call with our caller id */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CONNECT); + /* we send a connect to the join with our caller id */ + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_CONNECT); SCPY(message->param.connectinfo.id, e_callerinfo.id); message->param.connectinfo.present = e_callerinfo.present; message->param.connectinfo.screen = e_callerinfo.screen; @@ -3897,37 +3725,37 @@ reject: message->param.connectinfo.itype = eapp->e_callerinfo.itype; message->param.connectinfo.ntype = eapp->e_callerinfo.ntype; /* handle restricted caller ids */ - apply_callerid_restriction(e_ext.anon_ignore, ea_endpoint->ep_portlist->port_type, message->param.connectinfo.id, &message->param.connectinfo.ntype, &message->param.connectinfo.present, &message->param.connectinfo.screen, message->param.connectinfo.voip, message->param.connectinfo.intern, message->param.connectinfo.name); + apply_callerid_restriction(&e_ext, message->param.connectinfo.id, &message->param.connectinfo.ntype, &message->param.connectinfo.present, &message->param.connectinfo.screen, message->param.connectinfo.extension, message->param.connectinfo.name); /* display callerid if desired for extension */ - SCPY(message->param.connectinfo.display, apply_callerid_display(message->param.connectinfo.id, message->param.connectinfo.itype, message->param.connectinfo.ntype, message->param.connectinfo.present, message->param.connectinfo.screen, message->param.connectinfo.voip, message->param.connectinfo.intern, message->param.connectinfo.name)); + SCPY(message->param.connectinfo.display, apply_callerid_display(message->param.connectinfo.id, message->param.connectinfo.itype, message->param.connectinfo.ntype, message->param.connectinfo.present, message->param.connectinfo.screen, message->param.connectinfo.extension, message->param.connectinfo.name)); message_put(message); /* we send a connect to the audio path (not for vbox) */ - message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_call_id, EPOINT_TO_CALL, MESSAGE_CHANNEL); - message->param.channel = CHANNEL_STATE_CONNECT; + message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_AUDIOPATH); + message->param.audiopath = 1; message_put(message); /* beeing paranoid, we make call update */ - callpbx->c_mixer = 1; + joinpbx->j_updatebridge = 1; if (options.deb & DEBUG_EPOINT) { - class Call *debug_c = call_first; + class Join *debug_c = join_first; class Endpoint *debug_e = epoint_first; class Port *debug_p = port_first; - callpbx_debug(callpbx, "EndpointAppPBX::pick_call(after)"); + joinpbx_debug(joinpbx, "EndpointAppPBX::pick_join(after)"); - PDEBUG(DEBUG_EPOINT, "showing all calls:\n"); + PDEBUG(DEBUG_EPOINT, "showing all joins:\n"); while(debug_c) { - PDEBUG(DEBUG_EPOINT, "call=%ld\n", debug_c->c_serial); + PDEBUG(DEBUG_EPOINT, "join=%ld\n", debug_c->j_serial); debug_c = debug_c->next; } PDEBUG(DEBUG_EPOINT, "showing all endpoints:\n"); while(debug_e) { - PDEBUG(DEBUG_EPOINT, "ep=%ld, call=%ld\n", debug_e->ep_serial, debug_e->ep_call_id); + PDEBUG(DEBUG_EPOINT, "ep=%ld, join=%ld\n", debug_e->ep_serial, debug_e->ep_join_id); debug_e = debug_e->next; } PDEBUG(DEBUG_EPOINT, "showing all ports:\n"); @@ -3940,32 +3768,32 @@ reject: } -/* join calls (look for a call that is on hold (same isdn interface/terminal)) +/* join calls (look for a join that is on hold (same isdn interface/terminal)) */ -void EndpointAppPBX::join_call(void) +void EndpointAppPBX::join_join(void) { - struct message *message; - struct call_relation *our_relation, *other_relation; - struct call_relation **our_relation_pointer, **other_relation_pointer; - class Call *our_call, *other_call; - class CallPBX *our_callpbx, *other_callpbx; + struct lcr_msg *message; + struct join_relation *our_relation, *other_relation; + struct join_relation **our_relation_pointer, **other_relation_pointer; + class Join *our_join, *other_join; + class JoinPBX *our_joinpbx, *other_joinpbx; class EndpointAppPBX *other_eapp; class Endpoint *temp_epoint; class Port *our_port, *other_port; class Pdss1 *our_pdss1, *other_pdss1; - /* are we a candidate to join a call */ - our_call = find_call_id(ea_endpoint->ep_call_id); - if (!our_call) + /* are we a candidate to join a join */ + our_join = find_join_id(ea_endpoint->ep_join_id); + if (!our_join) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: our call doesn't exist anymore.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: our join doesn't exist anymore.\n", ea_endpoint->ep_serial); return; } - if (our_call->c_type != CALL_TYPE_PBX) + if (our_join->j_type != JOIN_TYPE_PBX) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: call is not a pbx call.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: join is not a pbx join.\n", ea_endpoint->ep_serial); return; } - our_callpbx = (class CallPBX *)our_call; + our_joinpbx = (class JoinPBX *)our_join; if (!ea_endpoint->ep_portlist) { PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: we have no port.\n", ea_endpoint->ep_serial); @@ -3998,10 +3826,10 @@ void EndpointAppPBX::join_call(void) other_eapp = other_eapp->next; continue; } - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) comparing other endpoint candiate: (ep%d) terminal='%s' port=%s call=%d.\n", ea_endpoint->ep_serial, other_eapp->ea_endpoint->ep_serial, other_eapp->e_ext.number, (other_eapp->ea_endpoint->ep_portlist)?"YES":"NO", other_eapp->ea_endpoint->ep_call_id); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) comparing other endpoint candiate: (ep%d) terminal='%s' port=%s join=%d.\n", ea_endpoint->ep_serial, other_eapp->ea_endpoint->ep_serial, other_eapp->e_ext.number, (other_eapp->ea_endpoint->ep_portlist)?"YES":"NO", other_eapp->ea_endpoint->ep_join_id); if (other_eapp->e_ext.number[0] /* has terminal */ && other_eapp->ea_endpoint->ep_portlist /* has port */ - && other_eapp->ea_endpoint->ep_call_id) /* has call */ + && other_eapp->ea_endpoint->ep_join_id) /* has join */ { other_port = find_port_id(other_eapp->ea_endpoint->ep_portlist->port_id); if (other_port) /* port still exists */ @@ -4033,90 +3861,89 @@ void EndpointAppPBX::join_call(void) } PDEBUG(DEBUG_EPOINT, "EPOINT(%d) port on hold found.\n", ea_endpoint->ep_serial); - /* if we have the same call */ - if (other_eapp->ea_endpoint->ep_call_id == ea_endpoint->ep_call_id) + /* if we have the same join */ + if (other_eapp->ea_endpoint->ep_join_id == ea_endpoint->ep_join_id) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: we an the other have the same call.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: we an the other have the same join.\n", ea_endpoint->ep_serial); return; } - other_call = find_call_id(other_eapp->ea_endpoint->ep_call_id); - if (!other_call) + other_join = find_join_id(other_eapp->ea_endpoint->ep_join_id); + if (!other_join) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: other call doesn't exist anymore.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: other join doesn't exist anymore.\n", ea_endpoint->ep_serial); return; } - if (other_call->c_type != CALL_TYPE_PBX) + if (other_join->j_type != JOIN_TYPE_PBX) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: other call is not a pbx call.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: other join is not a pbx join.\n", ea_endpoint->ep_serial); return; } - other_callpbx = (class CallPBX *)other_call; - if (our_callpbx->c_partyline && other_callpbx->c_partyline) + other_joinpbx = (class JoinPBX *)other_join; + if (our_joinpbx->j_partyline && other_joinpbx->j_partyline) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: both calls are partylines.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) cannot join: both joins are partylines.\n", ea_endpoint->ep_serial); return; } - /* remove relation to endpoint for call on hold */ - other_relation = other_callpbx->c_relation; - other_relation_pointer = &other_callpbx->c_relation; + /* remove relation to endpoint for join on hold */ + other_relation = other_joinpbx->j_relation; + other_relation_pointer = &other_joinpbx->j_relation; while(other_relation) { if (other_relation->epoint_id == other_eapp->ea_endpoint->ep_serial) { - /* detach other endpoint on hold */ + /* detach other endpoint on hold */ *other_relation_pointer = other_relation->next; - memset(other_relation, 0, sizeof(struct call_relation)); - free(other_relation); + FREE(other_relation, sizeof(struct join_relation)); cmemuse--; other_relation = *other_relation_pointer; - other_eapp->ea_endpoint->ep_call_id = NULL; + other_eapp->ea_endpoint->ep_join_id = 0; continue; } - /* change call/hold pointer of endpoint to the new call */ + /* change join/hold pointer of endpoint to the new join */ temp_epoint = find_epoint_id(other_relation->epoint_id); if (temp_epoint) { - if (temp_epoint->ep_call_id == other_call->c_serial) - temp_epoint->ep_call_id = our_call->c_serial; + if (temp_epoint->ep_join_id == other_join->j_serial) + temp_epoint->ep_join_id = our_join->j_serial; } other_relation_pointer = &other_relation->next; other_relation = other_relation->next; } - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) endpoint on hold removed, other enpoints on call relinked (to our call).\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) endpoint on hold removed, other enpoints on join relinked (to our join).\n", ea_endpoint->ep_serial); /* join call relations */ - our_relation = our_callpbx->c_relation; - our_relation_pointer = &our_callpbx->c_relation; + our_relation = our_joinpbx->j_relation; + our_relation_pointer = &our_joinpbx->j_relation; while(our_relation) { our_relation_pointer = &our_relation->next; our_relation = our_relation->next; } - *our_relation_pointer = other_callpbx->c_relation; - other_callpbx->c_relation = NULL; + *our_relation_pointer = other_joinpbx->j_relation; + other_joinpbx->j_relation = NULL; PDEBUG(DEBUG_EPOINT, "EPOINT(%d) relations joined.\n", ea_endpoint->ep_serial); /* release endpoint on hold */ - message = message_create(other_callpbx->c_serial, other_eapp->ea_endpoint->ep_serial, CALL_TO_EPOINT, MESSAGE_RELEASE); + message = message_create(other_joinpbx->j_serial, other_eapp->ea_endpoint->ep_serial, JOIN_TO_EPOINT, MESSAGE_RELEASE); message->param.disconnectinfo.cause = CAUSE_NORMAL; /* normal */ message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL; message_put(message); - /* if we are not a partyline, we get partyline state from other call */ - our_callpbx->c_partyline += other_callpbx->c_partyline; + /* if we are not a partyline, we get partyline state from other join */ + our_joinpbx->j_partyline += other_joinpbx->j_partyline; - /* remove empty call */ - delete other_call; - PDEBUG(DEBUG_EPOINT, "EPOINT(%d)d-call completely removed!\n"); + /* remove empty join */ + delete other_join; + PDEBUG(DEBUG_EPOINT, "EPOINT(%d)d-join completely removed!\n"); /* mixer must update */ - our_callpbx->c_mixer = 1; /* update mixer flag */ + our_joinpbx->j_updatebridge = 1; /* update mixer flag */ /* we send a retrieve to that endpoint */ - // mixer will update the hold-state of the call and send it to the endpoints is changes + // mixer will update the hold-state of the join and send it to the endpoints is changes } @@ -4125,9 +3952,9 @@ void EndpointAppPBX::join_call(void) */ int EndpointAppPBX::check_external(char **errstr, class Port **port) { - struct call_relation *relation; - class Call *call; - class CallPBX *callpbx; + struct join_relation *relation; + class Join *join; + class JoinPBX *joinpbx; class Endpoint *epoint; /* some paranoia check */ @@ -4144,37 +3971,37 @@ int EndpointAppPBX::check_external(char **errstr, class Port **port) return(1); } - /* check if we have a call with 2 parties */ - call = find_call_id(ea_endpoint->ep_call_id); - if (!call) + /* check if we have a join with 2 parties */ + join = find_join_id(ea_endpoint->ep_join_id); + if (!join) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) we have currently no call.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) we have currently no join.\n", ea_endpoint->ep_serial); *errstr = "No Call"; return(1); } - if (call->c_type != CALL_TYPE_PBX) + if (join->j_type != JOIN_TYPE_PBX) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) call is nto a pbx call.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) join is not a pbx join.\n", ea_endpoint->ep_serial); *errstr = "No PBX Call"; return(1); } - callpbx = (class CallPBX *)call; - relation = callpbx->c_relation; + joinpbx = (class JoinPBX *)join; + relation = joinpbx->j_relation; if (!relation) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) call has no relation.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) join has no relation.\n", ea_endpoint->ep_serial); *errstr = "No Call"; return(1); } if (!relation->next) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) call has no 2nd relation.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) join has no 2nd relation.\n", ea_endpoint->ep_serial); *errstr = "No Call"; return(1); } if (relation->next->next) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) call has more than two relations.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) join has more than two relations.\n", ea_endpoint->ep_serial); *errstr = "Err: Conference"; return(1); } @@ -4183,7 +4010,7 @@ int EndpointAppPBX::check_external(char **errstr, class Port **port) relation = relation->next; if (relation->epoint_id == ea_endpoint->ep_serial) { - PERROR("EPOINT(%d) SOFTWARE ERROR: both call relations are related to our endpoint.\n", ea_endpoint->ep_serial); + PERROR("EPOINT(%d) SOFTWARE ERROR: both join relations are related to our endpoint.\n", ea_endpoint->ep_serial); *errstr = "Software Error"; return(1); } @@ -4193,7 +4020,7 @@ int EndpointAppPBX::check_external(char **errstr, class Port **port) epoint = find_epoint_id(relation->epoint_id); if (!epoint) { - PDEBUG(DEBUG_EPOINT, "EPOINT(%d) call has no 2nd endpoint.\n", ea_endpoint->ep_serial); + PDEBUG(DEBUG_EPOINT, "EPOINT(%d) join has no 2nd endpoint.\n", ea_endpoint->ep_serial); *errstr = "No Call"; return(1); } @@ -4225,80 +4052,148 @@ int EndpointAppPBX::check_external(char **errstr, class Port **port) return(0); } -void EndpointAppPBX::logmessage(struct message *message) +void EndpointAppPBX::logmessage(int message_type, union parameter *param, unsigned int port_id, int dir) { - class Port *port; - class Pdss1 *pdss1; char *logtext = "unknown"; char buffer[64]; - if (message->flow != EPOINT_TO_PORT) - { - PERROR("EPOINT(%d) message not of correct flow type-\n", ea_endpoint->ep_serial); - return; - } - - switch(message->type) + switch(message_type) { case MESSAGE_SETUP: - trace_header("SETUP", DIRECTION_OUT); - if (message->param.setup.callerinfo.intern[0]) - add_trace("extension", NULL, "%s", message->param.setup.callerinfo.intern); - add_trace("caller id", "number", "%s", numberrize_callerinfo(message->param.setup.callerinfo.id, message->param.setup.callerinfo.ntype)); - if (message->param.setup.callerinfo.present == INFO_PRESENT_RESTRICTED) + trace_header("SETUP", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); + if (param->setup.callerinfo.extension[0]) + add_trace("extension", NULL, "%s", param->setup.callerinfo.extension); + add_trace("caller id", "number", "%s", numberrize_callerinfo(param->setup.callerinfo.id, param->setup.callerinfo.ntype, options.national, options.international)); + switch(param->setup.callerinfo.present) + { + case INFO_PRESENT_RESTRICTED: add_trace("caller id", "present", "restricted"); - if (message->param.setup.redirinfo.number[0]) + break; + case INFO_PRESENT_ALLOWED: + add_trace("caller id", "present", "allowed"); + break; + default: + add_trace("caller id", "present", "not available"); + } + if (param->setup.redirinfo.id[0]) { - add_trace("redir'ing", "number", "%s", numberrize_callerinfo(message->param.setup.redirinfo.id, message->param.setup.redirinfo.ntype)); - if (message->param.setup.redirinfo.present == INFO_PRESENT_RESTRICTED) + add_trace("redir'ing", "number", "%s", numberrize_callerinfo(param->setup.redirinfo.id, param->setup.redirinfo.ntype, options.national, options.international)); + switch(param->setup.redirinfo.present) + { + case INFO_PRESENT_RESTRICTED: add_trace("redir'ing", "present", "restricted"); + break; + case INFO_PRESENT_ALLOWED: + add_trace("redir'ing", "present", "allowed"); + break; + default: + add_trace("redir'ing", "present", "not available"); + } } - if (message->param.setup.dialinginfo.number[0]) - add_trace("dialing", NULL, "%s", message->param.setup.dialinginfo.number); + if (param->setup.dialinginfo.id[0]) + add_trace("dialing", NULL, "%s", param->setup.dialinginfo.id); end_trace(); break; case MESSAGE_OVERLAP: - trace_header("SETUP ACKNOWLEDGE", DIRECTION_OUT); + trace_header("SETUP ACKNOWLEDGE", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); end_trace(); break; case MESSAGE_PROCEEDING: - trace_header("PROCEEDING", DIRECTION_OUT); + trace_header("PROCEEDING", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); end_trace(); break; case MESSAGE_ALERTING: - trace_header("ALERTING", DIRECTION_OUT); + trace_header("ALERTING", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); end_trace(); break; case MESSAGE_CONNECT: - trace_header("CONNECT", DIRECTION_OUT); - if (message->param.connectinfo.intern[0]) - add_trace("extension", NULL, "%s", message->param.connectinfo.intern); - add_trace("connect id", "number", "%s", numberrize_callerinfo(message->param.connectinfo.id, message->param.connectinfo.ntype)); - if (message->param.connectinfo.present == INFO_PRESENT_RESTRICTED) + trace_header("CONNECT", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); + if (param->connectinfo.extension[0]) + add_trace("extension", NULL, "%s", param->connectinfo.extension); + add_trace("connect id", "number", "%s", numberrize_callerinfo(param->connectinfo.id, param->connectinfo.ntype, options.national, options.international)); + switch(param->connectinfo.present) + { + case INFO_PRESENT_RESTRICTED: add_trace("connect id", "present", "restricted"); + break; + case INFO_PRESENT_ALLOWED: + add_trace("connect id", "present", "allowed"); + break; + default: + add_trace("connect id", "present", "not available"); + } end_trace(); break; case MESSAGE_DISCONNECT: - trace_header("DISCONNECT", DIRECTION_OUT); - add_trace("cause", "value", "%d", message->param.disconnectinfo.cause); - add_trace("cause", "location", "%d", message->param.disconnectinfo.location); - end_trace(); - break; - case MESSAGE_RELEASE: - trace_header("RELEASE", DIRECTION_OUT); - add_trace("cause", "value", "%d", message->param.disconnectinfo.cause); - add_trace("cause", "location", "%d", message->param.disconnectinfo.location); + if (message_type == MESSAGE_DISCONNECT) + trace_header("DISCONNECT", dir); + else + trace_header("RELEASE", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); + add_trace("cause", "value", "%d", param->disconnectinfo.cause); + switch(param->disconnectinfo.location) + { + case LOCATION_USER: + add_trace("cause", "location", "0-User"); + break; + case LOCATION_PRIVATE_LOCAL: + add_trace("cause", "location", "1-Local-PBX"); + break; + case LOCATION_PUBLIC_LOCAL: + add_trace("cause", "location", "2-Local-Exchange"); + break; + case LOCATION_TRANSIT: + add_trace("cause", "location", "3-Transit"); + break; + case LOCATION_PUBLIC_REMOTE: + add_trace("cause", "location", "4-Remote-Exchange"); + break; + case LOCATION_PRIVATE_REMOTE: + add_trace("cause", "location", "5-Remote-PBX"); + break; + case LOCATION_INTERNATIONAL: + add_trace("cause", "location", "7-International-Exchange"); + break; + case LOCATION_BEYOND: + add_trace("cause", "location", "10-Beyond-Interworking"); + break; + default: + add_trace("cause", "location", "%d", param->disconnectinfo.location); + } end_trace(); break; case MESSAGE_NOTIFY: - switch(message->param.notifyinfo.notify) + switch(param->notifyinfo.notify) { case 0x00: logtext = "NULL"; @@ -4373,54 +4268,121 @@ void EndpointAppPBX::logmessage(struct message *message) logtext = "CALL_IS_DIVERTING"; break; default: - SPRINT(buffer, "%d", message->param.notifyinfo.notify - 0x80); + SPRINT(buffer, "%d", param->notifyinfo.notify - 0x80); logtext = buffer; } - trace_header("NOTIFY", DIRECTION_OUT); - if (message->param.notifyinfo.notify) + trace_header("NOTIFY", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); + if (param->notifyinfo.notify) add_trace("indicator", NULL, "%s", logtext); - if (message->param.notifyinfo.number[0]) + if (param->notifyinfo.id[0]) { - add_trace("redir'on", "number", "%s", numberrize_callerinfo(message->param.notifyinfo.id, message->param.notifyinfo.ntype)); - if (message->param.notifyinfo.present == INFO_PRESENT_RESTRICTED) + add_trace("redir'on", "number", "%s", numberrize_callerinfo(param->notifyinfo.id, param->notifyinfo.ntype, options.national, options.international)); + switch(param->notifyinfo.present) + { + case INFO_PRESENT_RESTRICTED: add_trace("redir'on", "present", "restricted"); + break; + case INFO_PRESENT_ALLOWED: + add_trace("redir'on", "present", "allowed"); + break; + default: + add_trace("redir'on", "present", "not available"); + } } - if (message->param.notifyinfo.display[0]) - add_trace("display", NULL, "%s", message->param.notifyinfo.display); + if (param->notifyinfo.display[0]) + add_trace("display", NULL, "%s", param->notifyinfo.display); end_trace(); break; case MESSAGE_INFORMATION: - trace_header("INFORMATION", DIRECTION_OUT); - add_trace("dialing", NULL, "%s", message->param.information.number); + trace_header("INFORMATION", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); + add_trace("dialing", NULL, "%s", param->information.id); end_trace(); break; case MESSAGE_FACILITY: - trace_header("FACILITY", DIRECTION_OUT); + trace_header("FACILITY", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); end_trace(); break; case MESSAGE_TONE: - trace_header("TONE", DIRECTION_OUT); - if (message->param.tone.name[0]) + trace_header("TONE", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); + if (param->tone.name[0]) { - add_trace("directory", NULL, "%s", message->param.tone.dir[0]?message->param.tone.dir:"default"); - add_trace("name", NULL, "%s", message->param.tone.name); + add_trace("directory", NULL, "%s", param->tone.dir[0]?param->tone.dir:"default"); + add_trace("name", NULL, "%s", param->tone.name); } else add_trace("off", NULL, NULL); end_trace(); break; + case MESSAGE_SUSPEND: + case MESSAGE_RESUME: + if (message_type == MESSAGE_SUSPEND) + trace_header("SUSPEND", dir); + else + trace_header("RESUME", dir); + if (dir == DIRECTION_OUT) + add_trace("to", NULL, "CH(%lu)", port_id); + if (dir == DIRECTION_IN) + add_trace("from", NULL, "CH(%lu)", port_id); + if (param->parkinfo.len) + add_trace("length", NULL, "%d", param->parkinfo.len); + end_trace(); + break; + +#if 0 + case MESSAGE_BCHANNEL: + trace_header("BCHANNEL", dir); + switch(param->bchannel.type) + { + case BCHANNEL_REQUEST: + add_trace("type", NULL, "request"); + break; + case BCHANNEL_ASSIGN: + add_trace("type", NULL, "assign"); + break; + case BCHANNEL_ASSIGN_ACK: + add_trace("type", NULL, "assign_ack"); + break; + case BCHANNEL_REMOVE: + add_trace("type", NULL, "remove"); + break; + case BCHANNEL_REMOVE_ACK: + add_trace("type", NULL, "remove_ack"); + break; + } + if (param->bchannel.addr) + add_trace("address", NULL, "%x", param->bchannel.addr); + end_trace(); + break; +#endif + default: - PERROR("EPOINT(%d) message not of correct type (%d)\n", ea_endpoint->ep_serial, message->type); + PERROR("EPOINT(%d) message not of correct type (%d)\n", ea_endpoint->ep_serial, message_type); } } void EndpointAppPBX::message_disconnect_port(struct port_list *portlist, int cause, int location, char *display) { - struct message *message; + struct lcr_msg *message; if (!portlist) return; @@ -4445,5 +4407,7 @@ void EndpointAppPBX::message_disconnect_port(struct port_list *portlist, int cau SCPY(message->param.notifyinfo.display, get_isdn_cause(cause, location, e_ext.display_cause)); } message_put(message); - logmessage(message); + logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT); } + +