X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=vbox.cpp;h=8447b896667b6a64935aa8b5ddacc21ee684d9de;hp=ef059433c9e397d052fe0f5eaf5eaa43db52603c;hb=79bd731c0db3e3202cfeed2af3fb217ae744b70f;hpb=8038fd190f3c0b451c07253190ec1d7de9ea822a diff --git a/vbox.cpp b/vbox.cpp index ef05943..8447b89 100644 --- a/vbox.cpp +++ b/vbox.cpp @@ -13,31 +13,27 @@ ** ** \*****************************************************************************/ -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include #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); } @@ -46,8 +42,9 @@ VBoxPort::VBoxPort(int type, struct port_settings *settings) : Port(type, "vbox" */ 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--; @@ -55,12 +52,12 @@ VBoxPort::~VBoxPort() } -static void vbox_trace_header(class VBoxPort *vbox, char *message, int direction) +static void vbox_trace_header(class VBoxPort *vbox, const char *message, int direction) { /* init trace with given values */ - start_trace(0, + start_trace(-1, NULL, - vbox?numberrize_callerinfo(vbox->p_callerinfo.id, vbox->p_callerinfo.ntype):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, @@ -69,137 +66,145 @@ static void vbox_trace_header(class VBoxPort *vbox, char *message, int direction } -/* - * handler of vbox - */ -int VBoxPort::handler(void) +int record_timeout(struct lcr_timer *timer, void *instance, int index) { + class VBoxPort *vboxport = (class VBoxPort *)instance; struct lcr_msg *message; - unsigned long tosend; - unsigned char buffer[ISDN_TRANSMIT]; - time_t currenttime; - class Endpoint *epoint; - int ret; - - if ((ret = Port::handler())) - return(ret); - - 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; - message_put(message); - vbox_trace_header(this, "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 */ - free_epointlist(p_epointlist); - } - /* recording is close during destruction */ - delete this; - return(-1); /* must return because port is gone */ - } + + 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) +{ + 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 < 1) - { - p_vbox_audio_start = now_d; - return(0); - } + if (!p_vbox_audio_start) + p_vbox_audio_start = now - PORT_TRANSMIT; /* calculate the number of bytes */ - tosend = (unsigned long)((now_d-p_vbox_audio_start)*8000) - p_vbox_audio_transferred; + tosend = (unsigned int)(now - p_vbox_audio_start) - p_vbox_audio_transferred; + if (tosend > sizeof(buffer)) + tosend = sizeof(buffer); - /* wait for more */ - if (tosend < sizeof(buffer)) - return(0); - 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 */ - if (p_vbox_announce_fh >=0) - { - 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--; - - 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_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); - vbox_trace_header(this, "CONNECT from VBox (announcement is over)", DIRECTION_IN); - end_trace(); - new_state(PORT_STATE_CONNECT); - } - } + 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--; - /* 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; + 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); - 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); + vbox_trace_header(this, "CONNECT from VBox (announcement is over)", DIRECTION_IN); end_trace(); - /* recording is close during destruction */ - delete this; - return(-1); /* must return because port is gone */ + new_state(PORT_STATE_CONNECT); } - } 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); + } + + /* 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; /* 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); } - - return(1); } +int VBoxPort::bridge_rx(unsigned char *data, int len) +{ + int ret; + + 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 lcr_msg *message; class Endpoint *epoint; @@ -209,18 +214,12 @@ int VBoxPort::message_epoint(unsigned long epoint_id, int message_id, union para 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); } - switch(message_id) - { - case MESSAGE_DATA: - record(param->data.data, param->data.len, 1); // from up - return(1); - + switch(message_id) { case MESSAGE_DISCONNECT: /* call has been disconnected */ new_state(PORT_STATE_OUT_DISCONNECT); vbox_trace_header(this, "DISCONNECT to VBox", DIRECTION_OUT); @@ -228,8 +227,7 @@ int VBoxPort::message_epoint(unsigned long epoint_id, int message_id, union para 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; @@ -244,7 +242,6 @@ int VBoxPort::message_epoint(unsigned long epoint_id, int message_id, union para /* 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); @@ -256,22 +253,20 @@ int VBoxPort::message_epoint(unsigned long epoint_id, int message_id, union para /* 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 = 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_ext.number); + 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_ext.number); + } else { + SPRINT(filename, "%s/%s/vbox/announcement", EXTENSION_DATA, p_vbox_ext.number); } vbox_trace_header(this, "SETUP to VBox", DIRECTION_OUT); add_trace("from", "id", "%s", param->setup.callerinfo.id); @@ -295,8 +290,7 @@ int VBoxPort::message_epoint(unsigned long epoint_id, int message_id, union para p_connectinfo.screen = INFO_SCREEN_NETWORK; /* connect unless we can send announcement while ringing */ - if (!p_vbox_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)); @@ -304,8 +298,7 @@ int VBoxPort::message_epoint(unsigned long epoint_id, int message_id, union para 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); @@ -315,9 +308,9 @@ int VBoxPort::message_epoint(unsigned long epoint_id, int message_id, union para } /* 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++; + schedule_timer(&p_vbox_announce_timer, 0, 300000); } vbox_trace_header(this, "ANNOUNCEMENT", DIRECTION_OUT); add_trace("file", "name", "%s", filename); @@ -326,14 +319,13 @@ int VBoxPort::message_epoint(unsigned long epoint_id, int message_id, union para /* 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) - { + 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);