X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=vbox.cpp;h=15475d94acb311c5e85b236c8e31e585dc69b57e;hp=84d679ec990c319cad01bd82490daebbf0acfa6c;hb=7f0d14c706328e1ff74fe8b8c16ae54407cc8055;hpb=e9bfe48fc5254e79e59c6ffc1698912175edf4e3 diff --git a/vbox.cpp b/vbox.cpp index 84d679e..15475d9 100644 --- a/vbox.cpp +++ b/vbox.cpp @@ -17,17 +17,23 @@ /* 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); } @@ -36,6 +42,8 @@ VBoxPort::VBoxPort(int type, struct port_settings *settings) : Port(type, "vbox" */ VBoxPort::~VBoxPort() { + 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; @@ -58,121 +66,135 @@ static void vbox_trace_header(class VBoxPort *vbox, const char *message, int dir } -/* - * 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; + + 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[ISDN_TRANSMIT]; - time_t currenttime; + 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 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 */ - } - } + 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 int)((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) +{ + if (p_record) + record(data, len, 1); // from up + return 0; +} /* * endpoint sends messages to the vbox port @@ -193,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); @@ -219,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); @@ -231,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] == '/') @@ -288,6 +305,7 @@ int VBoxPort::message_epoint(unsigned int epoint_id, int message_id, union param /* play the announcement */ 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); @@ -302,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);