From 5a22e57828617abc14e27814ee918cc63b96fd46 Mon Sep 17 00:00:00 2001 From: Super User Date: Tue, 17 Jul 2007 19:28:09 +0200 Subject: alpha phase is open, this means: it compiles! it runs! it calls without known bug yet! comments to jolly@eversberg.eu --- joinpbx.cpp | 967 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 967 insertions(+) create mode 100644 joinpbx.cpp (limited to 'joinpbx.cpp') diff --git a/joinpbx.cpp b/joinpbx.cpp new file mode 100644 index 0000000..9f8f533 --- /dev/null +++ b/joinpbx.cpp @@ -0,0 +1,967 @@ +/*****************************************************************************\ +** ** +** Linux Call Router ** +** ** +**---------------------------------------------------------------------------** +** Copyright: Andreas Eversberg ** +** ** +** join functions ** +** ** +\*****************************************************************************/ + +#include +#include +#include +#include +#include +#include +#include +#include +#include "main.h" +#define __u8 unsigned char +#define __u16 unsigned short +#define __u32 unsigned long +#include "linux/isdnif.h" + + +/* notify endpoint about state change (if any) */ +static int notify_state_change(int join_id, int epoint_id, int old_state, int new_state) +{ + int notify_off = 0, notify_on = 0; + struct message *message; + + if (old_state == new_state) + return(old_state); + + switch(old_state) + { + case NOTIFY_STATE_ACTIVE: + switch(new_state) + { + case NOTIFY_STATE_HOLD: + notify_on = INFO_NOTIFY_REMOTE_HOLD; + break; + case NOTIFY_STATE_SUSPEND: + notify_on = INFO_NOTIFY_USER_SUSPENDED; + break; + case NOTIFY_STATE_CONFERENCE: + notify_on = INFO_NOTIFY_CONFERENCE_ESTABLISHED; + break; + } + break; + + case NOTIFY_STATE_HOLD: + switch(new_state) + { + case NOTIFY_STATE_ACTIVE: + notify_off = INFO_NOTIFY_REMOTE_RETRIEVAL; + break; + case NOTIFY_STATE_SUSPEND: + notify_off = INFO_NOTIFY_REMOTE_RETRIEVAL; + notify_on = INFO_NOTIFY_USER_SUSPENDED; + break; + case NOTIFY_STATE_CONFERENCE: + notify_off = INFO_NOTIFY_REMOTE_RETRIEVAL; + notify_on = INFO_NOTIFY_CONFERENCE_ESTABLISHED; + break; + } + break; + + case NOTIFY_STATE_SUSPEND: + switch(new_state) + { + case NOTIFY_STATE_ACTIVE: + notify_off = INFO_NOTIFY_USER_RESUMED; + break; + case NOTIFY_STATE_HOLD: + notify_off = INFO_NOTIFY_USER_RESUMED; + notify_on = INFO_NOTIFY_REMOTE_HOLD; + break; + case NOTIFY_STATE_CONFERENCE: + notify_off = INFO_NOTIFY_USER_RESUMED; + notify_on = INFO_NOTIFY_CONFERENCE_ESTABLISHED; + break; + } + break; + + case NOTIFY_STATE_CONFERENCE: + switch(new_state) + { + case NOTIFY_STATE_ACTIVE: + notify_off = INFO_NOTIFY_CONFERENCE_DISCONNECTED; + break; + case NOTIFY_STATE_HOLD: + notify_off = INFO_NOTIFY_CONFERENCE_DISCONNECTED; + notify_on = INFO_NOTIFY_REMOTE_HOLD; + break; + case NOTIFY_STATE_SUSPEND: + notify_off = INFO_NOTIFY_CONFERENCE_DISCONNECTED; + notify_on = INFO_NOTIFY_USER_SUSPENDED; + break; + } + break; + } + + if (join_id && notify_off) + { + message = message_create(join_id, epoint_id, JOIN_TO_EPOINT, MESSAGE_NOTIFY); + message->param.notifyinfo.notify = notify_off; + message_put(message); + } + + if (join_id && notify_on) + { + message = message_create(join_id, epoint_id, JOIN_TO_EPOINT, MESSAGE_NOTIFY); + message->param.notifyinfo.notify = notify_on; + message_put(message); + } + + return(new_state); +} + + +/* debug function for join */ +void joinpbx_debug(class JoinPBX *joinpbx, char *function) +{ + struct join_relation *relation; + struct port_list *portlist; + class Endpoint *epoint; + class Port *port; + char buffer[512]; + + if (!(options.deb & DEBUG_JOIN)) + return; + + PDEBUG(DEBUG_JOIN, "join(%d) start (called from %s)\n", joinpbx->c_serial, function); + + relation = joinpbx->c_relation; + + if (!relation) + PDEBUG(DEBUG_JOIN, "join has no relations\n"); + while(relation) + { + epoint = find_epoint_id(relation->epoint_id); + if (!epoint) + { + PDEBUG(DEBUG_JOIN, "warning: relations epoint id=%ld doesn't exists!\n", relation->epoint_id); + relation = relation->next; + continue; + } + buffer[0] = '\0'; + UPRINT(strchr(buffer,0), "*** ep%ld", relation->epoint_id); + UPRINT(strchr(buffer,0), " ifs="); + portlist = epoint->ep_portlist; + while(portlist) + { + port = find_port_id(portlist->port_id); + if (port) + UPRINT(strchr(buffer,0), "%s,", port->p_name); + else + UPRINT(strchr(buffer,0), ",", portlist->port_id); + portlist = portlist->next; + } +// UPRINT(strchr(buffer,0), " endpoint=%d on=%s hold=%s", epoint->ep_serial, (epoint->ep_join_id==joinpbx->c_serial)?"yes":"no", (epoint->get_hold_id()==joinpbx->c_serial)?"yes":"no"); + UPRINT(strchr(buffer,0), " endpoint=%d on=%s", epoint->ep_serial, (epoint->ep_join_id==joinpbx->c_serial)?"yes":"no"); + switch(relation->type) + { + case RELATION_TYPE_CALLING: + UPRINT(strchr(buffer,0), " type=CALLING"); + break; + case RELATION_TYPE_SETUP: + UPRINT(strchr(buffer,0), " type=SETUP"); + break; + case RELATION_TYPE_CONNECT: + UPRINT(strchr(buffer,0), " type=CONNECT"); + break; + default: + UPRINT(strchr(buffer,0), " type=unknown"); + break; + } + switch(relation->channel_state) + { + case CHANNEL_STATE_CONNECT: + UPRINT(strchr(buffer,0), " channel=CONNECT"); + break; + case CHANNEL_STATE_HOLD: + UPRINT(strchr(buffer,0), " channel=HOLD"); + break; + default: + UPRINT(strchr(buffer,0), " channel=unknown"); + break; + } + switch(relation->tx_state) + { + case NOTIFY_STATE_ACTIVE: + UPRINT(strchr(buffer,0), " tx_state=ACTIVE"); + break; + case NOTIFY_STATE_HOLD: + UPRINT(strchr(buffer,0), " tx_state=HOLD"); + break; + case NOTIFY_STATE_SUSPEND: + UPRINT(strchr(buffer,0), " tx_state=SUSPEND"); + break; + case NOTIFY_STATE_CONFERENCE: + UPRINT(strchr(buffer,0), " tx_state=CONFERENCE"); + break; + default: + UPRINT(strchr(buffer,0), " tx_state=unknown"); + break; + } + switch(relation->rx_state) + { + case NOTIFY_STATE_ACTIVE: + UPRINT(strchr(buffer,0), " rx_state=ACTIVE"); + break; + case NOTIFY_STATE_HOLD: + UPRINT(strchr(buffer,0), " rx_state=HOLD"); + break; + case NOTIFY_STATE_SUSPEND: + UPRINT(strchr(buffer,0), " rx_state=SUSPEND"); + break; + case NOTIFY_STATE_CONFERENCE: + UPRINT(strchr(buffer,0), " rx_state=CONFERENCE"); + break; + default: + UPRINT(strchr(buffer,0), " rx_state=unknown"); + break; + } + PDEBUG(DEBUG_JOIN, "%s\n", buffer); + relation = relation->next; + } + + PDEBUG(DEBUG_JOIN, "end\n"); +} + + +/* + * constructor for a new join + * the join will have a relation to the calling endpoint + */ +JoinPBX::JoinPBX(class Endpoint *epoint) : Join() +{ + struct join_relation *relation; +// char filename[256]; + + if (!epoint) + FATAL("epoint is NULL.\n"); + + PDEBUG(DEBUG_JOIN, "creating new join and connecting it to the endpoint.\n"); + + c_type = JOIN_TYPE_PBX; + c_caller[0] = '\0'; + c_caller_id[0] = '\0'; + c_dialed[0] = '\0'; + c_todial[0] = '\0'; + c_pid = getpid(); + c_updatebridge = 0; + c_partyline = 0; + c_multicause = CAUSE_NOUSER; + c_multilocation = LOCATION_PRIVATE_LOCAL; + + /* initialize a relation only to the calling interface */ + relation = c_relation = (struct join_relation *)MALLOC(sizeof(struct join_relation)); + cmemuse++; + relation->type = RELATION_TYPE_CALLING; + relation->channel_state = CHANNEL_STATE_HOLD; /* audio is assumed on a new join */ + relation->tx_state = NOTIFY_STATE_ACTIVE; /* new joins always assumed to be active */ + relation->rx_state = NOTIFY_STATE_ACTIVE; /* new joins always assumed to be active */ + relation->epoint_id = epoint->ep_serial; + + + if (options.deb & DEBUG_JOIN) + joinpbx_debug(this, "JoinPBX::Constructor(new join)"); +} + + +/* + * join descructor + */ +JoinPBX::~JoinPBX() +{ + struct join_relation *relation, *rtemp; + + relation = c_relation; + while(relation) + { + rtemp = relation->next; + FREE(relation, sizeof(struct join_relation)); + cmemuse--; + relation = rtemp; + } +} + + +/* bridge sets the audio flow of all bchannels assiociated to 'this' join + * also it changes and notifies active/hold/conference states + */ +void JoinPBX::bridge(void) +{ + struct join_relation *relation; + struct message *message; + int numconnect = 0, relations = 0; + class Endpoint *epoint; + struct port_list *portlist; + class Port *port; +#ifdef DEBUG_COREBRIDGE + int allmISDN = 0; // never set for debug purpose +#else + int allmISDN = 1; // set until a non-mISDN relation is found +#endif + + relation = c_relation; + while(relation) + { + /* count all relations */ + relations++; + + /* check for relation's objects */ + epoint = find_epoint_id(relation->epoint_id); + if (!epoint) + { + PERROR("software error: relation without existing endpoints.\n"); + relation = relation->next; + continue; + } + portlist = epoint->ep_portlist; + if (!portlist) + { + PDEBUG(DEBUG_JOIN, "join%d ignoring relation without port object.\n", c_serial); +//#warning testing: keep on hold until single audio stream available + relation->channel_state = CHANNEL_STATE_HOLD; + relation = relation->next; + continue; + } + if (portlist->next) + { + PDEBUG(DEBUG_JOIN, "join%d ignoring relation with ep%d due to port_list.\n", c_serial, epoint->ep_serial); +//#warning testing: keep on hold until single audio stream available + relation->channel_state = CHANNEL_STATE_HOLD; + relation = relation->next; + continue; + } + port = find_port_id(portlist->port_id); + if (!port) + { + PDEBUG(DEBUG_JOIN, "join%d ignoring relation without existing port object.\n", c_serial); + relation = relation->next; + continue; + } + if ((port->p_type&PORT_CLASS_MASK)!=PORT_CLASS_mISDN) + { + PDEBUG(DEBUG_JOIN, "join%d ignoring relation ep%d because it's port is not mISDN.\n", c_serial, epoint->ep_serial); + if (allmISDN) + { + PDEBUG(DEBUG_JOIN, "join%d not all endpoints are mISDN.\n", c_serial); + allmISDN = 0; + } + relation = relation->next; + continue; + } + + relation = relation->next; + } + + PDEBUG(DEBUG_JOIN, "join%d members=%d %s\n", c_serial, relations, (allmISDN)?"(all are mISDN-members)":"(not all are mISDN-members)"); + /* we notify all relations about rxdata. */ + relation = c_relation; + while(relation) + { + /* count connected relations */ + if ((relation->channel_state == CHANNEL_STATE_CONNECT) + && (relation->rx_state != NOTIFY_STATE_SUSPEND) + && (relation->rx_state != NOTIFY_STATE_HOLD)) + numconnect ++; + + /* remove unconnected parties from conference, also remove remotely disconnected parties so conference will not be disturbed. */ + if (relation->channel_state == CHANNEL_STATE_CONNECT + && relation->rx_state != NOTIFY_STATE_HOLD + && relation->rx_state != NOTIFY_STATE_SUSPEND + && relations>1 // no conf with one member + && allmISDN) // no conf if any member is not mISDN + { + message = message_create(c_serial, relation->epoint_id, JOIN_TO_EPOINT, MESSAGE_mISDNSIGNAL); + message->param.mISDNsignal.message = mISDNSIGNAL_CONF; + message->param.mISDNsignal.conf = c_serial<<16 | c_pid; + PDEBUG(DEBUG_JOIN, "join%d EP%d +on+ id: 0x%08x\n", c_serial, relation->epoint_id, message->param.mISDNsignal.conf); + message_put(message); + } else + { + message = message_create(c_serial, relation->epoint_id, JOIN_TO_EPOINT, MESSAGE_mISDNSIGNAL); + message->param.mISDNsignal.message = mISDNSIGNAL_CONF; + message->param.mISDNsignal.conf = 0; + PDEBUG(DEBUG_JOIN, "join%d EP%d +off+ id: 0x%08x\n", c_serial, relation->epoint_id, message->param.mISDNsignal.conf); + message_put(message); + } + + /* + * request data from endpoint/port if: + * - two relations + * - any without mISDN + * in this case we bridge + */ + message = message_create(c_serial, relation->epoint_id, JOIN_TO_EPOINT, MESSAGE_mISDNSIGNAL); + message->param.mISDNsignal.message = mISDNSIGNAL_JOINDATA; + message->param.mISDNsignal.joindata = (relations==2 && !allmISDN); + PDEBUG(DEBUG_JOIN, "join%d EP%d set joindata=%d\n", c_serial, relation->epoint_id, message->param.mISDNsignal.joindata); + message_put(message); + + relation = relation->next; + } + + /* two people just exchange their states */ + if (relations==2 && !c_partyline) + { + PDEBUG(DEBUG_JOIN, "join%d 2 relations / no partyline\n", c_serial); + relation = c_relation; + relation->tx_state = notify_state_change(c_serial, relation->epoint_id, relation->tx_state, relation->next->rx_state); + relation->next->tx_state = notify_state_change(c_serial, relation->next->epoint_id, relation->next->tx_state, relation->rx_state); + } else + /* one member in a join, so we put her on hold */ + if (relations==1 || numconnect==1) + { + PDEBUG(DEBUG_JOIN, "join%d 1 member or only 1 connected, put on hold\n"); + relation = c_relation; + while(relation) + { + if ((relation->channel_state == CHANNEL_STATE_CONNECT) + && (relation->rx_state != NOTIFY_STATE_SUSPEND) + && (relation->rx_state != NOTIFY_STATE_HOLD)) + relation->tx_state = notify_state_change(c_serial, relation->epoint_id, relation->tx_state, NOTIFY_STATE_HOLD); + relation = relation->next; + } + } else + /* if conference/partyline or (more than two members and more than one is connected), so we set conference state */ + { + PDEBUG(DEBUG_JOIN, "join%d %d members, %d connected, signal conference\n", relations, numconnect); + relation = c_relation; + while(relation) + { + if ((relation->channel_state == CHANNEL_STATE_CONNECT) + && (relation->rx_state != NOTIFY_STATE_SUSPEND) + && (relation->rx_state != NOTIFY_STATE_HOLD)) + relation->tx_state = notify_state_change(c_serial, relation->epoint_id, relation->tx_state, NOTIFY_STATE_CONFERENCE); + relation = relation->next; + } + } +} + +/* + * bridging is only possible with two connected endpoints + */ +void JoinPBX::bridge_data(unsigned long epoint_from, struct join_relation *relation_from, union parameter *param) +{ + struct join_relation *relation_to; + + /* if we are alone */ + if (!c_relation->next) + return; + + /* if we are more than two */ + if (c_relation->next->next) + return; + + /* skip if source endpoint has NOT audio mode CONNECT */ + if (relation_from->channel_state != CHANNEL_STATE_CONNECT) + return; + + /* get destination relation */ + relation_to = c_relation; + if (relation_to == relation_from) + { + /* oops, we are the first, so destination is: */ + relation_to = relation_to->next; + } + + /* skip if destination endpoint has NOT audio mode CONNECT */ + if (relation_to->channel_state != CHANNEL_STATE_CONNECT) + return; + + /* now we may send our data to the endpoint where it + * will be delivered to the port + */ +//printf("from %d, to %d\n", relation_from->epoint_id, relation_to->epoint_id); + message_forward(c_serial, relation_to->epoint_id, JOIN_TO_EPOINT, param); +} + +/* release join from endpoint + * if the join has two relations, all relations are freed and the join will be + * destroyed + * on outgoing relations, the cause is collected, if not connected + * returns if join has been destroyed + */ +int JoinPBX::release(struct join_relation *relation, int location, int cause) +{ + struct join_relation *reltemp, **relationpointer; + struct message *message; + class Join *join; + int destroy = 0; + + /* remove from bridge */ + if (relation->channel_state != CHANNEL_STATE_HOLD) + { + relation->channel_state = CHANNEL_STATE_HOLD; + c_updatebridge = 1; /* update bridge flag */ + // note: if join is not released, bridge must be updated + } + + /* detach given interface */ + reltemp = c_relation; + relationpointer = &c_relation; + while(reltemp) + { + /* endpoint of function call */ + if (relation == reltemp) + break; + relationpointer = &reltemp->next; + reltemp = reltemp->next; + } + if (!reltemp) + FATAL("relation not in list of our relations. this must not happen.\n"); + *relationpointer = reltemp->next; + FREE(reltemp, sizeof(struct join_relation)); + cmemuse--; + relation = reltemp = NULL; // just in case of reuse fault; + + /* if no more relation */ + if (!c_relation) + { + PDEBUG(DEBUG_JOIN, "join is completely removed.\n"); + /* there is no more endpoint related to the join */ + destroy = 1; + delete this; + // end of join object! + PDEBUG(DEBUG_JOIN, "join completely removed!\n"); + } else + /* if join is a party line */ + if (c_partyline) + { + PDEBUG(DEBUG_JOIN, "join is a conference room, so we keep it alive until the last party left.\n"); + } else + /* if only one relation left */ + if (!c_relation->next) + { + PDEBUG(DEBUG_JOIN, "join has one relation left, so we send it a release with the given cause %d.\n", cause); + message = message_create(c_serial, c_relation->epoint_id, JOIN_TO_EPOINT, MESSAGE_RELEASE); + message->param.disconnectinfo.cause = cause; + message->param.disconnectinfo.location = location; + message_put(message); + destroy = 1; + delete this; + // end of join object! + PDEBUG(DEBUG_JOIN, "join completely removed!\n"); + } + + join = join_first; + while(join) + { + if (options.deb & DEBUG_JOIN && join->c_type==JOIN_TYPE_PBX) + joinpbx_debug((class JoinPBX *)join, "join_release{all joins left}"); + join = join->next; + } + PDEBUG(DEBUG_JOIN, "join_release(): ended.\n"); + return(destroy); +} + +/* count number of relations in a join + */ +int joinpbx_countrelations(unsigned long join_id) +{ + struct join_relation *relation; + int i; + class Join *join; + class JoinPBX *joinpbx; + + join = find_join_id(join_id); + + if (!join) + return(0); + + if (join->c_type != JOIN_TYPE_ASTERISK) + return(2); + + if (join->c_type != JOIN_TYPE_PBX) + return(0); + joinpbx = (class JoinPBX *)join; + + i = 0; + relation = joinpbx->c_relation; + while(relation) + { + i++; + relation = relation->next; + } + + return(i); +} + +void JoinPBX::remove_relation(struct join_relation *relation) +{ + struct join_relation *temp, **tempp; + + if (!relation) + return; + + temp = c_relation; + tempp = &c_relation; + while(temp) + { + if (temp == relation) + break; + tempp = &temp->next; + temp = temp->next; + } + if (!temp) + { + PERROR("relation not in join.\n"); + return; + } + + PDEBUG(DEBUG_JOIN, "removing relation.\n"); + *tempp = relation->next; + FREE(temp, sizeof(struct join_relation)); + cmemuse--; +} + + +struct join_relation *JoinPBX::add_relation(void) +{ + struct join_relation *relation; + + if (!c_relation) + { + PERROR("there is no first relation to this join\n"); + return(NULL); + } + relation = c_relation; + while(relation->next) + relation = relation->next; + + relation->next = (struct join_relation *)MALLOC(sizeof(struct join_relation)); + cmemuse++; + /* the record pointer is set at the first time the data is received for the relation */ + +// if (options.deb & DEBUG_JOIN) +// joinpbx_debug(join, "add_relation"); + return(relation->next); +} + +/* epoint sends a message to a join + * + */ +void JoinPBX::message_epoint(unsigned long epoint_id, int message_type, union parameter *param) +{ + class Join *cl; + struct join_relation *relation, *reltemp; + int num; + int new_state; + struct message *message; +// int size, writesize, oldpointer; + char *number, *numbers; + + if (!epoint_id) + { + PERROR("software error, epoint == NULL\n"); + return; + } + +// if (options.deb & DEBUG_JOIN) +// { +// PDEBUG(DEBUG_JOIN, "message %d received from ep%d.\n", message, epoint->ep_serial); +// joinpbx_debug(join,"Join::message_epoint"); +// } + if (options.deb & DEBUG_JOIN) + { + if (message_type != MESSAGE_DATA) + { + cl = join_first; + while(cl) + { + if (cl->c_type == JOIN_TYPE_PBX) + joinpbx_debug((class JoinPBX *)cl, "Join::message_epoint{all joins before processing}"); + cl = cl->next; + } + } + } + + /* check relation */ + relation = c_relation; + while(relation) + { + if (relation->epoint_id == epoint_id) + break; + relation = relation->next; + } + if (!relation) + { + PDEBUG(DEBUG_JOIN, "no relation back to the endpoint found, ignoring (join=%d, endpoint=%d)\n", c_serial, epoint_id); + return; + } + + switch(message_type) + { + /* process channel message */ + case MESSAGE_CHANNEL: + PDEBUG(DEBUG_JOIN, "join received channel message: %d.\n", param->channel); + if (relation->channel_state != param->channel) + { + relation->channel_state = param->channel; + c_updatebridge = 1; /* update bridge flag */ + if (options.deb & DEBUG_JOIN) + joinpbx_debug(this, "Join::message_epoint{after setting new channel state}"); + } + return; + + /* track notify */ + case MESSAGE_NOTIFY: + switch(param->notifyinfo.notify) + { + case INFO_NOTIFY_USER_SUSPENDED: + case INFO_NOTIFY_USER_RESUMED: + case INFO_NOTIFY_REMOTE_HOLD: + case INFO_NOTIFY_REMOTE_RETRIEVAL: + case INFO_NOTIFY_CONFERENCE_ESTABLISHED: + case INFO_NOTIFY_CONFERENCE_DISCONNECTED: + new_state = track_notify(relation->rx_state, param->notifyinfo.notify); + if (new_state != relation->rx_state) + { + relation->rx_state = new_state; + c_updatebridge = 1; + if (options.deb & DEBUG_JOIN) + joinpbx_debug(this, "Join::message_epoint{after setting new rx state}"); + } + break; + + default: + /* send notification to all other endpoints */ + reltemp = c_relation; + while(reltemp) + { + if (reltemp->epoint_id!=epoint_id && reltemp->epoint_id) + { + message = message_create(c_serial, reltemp->epoint_id, JOIN_TO_EPOINT, MESSAGE_NOTIFY); + memcpy(&message->param, param, sizeof(union parameter)); + message_put(message); + } + reltemp = reltemp->next; + } + } + return; + + /* audio data */ + case MESSAGE_DATA: + /* now send audio data to the other endpoint */ + bridge_data(epoint_id, relation, param); + return; + + /* relations sends a connect */ + case MESSAGE_CONNECT: + /* outgoing setup type becomes connected */ + if (relation->type == RELATION_TYPE_SETUP) + relation->type = RELATION_TYPE_CONNECT; + /* release other relations in setup state */ + release_again: + relation = c_relation; + while(relation) + { + if (relation->type == RELATION_TYPE_SETUP) + { + if (release(relation, LOCATION_PRIVATE_LOCAL, CAUSE_NONSELECTED)) + return; // must return, because join IS destroyed + goto release_again; + } + relation = relation->next; + } + break; // continue with our message + + /* release is sent by endpoint */ + case MESSAGE_RELEASE: + if (relation->type == RELATION_TYPE_SETUP) + { + /* collect cause and send collected cause */ + collect_cause(&c_multicause, &c_multilocation, param->disconnectinfo.cause, param->disconnectinfo.location); + release(relation, c_multilocation, c_multicause); + } else + { + /* send current cause */ + release(relation, param->disconnectinfo.location, param->disconnectinfo.cause); + } + return; // must return, because join may be destroyed + } + + /* process party line */ + if (message_type == MESSAGE_SETUP) if (param->setup.partyline) + { + PDEBUG(DEBUG_JOIN, "respsone with connect in partyline mode.\n"); + c_partyline = param->setup.partyline; + message = message_create(c_serial, epoint_id, JOIN_TO_EPOINT, MESSAGE_CONNECT); + message->param.setup.partyline = c_partyline; + message_put(message); + c_updatebridge = 1; /* update bridge flag */ + } + if (c_partyline) + { + if (message_type == MESSAGE_DISCONNECT) + { + PDEBUG(DEBUG_JOIN, "releasing after receiving disconnect, because join in partyline mode.\n"); + message = message_create(c_serial, epoint_id, JOIN_TO_EPOINT, MESSAGE_RELEASE); + message->param.disconnectinfo.cause = CAUSE_NORMAL; + message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL; + message_put(message); + return; + } + } + if (c_partyline) + { + PDEBUG(DEBUG_JOIN, "ignoring message, because join in partyline mode.\n"); + return; + } + + /* count relations */ + num=joinpbx_countrelations(c_serial); + + /* check number of relations */ + if (num > 2) + { + PDEBUG(DEBUG_JOIN, "join has more than two relations so there is no need to send a message.\n"); + return; + } + + /* find interfaces not related to calling epoint */ + relation = c_relation; + while(relation) + { + if (relation->epoint_id != epoint_id) + break; + relation = relation->next; + } + if (!relation) + { + switch(message_type) + { + case MESSAGE_SETUP: + if (param->setup.dialinginfo.itype == INFO_ITYPE_ISDN_EXTENSION) + { + numbers = param->setup.dialinginfo.id; + while((number = strsep(&numbers, ","))) + { + if (out_setup(epoint_id, message_type, param, number)) + return; // join destroyed + } + break; + } + if (out_setup(epoint_id, message_type, param, NULL)) + return; // join destroyed + break; + + default: + PDEBUG(DEBUG_JOIN, "no need to send a message because there is no other endpoint than the calling one.\n"); + } + } else + { + PDEBUG(DEBUG_JOIN, "sending message ep%ld -> ep%ld.\n", epoint_id, relation->epoint_id); + message = message_create(c_serial, relation->epoint_id, JOIN_TO_EPOINT, message_type); + memcpy(&message->param, param, sizeof(union parameter)); + message_put(message); + PDEBUG(DEBUG_JOIN, "message sent.\n"); + } +} + + +/* join process is called from the main loop + * it processes the current calling state. + * returns 0 if join nothing was done + */ +int JoinPBX::handler(void) +{ +// struct join_relation *relation; +// char dialing[32][32]; +// int port[32]; +// int found; +// int i, j; +// char *p; + + /* the bridge must be updated */ + if (c_updatebridge) + { + bridge(); + c_updatebridge = 0; + return(1); + } + + return(0); +} + + +int track_notify(int oldstate, int notify) +{ + int newstate = oldstate; + + switch(notify) + { + case INFO_NOTIFY_USER_RESUMED: + case INFO_NOTIFY_REMOTE_RETRIEVAL: + case INFO_NOTIFY_CONFERENCE_DISCONNECTED: + case INFO_NOTIFY_RESERVED_CT_1: + case INFO_NOTIFY_RESERVED_CT_2: + case INFO_NOTIFY_CALL_IS_DIVERTING: + newstate = NOTIFY_STATE_ACTIVE; + break; + + case INFO_NOTIFY_USER_SUSPENDED: + newstate = NOTIFY_STATE_SUSPEND; + break; + + case INFO_NOTIFY_REMOTE_HOLD: + newstate = NOTIFY_STATE_HOLD; + break; + + case INFO_NOTIFY_CONFERENCE_ESTABLISHED: + newstate = NOTIFY_STATE_CONFERENCE; + break; + } + + return(newstate); +} + + +/* + * setup to exactly one endpoint + * if it fails, the calling endpoint is released. + * if other outgoing endpoints already exists, they are release as well. + * note: if this functions fails, it will destroy its own join object! + */ +int JoinPBX::out_setup(unsigned long epoint_id, int message_type, union parameter *param, char *newnumber) +{ + struct join_relation *relation; + struct message *message; + class Endpoint *epoint; + + PDEBUG(DEBUG_JOIN, "no endpoint found, so we will create an endpoint and send the setup message we have.\n"); + /* create a new relation */ + if (!(relation=add_relation())) + FATAL("No memory for relation.\n"); + relation->type = RELATION_TYPE_SETUP; + relation->channel_state = CHANNEL_STATE_HOLD; /* audio is assumed on a new join */ + relation->tx_state = NOTIFY_STATE_ACTIVE; /* new joins always assumed to be active */ + relation->rx_state = NOTIFY_STATE_ACTIVE; /* new joins always assumed to be active */ + /* create a new endpoint */ + epoint = new Endpoint(0, c_serial, 0); + if (!epoint) + FATAL("No memory for Endpoint instance\n"); + if (!(epoint->ep_app = new DEFAULT_ENDPOINT_APP(epoint))) + FATAL("No memory for Endpoint Application instance\n"); + relation->epoint_id = epoint->ep_serial; + /* send setup message to new endpoint */ +//printf("JOLLY DEBUG: %d\n",join_countrelations(c_serial)); +//i if (options.deb & DEBUG_JOIN) +// joinpbx_debug(join, "Join::message_epoint"); + message = message_create(c_serial, relation->epoint_id, JOIN_TO_EPOINT, message_type); + memcpy(&message->param, param, sizeof(union parameter)); + if (newnumber) + SCPY(message->param.setup.dialinginfo.id, newnumber); + PDEBUG(DEBUG_JOIN, "setup message sent to ep %d with number='%s'.\n", relation->epoint_id, message->param.setup.dialinginfo.id); + message_put(message); + return(0); +} + + -- cgit v1.2.3-55-g7522