X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=action.cpp;h=3fc644943f5b07c714e0aa9f289ed9794fe0a670;hp=62f63edfb36c18d13fa40cdcb19360c6eca9c461;hb=acaf278f7f616d264afe480e4f9c64768540941b;hpb=8fb861ef9ece9f4bd68ef79a77625ec23c27aef1

diff --git a/action.cpp b/action.cpp
index 62f63ed..3fc6449 100644
--- a/action.cpp
+++ b/action.cpp
@@ -15,55 +15,26 @@ extern char **environ;
 
 
 /*
- * process init 'internal' / 'external' / 'remote' / 'vbox-record' / 'partyline'...
+ * process init 'internal' / 'external' / 'vbox-record' / 'partyline'...
  */
-int EndpointAppPBX::_action_init_call(char *remote)
+void EndpointAppPBX::action_init_call(void)
 {
 	class Join		*join;
-	struct port_list	*portlist = ea_endpoint->ep_portlist;
-	struct admin_list	*admin;
 
 	/* a created call, this should never happen */
 	if (ea_endpoint->ep_join_id) {
 		if (options.deb & DEBUG_EPOINT)
 			PERROR("EPOINT(%d): We already have a call instance, this should never happen!\n", ea_endpoint->ep_serial);
-		return(0);
+		return;
 	}
 
 	/* create join */
 	PDEBUG(DEBUG_EPOINT, "EPOINT(%d): Creating new join instance.\n", ea_endpoint->ep_serial);
-	if (remote) {
-		admin = admin_first;
-		while(admin) {
-			if (admin->remote_name[0] && !strcmp(admin->remote_name, remote))
-				break;
-			admin = admin->next;
-		}
-		if (!admin) {
-			/* resource not available */
-			trace_header("ACTION remote (not available)", DIRECTION_NONE);
-			add_trace("application", NULL, "%s", remote);
-			end_trace();
-			message_disconnect_port(portlist, CAUSE_OUTOFORDER, LOCATION_PRIVATE_LOCAL, "");
-			new_state(EPOINT_STATE_OUT_DISCONNECT);
-			set_tone(portlist,"cause_1b");
-			return(0);
-		}
-		join = new JoinRemote(ea_endpoint->ep_serial, remote, admin->sock);
-	}
-	else
-		join = new JoinPBX(ea_endpoint);
+	join = new JoinPBX(ea_endpoint);
 	if (!join)
 		FATAL("No memoy for Join instance.\n");
 	ea_endpoint->ep_join_id = join->j_serial;
-	return(1);
-}
-void EndpointAppPBX::action_init_call(void)
-{
-	_action_init_call(NULL);
-}
-void EndpointAppPBX::action_init_remote(void)
-{
+	return;
 }
 
 /*
@@ -74,6 +45,7 @@ void EndpointAppPBX::action_dialing_internal(void)
 	struct capa_info	capainfo;
 	struct caller_info	callerinfo;
 	struct redir_info	redirinfo;
+	struct rtp_info		rtpinfo;
 	struct dialing_info	dialinginfo;
 	struct port_list	*portlist = ea_endpoint->ep_portlist;
 	struct lcr_msg		*message;
@@ -91,6 +63,7 @@ void EndpointAppPBX::action_dialing_internal(void)
 	memcpy(&capainfo, &e_capainfo, sizeof(capainfo));
 	memcpy(&callerinfo, &e_callerinfo, sizeof(callerinfo));
 	memcpy(&redirinfo, &e_redirinfo, sizeof(redirinfo));
+	memcpy(&rtpinfo, &e_rtpinfo, sizeof(rtpinfo));
 	memset(&dialinginfo, 0, sizeof(dialinginfo));
 	dialinginfo.itype = INFO_ITYPE_ISDN_EXTENSION;
 	SCPY(dialinginfo.id, e_dialinginfo.id);
@@ -164,6 +137,7 @@ void EndpointAppPBX::action_dialing_internal(void)
 	memcpy(&message->param.setup.redirinfo, &redirinfo, sizeof(struct redir_info));
 	memcpy(&message->param.setup.callerinfo, &callerinfo, sizeof(struct caller_info));
 	memcpy(&message->param.setup.capainfo, &capainfo, sizeof(struct capa_info));
+	memcpy(&message->param.setup.rtpinfo, &rtpinfo, sizeof(struct rtp_info));
 	message_put(message);
 }
 
@@ -174,6 +148,7 @@ void EndpointAppPBX::action_dialing_external(void)
 	struct capa_info capainfo;
 	struct caller_info callerinfo;
 	struct redir_info redirinfo;
+	struct rtp_info rtpinfo;
 	struct dialing_info dialinginfo;
 	char *p;
 	struct port_list *portlist = ea_endpoint->ep_portlist;
@@ -206,15 +181,19 @@ void EndpointAppPBX::action_dialing_external(void)
 	memcpy(&capainfo, &e_capainfo, sizeof(capainfo));
 	memcpy(&callerinfo, &e_callerinfo, sizeof(callerinfo));
 	memcpy(&redirinfo, &e_redirinfo, sizeof(redirinfo));
+	memcpy(&rtpinfo, &e_rtpinfo, sizeof(rtpinfo));
 	memset(&dialinginfo, 0, sizeof(dialinginfo));
 	dialinginfo.itype = INFO_ITYPE_ISDN;
-	dialinginfo.sending_complete = 0;
+//	dialinginfo.sending_complete = 0;
 	SCPY(dialinginfo.id, e_extdialing);
 
 	/* process prefix */
 	if ((rparam = routeparam(e_action, PARAM_PREFIX)))
 		SPRINT(dialinginfo.id, "%s%s", rparam->string_value, e_extdialing);
 
+	if ((rparam = routeparam(e_action, PARAM_CONTEXT)))
+		SCPY(dialinginfo.context, rparam->string_value);
+
 	/* process keypad */
 	if ((rparam = routeparam(e_action, PARAM_KEYPAD))) {
 		SCPY(dialinginfo.keypad, dialinginfo.id);
@@ -223,8 +202,6 @@ void EndpointAppPBX::action_dialing_external(void)
 
 	/* process number complete */
 	if ((rparam = routeparam(e_action, PARAM_COMPLETE)))
-		if ((rparam = routeparam(e_action, PARAM_PREFIX)))
-			SCPY(dialinginfo.id, rparam->string_value);
 		dialinginfo.sending_complete = 1;
 
 	/* process number type */
@@ -313,6 +290,8 @@ void EndpointAppPBX::action_dialing_external(void)
 	/* add or update outgoing call */
 	trace_header("ACTION extern (calling)", DIRECTION_NONE);
 	add_trace("number", NULL, dialinginfo.id);
+	if (dialinginfo.sending_complete)
+	add_trace("number", "complete", "yes");
 	if (dialinginfo.interfaces[0])
 		add_trace("interfaces", NULL, dialinginfo.interfaces);
 	end_trace();
@@ -321,82 +300,11 @@ void EndpointAppPBX::action_dialing_external(void)
 	memcpy(&message->param.setup.redirinfo, &redirinfo, sizeof(struct redir_info));
 	memcpy(&message->param.setup.callerinfo, &callerinfo, sizeof(struct caller_info));
 	memcpy(&message->param.setup.capainfo, &capainfo, sizeof(struct capa_info));
+	memcpy(&message->param.setup.rtpinfo, &rtpinfo, sizeof(struct rtp_info));
 	message_put(message);
 }
 
 
-void EndpointAppPBX::action_dialing_remote(void)
-{
-	struct route_param	*rparam;
-	struct port_list	*portlist = ea_endpoint->ep_portlist;
-	struct lcr_msg		*message;
-	struct capa_info	capainfo;
-	struct caller_info	callerinfo;
-	struct redir_info	redirinfo;
-	struct dialing_info	dialinginfo;
-	char			context[128] = "";
-	char 			remote[32];
-
-	if (!ea_endpoint->ep_join_id) {
-		/* no join yet, sending setup */
-		if (!(rparam = routeparam(e_action, PARAM_APPLICATION))) {
-			trace_header("ACTION remote (no application given)", DIRECTION_NONE);
-			end_trace();
-			new_state(EPOINT_STATE_OUT_DISCONNECT);
-			message_disconnect_port(portlist, CAUSE_SERVICEUNAVAIL, LOCATION_PRIVATE_LOCAL, "");
-			set_tone(portlist, "cause_3f");
-			return;
-		}
-		SCPY(remote, rparam->string_value);
-		if (!_action_init_call(remote))
-			return;
-
-		/* create bearer/caller/dialinginfo */
-		memcpy(&capainfo, &e_capainfo, sizeof(capainfo));
-		memcpy(&callerinfo, &e_callerinfo, sizeof(callerinfo));
-		memcpy(&redirinfo, &e_redirinfo, sizeof(redirinfo));
-		memset(&dialinginfo, 0, sizeof(dialinginfo));
-
-		if ((rparam = routeparam(e_action, PARAM_CONTEXT))) {
-			SCPY(context, rparam->string_value);
-		}
-		if ((rparam = routeparam(e_action, PARAM_EXTEN))) {
-			SCPY(dialinginfo.id, rparam->string_value);
-			dialinginfo.ntype = INFO_NTYPE_UNKNOWN;
-		} else {
-			SCPY(dialinginfo.id, e_extdialing);
-		}
-		e_extdialing = e_dialinginfo.id + strlen(e_dialinginfo.id);
-		/* send setup to remote */
-		trace_header("ACTION remote (setup)", DIRECTION_NONE);
-		add_trace("number", NULL, dialinginfo.id);
-		add_trace("remote", NULL, remote);
-		if (context[0])
-			add_trace("context", NULL, context);
-		end_trace();
-		message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_SETUP);
-		memcpy(&message->param.setup.dialinginfo, &dialinginfo, sizeof(struct dialing_info));
-		memcpy(&message->param.setup.redirinfo, &redirinfo, sizeof(struct redir_info));
-		memcpy(&message->param.setup.callerinfo, &callerinfo, sizeof(struct caller_info));
-		memcpy(&message->param.setup.capainfo, &capainfo, sizeof(struct capa_info));
-		SCPY(message->param.setup.context, context);
-		message_put(message);
-	} else {
-		/* send overlap digits */
-		trace_header("ACTION remote (dialing)", DIRECTION_NONE);
-		add_trace("number", NULL, e_extdialing);
-		end_trace();
-		if (e_extdialing[0]) {
-			message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_INFORMATION);
-			memcpy(&message->param.information, &e_dialinginfo, sizeof(struct dialing_info));
-			SCPY(message->param.information.id, e_extdialing);
-			e_extdialing = e_dialinginfo.id + strlen(e_dialinginfo.id);
-			message_put(message);
-		}
-	}
-}
-
-
 /*
  * process dialing the "am" and record
  */
@@ -1965,7 +1873,7 @@ void EndpointAppPBX::action_execute(void)
 	int iWaitStatus;
 	char *command = (char *)"";
 	char isdn_port[10];
-	char *argv[11]; /* check also number of args below */
+	char *argv[12]; /* check also number of args below */
 	int i = 0;
 
 	/* get script / command */
@@ -1976,9 +1884,11 @@ void EndpointAppPBX::action_execute(void)
 		end_trace();
 		return;
 	}
+#if 0
 	argv[i++] = (char *)"/bin/sh";
 	argv[i++] = (char *)"-c";
 	argv[i++] = command;
+#endif
 	argv[i++] = command;
 	if ((rparam = routeparam(e_action, PARAM_PARAM))) {
 		argv[i++] = rparam->string_value;
@@ -1989,6 +1899,7 @@ void EndpointAppPBX::action_execute(void)
 	argv[i++] = e_callerinfo.name;
 	SPRINT(isdn_port, "%d", e_callerinfo.isdn_port);
 	argv[i++] = isdn_port;
+	argv[i++] = e_callerinfo.imsi;
 	argv[i++] = NULL; /* check also number of args above */
 	switch (pid = fork ()) {
 		case -1:
@@ -1998,12 +1909,10 @@ void EndpointAppPBX::action_execute(void)
 		case 0:
 			/* To be shure there are no zombies created double fork */
 			if ((pid2 = fork()) == 0) {
-				execve("/bin/sh", argv, environ);
-			}
-			else {
-				/* Exit immediately and release the waiting parent. The subprocess falls to init because the parent died */
-				exit(0);
+				execve(command, argv, environ);
 			}
+			/* Exit immediately and release the waiting parent. The subprocess falls to init because the parent died */
+			exit(0);
 			break;
 		default:
 			trace_header("ACTION execute", DIRECTION_NONE);
@@ -2140,6 +2049,398 @@ void EndpointAppPBX::action_dialing_password_wr(void)
 }
 
 
+/* process pots-retrieve
+ */
+void EndpointAppPBX::action_init_pots_retrieve(void)
+{
+	struct route_param *rparam;
+	struct port_list *portlist = ea_endpoint->ep_portlist;
+	class Port *port;
+	class Pfxs *ourfxs, *fxs;
+	int count = 0;
+	class Endpoint *epoint;
+
+	/* check given call */
+	if (!(rparam = routeparam(e_action, PARAM_POTS_CALL))) {
+		trace_header("ACTION pots-retrieve (no call given)", DIRECTION_NONE);
+		end_trace();
+
+		disconnect:
+		new_state(EPOINT_STATE_OUT_DISCONNECT);
+		message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, "");
+		set_tone(portlist, "cause_3f");
+		e_action = NULL;
+		return;
+	}
+
+	/* find call */
+	port = find_port_id(portlist->port_id);
+	if (!port)
+		goto disconnect;
+	if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) {
+		trace_header("ACTION pots-retrieve (call not of FXS type)", DIRECTION_NONE);
+		end_trace();
+		goto disconnect;
+	}
+	ourfxs = (class Pfxs *)port;
+
+	port = port_first;
+	while(port) {
+		if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) {
+			fxs = (class Pfxs *)port;
+			if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) {
+				count++;
+				if (count == rparam->integer_value)
+					break;
+			}
+		}
+		port = port->next;
+	}
+	if (!port) {
+		trace_header("ACTION pots-retrieve (call # does not exist)", DIRECTION_NONE);
+		end_trace();
+		goto disconnect;
+	}
+
+#ifdef ISDN_P_FXS_POTS
+	/* release our call */
+	ourfxs->hangup_ind(0);
+
+	/* retrieve selected call */
+	fxs->retrieve_ind(0);
+#endif
+
+	/* split if selected call is member of a 3pty */
+	epoint = find_epoint_id(ACTIVE_EPOINT(fxs->p_epointlist));
+	if (epoint && epoint->ep_app_type == EAPP_TYPE_PBX) {
+		PDEBUG(DEBUG_EPOINT, "EPOINT(%d) try spliting 3pty. this may fail because we don't have a 3pty.\n", epoint->ep_serial);
+		((class EndpointAppPBX *)epoint->ep_app)->split_3pty();
+	}
+}
+
+
+/* process pots-release
+ */
+void EndpointAppPBX::action_init_pots_release(void)
+{
+	struct route_param *rparam;
+	struct port_list *portlist = ea_endpoint->ep_portlist;
+	class Port *port;
+	class Pfxs *ourfxs, *fxs;
+	int count = 0;
+
+	/* check given call */
+	if (!(rparam = routeparam(e_action, PARAM_POTS_CALL))) {
+		trace_header("ACTION pots-release (no call given)", DIRECTION_NONE);
+		end_trace();
+
+		disconnect:
+		new_state(EPOINT_STATE_OUT_DISCONNECT);
+		message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, "");
+		set_tone(portlist, "cause_3f");
+		e_action = NULL;
+		return;
+	}
+
+	/* find call */
+	port = find_port_id(portlist->port_id);
+	if (!port)
+		goto disconnect;
+	if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) {
+		trace_header("ACTION pots-release (call not of FXS type)", DIRECTION_NONE);
+		end_trace();
+		goto disconnect;
+	}
+	ourfxs = (class Pfxs *)port;
+
+	port = port_first;
+	while(port) {
+		if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) {
+			fxs = (class Pfxs *)port;
+			if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) {
+				count++;
+				if (count == rparam->integer_value)
+					break;
+			}
+		}
+		port = port->next;
+	}
+	if (!port) {
+		trace_header("ACTION pots-release (call # does not exist)", DIRECTION_NONE);
+		end_trace();
+		goto disconnect;
+	}
+
+#if 0
+	/* disconnect our call */
+	new_state(EPOINT_STATE_OUT_DISCONNECT);
+	message_disconnect_port(portlist, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, "");
+	set_tone(portlist, "hangup");
+	e_action = NULL;
+#endif
+
+#ifdef ISDN_P_FXS_POTS
+	/* release selected call */
+	fxs->hangup_ind(0);
+#endif
+
+	/* indicate timeout, so next action will be processed */
+	process_dialing(1);
+}
+
+
+/* process pots-reject
+ */
+void EndpointAppPBX::action_init_pots_reject(void)
+{
+	struct port_list *portlist = ea_endpoint->ep_portlist;
+	class Port *port;
+	class Pfxs *ourfxs, *fxs;
+
+	/* find call */
+	port = find_port_id(portlist->port_id);
+	if (!port)
+		goto disconnect;
+	if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) {
+		trace_header("ACTION pots-reject (call not of FXS type)", DIRECTION_NONE);
+		end_trace();
+		disconnect:
+		new_state(EPOINT_STATE_OUT_DISCONNECT);
+		message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, "");
+		set_tone(portlist, "cause_3f");
+		e_action = NULL;
+		return;
+	}
+	ourfxs = (class Pfxs *)port;
+
+	port = port_first;
+	while(port) {
+		if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) {
+			fxs = (class Pfxs *)port;
+			if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) {
+				if (fxs->p_state == PORT_STATE_OUT_ALERTING)
+					break;
+			}
+		}
+		port = port->next;
+	}
+	if (!port) {
+		trace_header("ACTION pots-reject (no call waiting)", DIRECTION_NONE);
+		end_trace();
+		goto disconnect;
+	}
+
+#ifdef ISDN_P_FXS_POTS
+	/* reject alerting call */
+	fxs->reject_ind(0);
+#endif
+
+	/* indicate timeout, so next action will be processed */
+	process_dialing(1);
+}
+
+
+/* process pots-answer
+ */
+void EndpointAppPBX::action_init_pots_answer(void)
+{
+	struct port_list *portlist = ea_endpoint->ep_portlist;
+	class Port *port;
+	class Pfxs *ourfxs, *fxs;
+
+	/* find call */
+	port = find_port_id(portlist->port_id);
+	if (!port)
+		goto disconnect;
+	if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) {
+		trace_header("ACTION pots-answer (call not of FXS type)", DIRECTION_NONE);
+		end_trace();
+		disconnect:
+		new_state(EPOINT_STATE_OUT_DISCONNECT);
+		message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, "");
+		set_tone(portlist, "cause_3f");
+		e_action = NULL;
+		return;
+	}
+	ourfxs = (class Pfxs *)port;
+
+	port = port_first;
+	while(port) {
+		if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) {
+			fxs = (class Pfxs *)port;
+			if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) {
+				if (fxs->p_state == PORT_STATE_OUT_ALERTING)
+					break;
+			}
+		}
+		port = port->next;
+	}
+	if (!port) {
+		trace_header("ACTION pots-answer (no call waiting)", DIRECTION_NONE);
+		end_trace();
+		goto disconnect;
+	}
+
+#ifdef ISDN_P_FXS_POTS
+	/* release our call */
+	ourfxs->hangup_ind(0);
+
+	/* answer alerting call */
+	fxs->answer_ind(0);
+#endif
+}
+
+
+/* process pots-3pty
+ */
+void EndpointAppPBX::action_init_pots_3pty(void)
+{
+	struct port_list *portlist = ea_endpoint->ep_portlist;
+	class Port *port;
+	class Pfxs *ourfxs, *fxs, *fxs1 = NULL, *fxs2 = NULL;
+	class Endpoint *epoint;
+	int count = 0;
+
+	/* find call */
+	port = find_port_id(portlist->port_id);
+	if (!port)
+		goto disconnect;
+	if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) {
+		trace_header("ACTION pots-3pty (call not of FXS type)", DIRECTION_NONE);
+		end_trace();
+		disconnect:
+		new_state(EPOINT_STATE_OUT_DISCONNECT);
+		message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, "");
+		set_tone(portlist, "cause_3f");
+		e_action = NULL;
+		return;
+	}
+	ourfxs = (class Pfxs *)port;
+
+	port = port_first;
+	while(port) {
+		if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) {
+			fxs = (class Pfxs *)port;
+			if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) {
+				if (count == 0)
+					fxs1 = fxs;
+				if (count == 1)
+					fxs2 = fxs;
+				count++;
+			}
+		}
+		port = port->next;
+	}
+	if (count != 2) {
+		trace_header("ACTION pots-3pty (exactly two calls don't exist)", DIRECTION_NONE);
+		end_trace();
+		goto disconnect;
+	}
+
+#ifdef ISDN_P_FXS_POTS
+	/* release our call */
+	ourfxs->hangup_ind(0);
+#endif
+
+#ifdef ISDN_P_FXS_POTS
+	/* retrieve latest active call */
+	if (fxs2->p_m_fxs_age > fxs1->p_m_fxs_age) {
+		fxs2->retrieve_ind(0);
+		epoint = find_epoint_id(ACTIVE_EPOINT(fxs2->p_epointlist));
+	} else {
+		fxs1->retrieve_ind(0);
+		epoint = find_epoint_id(ACTIVE_EPOINT(fxs2->p_epointlist));
+	}
+#else
+	epoint = NULL;
+#endif
+
+	if (!epoint) {
+		trace_header("ACTION pots-3pty (interal error: no endpoint)", DIRECTION_NONE);
+		end_trace();
+		return;
+	}
+
+	if (epoint->ep_app_type != EAPP_TYPE_PBX) {
+		trace_header("ACTION pots-3pty (interal error: endpoint not PBX type)", DIRECTION_NONE);
+		end_trace();
+		return;
+	}
+
+	/* bridge calls */
+	if (((class EndpointAppPBX *)epoint->ep_app)->join_3pty_fxs()) {
+		trace_header("ACTION pots-3pty (interal error: join_3pty_fsx failed)", DIRECTION_NONE);
+		end_trace();
+		return;
+	}
+}
+
+/* process pots-transfer
+ */
+void EndpointAppPBX::action_init_pots_transfer(void)
+{
+	struct route_param *rparam;
+	struct port_list *portlist = ea_endpoint->ep_portlist;
+	class Port *port;
+	class Pfxs *ourfxs, *fxs, *fxs1 = NULL, *fxs2 = NULL;
+	int count = 0;
+
+	/* check given call */
+	if (!(rparam = routeparam(e_action, PARAM_POTS_CALL))) {
+		trace_header("ACTION pots-transfer (no call given)", DIRECTION_NONE);
+		end_trace();
+
+		disconnect:
+		new_state(EPOINT_STATE_OUT_DISCONNECT);
+		message_disconnect_port(portlist, CAUSE_UNSPECIFIED, LOCATION_PRIVATE_LOCAL, "");
+		set_tone(portlist, "cause_3f");
+		e_action = NULL;
+		return;
+	}
+
+	/* find call */
+	port = find_port_id(portlist->port_id);
+	if (!port)
+		goto disconnect;
+	if ((port->p_type & PORT_CLASS_POTS_MASK) != PORT_CLASS_POTS_FXS) {
+		trace_header("ACTION pots-transfer (call not of FXS type)", DIRECTION_NONE);
+		end_trace();
+		goto disconnect;
+	}
+	ourfxs = (class Pfxs *)port;
+
+	port = port_first;
+	while(port) {
+		if ((port->p_type & PORT_CLASS_POTS_MASK) == PORT_CLASS_POTS_FXS) {
+			fxs = (class Pfxs *)port;
+			if (fxs->p_m_mISDNport == ourfxs->p_m_mISDNport && fxs != ourfxs) {
+				if (count == 0)
+					fxs1 = fxs;
+				if (count == 1)
+					fxs2 = fxs;
+				count++;
+			}
+		}
+		port = port->next;
+	}
+	if (count != 2) {
+		trace_header("ACTION pots-transfer (exactly two calls don't exist)", DIRECTION_NONE);
+		end_trace();
+		goto disconnect;
+	}
+
+#ifdef ISDN_P_FXS_POTS
+	/* retrieve call */
+	if (fxs2->p_m_fxs_age > fxs1->p_m_fxs_age)
+		fxs2->retrieve_ind(0);
+	else
+		fxs1->retrieve_ind(0);
+#endif
+	/* bridge calls */
+	join_join_fxs();
+}
+
+
 /* general process dialing of incoming call
  * depending on the detected prefix, subfunctions above (action_*) will be
  * calles.
@@ -2268,12 +2569,6 @@ void EndpointAppPBX::process_dialing(int timeout)
 			e_action = &action_internal;
 			goto process_action;
 		}
-		/* check for chan call */
-		if (!strncmp(e_dialinginfo.id, "remote:", 7)) {
-			e_extdialing = e_dialinginfo.id+7;
-			e_action = &action_remote;
-			goto process_action;
-		}
 		/* check for vbox call */
 		if (!strncmp(e_dialinginfo.id, "vbox:", 5)) {
 			e_extdialing = e_dialinginfo.id+5;
@@ -2282,11 +2577,12 @@ void EndpointAppPBX::process_dialing(int timeout)
 		}
 
 		gettimeofday(&current_time, NULL);
-		if (timeout && TIME_SMALLER(&e_match_timeout.timeout, &current_time)) {
+		if (e_match_to_action && TIME_SMALLER(&e_match_timeout.timeout, &current_time)) {
 			/* return timeout rule */
 			PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal '%s' dialing: '%s', timeout in ruleset '%s'\n", ea_endpoint->ep_serial, e_ext.number, e_dialinginfo.id, e_ruleset->name);
 			unsched_timer(&e_match_timeout);
 			e_action = e_match_to_action;
+			e_match_to_action = NULL;
 			e_extdialing = e_match_to_extdialing;
 			trace_header("ROUTING (timeout)", DIRECTION_NONE);
 			add_trace("action", NULL, "%s", action_defs[e_action->index].name);