{
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;
/* 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;
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);
} 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
}
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);
/* 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);
/* 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] == '/')
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);