diff options
Diffstat (limited to 'usr.sbin/i4b/isdnd/msghdl.c')
| -rw-r--r-- | usr.sbin/i4b/isdnd/msghdl.c | 1350 |
1 files changed, 0 insertions, 1350 deletions
diff --git a/usr.sbin/i4b/isdnd/msghdl.c b/usr.sbin/i4b/isdnd/msghdl.c deleted file mode 100644 index 4787a95..0000000 --- a/usr.sbin/i4b/isdnd/msghdl.c +++ /dev/null @@ -1,1350 +0,0 @@ -/* - * Copyright (c) 1997, 2002 Hellmuth Michaelis. All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * 1. Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * 2. Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * - * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND - * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE - * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE - * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE - * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL - * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS - * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) - * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT - * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY - * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF - * SUCH DAMAGE. - * - *--------------------------------------------------------------------------- - * - * i4b daemon - message from kernel handling routines - * -------------------------------------------------- - * - * $FreeBSD$ - * - * last edit-date: [Sat May 13 13:09:33 2006] - * - *---------------------------------------------------------------------------*/ - -#include "isdnd.h" - -#include <sys/socket.h> -#include <net/if.h> -#include <net/if_types.h> - -#if defined(__FreeBSD__) -#include <net/if_var.h> -#endif - -#include <netinet/in.h> -#include <netinet/in_systm.h> -#include <netinet/in_var.h> -#include <netinet/ip.h> -#include <netinet/tcp.h> -#include <netinet/udp.h> -#include <netinet/ip_icmp.h> - -/*---------------------------------------------------------------------------* - * handle incoming CONNECT_IND (=SETUP) message - *---------------------------------------------------------------------------*/ -void -msg_connect_ind(msg_connect_ind_t *mp) -{ - cfg_entry_t *cep; - char *src_tela = "ERROR-src_tela"; - char *dst_tela = "ERROR-dst_tela"; - -#define SRC (aliasing == 0 ? mp->src_telno : src_tela) -#define DST (aliasing == 0 ? mp->dst_telno : dst_tela) - - /* Add prefixes. All preexisting alias files are useless - if this is on. */ - if(addprefix) - { - add_number_prefix(mp->src_telno, mp->src_ton); - add_number_prefix(mp->dst_telno, mp->dst_ton); - } - - if(aliasing) - { - src_tela = get_alias(mp->src_telno); - dst_tela = get_alias(mp->dst_telno); - } - - if((cep = find_matching_entry_incoming(mp)) == NULL) - { - /* log message generated in find_matching_entry_incoming() */ - sendm_connect_resp(NULL, mp->header.cdid, SETUP_RESP_DNTCRE, 0); - handle_scrprs(mp->header.cdid, mp->scr_ind, mp->prs_ind, SRC); - return; - } - - if(cep->cdid != CDID_UNUSED && cep->cdid != CDID_RESERVED) - { - /* - * This is an incoming call on a number we just dialed out. - * Stop our dial-out and accept the incoming call. - */ - if(cep->saved_call.cdid != CDID_UNUSED && - cep->saved_call.cdid != CDID_RESERVED) - { - int cdid; - - /* disconnect old, not new */ - - cdid = cep->cdid; - cep->cdid = cep->saved_call.cdid; - sendm_disconnect_req(cep, (CAUSET_I4B << 8) | CAUSE_I4B_NORMAL); - cep->cdid = cdid; - - /* - * Shortcut the state machine and mark this - * entry as free - */ -/* XXX */ cep->state = ST_IDLE; /* this is an invalid */ - /* transition, */ - /* so no next_state() */ - /* we have to wait here for an incoming */ - /* disconnect message !!! (-hm) */ - } - } - - if(cep->inout == DIR_OUTONLY) - { - llog(LL_CHD, "%05d %s incoming call from %s to %s not allowed by configuration!", - mp->header.cdid, cep->name, SRC, DST); - sendm_connect_resp(NULL, mp->header.cdid, SETUP_RESP_DNTCRE, 0); - handle_scrprs(mp->header.cdid, mp->scr_ind, mp->prs_ind, SRC); - return; - } - - cep->charge = 0; - cep->last_charge = 0; - - switch(cep->dialin_reaction) - { - case REACT_ACCEPT: - llog(LL_CHD, "%05d %s accepting: incoming call from %s to %s", - mp->header.cdid, cep->name, SRC, DST); - decr_free_channels(mp->controller); - next_state(cep, EV_MCI); - break; - - case REACT_REJECT: - llog(LL_CHD, "%05d %s rejecting: incoming call from %s to %s", - mp->header.cdid, cep->name, SRC, DST); - sendm_connect_resp(cep, mp->header.cdid, SETUP_RESP_REJECT, - (CAUSET_I4B << 8) | CAUSE_I4B_REJECT); - cep->cdid = CDID_UNUSED; - break; - - case REACT_IGNORE: - llog(LL_CHD, "%05d %s ignoring: incoming call from %s to %s", - mp->header.cdid, cep->name, SRC, DST); - sendm_connect_resp(NULL, mp->header.cdid, SETUP_RESP_DNTCRE, 0); - cep->cdid = CDID_UNUSED; - break; - - case REACT_ANSWER: - decr_free_channels(mp->controller); - if(cep->alert) - { - if(mp->display) - { - llog(LL_CHD, "%05d %s alerting: incoming call from %s to %s (%s)", - mp->header.cdid, cep->name, SRC, DST, mp->display); - } - else - { - llog(LL_CHD, "%05d %s alerting: incoming call from %s to %s", - mp->header.cdid, cep->name, SRC, DST); - } - next_state(cep, EV_ALRT); - } - else - { - if(mp->display) - { - llog(LL_CHD, "%05d %s answering: incoming call from %s to %s (%s)", - mp->header.cdid, cep->name, SRC, DST, mp->display); - } - else - { - llog(LL_CHD, "%05d %s answering: incoming call from %s to %s", - mp->header.cdid, cep->name, SRC, DST); - } - next_state(cep, EV_MCI); - } - break; - - case REACT_CALLBACK: - -#ifdef NOTDEF -/*XXX reserve channel ??? */ decr_free_channels(mp->controller); -#endif - if(cep->cdid == CDID_RESERVED) - { - llog(LL_CHD, "%05d %s reserved: incoming call from %s to %s", - mp->header.cdid, cep->name, SRC, DST); - sendm_connect_resp(cep, mp->header.cdid, SETUP_RESP_REJECT, -#if 0 - (CAUSET_I4B << 8) | CAUSE_I4B_NORMAL); -#else - (CAUSET_I4B << 8) | CAUSE_I4B_REJECT); -#endif - /* no state change */ - } - else - { - sendm_connect_resp(cep, mp->header.cdid, SETUP_RESP_REJECT, -#if 0 - (CAUSET_I4B << 8) | CAUSE_I4B_NORMAL); -#else - (CAUSET_I4B << 8) | CAUSE_I4B_REJECT); -#endif - if(cep->budget_callbackperiod && cep->budget_callbackncalls) - { - cep->budget_callback_req++; - cep->budget_calltype = 0; - if(cep->budget_callbackncalls_cnt == 0) - { - llog(LL_CHD, "%05d %s no budget: call from %s to %s", - mp->header.cdid, cep->name, SRC, DST); - cep->cdid = CDID_UNUSED; - cep->budget_callback_rej++; - break; - } - else - { - cep->budget_calltype = BUDGET_TYPE_CBACK; - } - } - - llog(LL_CHD, "%05d %s callback: incoming call from %s to %s", - mp->header.cdid, cep->name, SRC, DST); - - cep->last_release_time = time(NULL); - cep->cdid = CDID_RESERVED; - next_state(cep, EV_CBRQ); - } - break; - - default: - llog(LL_WRN, "msg_connect_ind: unknown response type, tx SETUP_RESP_DNTCRE"); - sendm_connect_resp(NULL, mp->header.cdid, SETUP_RESP_DNTCRE, 0); - break; - } - handle_scrprs(mp->header.cdid, mp->scr_ind, mp->prs_ind, SRC); -#undef SRC -#undef DST -} - -/*---------------------------------------------------------------------------* - * handle incoming CONNECT_ACTIVE_IND message - *---------------------------------------------------------------------------*/ -void -msg_connect_active_ind(msg_connect_active_ind_t *mp) -{ - cfg_entry_t *cep; - char *device; - - if((cep = get_cep_by_cdid(mp->header.cdid)) == NULL) - { - llog(LL_WRN, "msg_connect_active_ind: cdid not found!"); - return; - } - - cep->isdncontrollerused = mp->controller; - cep->isdnchannelused = mp->channel; - - cep->aoc_now = cep->connect_time = time(NULL); - cep->aoc_last = 0; - cep->aoc_diff = 0; - cep->aoc_valid = AOC_INVALID; - - cep->local_disconnect = DISCON_REM; - - cep->inbytes = INVALID; - cep->outbytes = INVALID; - cep->hangup = 0; - - device = bdrivername(cep->usrdevicename); - - /* set the B-channel to active */ - - if((set_channel_busy(cep->isdncontrollerused, cep->isdnchannelused)) == ERROR) - llog(LL_ERR, "msg_connect_active_ind: set_channel_busy failed!"); - - if(cep->direction == DIR_OUT) - { - llog(LL_CHD, "%05d %s outgoing call active (ctl %d, ch %d, %s%d)", - cep->cdid, cep->name, - cep->isdncontrollerused, cep->isdnchannelused, - bdrivername(cep->usrdevicename), cep->usrdeviceunit); - - if(cep->budget_calltype) - { - if(cep->budget_calltype == BUDGET_TYPE_CBACK) - { - cep->budget_callback_done++; - cep->budget_callbackncalls_cnt--; - DBGL(DL_BDGT, (llog(LL_DBG, "%s: new cback-budget = %d", - cep->name, cep->budget_callbackncalls_cnt))); - if(cep->budget_callbacks_file != NULL) - upd_callstat_file(cep->budget_callbacks_file, cep->budget_callbacksfile_rotate); - } - else if(cep->budget_calltype == BUDGET_TYPE_COUT) - { - cep->budget_callout_done++; - cep->budget_calloutncalls_cnt--; - DBGL(DL_BDGT, (llog(LL_DBG, "%s: new cout-budget = %d", - cep->name, cep->budget_calloutncalls_cnt))); - if(cep->budget_callouts_file != NULL) - upd_callstat_file(cep->budget_callouts_file, cep->budget_calloutsfile_rotate); - } - cep->budget_calltype = 0; - } - } - else - { - llog(LL_CHD, "%05d %s incoming call active (ctl %d, ch %d, %s%d)", - cep->cdid, cep->name, - cep->isdncontrollerused, cep->isdnchannelused, - bdrivername(cep->usrdevicename), cep->usrdeviceunit); - } - -#ifdef USE_CURSES - if(do_fullscreen) - display_connect(cep); -#endif -#ifdef I4B_EXTERNAL_MONITOR - if(do_monitor && accepted) - monitor_evnt_connect(cep); -#endif - - if(isdntime && (mp->datetime[0] != '\0')) - { - llog(LL_DMN, "date/time from exchange = %s", mp->datetime); - } - - next_state(cep, EV_MCAI); -} - -/*---------------------------------------------------------------------------* - * handle incoming PROCEEDING_IND message - *---------------------------------------------------------------------------*/ -void -msg_proceeding_ind(msg_proceeding_ind_t *mp) -{ - cfg_entry_t *cep; - - if((cep = get_cep_by_cdid(mp->header.cdid)) == NULL) - { - llog(LL_WRN, "msg_proceeding_ind: cdid not found!"); - return; - } - - cep->isdncontrollerused = mp->controller; - cep->isdnchannelused = mp->channel; - - /* set the B-channels active */ - - if((set_channel_busy(cep->isdncontrollerused, cep->isdnchannelused)) == ERROR) - llog(LL_ERR, "msg_proceeding_ind: set_channel_busy failed!"); - - llog(LL_CHD, "%05d %s outgoing call proceeding (ctl %d, ch %d)", - cep->cdid, cep->name, - cep->isdncontrollerused, cep->isdnchannelused); -} - -/*---------------------------------------------------------------------------* - * handle incoming ALERT_IND message - *---------------------------------------------------------------------------*/ -void -msg_alert_ind(msg_alert_ind_t *mp) -{ - cfg_entry_t *cep; - - if((cep = get_cep_by_cdid(mp->header.cdid)) == NULL) - { - llog(LL_WRN, "msg_alert_ind: cdid not found!"); - return; - } -#ifdef NOTDEF - llog(LL_CHD, "%05d %s incoming alert", cep->cdid, cep->name); -#endif -} - -/*---------------------------------------------------------------------------* - * handle incoming L12STAT_IND message - *---------------------------------------------------------------------------*/ -void -msg_l12stat_ind(msg_l12stat_ind_t *ml) -{ - if((ml->controller < 0) || (ml->controller >= ncontroller)) - { - llog(LL_ERR, "msg_l12stat_ind: invalid controller number [%d]!", ml->controller); - return; - } - -#ifdef USE_CURSES - if(do_fullscreen) - display_l12stat(ml->controller, ml->layer, ml->state); -#endif -#ifdef I4B_EXTERNAL_MONITOR - if(do_monitor && accepted) - monitor_evnt_l12stat(ml->controller, ml->layer, ml->state); -#endif - - DBGL(DL_CNST, (llog(LL_DBG, "msg_l12stat_ind: unit %d, layer %d, state %d", - ml->controller, ml->layer, ml->state))); - - if(ml->layer == LAYER_ONE) - { - if(ml->state == LAYER_IDLE) - isdn_ctrl_tab[ml->controller].l2stat = ml->state; - isdn_ctrl_tab[ml->controller].l1stat = ml->state; - } - else if(ml->layer == LAYER_TWO) - { - if(ml->state == LAYER_ACTIVE) - isdn_ctrl_tab[ml->controller].l1stat = ml->state; - isdn_ctrl_tab[ml->controller].l2stat = ml->state; - } - else - { - llog(LL_ERR, "msg_l12stat_ind: invalid layer number [%d]!", ml->layer); - } -} - -/*---------------------------------------------------------------------------* - * handle incoming TEIASG_IND message - *---------------------------------------------------------------------------*/ -void -msg_teiasg_ind(msg_teiasg_ind_t *mt) -{ - if((mt->controller < 0) || (mt->controller >= ncontroller)) - { - llog(LL_ERR, "msg_teiasg_ind: invalid controller number [%d]!", mt->controller); - return; - } - -#ifdef USE_CURSES - if(do_fullscreen) - display_tei(mt->controller, mt->tei); -#endif -#ifdef I4B_EXTERNAL_MONITOR - if(do_monitor && accepted) - monitor_evnt_tei(mt->controller, mt->tei); -#endif - - DBGL(DL_CNST, (llog(LL_DBG, "msg_teiasg_ind: unit %d, tei = %d", - mt->controller, mt->tei))); - - isdn_ctrl_tab[mt->controller].tei = mt->tei; -} - -/*---------------------------------------------------------------------------* - * handle incoming PDEACT_IND message - *---------------------------------------------------------------------------*/ -void -msg_pdeact_ind(msg_pdeact_ind_t *md) -{ - int i; - int ctrl = md->controller; - cfg_entry_t *cep; - -#ifdef USE_CURSES - if(do_fullscreen) - { - display_l12stat(ctrl, LAYER_ONE, LAYER_IDLE); - display_l12stat(ctrl, LAYER_TWO, LAYER_IDLE); - display_tei(ctrl, -1); - } -#endif -#ifdef I4B_EXTERNAL_MONITOR - if(do_monitor && accepted) - { - monitor_evnt_l12stat(ctrl, LAYER_ONE, LAYER_IDLE); - monitor_evnt_l12stat(ctrl, LAYER_TWO, LAYER_IDLE); - monitor_evnt_tei(ctrl, -1); - } -#endif - - DBGL(DL_CNST, (llog(LL_DBG, "msg_pdeact_ind: unit %d, persistent deactivation", ctrl))); - - isdn_ctrl_tab[ctrl].l1stat = LAYER_IDLE; - isdn_ctrl_tab[ctrl].l2stat = LAYER_IDLE; - isdn_ctrl_tab[ctrl].tei = -1; - - for(i=0; i < nentries; i++) - { - if((cfg_entry_tab[i].cdid != CDID_UNUSED) && - (cfg_entry_tab[i].isdncontrollerused == ctrl)) - { - cep = &cfg_entry_tab[i]; - - if(cep->cdid == CDID_RESERVED) - { - cep->state = ST_IDLE; - cep->cdid = CDID_UNUSED; - continue; - } - - cep->cdid = CDID_UNUSED; - - cep->last_release_time = time(NULL); - - SET_CAUSE_TYPE(cep->disc_cause, CAUSET_I4B); - SET_CAUSE_VAL(cep->disc_cause, CAUSE_I4B_L1ERROR); - - if(cep->direction == DIR_OUT) - { - llog(LL_CHD, "%05d %s outgoing call disconnected (local)", - cep->cdid, cep->name); - } - else - { - llog(LL_CHD, "%05d %s incoming call disconnected (local)", - cep->cdid, cep->name); - } - - llog(LL_CHD, "%05d %s cause %s", - cep->cdid, cep->name, print_i4b_cause(cep->disc_cause)); - -#ifdef USE_CURSES - if(do_fullscreen && (cep->connect_time > 0)) - display_disconnect(cep); -#endif -#ifdef I4B_EXTERNAL_MONITOR - if(do_monitor && accepted) - monitor_evnt_disconnect(cep); -#endif - - if(cep->disconnectprog) - exec_connect_prog(cep, cep->disconnectprog, 1); - - if(cep->connect_time > 0) - { - if(cep->direction == DIR_OUT) - { - llog(LL_CHD, "%05d %s charging: %d units, %d seconds", - cep->cdid, cep->name, cep->charge, - (int)difftime(time(NULL), cep->connect_time)); - } - else - { - llog(LL_CHD, "%05d %s connected %d seconds", - cep->cdid, cep->name, - (int)difftime(time(NULL), cep->connect_time)); - } - - if((cep->inbytes != INVALID) && (cep->outbytes != INVALID)) - { - if((cep->ioutbytes != cep->outbytes) || - (cep->iinbytes != cep->inbytes)) - { - llog(LL_CHD, "%05d %s accounting: in %d, out %d (in %d, out %d)", - cep->cdid, cep->name, - cep->inbytes, cep->outbytes, - cep->iinbytes, cep->ioutbytes); - } - else - { - llog(LL_CHD, "%05d %s accounting: in %d, out %d", - cep->cdid, cep->name, - cep->inbytes, cep->outbytes); - } - } - } - - if(useacctfile && (cep->connect_time > 0)) - { - int con_secs; - char logdatetime[41]; - struct tm *tp; - - con_secs = difftime(time(NULL), cep->connect_time); - - tp = localtime(&cep->connect_time); - - strftime(logdatetime,40,I4B_TIME_FORMAT,tp); - - if(cep->inbytes != INVALID && cep->outbytes != INVALID) - { - fprintf(acctfp, "%s - %s %s %d (%d) (%d/%d)\n", - logdatetime, getlogdatetime(), - cep->name, cep->charge, con_secs, - cep->inbytes, cep->outbytes); - } - else - { - fprintf(acctfp, "%s - %s %s %d (%d)\n", - logdatetime, getlogdatetime(), - cep->name, cep->charge, con_secs); - } - } - - /* set the B-channel inactive */ - - if((set_channel_idle(cep->isdncontrollerused, cep->isdnchannelused)) == ERROR) - llog(LL_ERR, "msg_pdeact_ind: set_channel_idle failed!"); - - incr_free_channels(cep->isdncontrollerused); - - cep->connect_time = 0; - - cep->state = ST_IDLE; - } - } -} - -/*---------------------------------------------------------------------------* - * handle incoming NEGCOMP_IND message - *---------------------------------------------------------------------------*/ -void -msg_negcomplete_ind(msg_negcomplete_ind_t *mp) -{ - cfg_entry_t *cep; - - if((cep = get_cep_by_cdid(mp->header.cdid)) == NULL) - { - llog(LL_WRN, "msg_negcomp_ind: cdid not found"); - return; - } - - if(cep->connectprog) - exec_connect_prog(cep, cep->connectprog, 0); -} - -/*---------------------------------------------------------------------------* - * handle incoming IFSTATE_CHANGED indication - *---------------------------------------------------------------------------*/ -void -msg_ifstatechg_ind(msg_ifstatechg_ind_t *mp) -{ - cfg_entry_t *cep; - char *device; - - if((cep = get_cep_by_cdid(mp->header.cdid)) == NULL) - { - llog(LL_WRN, "msg_negcomp_ind: cdid not found"); - return; - } - - device = bdrivername(cep->usrdevicename); - llog(LL_DBG, "%s%d: switched to state %d", device, cep->usrdeviceunit, mp->state); -} - -/*---------------------------------------------------------------------------* - * handle incoming DISCONNECT_IND message - *---------------------------------------------------------------------------*/ -void -msg_disconnect_ind(msg_disconnect_ind_t *mp) -{ - cfg_entry_t *cep; - - if((cep = get_cep_by_cdid(mp->header.cdid)) == NULL) - { - llog(LL_WRN, "msg_disconnect_ind: cdid not found"); - return; - } - - /* is this an aborted out-call prematurely called back? */ - if (cep->saved_call.cdid == mp->header.cdid) - { - DBGL(DL_CNST, (llog(LL_DBG, "aborted outcall %05d disconnected", - mp->header.cdid))); - cep->saved_call.cdid = CDID_UNUSED; - - set_channel_idle(cep->saved_call.controller, cep->saved_call.channel); - - incr_free_channels(cep->saved_call.controller); - return; - } - - cep->last_release_time = time(NULL); - cep->disc_cause = mp->cause; - - if(cep->direction == DIR_OUT) - { - llog(LL_CHD, "%05d %s outgoing call disconnected %s", - cep->cdid, cep->name, - cep->local_disconnect == DISCON_LOC ? - "(local)" : "(remote)"); - } - else - { - llog(LL_CHD, "%05d %s incoming call disconnected %s", - cep->cdid, cep->name, - cep->local_disconnect == DISCON_LOC ? - "(local)" : "(remote)"); - } - - llog(LL_CHD, "%05d %s cause %s", - cep->cdid, cep->name, print_i4b_cause(mp->cause)); - -#ifdef USE_CURSES - if(do_fullscreen && (cep->connect_time > 0)) - display_disconnect(cep); -#endif -#ifdef I4B_EXTERNAL_MONITOR - if(do_monitor && accepted) - monitor_evnt_disconnect(cep); -#endif - - if(cep->disconnectprog) - exec_connect_prog(cep, cep->disconnectprog, 1); - - if(cep->connect_time > 0) - { - if(cep->direction == DIR_OUT) - { - llog(LL_CHD, "%05d %s charging: %d units, %d seconds", - cep->cdid, cep->name, cep->charge, - (int)difftime(time(NULL), cep->connect_time)); - } - else - { - llog(LL_CHD, "%05d %s connected %d seconds", - cep->cdid, cep->name, - (int)difftime(time(NULL), cep->connect_time)); - } - - if((cep->inbytes != INVALID) && (cep->outbytes != INVALID)) - { - if((cep->ioutbytes != cep->outbytes) || - (cep->iinbytes != cep->inbytes)) - { - llog(LL_CHD, "%05d %s accounting: in %d, out %d (in %d, out %d)", - cep->cdid, cep->name, - cep->inbytes, cep->outbytes, - cep->iinbytes, cep->ioutbytes); - } - else - { - llog(LL_CHD, "%05d %s accounting: in %d, out %d", - cep->cdid, cep->name, - cep->inbytes, cep->outbytes); - } - } - } - - if(useacctfile && (cep->connect_time > 0)) - { - int con_secs; - char logdatetime[41]; - struct tm *tp; - - con_secs = difftime(time(NULL), cep->connect_time); - - tp = localtime(&cep->connect_time); - - strftime(logdatetime,40,I4B_TIME_FORMAT,tp); - - if(cep->inbytes != INVALID && cep->outbytes != INVALID) - { - fprintf(acctfp, "%s - %s %s %d (%d) (%d/%d)\n", - logdatetime, getlogdatetime(), - cep->name, cep->charge, con_secs, - cep->inbytes, cep->outbytes); - } - else - { - fprintf(acctfp, "%s - %s %s %d (%d)\n", - logdatetime, getlogdatetime(), - cep->name, cep->charge, con_secs); - } - } - - /* set the B-channel inactive */ - - set_channel_idle(cep->isdncontrollerused, cep->isdnchannelused); - - incr_free_channels(cep->isdncontrollerused); - - cep->connect_time = 0; - cep->cdid = CDID_UNUSED; - - next_state(cep, EV_MDI); -} - -/*---------------------------------------------------------------------------* - * handle incoming DIALOUT message - *---------------------------------------------------------------------------*/ -void -msg_dialout(msg_dialout_ind_t *mp) -{ - cfg_entry_t *cep; - - DBGL(DL_DRVR, (llog(LL_DBG, "msg_dialout: dial req from %s, unit %d", bdrivername(mp->driver), mp->driver_unit))); - - if((cep = find_by_device_for_dialout(mp->driver, mp->driver_unit)) == NULL) - { - DBGL(DL_DRVR, (llog(LL_DBG, "msg_dialout: config entry reserved or no match"))); - return; - } - - if(cep->inout == DIR_INONLY) - { - dialresponse(cep, DSTAT_INONLY); - return; - } - - if(cep->budget_calloutperiod && cep->budget_calloutncalls) - { - cep->budget_calltype = 0; - cep->budget_callout_req++; - - if(cep->budget_calloutncalls_cnt == 0) - { - llog(LL_CHD, "%05d %s no budget for calling out", 0, cep->name); - cep->budget_callout_rej++; - dialresponse(cep, DSTAT_TFAIL); - return; - } - else - { - cep->budget_calltype = BUDGET_TYPE_COUT; - } - } - - if((cep->cdid = get_cdid()) == 0) - { - DBGL(DL_DRVR, (llog(LL_DBG, "msg_dialout: get_cdid() returned 0!"))); - return; - } - - cep->charge = 0; - cep->last_charge = 0; - cep->hangup = 0; - - next_state(cep, EV_MDO); -} - -/*---------------------------------------------------------------------------* - * handle incoming DIALOUTNUMBER message - *---------------------------------------------------------------------------*/ -void -msg_dialoutnumber(msg_dialoutnumber_ind_t *mp) -{ - cfg_entry_t *cep; - - DBGL(DL_DRVR, (llog(LL_DBG, "msg_dialoutnumber: dial req from %s, unit %d", bdrivername(mp->driver), mp->driver_unit))); - - if((cep = find_by_device_for_dialoutnumber(mp)) == NULL) - { - DBGL(DL_DRVR, (llog(LL_DBG, "msg_dialoutnumber: config entry reserved or no match"))); - return; - } - - if(cep->inout == DIR_INONLY) - { - dialresponse(cep, DSTAT_INONLY); - return; - } - - if(cep->budget_calloutperiod && cep->budget_calloutncalls) - { - cep->budget_calltype = 0; - cep->budget_callout_req++; - - if(cep->budget_calloutncalls_cnt == 0) - { - llog(LL_CHD, "%05d %s no budget for calling out", 0, cep->name); - cep->budget_callout_rej++; - dialresponse(cep, DSTAT_TFAIL); - return; - } - else - { - cep->budget_calltype = BUDGET_TYPE_COUT; - } - } - - if((cep->cdid = get_cdid()) == 0) - { - DBGL(DL_DRVR, (llog(LL_DBG, "msg_dialoutnumber: get_cdid() returned 0!"))); - return; - } - - cep->keypad[0] = '\0'; - cep->charge = 0; - cep->last_charge = 0; - cep->hangup = 0; - - next_state(cep, EV_MDO); -} - -/*---------------------------------------------------------------------------* - * handle incoming KEYPAD message - *---------------------------------------------------------------------------*/ -void -msg_keypad(msg_keypad_ind_t *mp) -{ - cfg_entry_t *cep; - - DBGL(DL_DRVR, (llog(LL_DBG, "msg_keypad: dial req from %s, unit %d", bdrivername(mp->driver), mp->driver_unit))); - - if((cep = find_by_device_for_keypad(mp->driver, mp->driver_unit, mp->cmdlen, mp->cmd)) == NULL) - { - DBGL(DL_DRVR, (llog(LL_DBG, "msg_keypad: config entry reserved or no match"))); - return; - } - - if(cep->inout == DIR_INONLY) - { - dialresponse(cep, DSTAT_INONLY); - return; - } - - if(cep->budget_calloutperiod && cep->budget_calloutncalls) - { - cep->budget_calltype = 0; - cep->budget_callout_req++; - - if(cep->budget_calloutncalls_cnt == 0) - { - llog(LL_CHD, "%05d %s no budget for calling out", 0, cep->name); - cep->budget_callout_rej++; - dialresponse(cep, DSTAT_TFAIL); - return; - } - else - { - cep->budget_calltype = BUDGET_TYPE_COUT; - } - } - - if((cep->cdid = get_cdid()) == 0) - { - DBGL(DL_DRVR, (llog(LL_DBG, "msg_keypad: get_cdid() returned 0!"))); - return; - } - - cep->charge = 0; - cep->last_charge = 0; - cep->hangup = 0; - - next_state(cep, EV_MDO); -} - -/*---------------------------------------------------------------------------* - * handle incoming DRVRDISC_REQ message - *---------------------------------------------------------------------------*/ -void -msg_drvrdisc_req(msg_drvrdisc_req_t *mp) -{ - cfg_entry_t *cep; - - DBGL(DL_DRVR, (llog(LL_DBG, "msg_drvrdisc_req: req from %s, unit %d", bdrivername(mp->driver), mp->driver_unit))); - - if((cep = get_cep_by_driver(mp->driver, mp->driver_unit)) == NULL) - { - DBGL(DL_DRVR, (llog(LL_DBG, "msg_drvrdisc_req: config entry not found"))); - return; - } - next_state(cep, EV_DRQ); -} - -/*---------------------------------------------------------------------------* - * handle incoming ACCOUNTING message - *---------------------------------------------------------------------------*/ -void -msg_accounting(msg_accounting_ind_t *mp) -{ - cfg_entry_t *cep; - - if((cep = find_active_entry_by_driver(mp->driver, mp->driver_unit)) == NULL) - { - llog(LL_WRN, "msg_accounting: no config entry found!"); - return; - } - - cep->inbytes = mp->inbytes; - cep->iinbytes = mp->iinbytes; - cep->outbytes = mp->outbytes; - cep->ioutbytes = mp->ioutbytes; - cep->inbps = mp->inbps; - cep->outbps = mp->outbps; - - if(mp->accttype == ACCT_DURING) - { -#ifdef USE_CURSES - if(do_fullscreen) - display_acct(cep); -#endif -#ifdef I4B_EXTERNAL_MONITOR - if(do_monitor && accepted) - monitor_evnt_acct(cep); -#endif - } -} - -/*---------------------------------------------------------------------------* - * handle incoming CHARGING message - *---------------------------------------------------------------------------*/ -void -msg_charging_ind(msg_charging_ind_t *mp) -{ - static char *cttab[] = { - "invalid", - "AOCD", - "AOCE", - "estimated" }; - - cfg_entry_t *cep; - - if((cep = get_cep_by_cdid(mp->header.cdid)) == NULL) - { - llog(LL_WRN, "msg_charging_ind: cdid not found"); - return; - } - - if(mp->units_type < CHARGE_INVALID || mp->units_type > CHARGE_CALC) - { - llog(LL_ERR, "msg_charging: units_type %d out of range!", mp->units_type); - error_exit(1, "msg_charging: units_type %d out of range!", mp->units_type); - } - - DBGL(DL_DRVR, (llog(LL_DBG, "msg_charging: %d unit(s) (%s)", - mp->units, cttab[mp->units_type]))); - - cep->charge = mp->units; - - switch(mp->units_type) - { - case CHARGE_AOCD: - if((cep->unitlengthsrc == ULSRC_DYN) && - (cep->charge != cep->last_charge)) - { - cep->last_charge = cep->charge; - handle_charge(cep); - } - break; - - case CHARGE_CALC: -#ifdef USE_CURSES - if(do_fullscreen) - display_ccharge(cep, mp->units); -#endif -#ifdef I4B_EXTERNAL_MONITOR - if(do_monitor && accepted) - monitor_evnt_charge(cep, mp->units, 1); -#endif - break; - } -} - -/*---------------------------------------------------------------------------* - * handle incoming IDLE_TIMEOUT_IND message - *---------------------------------------------------------------------------*/ -void -msg_idle_timeout_ind(msg_idle_timeout_ind_t *mp) -{ - cfg_entry_t *cep; - - if((cep = get_cep_by_cdid(mp->header.cdid)) == NULL) - { - llog(LL_WRN, "msg_idle_timeout_ind: cdid not found!"); - return; - } - - cep->local_disconnect = DISCON_LOC; - - DBGL(DL_DRVR, (llog(LL_DBG, "msg_idle_timeout_ind: idletimeout, kernel sent disconnect!"))); - - check_and_kill(cep); -} - -/*---------------------------------------------------------------------------* - * handle incoming MSG_PACKET_IND message - *---------------------------------------------------------------------------*/ -static char * -strapp(char *buf, const char *txt) -{ - while(*txt) - *buf++ = *txt++; - *buf = '\0'; - return buf; -} - -/*---------------------------------------------------------------------------* - * handle incoming MSG_PACKET_IND message - *---------------------------------------------------------------------------*/ -static char * -ipapp(char *buf, unsigned long a ) -{ - unsigned long ma = ntohl( a ); - - buf += sprintf(buf, "%lu.%lu.%lu.%lu", - (ma>>24)&0xFF, - (ma>>16)&0xFF, - (ma>>8)&0xFF, - (ma)&0xFF); - return buf; -} - -/*---------------------------------------------------------------------------* - * handle incoming MSG_PACKET_IND message - *---------------------------------------------------------------------------*/ -void -msg_packet_ind(msg_packet_ind_t *mp) -{ - cfg_entry_t *cep; - struct ip *ip; - u_char *proto_hdr; - char tmp[80]; - char *cptr = tmp; - char *name = "???"; - int i; - - for(i=0; i < nentries; i++) - { - cep = &cfg_entry_tab[i]; /* ptr to config entry */ - - if(cep->usrdevicename == mp->driver && - cep->usrdeviceunit == mp->driver_unit) - { - name = cep->name; - break; - } - } - - ip = (struct ip*)mp->pktdata; - proto_hdr = mp->pktdata + ((ip->ip_hl)<<2); - - if( ip->ip_p == IPPROTO_TCP ) - { - struct tcphdr* tcp = (struct tcphdr*)proto_hdr; - - cptr = strapp( cptr, "TCP " ); - cptr = ipapp( cptr, ip->ip_src.s_addr ); - cptr += sprintf( cptr, ":%u -> ", ntohs( tcp->th_sport ) ); - cptr = ipapp( cptr, ip->ip_dst.s_addr ); - cptr += sprintf( cptr, ":%u", ntohs( tcp->th_dport ) ); - - if(tcp->th_flags & TH_FIN) cptr = strapp( cptr, " FIN" ); - if(tcp->th_flags & TH_SYN) cptr = strapp( cptr, " SYN" ); - if(tcp->th_flags & TH_RST) cptr = strapp( cptr, " RST" ); - if(tcp->th_flags & TH_PUSH) cptr = strapp( cptr, " PUSH" ); - if(tcp->th_flags & TH_ACK) cptr = strapp( cptr, " ACK" ); - if(tcp->th_flags & TH_URG) cptr = strapp( cptr, " URG" ); - } - else if( ip->ip_p == IPPROTO_UDP ) - { - struct udphdr* udp = (struct udphdr*)proto_hdr; - - cptr = strapp( cptr, "UDP " ); - cptr = ipapp( cptr, ip->ip_src.s_addr ); - cptr += sprintf( cptr, ":%u -> ", ntohs( udp->uh_sport ) ); - cptr = ipapp( cptr, ip->ip_dst.s_addr ); - cptr += sprintf( cptr, ":%u", ntohs( udp->uh_dport ) ); - } - else if( ip->ip_p == IPPROTO_ICMP ) - { - struct icmp* icmp = (struct icmp*)proto_hdr; - - cptr += sprintf( cptr, "ICMP:%u.%u", icmp->icmp_type, icmp->icmp_code); - cptr = ipapp( cptr, ip->ip_src.s_addr ); - cptr = strapp( cptr, " -> " ); - cptr = ipapp( cptr, ip->ip_dst.s_addr ); - } - else - { - cptr += sprintf( cptr, "PROTO=%u ", ip->ip_p); - cptr = ipapp( cptr, ip->ip_src.s_addr); - cptr = strapp( cptr, " -> " ); - cptr = ipapp( cptr, ip->ip_dst.s_addr); - } - - llog(LL_PKT, "%s %s %u %s", - name, mp->direction ? "send" : "recv", - ntohs( ip->ip_len ), tmp ); -} - -/*---------------------------------------------------------------------------* - * get a cdid from kernel - *---------------------------------------------------------------------------*/ -int -get_cdid(void) -{ - msg_cdid_req_t mcr; - - mcr.cdid = 0; - - if((ioctl(isdnfd, I4B_CDID_REQ, &mcr)) < 0) - { - llog(LL_ERR, "get_cdid: ioctl I4B_CDID_REQ failed: %s", strerror(errno)); - error_exit(1, "get_cdid: ioctl I4B_CDID_REQ failed: %s", strerror(errno)); - } - - return(mcr.cdid); -} - -/*---------------------------------------------------------------------------* - * send message "connect request" to kernel - *---------------------------------------------------------------------------*/ -int -sendm_connect_req(cfg_entry_t *cep) -{ - msg_connect_req_t mcr; - int ret; - - cep->local_disconnect = DISCON_REM; - - cep->unitlength = get_current_rate(cep, 1); - - mcr.cdid = cep->cdid; - - mcr.controller = cep->isdncontrollerused; - mcr.channel = cep->isdnchannelused; - mcr.txdelay = cep->isdntxdelout; - - mcr.bprot = cep->b1protocol; - mcr.bcap = cep->bcap; - - mcr.driver = cep->usrdevicename; - mcr.driver_unit = cep->usrdeviceunit; - - /* setup the shorthold data */ - mcr.shorthold_data.shorthold_algorithm = cep->shorthold_algorithm; - mcr.shorthold_data.unitlen_time = cep->unitlength; - mcr.shorthold_data.idle_time = cep->idle_time_out; - mcr.shorthold_data.earlyhup_time = cep->earlyhangup; - - if(cep->unitlengthsrc == ULSRC_DYN) - mcr.unitlen_method = ULEN_METHOD_DYNAMIC; - else - mcr.unitlen_method = ULEN_METHOD_STATIC; - - strcpy(mcr.dst_telno, cep->remote_phone_dialout.number); - if(cep->usesubaddr) - strcpy(mcr.dst_subaddr, cep->remote_phone_dialout.subaddr); - strcpy(mcr.src_telno, cep->local_phone_dialout.number); - if(cep->usesubaddr) - strcpy(mcr.src_subaddr, cep->local_phone_dialout.subaddr); - strcpy(mcr.keypad, cep->keypad); - - cep->last_dial_time = time(NULL); - cep->direction = DIR_OUT; - - DBGL(DL_CNST, (llog(LL_DBG, "sendm_connect_req: ctrl = %d, chan = %d", cep->isdncontrollerused, cep->isdnchannelused))); - - if((ret = ioctl(isdnfd, I4B_CONNECT_REQ, &mcr)) < 0) - { - llog(LL_ERR, "sendm_connect_req: ioctl I4B_CONNECT_REQ failed: %s", strerror(errno)); - error_exit(1, "sendm_connect_req: ioctl I4B_CONNECT_REQ failed: %s", strerror(errno)); - } - - decr_free_channels(cep->isdncontrollerused); - - llog(LL_CHD, "%05d %s dialing out from %s to %s", - cep->cdid, - cep->name, - aliasing ? get_alias(cep->local_phone_dialout.number) : cep->local_phone_dialout.number, - aliasing ? get_alias(cep->remote_phone_dialout.number) : cep->remote_phone_dialout.number); - - return(ret); -} - -/*---------------------------------------------------------------------------* - * send message "connect response" to kernel - *---------------------------------------------------------------------------*/ -int -sendm_connect_resp(cfg_entry_t *cep, int cdid, int response, cause_t cause) -{ - msg_connect_resp_t mcr; - int ret; - - mcr.cdid = cdid; - - mcr.response = response; - - if(response == SETUP_RESP_REJECT) - { - mcr.cause = cause; - DBGL(DL_DRVR, (llog(LL_DBG, "sendm_connect_resp: reject, cause=0x%x", cause))); - } - else if(response == SETUP_RESP_ACCEPT) - { - cep->direction = DIR_IN; - - mcr.txdelay = cep->isdntxdelin; - - mcr.bprot = cep->b1protocol; - mcr.bcap = cep->bcap; - - mcr.driver = cep->usrdevicename; - mcr.driver_unit = cep->usrdeviceunit; - - mcr.max_idle_time = cep->idle_time_in; - - DBGL(DL_DRVR, (llog(LL_DBG, "sendm_connect_resp: accept"))); - } - - if((ret = ioctl(isdnfd, I4B_CONNECT_RESP, &mcr)) < 0) - { - llog(LL_ERR, "sendm_connect_resp: ioctl I4B_CONNECT_RESP failed: %s", strerror(errno)); - error_exit(1, "sendm_connect_resp: ioctl I4B_CONNECT_RESP failed: %s", strerror(errno)); - } - return(ret); -} - -/*---------------------------------------------------------------------------* - * send message "disconnect request" to kernel - *---------------------------------------------------------------------------*/ -int -sendm_disconnect_req(cfg_entry_t *cep, cause_t cause) -{ - msg_discon_req_t mcr; - int ret = 0; - - mcr.cdid = cep->cdid; - - mcr.cause = cause; - - cep->local_disconnect = DISCON_LOC; - - if((ret = ioctl(isdnfd, I4B_DISCONNECT_REQ, &mcr)) < 0) - { - llog(LL_ERR, "sendm_disconnect_req: ioctl I4B_DISCONNECT_REQ failed: %s", strerror(errno)); - } - else - { - DBGL(DL_DRVR, (llog(LL_DBG, "sendm_disconnect_req: sent DISCONNECT_REQ"))); - } - return(ret); -} - -/*---------------------------------------------------------------------------* - * send message "alert request" to kernel - *---------------------------------------------------------------------------*/ -int -sendm_alert_req(cfg_entry_t *cep) -{ - msg_alert_req_t mar; - int ret; - - mar.cdid = cep->cdid; - - if((ret = ioctl(isdnfd, I4B_ALERT_REQ, &mar)) < 0) - { - llog(LL_ERR, "sendm_alert_req: ioctl I4B_ALERT_REQ failed: %s", strerror(errno)); - error_exit(1, "sendm_alert_req: ioctl I4B_ALERT_REQ failed: %s", strerror(errno)); - } - else - { - DBGL(DL_DRVR, (llog(LL_DBG, "sendm_alert_req: sent ALERT_REQ"))); - } - return(ret); -} - -/* EOF */ |
