FreeBSD-5.3/usr.sbin/i4b/isdnd/exec.c
/*
* 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.
*
*---------------------------------------------------------------------------
*
* exec.h - supplemental program/script execution
* ----------------------------------------------
*
* $FreeBSD: src/usr.sbin/i4b/isdnd/exec.c,v 1.12 2003/06/07 18:45:45 imp Exp $
*
* last edit-date: [Tue Mar 26 14:35:46 2002]
*
*---------------------------------------------------------------------------*/
#include "isdnd.h"
#include <sys/wait.h>
#include <sys/socket.h>
#include <net/if.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <paths.h>
#define MAX_PIDS 32
static struct pid_tab {
pid_t pid;
cfg_entry_t *cep;
} pid_tab[MAX_PIDS];
/*---------------------------------------------------------------------------*
* SIGCHLD signal handler
*---------------------------------------------------------------------------*/
void
sigchild_handler(int sig)
{
int retstat;
register int i;
pid_t pid;
if((pid = waitpid(-1, &retstat, WNOHANG)) <= 0)
{
log(LL_ERR, "ERROR, sigchild_handler, waitpid: %s", strerror(errno));
error_exit(1, "ERROR, sigchild_handler, waitpid: %s", strerror(errno));
}
else
{
if(WIFEXITED(retstat))
{
DBGL(DL_PROC, (log(LL_DBG, "normal child (pid=%d) termination, exitstat = %d",
pid, WEXITSTATUS(retstat))));
}
else if(WIFSIGNALED(retstat))
{
if(WCOREDUMP(retstat))
log(LL_WRN, "child (pid=%d) termination due to signal %d (coredump)",
pid, WTERMSIG(retstat));
else
log(LL_WRN, "child (pid=%d) termination due to signal %d",
pid, WTERMSIG(retstat));
}
}
/* check if hangup required */
for(i=0; i < MAX_PIDS; i++)
{
if(pid_tab[i].pid == pid)
{
if(pid_tab[i].cep->cdid != CDID_UNUSED)
{
DBGL(DL_PROC, (log(LL_DBG, "sigchild_handler: scheduling hangup for cdid %d, pid %d",
pid_tab[i].cep->cdid, pid_tab[i].pid)));
pid_tab[i].cep->hangup = 1;
}
pid_tab[i].pid = 0;
break;
}
}
}
/*---------------------------------------------------------------------------*
* execute prog as a subprocess and pass an argumentlist
*---------------------------------------------------------------------------*/
pid_t
exec_prog(char *prog, char **arglist)
{
char tmp[MAXPATHLEN];
char path[MAXPATHLEN];
pid_t pid;
int a;
snprintf(path, sizeof(path), "%s/%s", ETCPATH, prog);
arglist[0] = path;
tmp[0] = '\0';
for(a=1; arglist[a] != NULL; ++a )
{
strcat(tmp, " " );
strcat(tmp, arglist[a]);
}
DBGL(DL_PROC, (log(LL_DBG, "exec_prog: %s, args:%s", path, tmp)));
switch(pid = fork())
{
case -1: /* error */
log(LL_ERR, "ERROR, exec_prog/fork: %s", strerror(errno));
error_exit(1, "ERROR, exec_prog/fork: %s", strerror(errno));
case 0: /* child */
break;
default: /* parent */
return(pid);
}
/* this is the child now */
/*
* close files used only by isdnd, e.g.
* 1. /dev/i4b
* 2. /var/log/isdnd.acct (or similar, when used)
* 3. /var/log/isdnd.log (or similar, when used)
*/
close(isdnfd);
if(useacctfile && acctfp)
fclose(acctfp);
if(uselogfile && logfp)
fclose(logfp);
if(execvp(path,arglist) < 0 )
_exit(127);
return(-1);
}
/*---------------------------------------------------------------------------*
* run interface up/down script
*---------------------------------------------------------------------------*/
int
exec_connect_prog(cfg_entry_t *cep, const char *prog, int link_down)
{
char *argv[32], **av = argv;
char devicename[MAXPATHLEN], addr[100];
char *device;
int s;
struct ifreq ifr;
/* the obvious things */
device = bdrivername(cep->usrdevicename);
snprintf(devicename, sizeof(devicename), "%s%d", device, cep->usrdeviceunit);
*av++ = (char*)prog;
*av++ = "-d";
*av++ = devicename;
*av++ = "-f";
*av++ = link_down ? "down" : "up";
/* try to figure AF_INET address of interface */
addr[0] = '\0';
memset(&ifr, 0, sizeof ifr);
ifr.ifr_addr.sa_family = AF_INET;
strncpy(ifr.ifr_name, devicename, sizeof(ifr.ifr_name));
s = socket(AF_INET, SOCK_DGRAM, 0);
if (s >= 0) {
if (ioctl(s, SIOCGIFADDR, (caddr_t)&ifr) >= 0) {
struct sockaddr_in *sin = (struct sockaddr_in *)&ifr.ifr_addr;
strcpy(addr, inet_ntoa(sin->sin_addr));
*av++ = "-a";
*av++ = addr;
}
close(s);
}
/* terminate argv */
*av++ = NULL;
return exec_prog((char*)prog, argv);
}
/*---------------------------------------------------------------------------*
* run answeringmachine application
*---------------------------------------------------------------------------*/
int
exec_answer(cfg_entry_t *cep)
{
char *argv[32];
u_char devicename[MAXPATHLEN];
int pid;
char *device;
device = bdrivername(cep->usrdevicename);
snprintf(devicename, sizeof(devicename), "%si4b%s%d", _PATH_DEV, device,
cep->usrdeviceunit);
argv[0] = cep->answerprog;
argv[1] = "-D";
argv[2] = devicename;
argv[3] = "-d";
argv[4] = "unknown";
argv[5] = "-s";
argv[6] = "unknown";
argv[7] = NULL;
/* if destination telephone number avail, add it as argument */
if(*cep->local_phone_incoming.number)
argv[4] = cep->local_phone_incoming.number;
/* if source telephone number avail, add it as argument */
if(*cep->real_phone_incoming.number)
argv[6] = cep->real_phone_incoming.number;
if(*cep->display)
{
argv[7] = "-t";
argv[8] = cep->display;
argv[9] = NULL;
}
/* exec program */
DBGL(DL_PROC, (log(LL_DBG, "exec_answer: prog=[%s]", cep->answerprog)));
pid = exec_prog(cep->answerprog, argv);
/* enter pid and conf ptr entry addr into table */
if(pid != -1)
{
int i;
for(i=0; i < MAX_PIDS; i++)
{
if(pid_tab[i].pid == 0)
{
pid_tab[i].pid = pid;
pid_tab[i].cep = cep;
break;
}
}
return(GOOD);
}
return(ERROR);
}
/*---------------------------------------------------------------------------*
* check if a connection has an outstanding process, if yes, kill it
*---------------------------------------------------------------------------*/
void
check_and_kill(cfg_entry_t *cep)
{
int i;
for(i=0; i < MAX_PIDS; i++)
{
if(pid_tab[i].cep == cep)
{
pid_t kp;
DBGL(DL_PROC, (log(LL_DBG, "check_and_kill: killing pid %d", pid_tab[i].pid)));
kp = pid_tab[i].pid;
pid_tab[i].pid = 0;
kill(kp, SIGHUP);
break;
}
}
}
/*---------------------------------------------------------------------------*
* update budget callout/callback statistics counter file
*---------------------------------------------------------------------------*/
void
upd_callstat_file(char *filename, int rotateflag)
{
FILE *fp;
time_t s, l, now;
int n;
int ret;
now = time(NULL);
fp = fopen(filename, "r+");
if(fp == NULL)
{
/* file not there, create it and exit */
log(LL_WRN, "upd_callstat_file: creating %s", filename);
fp = fopen(filename, "w");
if(fp == NULL)
{
log(LL_ERR, "ERROR, upd_callstat_file: cannot create %s, %s", filename, strerror(errno));
return;
}
ret = fprintf(fp, "%ld %ld 1", now, now);
if(ret <= 0)
log(LL_ERR, "ERROR, upd_callstat_file: fprintf failed: %s", strerror(errno));
fclose(fp);
return;
}
/* get contents */
ret = fscanf(fp, "%ld %ld %d", &s, &l, &n);
/* reset fp */
rewind(fp);
if(ret != 3)
{
/* file corrupt ? anyway, initialize */
log(LL_WRN, "upd_callstat_file: initializing %s", filename);
s = l = now;
n = 0;
}
if(rotateflag)
{
struct tm *stmp;
int dom;
/* get day of month for last timestamp */
stmp = localtime(&l);
dom = stmp->tm_mday;
/* get day of month for just now */
stmp = localtime(&now);
if(dom != stmp->tm_mday)
{
FILE *nfp;
char buf[MAXPATHLEN];
/* new day, write last days stats */
sprintf(buf, "%s-%02d", filename, stmp->tm_mday);
nfp = fopen(buf, "w");
if(nfp == NULL)
{
log(LL_ERR, "ERROR, upd_callstat_file: cannot open for write %s, %s", buf, strerror(errno));
return;
}
ret = fprintf(nfp, "%ld %ld %d", s, l, n);
if(ret <= 0)
log(LL_ERR, "ERROR, upd_callstat_file: fprintf failed: %s", strerror(errno));
fclose(nfp);
/* init new days stats */
n = 0;
s = now;
log(LL_WRN, "upd_callstat_file: rotate %s, new s=%ld l=%ld n=%d", filename, s, l, n);
}
}
n++; /* increment call count */
/*
* the "%-3d" is necessary to overwrite any
* leftovers from previous contents!
*/
ret = fprintf(fp, "%ld %ld %-3d", s, now, n);
if(ret <= 0)
log(LL_ERR, "ERROR, upd_callstat_file: fprintf failed: %s", strerror(errno));
fclose(fp);
}
/* EOF */