NetBSD-5.0.2/usr.sbin/isdn/isdnd/msghdl.c
/*
* Copyright (c) 1997, 2000 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
* --------------------------------------------------
*
* $Id: msghdl.c,v 1.10 2004/03/28 20:49:22 pooka Exp $
*
* $FreeBSD$
*
* last edit-date: [Thu Sep 21 11:11:48 2000]
*
*---------------------------------------------------------------------------*/
#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, int len)
{
struct cfg_entry *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)
if (aliasing)
{
src_tela = get_alias(mp->src_telno);
dst_tela = get_alias(mp->dst_telno);
}
if ((cep = find_matching_entry_incoming(mp, len)) == 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)
{
logit(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:
logit(LL_CHD, "%05d %s accepting: incoming call from %s to %s",
mp->header.cdid, cep->name, SRC, DST);
decr_free_channels(find_ctrl_state(mp->controller));
next_state(cep, EV_MCI);
break;
case REACT_REJECT:
logit(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:
logit(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);
break;
case REACT_ANSWER:
decr_free_channels(find_ctrl_state(mp->controller));
if (cep->alert)
{
if (mp->display)
{
logit(LL_CHD, "%05d %s alerting: incoming call from %s to %s (%s)",
mp->header.cdid, cep->name, SRC, DST, mp->display);
}
else
{
logit(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)
{
logit(LL_CHD, "%05d %s answering: incoming call from %s to %s (%s)",
mp->header.cdid, cep->name, SRC, DST, mp->display);
}
else
{
logit(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)
{
logit(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)
{
logit(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;
}
}
logit(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:
logit(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)
{
struct cfg_entry *cep;
if ((cep = get_cep_by_cdid(mp->header.cdid)) == NULL)
{
logit(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;
/* set the B-channel to active */
if ((set_channel_busy(find_ctrl_state(cep->isdncontrollerused), cep->isdnchannelused)) == ERROR)
logit(LL_ERR, "msg_connect_active_ind: set_channel_busy failed!");
if (cep->direction == DIR_OUT)
{
logit(LL_CHD, "%05d %s outgoing call active (ctl %d, ch %d, %s%d)",
cep->cdid, cep->name,
cep->isdncontrollerused, cep->isdnchannelused,
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, (logit(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, (logit(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
{
logit(LL_CHD, "%05d %s incoming call active (ctl %d, ch %d, %s%d)",
cep->cdid, cep->name,
cep->isdncontrollerused, cep->isdnchannelused,
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'))
{
logit(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)
{
struct cfg_entry *cep;
if ((cep = get_cep_by_cdid(mp->header.cdid)) == NULL)
{
logit(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(find_ctrl_state(cep->isdncontrollerused), cep->isdnchannelused)) == ERROR)
logit(LL_ERR, "msg_proceeding_ind: set_channel_busy failed!");
logit(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)
{
struct cfg_entry *cep;
if ((cep = get_cep_by_cdid(mp->header.cdid)) == NULL)
{
logit(LL_WRN, "msg_alert_ind: cdid not found!");
return;
}
#ifdef NOTDEF
logit(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)
{
struct isdn_ctrl_state * ctrl = find_ctrl_state(ml->controller);
if (ctrl == NULL) {
logit(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, (logit(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)
ctrl->l2stat = ml->state;
ctrl->l1stat = ml->state;
}
else if (ml->layer == LAYER_TWO)
{
if (ml->state == LAYER_ACTIVE)
ctrl->l1stat = ml->state;
ctrl->l2stat = ml->state;
}
else
{
logit(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)
{
struct isdn_ctrl_state *ctrl = find_ctrl_state(mt->controller);
if (ctrl == NULL) {
logit(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, (logit(LL_DBG, "msg_teiasg_ind: unit %d, tei = %d",
mt->controller, mt->tei)));
ctrl->tei = mt->tei;
}
/*---------------------------------------------------------------------------*
* handle incoming PDEACT_IND message
*---------------------------------------------------------------------------*/
void
msg_pdeact_ind(msg_pdeact_ind_t *md)
{
int isdnif = md->controller;
struct cfg_entry *cep;
struct isdn_ctrl_state * ctrl = find_ctrl_state(isdnif);
#ifdef USE_CURSES
if (do_fullscreen)
{
display_l12stat(isdnif, LAYER_ONE, LAYER_IDLE);
display_l12stat(isdnif, LAYER_TWO, LAYER_IDLE);
display_tei(isdnif, -1);
}
#endif
#ifdef I4B_EXTERNAL_MONITOR
if (do_monitor && accepted)
{
monitor_evnt_l12stat(isdnif, LAYER_ONE, LAYER_IDLE);
monitor_evnt_l12stat(isdnif, LAYER_TWO, LAYER_IDLE);
monitor_evnt_tei(isdnif, -1);
}
#endif
DBGL(DL_CNST, (logit(LL_DBG, "msg_pdeact_ind: BRI %d, persistent deactivation", isdnif)));
ctrl->l1stat = LAYER_IDLE;
ctrl->l2stat = LAYER_IDLE;
ctrl->tei = -1;
for (cep = get_first_cfg_entry(); cep; cep = NEXT_CFE(cep)) {
if (cep->cdid != CDID_UNUSED &&
cep->isdncontrollerused == isdnif) {
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)
{
logit(LL_CHD, "%05d %s outgoing call disconnected (local)",
cep->cdid, cep->name);
}
else
{
logit(LL_CHD, "%05d %s incoming call disconnected (local)",
cep->cdid, cep->name);
}
logit(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)
{
logit(LL_CHD, "%05d %s charging: %d units, %d seconds",
cep->cdid, cep->name, cep->charge,
(int)difftime(time(NULL), cep->connect_time));
}
else
{
logit(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))
{
logit(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
{
logit(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(ctrl, cep->isdnchannelused)) == ERROR)
logit(LL_ERR, "msg_pdeact_ind: set_channel_idle failed!");
incr_free_channels(ctrl);
cep->connect_time = 0;
cep->state = ST_IDLE;
}
}
}
/*---------------------------------------------------------------------------*
* handle incoming NEGCOMP_IND message
*---------------------------------------------------------------------------*/
void
msg_negcomplete_ind(msg_negcomplete_ind_t *mp)
{
struct cfg_entry *cep;
if ((cep = get_cep_by_cdid(mp->header.cdid)) == NULL)
{
logit(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)
{
struct cfg_entry *cep;
if ((cep = get_cep_by_cdid(mp->header.cdid)) == NULL)
{
logit(LL_WRN, "msg_negcomp_ind: cdid not found");
return;
}
logit(LL_DBG, "%s%d: switched to state %d", cep->usrdevicename, cep->usrdeviceunit, mp->state);
}
/*---------------------------------------------------------------------------*
* handle incoming DISCONNECT_IND message
*---------------------------------------------------------------------------*/
void
msg_disconnect_ind(msg_disconnect_ind_t *mp)
{
struct cfg_entry *cep;
struct isdn_ctrl_state *ctrl;
if ((cep = get_cep_by_cdid(mp->header.cdid)) == NULL)
{
logit(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, (logit(LL_DBG, "aborted outcall %05d disconnected",
mp->header.cdid)));
cep->saved_call.cdid = CDID_UNUSED;
ctrl = find_ctrl_state(cep->saved_call.controller);
set_channel_idle(ctrl, cep->saved_call.channel);
incr_free_channels(ctrl);
return;
}
cep->last_release_time = time(NULL);
cep->disc_cause = mp->cause;
if (cep->direction == DIR_OUT)
{
logit(LL_CHD, "%05d %s outgoing call disconnected %s",
cep->cdid, cep->name,
cep->local_disconnect == DISCON_LOC ?
"(local)" : "(remote)");
}
else
{
logit(LL_CHD, "%05d %s incoming call disconnected %s",
cep->cdid, cep->name,
cep->local_disconnect == DISCON_LOC ?
"(local)" : "(remote)");
}
logit(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)
{
logit(LL_CHD, "%05d %s charging: %d units, %d seconds",
cep->cdid, cep->name, cep->charge,
(int)difftime(time(NULL), cep->connect_time));
}
else
{
logit(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))
{
logit(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
{
logit(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 */
ctrl = find_ctrl_state(cep->isdncontrollerused);
set_channel_idle(ctrl, cep->isdnchannelused);
incr_free_channels(ctrl);
cep->connect_time = 0;
next_state(cep, EV_MDI);
}
/*---------------------------------------------------------------------------*
* handle incoming DIALOUT message
*---------------------------------------------------------------------------*/
void
msg_dialout(msg_dialout_ind_t *mp)
{
struct cfg_entry *cep;
if ((cep = find_by_device_for_dialout(mp->driver, mp->driver_unit)) == NULL)
{
DBGL(DL_DRVR, (logit(LL_DBG, "msg_dialout: config entry reserved or no match")));
return;
}
DBGL(DL_DRVR, (logit(LL_DBG, "msg_dialout: dial req from %s%d", cep->usrdevicename, mp->driver_unit)));
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)
{
logit(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, (logit(LL_DBG, "msg_dialout: get_cdid() returned 0!")));
return;
}
cep->charge = 0;
cep->last_charge = 0;
next_state(cep, EV_MDO);
}
/*---------------------------------------------------------------------------*
* handle incoming DIALOUTNUMBER message
*---------------------------------------------------------------------------*/
void
msg_dialoutnumber(msg_dialoutnumber_ind_t *mp)
{
struct cfg_entry *cep;
if ((cep = find_by_device_for_dialoutnumber(mp->driver, mp->driver_unit, mp->cmdlen, mp->cmd)) == NULL)
{
DBGL(DL_DRVR, (logit(LL_DBG, "msg_dialoutnumber: config entry reserved or no match")));
return;
}
DBGL(DL_DRVR, (logit(LL_DBG, "msg_dialoutnumber: dial req from %s%d", cep->usrdevicename, mp->driver_unit)));
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)
{
logit(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, (logit(LL_DBG, "msg_dialoutnumber: get_cdid() returned 0!")));
return;
}
cep->charge = 0;
cep->last_charge = 0;
next_state(cep, EV_MDO);
}
/*---------------------------------------------------------------------------*
* handle incoming DRVRDISC_REQ message
*---------------------------------------------------------------------------*/
void
msg_drvrdisc_req(msg_drvrdisc_req_t *mp)
{
struct cfg_entry *cep;
DBGL(DL_DRVR, (logit(LL_DBG, "msg_drvrdisc_req for call %d", mp->header.cdid)));
if ((cep = get_cep_by_cdid(mp->header.cdid)) == NULL)
{
DBGL(DL_DRVR, (logit(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)
{
struct cfg_entry *cep;
if ((cep = get_cep_by_cdid(mp->header.cdid)) == NULL)
{
logit(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" };
struct cfg_entry *cep;
if ((cep = get_cep_by_cdid(mp->header.cdid)) == NULL)
{
logit(LL_WRN, "msg_charging_ind: cdid not found");
return;
}
if (mp->units_type < CHARGE_INVALID || mp->units_type > CHARGE_CALC)
{
logit(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, (logit(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)
{
struct cfg_entry *cep;
if ((cep = get_cep_by_cdid(mp->header.cdid)) == NULL)
{
logit(LL_WRN, "msg_idle_timeout_ind: cdid not found!");
return;
}
cep->local_disconnect = DISCON_LOC;
DBGL(DL_DRVR, (logit(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, char *lim, const char *txt)
{
while (*txt && buf < lim - 1)
*buf++ = *txt++;
*buf = '\0';
return buf;
}
/*---------------------------------------------------------------------------*
* handle incoming MSG_PACKET_IND message
*---------------------------------------------------------------------------*/
static char *
ipapp(char *buf, char *lim, unsigned long a)
{
unsigned long ma = ntohl(a);
ssize_t n;
n = snprintf(buf, lim - buf, "%lu.%lu.%lu.%lu", (ma>>24)&0xFF,
(ma>>16)&0xFF, (ma>>8)&0xFF, (ma)&0xFF);
if (n > 0)
return buf + n;
else
return NULL;
}
/*---------------------------------------------------------------------------*
* handle incoming MSG_PACKET_IND message
*---------------------------------------------------------------------------*/
void
msg_packet_ind(msg_packet_ind_t *mp)
{
struct cfg_entry *cep;
struct ip *ip;
u_char *proto_hdr;
char tmp[80];
char *cptr = tmp;
char *name = "???";
for (cep = get_first_cfg_entry(); cep; cep = NEXT_CFE(cep)) {
if (cep->usrdevice == 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, tmp + sizeof(tmp), "TCP ");
cptr = ipapp(cptr, tmp + sizeof(tmp), ip->ip_src.s_addr);
cptr += snprintf(cptr, sizeof(tmp) - (cptr - tmp),
":%u -> ", ntohs(tcp->th_sport));
cptr = ipapp(cptr, tmp + sizeof(tmp), ip->ip_dst.s_addr);
cptr += snprintf(cptr, sizeof(tmp) - (cptr - tmp),
":%u", ntohs(tcp->th_dport));
if (tcp->th_flags & TH_FIN)
cptr = strapp(cptr, tmp + sizeof(tmp), " FIN");
if (tcp->th_flags & TH_SYN)
cptr = strapp(cptr, tmp + sizeof(tmp), " SYN");
if (tcp->th_flags & TH_RST)
cptr = strapp(cptr, tmp + sizeof(tmp), " RST");
if (tcp->th_flags & TH_PUSH)
cptr = strapp(cptr, tmp + sizeof(tmp), " PUSH");
if (tcp->th_flags & TH_ACK)
cptr = strapp(cptr, tmp + sizeof(tmp), " ACK");
if (tcp->th_flags & TH_URG)
cptr = strapp(cptr, tmp + sizeof(tmp), " URG");
}
else if (ip->ip_p == IPPROTO_UDP)
{
struct udphdr* udp = (struct udphdr*)proto_hdr;
cptr = strapp(cptr, tmp + sizeof(tmp), "UDP ");
cptr = ipapp(cptr, tmp + sizeof(tmp), ip->ip_src.s_addr);
cptr += snprintf(cptr, sizeof(tmp) - (cptr - tmp),
":%u -> ", ntohs(udp->uh_sport));
cptr = ipapp(cptr, tmp + sizeof(tmp), ip->ip_dst.s_addr);
cptr += snprintf(cptr, sizeof(tmp) - (cptr - tmp),
":%u", ntohs(udp->uh_dport));
}
else if (ip->ip_p == IPPROTO_ICMP)
{
struct icmp* icmp = (struct icmp*)proto_hdr;
cptr += snprintf(cptr, sizeof(tmp) - (cptr - tmp),
"ICMP:%u.%u", icmp->icmp_type, icmp->icmp_code);
cptr = ipapp(cptr, tmp + sizeof(tmp), ip->ip_src.s_addr);
cptr = strapp(cptr, tmp + sizeof(tmp), " -> ");
cptr = ipapp(cptr, tmp + sizeof(tmp), ip->ip_dst.s_addr);
}
else
{
cptr += snprintf(cptr, sizeof(tmp) - (cptr - tmp),
"PROTO=%u ", ip->ip_p);
cptr = ipapp(cptr, tmp + sizeof(tmp), ip->ip_src.s_addr);
cptr = strapp(cptr, tmp + sizeof(tmp), " -> ");
cptr = ipapp(cptr, tmp + sizeof(tmp), ip->ip_dst.s_addr);
}
logit(LL_PKT, "%s %s %u %s", name, mp->direction ? "send" : "recv",
ntohs(ip->ip_len), tmp);
}
/*
* A new controller arrived or is gone away
*/
void
msg_ctrl_ev_ind(msg_ctrl_ev_ind_t *mp)
{
logit(LL_DMN, "controller %d %s", mp->controller, mp->event?"attached":"detached");
if (mp->event) {
/* new, add to controller list */
init_new_controller(mp->controller);
init_single_controller_protocol(find_ctrl_state(mp->controller));
} else {
/* controller gone, remove */
remove_ctrl_state(mp->controller);
}
}
/*---------------------------------------------------------------------------*
* 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)
{
logit(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(struct cfg_entry *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.driver = cep->usrdevice;
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;
strlcpy(mcr.dst_telno, cep->remote_phone_dialout,
sizeof(mcr.dst_telno));
strlcpy(mcr.src_telno, cep->local_phone_dialout, sizeof(mcr.src_telno));
cep->last_dial_time = time(NULL);
cep->direction = DIR_OUT;
DBGL(DL_CNST, (logit(LL_DBG, "sendm_connect_req: ctrl = %d, chan = %d", cep->isdncontrollerused, cep->isdnchannelused)));
if ((ret = ioctl(isdnfd, I4B_CONNECT_REQ, &mcr)) < 0)
{
logit(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(find_ctrl_state(cep->isdncontrollerused));
logit(LL_CHD, "%05d %s dialing out from %s to %s",
cep->cdid,
cep->name,
aliasing ? get_alias(cep->local_phone_dialout) : cep->local_phone_dialout,
aliasing ? get_alias(cep->remote_phone_dialout) : cep->remote_phone_dialout);
return(ret);
}
/*---------------------------------------------------------------------------*
* send message "connect response" to kernel
*---------------------------------------------------------------------------*/
int
sendm_connect_resp(struct cfg_entry *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, (logit(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.driver = cep->usrdevice;
mcr.driver_unit = cep->usrdeviceunit;
mcr.max_idle_time = cep->idle_time_in;
DBGL(DL_DRVR, (logit(LL_DBG, "sendm_connect_resp: accept")));
}
if ((ret = ioctl(isdnfd, I4B_CONNECT_RESP, &mcr)) < 0)
{
logit(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(struct cfg_entry *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)
{
logit(LL_ERR, "sendm_disconnect_req: ioctl I4B_DISCONNECT_REQ failed: %s", strerror(errno));
}
else
{
DBGL(DL_DRVR, (logit(LL_DBG, "sendm_disconnect_req: sent DISCONNECT_REQ")));
}
return(ret);
}
/*---------------------------------------------------------------------------*
* send message "alert request" to kernel
*---------------------------------------------------------------------------*/
int
sendm_alert_req(struct cfg_entry *cep)
{
msg_alert_req_t mar;
int ret;
mar.cdid = cep->cdid;
if ((ret = ioctl(isdnfd, I4B_ALERT_REQ, &mar)) < 0)
{
logit(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, (logit(LL_DBG, "sendm_alert_req: sent ALERT_REQ")));
}
return(ret);
}
/* EOF */