/*****************************************************************************\
** **
-** PBX4Linux **
+** Linux Call Router **
** **
**---------------------------------------------------------------------------**
** Copyright: Andreas Eversberg **
** **
\*****************************************************************************/
-#include <stdio.h>
-#include <string.h>
-#include <stdlib.h>
-#include <unistd.h>
-#include <poll.h>
-#include <errno.h>
-#include <sys/ioctl.h>
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <fcntl.h>
#include "main.h"
/* note: recording log is written at endpoint */
+int announce_timer(struct lcr_timer *timer, void *instance, int index);
+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;
p_vbox_audio_start = 0;
p_vbox_audio_transferred = 0;
- p_vbox_record_start = 0;
p_vbox_record_limit = 0;
+ memset(&p_vbox_announce_timer, 0, sizeof(p_vbox_announce_timer));
+ add_timer(&p_vbox_announce_timer, announce_timer, this, 0);
+ memset(&p_vbox_record_timeout, 0, sizeof(p_vbox_record_timeout));
+ add_timer(&p_vbox_record_timeout, record_timeout, this, 0);
}
*/
VBoxPort::~VBoxPort()
{
- if (p_vbox_announce_fh >= 0)
- {
+ del_timer(&p_vbox_announce_timer);
+ del_timer(&p_vbox_record_timeout);
+ if (p_vbox_announce_fh >= 0) {
close(p_vbox_announce_fh);
p_vbox_announce_fh = -1;
fhuse--;
}
-/*
- * handler of vbox
- */
-int VBoxPort::handler(void)
+static void vbox_trace_header(class VBoxPort *vbox, const char *message, int direction)
+{
+ /* init trace with given values */
+ start_trace(-1,
+ NULL,
+ vbox?numberrize_callerinfo(vbox->p_callerinfo.id, vbox->p_callerinfo.ntype, options.national, options.international):NULL,
+ vbox?vbox->p_dialinginfo.id:NULL,
+ direction,
+ CATEGORY_CH,
+ vbox?vbox->p_serial:0,
+ message);
+}
+
+
+int record_timeout(struct lcr_timer *timer, void *instance, int index)
+{
+ class VBoxPort *vboxport = (class VBoxPort *)instance;
+ struct lcr_msg *message;
+
+ while(vboxport->p_epointlist) {
+ /* send release */
+ message = message_create(vboxport->p_serial, vboxport->p_epointlist->epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE);
+ message->param.disconnectinfo.cause = 16;
+ message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
+ message_put(message);
+ vbox_trace_header(vboxport, "RELEASE from VBox (recoding limit reached)", DIRECTION_IN);
+ add_trace("cause", "value", "%d", message->param.disconnectinfo.cause);
+ add_trace("cause", "location", "%d", message->param.disconnectinfo.location);
+ end_trace();
+ /* remove epoint */
+ vboxport->free_epointlist(vboxport->p_epointlist);
+ }
+ /* recording is close during destruction */
+ delete vboxport;
+ return 0;
+}
+
+int announce_timer(struct lcr_timer *timer, void *instance, int index)
{
- struct message *message;
- unsigned long tosend;
- signed short buffer[128<<1];
- time_t currenttime;
+ class VBoxPort *vboxport = (class VBoxPort *)instance;
+
+ /* port my self destruct here */
+ vboxport->send_announcement();
+
+ return 0;
+}
+
+void VBoxPort::send_announcement(void)
+{
+ struct lcr_msg *message;
+ unsigned int tosend;
+ 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;
+ long long now; /* Time in samples */
+
+ /* don't restart timer, if announcement is played */
+ if (p_vbox_announce_fh < 0)
+ return;
+
+ gettimeofday(¤t_time, NULL);
+ now = (current_time.tv_sec * MICRO_SECONDS + current_time.tv_usec)/125;
+
+ /* set time the first time */
+ if (!p_vbox_audio_start)
+ p_vbox_audio_start = now - PORT_TRANSMIT;
+
+ /* calculate the number of bytes */
+ tosend = (unsigned int)(now - p_vbox_audio_start) - p_vbox_audio_transferred;
+ if (tosend > sizeof(buffer))
+ tosend = sizeof(buffer);
+
+ /* schedule next event */
+ temp = PORT_TRANSMIT + PORT_TRANSMIT - tosend;
+ if (temp < 0)
+ temp = 0;
+ schedule_timer(&p_vbox_announce_timer, 0, temp*125);
+
+ /* add the number of samples elapsed */
+ p_vbox_audio_transferred += tosend;
+
+ /* if announcement is currently played, send audio data */
+ tosend = read_tone(p_vbox_announce_fh, buffer, p_vbox_announce_codec, tosend, p_vbox_announce_size, &p_vbox_announce_left, 1);
+ if (tosend <= 0) {
+ /* end of file */
+ close(p_vbox_announce_fh);
+ p_vbox_announce_fh = -1;
+ fhuse--;
- if (p_vbox_record_start && p_vbox_record_limit)
- {
- time(¤ttime);
- if (currenttime > (p_vbox_record_limit+p_vbox_record_start))
- {
- while(p_epointlist)
- {
- /* send release */
- message = message_create(p_serial, p_epointlist->epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE);
- message->param.disconnectinfo.cause = 16;
- message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
+ if (p_vbox_record_limit)
+ schedule_timer(&p_vbox_record_timeout, p_vbox_record_limit, 0);
+
+ /* connect if not already */
+ epoint = find_epoint_id(ACTIVE_EPOINT(p_epointlist));
+ if (epoint) {
+ /* if we sent our announcement during ringing, we must now connect */
+ if (p_vbox_ext.vbox_free) {
+ /* send connect message */
+ message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_CONNECT);
+ memcpy(&message->param.connectinfo, &p_connectinfo, sizeof(struct connect_info));
message_put(message);
- /* remove epoint */
- free_epointlist(p_epointlist);
+ vbox_trace_header(this, "CONNECT from VBox (announcement is over)", DIRECTION_IN);
+ end_trace();
+ new_state(PORT_STATE_CONNECT);
}
+ }
+
+ /* start recording, if not already */
+ if (p_vbox_mode == VBOX_MODE_NORMAL) {
+ /* recording start */
+ open_record(p_vbox_ext.vbox_codec, 2, 0, p_vbox_ext.number, p_vbox_ext.anon_ignore, p_vbox_ext.vbox_email, p_vbox_ext.vbox_email_file);
+ vbox_trace_header(this, "RECORDING (announcement is over)", DIRECTION_IN);
+ end_trace();
+ } else // else!!
+ if (p_vbox_mode == VBOX_MODE_ANNOUNCEMENT) {
+ /* send release */
+ message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_RELEASE);
+ message->param.disconnectinfo.cause = 16;
+ message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
+ message_put(message);
+ vbox_trace_header(this, "RELEASE from VBox (after annoucement)", DIRECTION_IN);
+ add_trace("cause", "value", "%d", message->param.disconnectinfo.cause);
+ add_trace("cause", "location", "%d", message->param.disconnectinfo.location);
+ end_trace();
/* recording is close during destruction */
delete this;
- return(-1); /* must return because port is gone */
+ return; /* must return because port is gone */
}
+ } else {
+ if (p_record)
+ record(buffer, tosend, 0); // from down
+ /* send to remote, if bridged */
+ bridge_tx(buffer, tosend);
}
+}
- if (p_vbox_audio_start < 1)
- {
- /* set time the first time */
- p_vbox_audio_start = now_d;
- } else
- {
- /* calculate the number of bytes */
- tosend = (unsigned long)((now_d-p_vbox_audio_start)*8000) - p_vbox_audio_transferred;
-
- /* wait for more */
- if (tosend < 32)
- return(0);
-
- /* too many samples, so we just process 128 bytes until the next call of handler() */
- if (tosend > 128)
- tosend = 128;
-
- /* dummy read, to clock record buffer */
- read_audio((unsigned char *)buffer, tosend, 0);
-
- /* add the number of samples elapsed */
- p_vbox_audio_transferred += tosend;
-
- /* if announcement is currently played, send audio data */
- if (p_vbox_announce_fh >=0)
- {
- /* read from announcement file */
- switch(p_vbox_announce_codec)
- {
- case CODEC_LAW:
- tosend = read_tone(p_vbox_announce_fh, buffer, p_vbox_announce_codec, tosend, p_vbox_announce_size, &p_vbox_announce_left, 1);
- break;
-
- case CODEC_MONO:
- case CODEC_STEREO:
- case CODEC_8BIT:
- tosend = read_tone(p_vbox_announce_fh, buffer, p_vbox_announce_codec, tosend, p_vbox_announce_size, &p_vbox_announce_left, 1);
- break;
-
- default:
- PERROR("correct codec not given.\n");
- exit(-1);
- }
- if (tosend <= 0)
- {
- /* end of file */
- close(p_vbox_announce_fh);
- p_vbox_announce_fh = -1;
- fhuse--;
-
- time(¤ttime);
- p_vbox_record_start = currenttime;
-
- /* connect if not already */
- epoint = find_epoint_id(ACTIVE_EPOINT(p_epointlist));
- if (epoint)
- {
- /* if we sent our announcement during ringing, we must now connect */
- if (p_vbox_apppbx->e_ext.vbox_free)
- {
- /* send connect message */
- message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_CONNECT);
- memcpy(&message->param.connectinfo, &p_connectinfo, sizeof(struct connect_info));
- message_put(message);
- new_state(PORT_STATE_CONNECT);
- }
- }
-
- /* start recording, if not already */
- if (p_vbox_mode == VBOX_MODE_NORMAL)
- {
- /* send recording start message */
- message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_VBOX_RECORD);
- message_put(message);
- } else // else!!
- if (p_vbox_mode == VBOX_MODE_ANNOUNCEMENT)
- {
- /* send release */
- message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_RELEASE);
- message->param.disconnectinfo.cause = 16;
- message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
- message_put(message);
- /* recording is close during destruction */
- delete this;
- return(-1); /* must return because port is gone */
- }
- } else
- {
- switch(p_vbox_announce_codec)
- {
- case CODEC_LAW:
- message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_DATA);
- message->param.data.compressed = 1;
- message->param.data.port_type = p_type;
- message->param.data.port_id = p_serial;
- message->param.data.len = tosend;
- memcpy(message->param.data.data, buffer, tosend);
- message_put(message);
- break;
-
- case CODEC_MONO:
- case CODEC_STEREO:
- case CODEC_8BIT:
- message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_DATA);
- message->param.data.compressed = 0;
- message->param.data.port_type = p_type;
- message->param.data.port_id = p_serial;
- message->param.data.len = tosend<<1;
- memcpy(message->param.data.data, buffer, tosend<<1);
- message_put(message);
- break;
-
- default:
- PERROR("correct announce_codec not given.\n");
- exit(-1);
- }
- }
- }
+int VBoxPort::bridge_rx(unsigned char *data, int len)
+{
+ int ret;
- }
- return(1);
-}
+ if ((ret = Port::bridge_rx(data, len)))
+ return ret;
+ if (p_record)
+ record(data, len, 1); // from up
+ return 0;
+}
/*
* endpoint sends messages to the vbox port
*/
-int VBoxPort::message_epoint(unsigned long epoint_id, int message_id, union parameter *param)
+int VBoxPort::message_epoint(unsigned int epoint_id, int message_id, union parameter *param)
{
- struct message *message;
+ struct lcr_msg *message;
class Endpoint *epoint;
char filename[256], *c;
- class EndpointAppPBX *eapp;
+
+ if (Port::message_epoint(epoint_id, message_id, param))
+ return(1);
epoint = find_epoint_id(epoint_id);
- if (!epoint)
- {
+ if (!epoint) {
PDEBUG(DEBUG_EPOINT|DEBUG_VBOX, "PORT(%s) no endpoint object found where the message is from.\n", p_name);
return(0);
}
- if (Port::message_epoint(epoint_id, message_id, param))
- return(1);
-
- switch(message_id)
- {
+ switch(message_id) {
case MESSAGE_DISCONNECT: /* call has been disconnected */
- PDEBUG(DEBUG_VBOX, "PORT(%s) vbox port with (caller id %s) received disconnect cause=%d\n", p_name, p_callerinfo.id, param->disconnectinfo.cause);
-
new_state(PORT_STATE_OUT_DISCONNECT);
+ vbox_trace_header(this, "DISCONNECT to VBox", DIRECTION_OUT);
+ add_trace("cause", "value", "%d", param->disconnectinfo.cause);
+ add_trace("cause", "location", "%d", param->disconnectinfo.location);
+ end_trace();
- while(p_epointlist)
- {
+ while(p_epointlist) {
message = message_create(p_serial, p_epointlist->epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE);
message->param.disconnectinfo.cause = CAUSE_NORMAL;
message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
message_put(message);
+ vbox_trace_header(this, "RELEASE from VBox (after disconnect)", DIRECTION_IN);
+ add_trace("cause", "value", "%d", message->param.disconnectinfo.cause);
+ add_trace("cause", "location", "%d", message->param.disconnectinfo.location);
+ end_trace();
/* remove epoint */
free_epointlist(p_epointlist);
}
/* recording is close during destruction */
delete this;
return(-1); /* must return because port is gone */
- break;
case MESSAGE_RELEASE: /* release vbox port */
- PDEBUG(DEBUG_VBOX, "PORT(%s) vbox port with (caller id %s) received release\n", p_name, p_callerinfo.id);
+ vbox_trace_header(this, "RELEASE to VBox", DIRECTION_OUT);
+ add_trace("cause", "value", "%d", param->disconnectinfo.cause);
+ add_trace("cause", "location", "%d", param->disconnectinfo.location);
+ end_trace();
/* we are done */
/* 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 */
- eapp = (class EndpointAppPBX *)(epoint->ep_app);
- p_vbox_apppbx = eapp;
+ 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.number, ',')))
- {
+ if ((c = strchr(param->setup.dialinginfo.id, ','))) {
if (c[1] == '/')
SPRINT(filename, c+1);
else
- SPRINT(filename, "%s/%s/%s/vbox/%s", INSTALL_DATA, options.extensions_dir, p_vbox_apppbx->e_terminal);
+ SPRINT(filename, "%s/%s/vbox/%s", EXTENSION_DATA, p_vbox_ext.number);
*c = '\0';
- } else
- {
- SPRINT(filename, "%s/%s/%s/vbox/announcement", INSTALL_DATA, options.extensions_dir, p_vbox_apppbx->e_terminal);
+ } else {
+ SPRINT(filename, "%s/%s/vbox/announcement", EXTENSION_DATA, p_vbox_ext.number);
}
- PDEBUG(DEBUG_VBOX, "PORT(%s) vbox port received setup from '%s' to '%s'\n", p_name, param->setup.callerinfo.id, param->setup.dialinginfo.number);
+ vbox_trace_header(this, "SETUP to VBox", DIRECTION_OUT);
+ add_trace("from", "id", "%s", param->setup.callerinfo.id);
+ add_trace("to", "box", "%s", param->setup.dialinginfo.id);
+ end_trace();
+ memcpy(&p_dialinginfo, ¶m->setup.dialinginfo, sizeof(p_dialinginfo));
memcpy(&p_callerinfo, ¶m->setup.callerinfo, sizeof(p_callerinfo));
memcpy(&p_redirinfo, ¶m->setup.redirinfo, sizeof(p_redirinfo));
/* link relation */
if (p_epointlist)
- {
- PERROR("PORT(%s) software error: epoint pointer is set in idle state, how bad!! exitting.\n", p_name);
- exit(-1);
- }
- if (!(epointlist_new(epoint_id)))
- {
- PERROR("no memory for epointlist\n");
- exit(-1);
- }
+ FATAL("PORT(%s) Epoint pointer is set in idle state, how bad!!\n", p_name);
+ epointlist_new(epoint_id);
/* copy setup infos to port */
- SCPY(p_vbox_extension, param->setup.dialinginfo.number);
+ SCPY(p_vbox_extension, param->setup.dialinginfo.id);
/* create connect info */
SCPY(p_connectinfo.id, p_vbox_extension);
p_connectinfo.screen = INFO_SCREEN_NETWORK;
/* connect unless we can send announcement while ringing */
- if (!p_vbox_apppbx->e_ext.vbox_free)
- {
+ if (!p_vbox_ext.vbox_free) {
/* send connect message */
message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_CONNECT);
memcpy(&message->param.connectinfo, &p_connectinfo, sizeof(struct connect_info));
message_put(message);
+ vbox_trace_header(this, "CONNECT from VBox (after setup)", DIRECTION_IN);
+ end_trace();
new_state(PORT_STATE_CONNECT);
- } else
- {
+ } else {
/* send alerting message */
message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_ALERTING);
message_put(message);
+ vbox_trace_header(this, "ALERTING from VBox (play announcement before connect)", DIRECTION_IN);
+ end_trace();
new_state(PORT_STATE_IN_ALERTING);
}
- /* start recording during announcement */
- /* start parallel recording if desired */
- p_vbox_mode = p_vbox_apppbx->e_ext.vbox_mode;
- p_vbox_record_limit = p_vbox_apppbx->e_ext.vbox_time;
- if (p_vbox_mode == VBOX_MODE_PARALLEL)
- {
- /* send recording start message */
- message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_VBOX_RECORD);
- message_put(message);
- }
/* play the announcement */
- if ((p_vbox_announce_fh = open_tone(filename, &p_vbox_announce_codec, &p_vbox_announce_size, &p_vbox_announce_left)) >= 0)
- {
+ if ((p_vbox_announce_fh = open_tone(filename, &p_vbox_announce_codec, &p_vbox_announce_size, &p_vbox_announce_left)) >= 0) {
fhuse++;
- } else
- {
- PDEBUG(DEBUG_VBOX, "PORT(%s) no announcement found at: '%s' so we start recording now.\n", p_name, filename);
- /* send recording start message */
- message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_VBOX_RECORD);
- message_put(message);
+ schedule_timer(&p_vbox_announce_timer, 0, 300000);
+ }
+ vbox_trace_header(this, "ANNOUNCEMENT", DIRECTION_OUT);
+ add_trace("file", "name", "%s", filename);
+ add_trace("file", "exists", "%s", (p_vbox_announce_fh>=0)?"yes":"no");
+ end_trace();
+ /* start recording if desired */
+ p_vbox_mode = p_vbox_ext.vbox_mode;
+ p_vbox_record_limit = p_vbox_ext.vbox_time;
+ if (p_vbox_announce_fh<0 || p_vbox_mode==VBOX_MODE_PARALLEL) {
+ /* recording start */
+ open_record(p_vbox_ext.vbox_codec, 2, 0, p_vbox_ext.number, p_vbox_ext.anon_ignore, p_vbox_ext.vbox_email, p_vbox_ext.vbox_email_file);
+ 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);
projects / lcr.git / blobdiff