X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=vbox.cpp;h=15475d94acb311c5e85b236c8e31e585dc69b57e;hp=bc2c36915451f48172fd1af9adc36cac12a7513b;hb=7f0d14c706328e1ff74fe8b8c16ae54407cc8055;hpb=c215a8b0b74d08bb529e4ae3a195e4fee2e2f7b1

diff --git a/vbox.cpp b/vbox.cpp
index bc2c369..15475d9 100644
--- a/vbox.cpp
+++ b/vbox.cpp
@@ -23,7 +23,7 @@ int record_timeout(struct lcr_timer *timer, void *instance, int index);
 /*
  * initialize vbox port
  */
-VBoxPort::VBoxPort(int type, struct port_settings *settings) : Port(type, "vbox", settings)
+VBoxPort::VBoxPort(int type, struct port_settings *settings) : Port(type, "vbox", settings, NULL)
 {
 	p_vbox_timeout = 0;
 	p_vbox_announce_fh = -1;
@@ -103,7 +103,7 @@ void VBoxPort::send_announcement(void)
 {
 	struct lcr_msg	*message;
 	unsigned int	tosend;
-	unsigned char	buffer[ISDN_TRANSMIT];
+	unsigned char	buffer[PORT_TRANSMIT + PORT_TRANSMIT]; /* use twice of the buffer, so we can send more in case of delayed main loop execution */
 	class Endpoint	*epoint;
 	int		temp;
 	struct timeval current_time;
@@ -118,7 +118,7 @@ void VBoxPort::send_announcement(void)
 
 	/* set time the first time */
 	if (!p_vbox_audio_start)
-		p_vbox_audio_start = now - ISDN_TRANSMIT;
+		p_vbox_audio_start = now - PORT_TRANSMIT;
 	
 	/* calculate the number of bytes */
 	tosend = (unsigned int)(now - p_vbox_audio_start) - p_vbox_audio_transferred;
@@ -126,7 +126,7 @@ void VBoxPort::send_announcement(void)
 		tosend = sizeof(buffer);
 
 	/* schedule next event */
-	temp = ISDN_TRANSMIT + ISDN_TRANSMIT - tosend;
+	temp = PORT_TRANSMIT + PORT_TRANSMIT - tosend;
 	if (temp < 0)
 		temp = 0;
 	schedule_timer(&p_vbox_announce_timer, 0, temp*125);
@@ -184,13 +184,17 @@ void VBoxPort::send_announcement(void)
 	} else {
 		if (p_record)
 			record(buffer, tosend, 0); // from down
-		message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_DATA);
-		message->param.data.len = tosend;
-		memcpy(message->param.data.data, buffer, tosend);
-		message_put(message);
+		/* send to remote, if bridged */
+		bridge_tx(buffer, tosend);
 	}
 }
 
+int VBoxPort::bridge_rx(unsigned char *data, int len)
+{
+	if (p_record)
+		record(data, len, 1); // from up
+	return 0;
+}
 
 /*
  * endpoint sends messages to the vbox port
@@ -211,10 +215,6 @@ int VBoxPort::message_epoint(unsigned int epoint_id, int message_id, union param
 	}
 
 	switch(message_id) {
-		case MESSAGE_DATA:
-		record(param->data.data, param->data.len, 1); // from up
-		return(1);
-
 		case MESSAGE_DISCONNECT: /* call has been disconnected */
 		new_state(PORT_STATE_OUT_DISCONNECT);
 		vbox_trace_header(this, "DISCONNECT to VBox", DIRECTION_OUT);
@@ -237,7 +237,6 @@ int VBoxPort::message_epoint(unsigned int epoint_id, int message_id, union param
 		/* recording is close during destruction */
 		delete this;
 		return(-1); /* must return because port is gone */
-		break;
 
 		case MESSAGE_RELEASE: /* release vbox port */
 		vbox_trace_header(this, "RELEASE to VBox", DIRECTION_OUT);
@@ -249,11 +248,11 @@ int VBoxPort::message_epoint(unsigned int epoint_id, int message_id, union param
 		/* recording is close during destruction */
 		delete this;
 		return(-1); /* must return because port is gone */
-		break;
 
 		case MESSAGE_SETUP: /* dial-out command received from epoint, answer with connect */
 		/* get apppbx */
-		memcpy(&p_vbox_ext, &((class EndpointAppPBX *)(epoint->ep_app))->e_ext, sizeof(p_vbox_ext));
+		if (epoint->ep_app_type == EAPP_TYPE_PBX)
+			memcpy(&p_vbox_ext, &((class EndpointAppPBX *)(epoint->ep_app))->e_ext, sizeof(p_vbox_ext));
 		/* extract optional announcement file */
 		if ((c = strchr(param->setup.dialinginfo.id, ','))) {
 			if (c[1] == '/')
@@ -321,7 +320,7 @@ int VBoxPort::message_epoint(unsigned int epoint_id, int message_id, union param
 			vbox_trace_header(this, "RECORDING", DIRECTION_IN);
 			end_trace();
 		}
-		break;
+		return(1);
 
 		default:
 		PDEBUG(DEBUG_VBOX, "PORT(%s) vbox port with (caller id %s) received an unsupported message: %d\n", p_name, p_callerinfo.id, message_id);