1 /*****************************************************************************\
3 ** Linux Call Router **
5 **---------------------------------------------------------------------------**
6 ** Copyright: Andreas Eversberg **
8 ** The EndpointAppBridge implements direct bridge between interfaces **
10 \*****************************************************************************/
15 class EndpointAppBridge *appbridge_first = NULL;
18 * EndpointAppBridge constructor
20 EndpointAppBridge::EndpointAppBridge(class Endpoint *epoint, int origin) : EndpointApp(epoint, origin, EAPP_TYPE_BRIDGE)
22 class EndpointAppBridge **apppointer;
24 /* add application to chain */
26 apppointer = &appbridge_first;
28 apppointer = &((*apppointer)->next);
31 PDEBUG(DEBUG_EPOINT, "Bridge endpoint created\n");
35 * EpointAppBridge destructor
37 EndpointAppBridge::~EndpointAppBridge(void)
39 class EndpointAppBridge *temp, **tempp;
42 temp =appbridge_first;
43 tempp = &appbridge_first;
52 FATAL("Endpoint not in endpoint's list.\n");
55 PDEBUG(DEBUG_EPOINT, "Bridge endpoint destroyed\n");
60 * trace header for application
62 void EndpointAppBridge::trace_header(const char *name, int direction)
66 char msgtext[sizeof(_trace.name)];
70 /* init trace with given values */
73 "", //numberrize_callerinfo(e_callerinfo.id, e_callerinfo.ntype, options.national, options.international),
74 "", // e_dialinginfo.id,
77 ea_endpoint->ep_serial,
81 /* port MESSAGE_SETUP */
82 void EndpointAppBridge::port_setup(struct port_list *portlist, int message_type, union parameter *param)
84 struct interface *interface_in = interface_first;
85 struct interface *interface_out = interface_first;
86 struct port_settings port_settings;
87 class Port *port = NULL;
88 struct lcr_msg *message;
89 unsigned int bridge_id;
90 unsigned int source_port_id = portlist->port_id;
94 PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint received setup from='%s' to='%s'\n", ea_endpoint->ep_serial, param->setup.callerinfo.id, param->setup.dialinginfo.id);
96 if (!ea_endpoint->ep_portlist) {
97 PERROR("Endpoint has no port in portlist\n");
100 if (ea_endpoint->ep_portlist->next) {
101 PDEBUG(DEBUG_EPOINT, "Endpoint already received setup, ignoring.\n");
105 while (interface_in) {
106 if (!strcmp(interface_in->name, param->setup.callerinfo.interface))
108 interface_in = interface_in->next;
111 PERROR("Cannot find source interface %s.\n", param->setup.callerinfo.interface);
113 message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_RELEASE);
114 message->param.disconnectinfo.cause = cause;
115 message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
116 message_put(message);
118 /* destroy endpoint */
119 ea_endpoint->ep_use = 0;
120 trigger_work(&ea_endpoint->ep_delete);
124 while (interface_out) {
125 if (!strcmp(interface_out->name, interface_in->bridge_if))
127 interface_out = interface_out->next;
129 if (!interface_out) {
130 PERROR("Cannot find destination interface %s.\n", interface_in->bridge_if);
135 /* create port for interface */
136 SPRINT(portname, "%s-%d-out", interface_out->name, 0);
137 memset(&port_settings, 0, sizeof(port_settings));
139 if (interface_out->sip) {
140 port = new Psip(PORT_TYPE_SIP_OUT, portname, &port_settings, interface_out);
144 if (interface_out->gsm_bs) {
145 port = new Pgsm_bs(PORT_TYPE_GSM_BS_OUT, portname, &port_settings, interface_out);
149 if (interface_out->gsm_ms) {
150 port = new Pgsm_bs(PORT_TYPE_GSM_MS_OUT, portname, &port_settings, interface_out);
155 struct mISDNport *mISDNport;
156 char *ifname = interface_out->name;
158 struct admin_list *admin;
160 int mode = B_MODE_TRANSPARENT;
162 /* hunt for mISDNport and create Port */
163 mISDNport = hunt_port(ifname, &channel);
165 trace_header("INTERFACE (busy)", DIRECTION_NONE);
166 add_trace("interface", NULL, "%s", ifname);
172 SPRINT(portname, "%s-%d-out", mISDNport->ifport->interface->name, mISDNport->portnum);
175 port = ss5_hunt_line(mISDNport);
178 if (mISDNport->ifport->remote) {
181 if (admin->remote_name[0] && !strcmp(admin->remote_name, mISDNport->ifport->remote_app))
186 trace_header("INTERFACE (remote not connected)", DIRECTION_NONE);
187 add_trace("application", NULL, "%s", mISDNport->ifport->remote_app);
192 port = new Premote(PORT_TYPE_REMOTE_OUT, mISDNport, portname, &port_settings, channel, mISDNport->ifport->channel_force, mode, admin->sock);
194 port = new Pdss1((mISDNport->ntmode)?PORT_TYPE_DSS1_NT_OUT:PORT_TYPE_DSS1_TE_OUT, mISDNport, portname, &port_settings, channel, mISDNport->ifport->channel_force, mode);
195 earlyb = mISDNport->earlyb;
197 trace_header("INTERFACE (has no function)", DIRECTION_NONE);
198 add_trace("interface", NULL, "%s", ifname);
205 FATAL("Remote interface, but not supported???\n");
206 portlist = ea_endpoint->portlist_new(port->p_serial, port->p_type, interface_out->is_earlyb == IS_YES);
208 FATAL("EPOINT(%d) cannot allocate port_list relation\n", ea_endpoint->ep_serial);
210 message_forward(ea_endpoint->ep_serial, port->p_serial, EPOINT_TO_PORT, param);
212 /* apply bridge to interfaces */
213 /* FIXME: use mISDN bridge for mISDN ports */
214 bridge_id = join_serial++;
215 message = message_create(ea_endpoint->ep_serial, source_port_id, EPOINT_TO_PORT, MESSAGE_BRIDGE);
216 message->param.bridge_id = bridge_id;
217 message_put(message);
218 message = message_create(ea_endpoint->ep_serial, port->p_serial, EPOINT_TO_PORT, MESSAGE_BRIDGE);
219 message->param.bridge_id = bridge_id;
220 message_put(message);
223 /* port MESSAGE_RELEASE */
224 void EndpointAppBridge::port_release(struct port_list *portlist, int message_type, union parameter *param)
228 PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint received release from port\n");
230 if (!ea_endpoint->ep_portlist || !ea_endpoint->ep_portlist->next)
232 if (ea_endpoint->ep_portlist->port_id == portlist->port_id)
233 remote = ea_endpoint->ep_portlist->next->port_id;
235 remote = ea_endpoint->ep_portlist->port_id;
236 /* forward release */
237 message_forward(ea_endpoint->ep_serial, remote, EPOINT_TO_PORT, param);
240 /* destroy endpoint */
241 ea_endpoint->ep_use = 0;
242 trigger_work(&ea_endpoint->ep_delete);
245 /* port other messages */
246 void EndpointAppBridge::port_other(struct port_list *portlist, int message_type, union parameter *param)
250 PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint received message %d from port\n", message_type);
252 if (!ea_endpoint->ep_portlist || !ea_endpoint->ep_portlist->next)
254 if (ea_endpoint->ep_portlist->port_id == portlist->port_id)
255 remote = ea_endpoint->ep_portlist->next->port_id;
257 remote = ea_endpoint->ep_portlist->port_id;
258 /* forward release */
259 message_forward(ea_endpoint->ep_serial, remote, EPOINT_TO_PORT, param);
262 /* port sends message to the endpoint
264 void EndpointAppBridge::ea_message_port(unsigned int port_id, int message_type, union parameter *param)
266 struct port_list *portlist;
268 portlist = ea_endpoint->ep_portlist;
270 if (port_id == portlist->port_id)
272 portlist = portlist->next;
275 PDEBUG(DEBUG_EPOINT, "EPOINT(%d) warning: port is not related to this endpoint. This may happen, if port has been released after the message was created.\n", ea_endpoint->ep_serial);
279 // PDEBUG(DEBUG_EPOINT, "received message %d (terminal %s, caller id %s)\n", message, e_ext.number, e_callerinfo.id);
280 switch(message_type) {
281 /* PORT sends SETUP message */
283 port_setup(portlist, message_type, param);
286 /* PORT sends RELEASE message */
287 case MESSAGE_RELEASE:
288 port_release(portlist, message_type, param);
292 port_other(portlist, message_type, param);
295 /* Note: this endpoint may be destroyed, so we MUST return */