1 /*****************************************************************************\
3 ** Linux Call Router **
5 **---------------------------------------------------------------------------**
6 ** Copyright: Andreas Eversberg **
10 \*****************************************************************************/
13 //#define __u8 unsigned char
14 //#define __u16 unsigned short
15 //#define __u32 unsigned int
18 /* notify endpoint about state change (if any) */
19 static int notify_state_change(int join_id, int epoint_id, int old_state, int new_state)
21 int notify_off = 0, notify_on = 0;
22 struct lcr_msg *message;
24 if (old_state == new_state)
28 case NOTIFY_STATE_ACTIVE:
30 case NOTIFY_STATE_HOLD:
31 notify_on = INFO_NOTIFY_REMOTE_HOLD;
33 case NOTIFY_STATE_SUSPEND:
34 notify_on = INFO_NOTIFY_USER_SUSPENDED;
36 case NOTIFY_STATE_CONFERENCE:
37 notify_on = INFO_NOTIFY_CONFERENCE_ESTABLISHED;
42 case NOTIFY_STATE_HOLD:
44 case NOTIFY_STATE_ACTIVE:
45 notify_off = INFO_NOTIFY_REMOTE_RETRIEVAL;
47 case NOTIFY_STATE_SUSPEND:
48 notify_off = INFO_NOTIFY_REMOTE_RETRIEVAL;
49 notify_on = INFO_NOTIFY_USER_SUSPENDED;
51 case NOTIFY_STATE_CONFERENCE:
52 notify_off = INFO_NOTIFY_REMOTE_RETRIEVAL;
53 notify_on = INFO_NOTIFY_CONFERENCE_ESTABLISHED;
58 case NOTIFY_STATE_SUSPEND:
60 case NOTIFY_STATE_ACTIVE:
61 notify_off = INFO_NOTIFY_USER_RESUMED;
63 case NOTIFY_STATE_HOLD:
64 notify_off = INFO_NOTIFY_USER_RESUMED;
65 notify_on = INFO_NOTIFY_REMOTE_HOLD;
67 case NOTIFY_STATE_CONFERENCE:
68 notify_off = INFO_NOTIFY_USER_RESUMED;
69 notify_on = INFO_NOTIFY_CONFERENCE_ESTABLISHED;
74 case NOTIFY_STATE_CONFERENCE:
76 case NOTIFY_STATE_ACTIVE:
77 notify_off = INFO_NOTIFY_CONFERENCE_DISCONNECTED;
79 case NOTIFY_STATE_HOLD:
80 notify_off = INFO_NOTIFY_CONFERENCE_DISCONNECTED;
81 notify_on = INFO_NOTIFY_REMOTE_HOLD;
83 case NOTIFY_STATE_SUSPEND:
84 notify_off = INFO_NOTIFY_CONFERENCE_DISCONNECTED;
85 notify_on = INFO_NOTIFY_USER_SUSPENDED;
91 if (join_id && notify_off) {
92 message = message_create(join_id, epoint_id, JOIN_TO_EPOINT, MESSAGE_NOTIFY);
93 message->param.notifyinfo.notify = notify_off;
97 if (join_id && notify_on) {
98 message = message_create(join_id, epoint_id, JOIN_TO_EPOINT, MESSAGE_NOTIFY);
99 message->param.notifyinfo.notify = notify_on;
100 message_put(message);
107 /* debug function for join */
108 void joinpbx_debug(class JoinPBX *joinpbx, const char *function)
110 struct join_relation *relation;
111 struct port_list *portlist;
112 class Endpoint *epoint;
116 if (!(options.deb & DEBUG_JOIN))
119 PDEBUG(DEBUG_JOIN, "join(%d) start (called from %s)\n", joinpbx->j_serial, function);
121 relation = joinpbx->j_relation;
124 PDEBUG(DEBUG_JOIN, "join has no relations\n");
126 epoint = find_epoint_id(relation->epoint_id);
128 PDEBUG(DEBUG_JOIN, "warning: relations epoint id=%d doesn't exists!\n", relation->epoint_id);
129 relation = relation->next;
133 UPRINT(strchr(buffer,0), "*** ep%d", relation->epoint_id);
134 UPRINT(strchr(buffer,0), " ifs=");
135 portlist = epoint->ep_portlist;
137 port = find_port_id(portlist->port_id);
139 UPRINT(strchr(buffer,0), "%s,", port->p_name);
141 UPRINT(strchr(buffer,0), "<port %d doesn't exist>,", portlist->port_id);
142 portlist = portlist->next;
144 // UPRINT(strchr(buffer,0), " endpoint=%d on=%s hold=%s", epoint->ep_serial, (epoint->ep_join_id==joinpbx->j_serial)?"yes":"no", (epoint->get_hold_id()==joinpbx->j_serial)?"yes":"no");
145 UPRINT(strchr(buffer,0), " endpoint=%d on=%s", epoint->ep_serial, (epoint->ep_join_id==joinpbx->j_serial)?"yes":"no");
146 switch(relation->type) {
147 case RELATION_TYPE_CALLING:
148 UPRINT(strchr(buffer,0), " type=CALLING");
150 case RELATION_TYPE_SETUP:
151 UPRINT(strchr(buffer,0), " type=SETUP");
153 case RELATION_TYPE_CONNECT:
154 UPRINT(strchr(buffer,0), " type=CONNECT");
157 UPRINT(strchr(buffer,0), " type=unknown");
160 if (relation->channel_state)
161 UPRINT(strchr(buffer,0), " channel=CONNECT");
163 UPRINT(strchr(buffer,0), " channel=HOLD");
164 switch(relation->tx_state) {
165 case NOTIFY_STATE_ACTIVE:
166 UPRINT(strchr(buffer,0), " tx_state=ACTIVE");
168 case NOTIFY_STATE_HOLD:
169 UPRINT(strchr(buffer,0), " tx_state=HOLD");
171 case NOTIFY_STATE_SUSPEND:
172 UPRINT(strchr(buffer,0), " tx_state=SUSPEND");
174 case NOTIFY_STATE_CONFERENCE:
175 UPRINT(strchr(buffer,0), " tx_state=CONFERENCE");
178 UPRINT(strchr(buffer,0), " tx_state=unknown");
181 switch(relation->rx_state) {
182 case NOTIFY_STATE_ACTIVE:
183 UPRINT(strchr(buffer,0), " rx_state=ACTIVE");
185 case NOTIFY_STATE_HOLD:
186 UPRINT(strchr(buffer,0), " rx_state=HOLD");
188 case NOTIFY_STATE_SUSPEND:
189 UPRINT(strchr(buffer,0), " rx_state=SUSPEND");
191 case NOTIFY_STATE_CONFERENCE:
192 UPRINT(strchr(buffer,0), " rx_state=CONFERENCE");
195 UPRINT(strchr(buffer,0), " rx_state=unknown");
198 PDEBUG(DEBUG_JOIN, "%s\n", buffer);
199 relation = relation->next;
202 PDEBUG(DEBUG_JOIN, "end\n");
205 int update_bridge(struct lcr_work *work, void *instance, int index);
208 * constructor for a new join
209 * the join will have a relation to the calling endpoint
211 JoinPBX::JoinPBX(class Endpoint *epoint) : Join()
213 struct join_relation *relation;
214 // char filename[256];
217 FATAL("epoint is NULL.\n");
219 PDEBUG(DEBUG_JOIN, "creating new join and connecting it to the endpoint.\n");
221 j_type = JOIN_TYPE_PBX;
223 j_caller_id[0] = '\0';
228 j_partyline_jingle = 0;
232 memset(&j_updatebridge, 0, sizeof(j_updatebridge));
233 add_work(&j_updatebridge, update_bridge, this, 0);
235 /* initialize a relation only to the calling interface */
236 relation = j_relation = (struct join_relation *)MALLOC(sizeof(struct join_relation));
238 relation->type = RELATION_TYPE_CALLING;
239 relation->channel_state = 0; /* audio is assumed on a new join */
240 relation->tx_state = NOTIFY_STATE_ACTIVE; /* new joins always assumed to be active */
241 relation->rx_state = NOTIFY_STATE_ACTIVE; /* new joins always assumed to be active */
242 relation->epoint_id = epoint->ep_serial;
245 if (options.deb & DEBUG_JOIN)
246 joinpbx_debug(this, "JoinPBX::Constructor(new join)");
255 struct join_relation *relation, *rtemp;
257 relation = j_relation;
259 rtemp = relation->next;
260 FREE(relation, sizeof(struct join_relation));
265 /* remove 3PTY from other join */
268 class JoinPBX *joinpbx;
270 join = find_join_id(j_3pty);
271 if (join && join->j_type == JOIN_TYPE_PBX) {
272 joinpbx = (class JoinPBX *)join;
274 trigger_work(&joinpbx->j_updatebridge);
278 del_work(&j_updatebridge);
282 /* bridge sets the audio flow of all bchannels assiociated to 'this' join
283 * also it changes and notifies active/hold/conference states
285 int update_bridge(struct lcr_work *work, void *instance, int index)
287 class JoinPBX *joinpbx = (class JoinPBX *)instance;
294 void JoinPBX::bridge(void)
296 struct join_relation *relation;
297 struct lcr_msg *message;
298 int numconnect = 0, relations = 0;
299 class Endpoint *epoint;
300 struct port_list *portlist;
302 unsigned int bridge_id;
303 class Join *join_3pty;
304 class JoinPBX *joinpbx_3pty;
305 #ifdef DEBUG_COREBRIDGE
306 int allmISDN = 0; // never set for debug purpose
308 int allmISDN = 1; // set until a non-mISDN relation is found
311 /* bridge id is the serial of join
312 * if we have a 3pty with another join, we always use the lowest brigde id.
313 * this way we use common ids, so both joins share same bridge */
314 if (j_3pty && j_3pty < j_serial)
317 bridge_id = j_serial;
319 relation = j_relation;
321 /* count all relations */
324 /* check for relation's objects */
325 epoint = find_epoint_id(relation->epoint_id);
327 PERROR("software error: relation without existing endpoints.\n");
328 relation = relation->next;
331 portlist = epoint->ep_portlist;
333 PDEBUG(DEBUG_JOIN, "join%d ignoring relation without port object.\n", j_serial);
334 //#warning testing: keep on hold until single audio stream available
335 relation->channel_state = 0;
336 relation = relation->next;
339 if (portlist->next) {
340 PDEBUG(DEBUG_JOIN, "join%d ignoring relation with ep%d due to port_list.\n", j_serial, epoint->ep_serial);
341 //#warning testing: keep on hold until single audio stream available
342 relation->channel_state = 0;
343 relation = relation->next;
346 port = find_port_id(portlist->port_id);
348 PDEBUG(DEBUG_JOIN, "join%d ignoring relation without existing port object.\n", j_serial);
349 relation = relation->next;
352 if ((port->p_type&PORT_CLASS_MASK)!=PORT_CLASS_mISDN) {
353 PDEBUG(DEBUG_JOIN, "join%d ignoring relation ep%d because it's port is not mISDN.\n", j_serial, epoint->ep_serial);
355 PDEBUG(DEBUG_JOIN, "join%d not all endpoints are mISDN.\n", j_serial);
358 relation = relation->next;
363 PDEBUG(DEBUG_JOIN, "join%d ignoring relation ep%d because it's port uses VoOTP.\n", j_serial, epoint->ep_serial);
365 PDEBUG(DEBUG_JOIN, "join%d not all endpoints can support mISDN bridging.\n", j_serial);
368 relation = relation->next;
373 relation = relation->next;
376 /* check if 3pty members have no mISDN, so bridging via mISDN/lcr will be selected correctly */
377 join_3pty = find_join_id(j_3pty);
378 if (join_3pty && join_3pty->j_type == JOIN_TYPE_PBX) {
379 joinpbx_3pty = (class JoinPBX *)join_3pty;
380 relation = joinpbx_3pty->j_relation;
384 no need to count, because j_3pty is taken into account below when checking relations
385 /* count all relations */
389 /* check for relation's objects */
390 epoint = find_epoint_id(relation->epoint_id);
392 PERROR("software error: relation without existing endpoints.\n");
393 relation = relation->next;
396 portlist = epoint->ep_portlist;
398 PDEBUG(DEBUG_JOIN, "other 3pty join %d: ignoring relation without port object.\n", joinpbx_3pty->j_serial);
399 //#warning testing: keep on hold until single audio stream available
400 relation->channel_state = 0;
401 relation = relation->next;
404 if (portlist->next) {
405 PDEBUG(DEBUG_JOIN, "other 3pty join %d: ignoring relation with ep%d due to port_list.\n", joinpbx_3pty->j_serial, epoint->ep_serial);
406 //#warning testing: keep on hold until single audio stream available
407 relation->channel_state = 0;
408 relation = relation->next;
411 port = find_port_id(portlist->port_id);
413 PDEBUG(DEBUG_JOIN, "other 3pty join %d: ignoring relation without existing port object.\n", joinpbx_3pty->j_serial);
414 relation = relation->next;
417 if ((port->p_type&PORT_CLASS_MASK)!=PORT_CLASS_mISDN) {
418 PDEBUG(DEBUG_JOIN, "other 3pty join %d: ignoring relation ep%d because it's port is not mISDN.\n", joinpbx_3pty->j_serial, epoint->ep_serial);
420 PDEBUG(DEBUG_JOIN, "other 3pty join %d: not all endpoints are mISDN.\n", joinpbx_3pty->j_serial);
423 relation = relation->next;
428 PDEBUG(DEBUG_JOIN, "join%d ignoring relation ep%d because it's port uses VoOTP.\n", joinpbx_3pty->j_serial, epoint->ep_serial);
430 PDEBUG(DEBUG_JOIN, "join%d not all endpoints can support mISDN bridging.\n", joinpbx_3pty->j_serial);
433 relation = relation->next;
438 relation = relation->next;
442 PDEBUG(DEBUG_JOIN, "join%d members=%d %s\n", j_serial, relations, (allmISDN)?"(all are mISDN-members)":"(not all are mISDN-members)");
443 /* we notify all relations about rxdata. */
444 relation = j_relation;
446 /* count connected relations */
447 if ((relation->channel_state == 1)
448 && (relation->rx_state != NOTIFY_STATE_SUSPEND)
449 && (relation->rx_state != NOTIFY_STATE_HOLD))
452 /* remove unconnected parties from conference, also remove remotely disconnected parties so conference will not be disturbed. */
455 if (relation->channel_state == 1
456 && relation->rx_state != NOTIFY_STATE_HOLD
457 && relation->rx_state != NOTIFY_STATE_SUSPEND
458 && relations>1 // no conf with one member
459 && allmISDN) { // no conf if any member is not mISDN
460 message = message_create(j_serial, relation->epoint_id, JOIN_TO_EPOINT, MESSAGE_mISDNSIGNAL);
461 message->param.mISDNsignal.message = mISDNSIGNAL_CONF;
462 message->param.mISDNsignal.conf = (bridge_id << 16) | j_pid;
463 PDEBUG(DEBUG_JOIN, "join%d EP%d +on+ id: 0x%08x\n", j_serial, relation->epoint_id, message->param.mISDNsignal.conf);
464 message_put(message);
466 message = message_create(j_serial, relation->epoint_id, JOIN_TO_EPOINT, MESSAGE_mISDNSIGNAL);
467 message->param.mISDNsignal.message = mISDNSIGNAL_CONF;
468 message->param.mISDNsignal.conf = 0;
469 PDEBUG(DEBUG_JOIN, "join%d EP%d +off+ id: 0x%08x\n", j_serial, relation->epoint_id, message->param.mISDNsignal.conf);
470 message_put(message);
474 if (relation->channel_state == 1
475 && relation->rx_state != NOTIFY_STATE_HOLD
476 && relation->rx_state != NOTIFY_STATE_SUSPEND
477 && relations>1 // no bridge with one member
478 && !allmISDN) { // no bridge if all members are mISDN
479 message = message_create(j_serial, relation->epoint_id, JOIN_TO_EPOINT, MESSAGE_BRIDGE);
480 message->param.bridge_id = bridge_id;
481 PDEBUG(DEBUG_JOIN, "join%u EP%u requests bridge=%u\n", j_serial, relation->epoint_id, bridge_id);
482 message_put(message);
484 message = message_create(j_serial, relation->epoint_id, JOIN_TO_EPOINT, MESSAGE_BRIDGE);
485 message->param.bridge_id = 0;
486 PDEBUG(DEBUG_JOIN, "join%u EP%u drop bridge=%u\n", j_serial, relation->epoint_id, bridge_id);
487 message_put(message);
490 relation = relation->next;
493 /* two people just exchange their states */
494 if (!j_3pty && relations==2 && !j_partyline) {
495 PDEBUG(DEBUG_JOIN, "join%d 2 relations / no partyline\n", j_serial);
496 relation = j_relation;
497 relation->tx_state = notify_state_change(j_serial, relation->epoint_id, relation->tx_state, relation->next->rx_state);
498 relation->next->tx_state = notify_state_change(j_serial, relation->next->epoint_id, relation->next->tx_state, relation->rx_state);
500 /* one member in a join, so we put her on hold */
501 if (!j_3pty && (relations==1 || numconnect==1)/* && !j_partyline_jingle*/) {
502 PDEBUG(DEBUG_JOIN, "join%d 1 member or only 1 connected, put on hold\n", j_serial);
503 relation = j_relation;
505 if ((relation->channel_state == 1)
506 && (relation->rx_state != NOTIFY_STATE_SUSPEND)
507 && (relation->rx_state != NOTIFY_STATE_HOLD))
508 relation->tx_state = notify_state_change(j_serial, relation->epoint_id, relation->tx_state, NOTIFY_STATE_HOLD);
509 relation = relation->next;
512 /* if conference/partyline (or more than two members and more than one is connected), so we set conference state */
513 PDEBUG(DEBUG_JOIN, "join%d %d members, %d connected, signal conference\n", j_serial, relations, numconnect);
514 relation = j_relation;
516 if ((relation->channel_state == 1)
517 && (relation->rx_state != NOTIFY_STATE_SUSPEND)
518 && (relation->rx_state != NOTIFY_STATE_HOLD))
519 relation->tx_state = notify_state_change(j_serial, relation->epoint_id, relation->tx_state, NOTIFY_STATE_CONFERENCE);
520 relation = relation->next;
525 /* release join from endpoint
526 * if the join has two relations, all relations are freed and the join will be
528 * on outgoing relations, the cause is collected, if not connected
529 * returns if join has been destroyed
531 int JoinPBX::release(struct join_relation *relation, int location, int cause)
533 struct join_relation *reltemp, **relationpointer;
534 struct lcr_msg *message;
538 /* remove from bridge */
539 if (relation->channel_state != 0) {
540 relation->channel_state = 0;
541 trigger_work(&j_updatebridge);
542 // note: if join is not released, bridge must be updated
545 /* detach given interface */
546 reltemp = j_relation;
547 relationpointer = &j_relation;
549 /* endpoint of function call */
550 if (relation == reltemp)
552 relationpointer = &reltemp->next;
553 reltemp = reltemp->next;
556 FATAL("relation not in list of our relations. this must not happen.\n");
557 //printf("releasing relation %d\n", reltemp->epoint_id);
558 *relationpointer = reltemp->next;
559 FREE(reltemp, sizeof(struct join_relation));
561 relation = reltemp = NULL; // just in case of reuse fault;
563 /* if no more relation */
565 PDEBUG(DEBUG_JOIN, "join is completely removed.\n");
566 /* there is no more endpoint related to the join */
569 // end of join object!
570 PDEBUG(DEBUG_JOIN, "join completely removed!\n");
572 /* if join is a party line */
574 PDEBUG(DEBUG_JOIN, "join is a conference room, so we keep it alive until the last party left.\n");
576 /* if only one relation left */
577 if (!j_relation->next) {
578 PDEBUG(DEBUG_JOIN, "join has one relation left, so we send it a release with the given cause %d.\n", cause);
579 message = message_create(j_serial, j_relation->epoint_id, JOIN_TO_EPOINT, MESSAGE_RELEASE);
580 message->param.disconnectinfo.cause = cause;
581 message->param.disconnectinfo.location = location;
582 message_put(message);
585 // end of join object!
586 PDEBUG(DEBUG_JOIN, "join completely removed!\n");
591 if (options.deb & DEBUG_JOIN && join->j_type==JOIN_TYPE_PBX)
592 joinpbx_debug((class JoinPBX *)join, "join_release{all joins left}");
595 PDEBUG(DEBUG_JOIN, "join_release(): ended.\n");
599 /* count number of relations in a join
601 int joinpbx_countrelations(unsigned int join_id)
603 struct join_relation *relation;
606 class JoinPBX *joinpbx;
608 join = find_join_id(join_id);
613 if (join->j_type != JOIN_TYPE_PBX)
615 joinpbx = (class JoinPBX *)join;
618 relation = joinpbx->j_relation;
621 relation = relation->next;
627 /* check if one is calling and all other relations are setup-realations */
628 int joinpbx_onecalling_othersetup(struct join_relation *relation)
630 int calling = 0, other = 0;
633 switch(relation->type) {
634 case RELATION_TYPE_CALLING:
637 case RELATION_TYPE_SETUP:
644 relation = relation->next;
647 if (calling == 1 && other == 0)
652 void JoinPBX::remove_relation(struct join_relation *relation)
654 struct join_relation *temp, **tempp;
662 if (temp == relation)
668 PERROR("relation not in join.\n");
672 PDEBUG(DEBUG_JOIN, "removing relation.\n");
673 *tempp = relation->next;
674 FREE(temp, sizeof(struct join_relation));
679 struct join_relation *JoinPBX::add_relation(void)
681 struct join_relation *relation;
684 PERROR("there is no first relation to this join\n");
687 relation = j_relation;
688 while(relation->next)
689 relation = relation->next;
691 relation->next = (struct join_relation *)MALLOC(sizeof(struct join_relation));
693 /* the record pointer is set at the first time the data is received for the relation */
695 // if (options.deb & DEBUG_JOIN)
696 // joinpbx_debug(join, "add_relation");
697 return(relation->next);
700 /* epoint sends a message to a join
703 void JoinPBX::message_epoint(unsigned int epoint_id, int message_type, union parameter *param)
706 struct join_relation *relation, *reltemp;
709 struct lcr_msg *message;
710 // int size, writesize, oldpointer;
711 char *number, *numbers;
714 PERROR("software error, epoint == NULL\n");
718 // if (options.deb & DEBUG_JOIN) {
719 // PDEBUG(DEBUG_JOIN, "message %d received from ep%d.\n", message, epoint->ep_serial);
720 // joinpbx_debug(join,"Join::message_epoint");
722 if (options.deb & DEBUG_JOIN) {
726 if (cl->j_type == JOIN_TYPE_PBX)
727 joinpbx_debug((class JoinPBX *)cl, "Join::message_epoint{all joins before processing}");
734 relation = j_relation;
736 if (relation->epoint_id == epoint_id)
738 relation = relation->next;
741 PDEBUG(DEBUG_JOIN, "no relation back to the endpoint found, ignoring (join=%d, endpoint=%d)\n", j_serial, epoint_id);
745 /* count relations */
746 num=joinpbx_countrelations(j_serial);
748 /* process party line */
749 if (message_type == MESSAGE_SETUP) if (param->setup.partyline && !j_partyline) {
750 j_partyline = param->setup.partyline;
751 j_partyline_jingle = param->setup.partyline_jingle;
754 switch(message_type) {
756 PDEBUG(DEBUG_JOIN, "respsone with connect in partyline mode.\n");
757 relation->type = RELATION_TYPE_CONNECT;
758 message = message_create(j_serial, epoint_id, JOIN_TO_EPOINT, MESSAGE_CONNECT);
759 SPRINT(message->param.connectinfo.id, "%d", j_partyline);
760 message->param.connectinfo.ntype = INFO_NTYPE_UNKNOWN;
761 message_put(message);
762 trigger_work(&j_updatebridge);
763 if (j_partyline_jingle)
767 case MESSAGE_AUDIOPATH:
768 PDEBUG(DEBUG_JOIN, "join received channel message: %d.\n", param->audiopath);
769 if (relation->channel_state != param->audiopath) {
770 relation->channel_state = param->audiopath;
771 trigger_work(&j_updatebridge);
772 if (options.deb & DEBUG_JOIN)
773 joinpbx_debug(this, "Join::message_epoint{after setting new channel state}");
779 switch(param->notifyinfo.notify) {
780 case INFO_NOTIFY_USER_SUSPENDED:
781 case INFO_NOTIFY_USER_RESUMED:
782 case INFO_NOTIFY_REMOTE_HOLD:
783 case INFO_NOTIFY_REMOTE_RETRIEVAL:
784 case INFO_NOTIFY_CONFERENCE_ESTABLISHED:
785 case INFO_NOTIFY_CONFERENCE_DISCONNECTED:
786 new_state = track_notify(relation->rx_state, param->notifyinfo.notify);
787 if (new_state != relation->rx_state) {
788 relation->rx_state = new_state;
789 trigger_work(&j_updatebridge);
790 if (options.deb & DEBUG_JOIN)
791 joinpbx_debug(this, "Join::message_epoint{after setting new rx state}");
797 case MESSAGE_DISCONNECT:
798 PDEBUG(DEBUG_JOIN, "releasing after receiving disconnect, because join in partyline mode.\n");
799 message = message_create(j_serial, epoint_id, JOIN_TO_EPOINT, MESSAGE_RELEASE);
800 message->param.disconnectinfo.cause = CAUSE_NORMAL;
801 message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
802 message_put(message);
805 case MESSAGE_RELEASE:
806 PDEBUG(DEBUG_JOIN, "releasing from join\n");
807 release(relation, 0, 0);
808 if (j_partyline_jingle)
813 PDEBUG(DEBUG_JOIN, "ignoring message, because join in partyline mode.\n");
819 /* process messages */
820 switch(message_type) {
821 /* process audio path message */
822 case MESSAGE_AUDIOPATH:
823 PDEBUG(DEBUG_JOIN, "join received channel message: audiopath=%d, current relation's channel_state=%d\n", param->audiopath, relation->channel_state);
824 if (relation->channel_state != param->audiopath) {
825 relation->channel_state = param->audiopath;
826 trigger_work(&j_updatebridge);
827 if (options.deb & DEBUG_JOIN)
828 joinpbx_debug(this, "Join::message_epoint{after setting new channel state}");
832 case MESSAGE_UPDATEBRIDGE:
833 trigger_work(&j_updatebridge);
834 joinpbx_debug(this, "Join::message_epoint{bridge is updated due to request from mISDN port}");
839 switch(param->notifyinfo.notify) {
840 case INFO_NOTIFY_USER_SUSPENDED:
841 case INFO_NOTIFY_USER_RESUMED:
842 case INFO_NOTIFY_REMOTE_HOLD:
843 case INFO_NOTIFY_REMOTE_RETRIEVAL:
844 case INFO_NOTIFY_CONFERENCE_ESTABLISHED:
845 case INFO_NOTIFY_CONFERENCE_DISCONNECTED:
846 new_state = track_notify(relation->rx_state, param->notifyinfo.notify);
847 if (new_state != relation->rx_state) {
848 relation->rx_state = new_state;
849 trigger_work(&j_updatebridge);
850 if (options.deb & DEBUG_JOIN)
851 joinpbx_debug(this, "Join::message_epoint{after setting new rx state}");
856 /* send notification to all other endpoints */
857 reltemp = j_relation;
859 if (reltemp->epoint_id!=epoint_id && reltemp->epoint_id) {
860 message = message_create(j_serial, reltemp->epoint_id, JOIN_TO_EPOINT, MESSAGE_NOTIFY);
861 memcpy(&message->param, param, sizeof(union parameter));
862 message_put(message);
864 reltemp = reltemp->next;
869 /* relations sends a connect */
870 case MESSAGE_CONNECT:
871 /* outgoing setup type becomes connected */
872 if (relation->type == RELATION_TYPE_SETUP)
873 relation->type = RELATION_TYPE_CONNECT;
874 /* release other relations in setup state */
876 reltemp = j_relation;
878 //printf("connect, checking relation %d\n", reltemp->epoint_id);
879 if (reltemp->type == RELATION_TYPE_SETUP) {
880 //printf("relation %d is of type setup, releasing\n", reltemp->epoint_id);
881 /* send release to endpoint */
882 message = message_create(j_serial, reltemp->epoint_id, JOIN_TO_EPOINT, MESSAGE_RELEASE);
883 message->param.disconnectinfo.cause = CAUSE_NONSELECTED;
884 message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
885 message_put(message);
887 if (release(reltemp, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL)) // dummy cause, should not be used, since calling and connected endpoint still exist afterwards.
888 return; // must return, because join IS destroyed
891 if (reltemp->type == RELATION_TYPE_CALLING)
892 reltemp->type = RELATION_TYPE_CONNECT;
893 reltemp = reltemp->next;
895 break; // continue with our message
897 /* release is sent by endpoint */
898 case MESSAGE_RELEASE:
899 switch(relation->type) {
900 case RELATION_TYPE_SETUP: /* by called */
901 /* collect cause and send collected cause */
902 collect_cause(&j_multicause, &j_multilocation, param->disconnectinfo.cause, param->disconnectinfo.location);
904 release(relation, j_multilocation, j_multicause);
906 release(relation, LOCATION_PRIVATE_LOCAL, CAUSE_UNSPECIFIED);
909 case RELATION_TYPE_CALLING: /* by calling */
910 /* remove us, if we don't have a called releation yet */
911 if (!j_relation->next) {
912 release(j_relation, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL);
913 return; // must return, because join IS destroyed
915 /* in a conf, we don't kill the other members */
916 if (num > 2 && !joinpbx_onecalling_othersetup(j_relation)) {
917 release(relation, 0, 0);
920 /* remove all relations that are of called type */
922 reltemp = j_relation;
924 if (reltemp->type == RELATION_TYPE_SETUP) {
925 /* send release to endpoint */
926 message = message_create(j_serial, reltemp->epoint_id, JOIN_TO_EPOINT, message_type);
927 memcpy(&message->param, param, sizeof(union parameter));
928 message_put(message);
930 if (release(reltemp, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL))
931 return; // must return, because join IS destroyed
934 reltemp = reltemp->next;
936 PERROR("we are still here, this should not happen\n");
939 default: /* by connected */
940 /* send current cause */
941 release(relation, param->disconnectinfo.location, param->disconnectinfo.cause);
943 return; // must return, because join may be destroyed
946 /* check number of relations */
947 if (num > 2 && !joinpbx_onecalling_othersetup(j_relation) && message_type != MESSAGE_CONNECT) {
948 PDEBUG(DEBUG_JOIN, "we are in a conference, so we ignore the messages, except MESSAGE_CONNECT.\n");
952 /* if join has no other relation, we process the setup message */
954 switch(message_type) {
956 if (param->setup.dialinginfo.itype == INFO_ITYPE_ISDN_EXTENSION) {
957 /* in case of keypad */
958 numbers = param->setup.dialinginfo.keypad;
960 while((number = strsep(&numbers, ","))) {
961 if (out_setup(epoint_id, message_type, param, NULL, number))
962 return; // join destroyed
964 /* after keypad finish dialing */
968 numbers = param->setup.dialinginfo.id;
969 while((number = strsep(&numbers, ","))) {
970 if (out_setup(epoint_id, message_type, param, number, NULL))
971 return; // join destroyed
975 if (out_setup(epoint_id, message_type, param, param->setup.dialinginfo.id, param->setup.dialinginfo.keypad))
976 return; // join destroyed
980 PDEBUG(DEBUG_JOIN, "no need to send a message because there is no other endpoint than the calling one.\n");
983 /* sending message to other relation(s) */
984 relation = j_relation;
986 if (relation->epoint_id != epoint_id) {
987 PDEBUG(DEBUG_JOIN, "sending message ep%ld -> ep%ld.\n", epoint_id, relation->epoint_id);
988 message = message_create(j_serial, relation->epoint_id, JOIN_TO_EPOINT, message_type);
989 memcpy(&message->param, param, sizeof(union parameter));
990 message_put(message);
991 PDEBUG(DEBUG_JOIN, "message sent.\n");
993 relation = relation->next;
999 int track_notify(int oldstate, int notify)
1001 int newstate = oldstate;
1004 case INFO_NOTIFY_USER_RESUMED:
1005 case INFO_NOTIFY_REMOTE_RETRIEVAL:
1006 case INFO_NOTIFY_CONFERENCE_DISCONNECTED:
1007 case INFO_NOTIFY_RESERVED_CT_1:
1008 case INFO_NOTIFY_RESERVED_CT_2:
1009 case INFO_NOTIFY_CALL_IS_DIVERTING:
1010 newstate = NOTIFY_STATE_ACTIVE;
1013 case INFO_NOTIFY_USER_SUSPENDED:
1014 newstate = NOTIFY_STATE_SUSPEND;
1017 case INFO_NOTIFY_REMOTE_HOLD:
1018 newstate = NOTIFY_STATE_HOLD;
1021 case INFO_NOTIFY_CONFERENCE_ESTABLISHED:
1022 newstate = NOTIFY_STATE_CONFERENCE;
1031 * setup to exactly one endpoint
1032 * if it fails, the calling endpoint is released.
1033 * if other outgoing endpoints already exists, they are release as well.
1034 * note: if this functions fails, it will destroy its own join object!
1036 int JoinPBX::out_setup(unsigned int epoint_id, int message_type, union parameter *param, char *newnumber, char *newkeypad)
1038 struct join_relation *relation;
1039 struct lcr_msg *message;
1040 class Endpoint *epoint;
1042 PDEBUG(DEBUG_JOIN, "no endpoint found, so we will create an endpoint and send the setup message we have.\n");
1043 /* create a new relation */
1044 if (!(relation=add_relation()))
1045 FATAL("No memory for relation.\n");
1046 relation->type = RELATION_TYPE_SETUP;
1047 relation->channel_state = 0; /* audio is assumed on a new join */
1048 relation->tx_state = NOTIFY_STATE_ACTIVE; /* new joins always assumed to be active */
1049 relation->rx_state = NOTIFY_STATE_ACTIVE; /* new joins always assumed to be active */
1050 /* create a new endpoint */
1051 epoint = new Endpoint(0, j_serial);
1053 FATAL("No memory for Endpoint instance\n");
1054 epoint->ep_app = new_endpointapp(epoint, 1, EAPP_TYPE_PBX); // outgoing
1055 relation->epoint_id = epoint->ep_serial;
1056 /* send setup message to new endpoint */
1057 //printf("JOLLY DEBUG: %d\n",join_countrelations(j_serial));
1058 //i if (options.deb & DEBUG_JOIN)
1059 // joinpbx_debug(join, "Join::message_epoint");
1060 message = message_create(j_serial, relation->epoint_id, JOIN_TO_EPOINT, message_type);
1061 memcpy(&message->param, param, sizeof(union parameter));
1063 SCPY(message->param.setup.dialinginfo.id, newnumber);
1065 message->param.setup.dialinginfo.id[0] = '\0';
1067 SCPY(message->param.setup.dialinginfo.keypad, newkeypad);
1069 message->param.setup.dialinginfo.keypad[0] = '\0';
1070 PDEBUG(DEBUG_JOIN, "setup message sent to ep %d with number='%s' keypad='%s'.\n", relation->epoint_id, message->param.setup.dialinginfo.id, message->param.setup.dialinginfo.keypad);
1071 message_put(message);
1076 /* send play message to all members to play join/release jingle */
1077 void JoinPBX::play_jingle(int in)
1079 struct join_relation *relation;
1080 struct lcr_msg *message;
1082 relation = j_relation;
1086 if (!relation->next)
1089 message = message_create(j_serial, relation->epoint_id, JOIN_TO_EPOINT, MESSAGE_TONE);
1090 SCPY(message->param.tone.name, (char *)((in)?"joined":"left"));
1091 message_put(message);
1092 relation = relation->next;