2BSD/src/net/netdaemon.c
/* Copyright (c) 1979 Regents of the University of California */
# include "defs.h"
/* must be setuid root */
/* netdaemon mach readfd writefd */
static char hbuf[10];
static char header[] = "ABCDE";
static long length;
char code, sin;
FILE *temp, *dir, *jfile;
char resp[FNS], infile[FNS], outfile[FNS];
static char jname[FNS];
char buf[BFS*2];
static char nsendfail;
char frommach;
static char tempfile[]= TEMPFILE;
static char publogfile[]= PUBLOGFILE;
static char dumpfile[]= DUMPFILE;
static char namefile[]= NAMEFILE;
extern char **environ;
int handlekill();
main(argc,argv)
char **argv; {
register int i;
long ltime,t;
signal(SIGTERM,handlekill);
debugflg = DBV;
setupdaemon(argc,argv);
/* now running alone as a daemon */
/*
for(i=0; i<15; i++)close(i);
signal(SIGHUP,SIG_IGN);
signal(SIGQUIT,SIG_IGN);
signal(SIGINT,SIG_IGN);
*/
senddir[strlen(senddir)-1] = remote; /* choose dir */
if(chdir(senddir) < 0){
perror(senddir);
exit(1);
}
dir = fopen(senddir,"r");
if(dir == NULL){
perror(senddir);
exit(1);
}
mktemp(tempfile);
tempfile[strlen(tempfile) - 7] = remote;
ltime = gettime();
sprintf(buf,"net restarted to %s %d %s",longname(remote),
getpid(),ctime(<ime));
dump.longtime = dump.shorttime = ltime;
addtolog(remote,buf);
addtodump(remote,buf);
addtopublic(buf);
fprintf(stderr,buf);
if(!debugflg)fclose(stderr);
sendpurge();
nsendfail = 0;
for(;;){ /* begin reading file */
debug("daemon %c %d\nreceive",remote,getpid());
i = getreset();
dump.waittime = 0L;
if(i == BROKENREAD){
if(nsendfail < NSEND){
debug("send");
netsend();
}
else nsendfail++;
}
else {
i = netrcv();
if(i >= 0){
nsendfail = 0; /* it sent, it is up */
dump.waittot += dump.waittime;
}
if(i == -1)dump.nabnormal++;
}
t = gettime();
if(t - dump.shorttime > SAMPL)pload(t);
if(t - dump.longtime > BIGSAMPL)dumpit(t);
dump.nloop++;
/* count up to NSEND, sending, then wait NSEND */
if(nsendfail >= NSEND*2)nsendfail = 0;
}
}
netsend(){
static long lasttime = 0;
static char nleft = 1;
long jsize,diff;
double r;
int jusr;
char *s,*p,*tt;
long ot,nt,filesize;
register int i;
if(stat(senddir,&statbuf) < 0){
error("%s %s",senddir,sys_errlist[errno]);
return;
}
if(statbuf.st_mtime == lasttime && nleft == 0)return; /* no need to search */
lasttime = statbuf.st_mtime;
fseek(dir,0L,0);
jsize = -1;
nleft = 0;
while(fread(&dirbuf,1,sizeof dirbuf,dir) == sizeof dirbuf){
if(dirbuf.d_ino == 0
|| dirbuf.d_name[0] != 'c'
|| dirbuf.d_name[1] != 'f'
|| dirbuf.d_name[2] != remote
|| stat(dirbuf.d_name,&statbuf) < 0)
continue;
dirbuf.d_name[0] = 'd';
if(stat(dirbuf.d_name,&statbuf) < 0)continue;
filesize = getsize(&statbuf);
nleft++;
if(jsize == -1 || jsize > filesize){
jsize = filesize;
for(i=0; i<DIRSIZ; i++)
jname[i] = dirbuf.d_name[i];
jusr = guid(statbuf.st_uid,statbuf.st_gid);
}
}
if(jsize == -1)return;
strcpy(cmd,jname);
cmd[0] = 'c';
p = getun(jusr);
addtolog(remote,"^S %s %c: %s ",p,remote,jname+2);
ot = gettime();
dump.waittime = 0L;
if(send() == 0)return;
nt = gettime();
dump.waittot += dump.waittime;
filesize = getsize(&statbuf);
unlink(jname);
unlink(cmd);
diff = nt - ot;
s = ctime(&nt)+4;
s[strlen(s) -9] = 0;
r = filesize;
r = r/diff;
tt = comptime(ot - statbuf.st_mtime);
jname[3] = jname[2];
addtolog(remote,"^T%c(%s, %ldb, %ldsec, %4.1fb/sec, w %s)\n",
remote,s,filesize, diff,r, tt);
addtopublic("%s: sent to %s: %s (%s, %ld bytes, wait %s)\n",
s,longname(remote), p,jname+3,filesize,tt);
dump.nsend++;
dump.bytetot += filesize;
dump.elaptot += diff;
addtoname(p);
}
send(){ /* push those bytes */
/* returns 0 if send fails, 1 otherwise */
register int n;
int i;
long lsize;
char mbuf[2*BFS];
register char *p;
if(stat(jname,&statbuf) < 0)goto sfail;
lsize = getsize(&statbuf);
if(lsize < MINSIZE){ /* all files are at least this long */
unlink(jname);
jname[0] = 'c';
unlink(jname);
return(1);
}
jfile = fopen(jname,"r");
if(jfile == NULL)goto sfail;
strcpy(mbuf,header);
i = strlen(header);
p = (char *)&lsize;
lsize = fixuplong(lsize);
mbuf[i] = *p++;
mbuf[i+1] = *p++;
mbuf[i+2] = *p++;
mbuf[i+3] = *p++;
i = i + 4;
sendreset();
masterseqno = 1;
lastseqno = 0;
if(xwrite(mbuf,1,i) == WRITEFAIL)goto bwrite;
while((n=fread(buf,1,BLOCKSIZE,jfile)) > 0)
if(xwrite(buf,1,n) == WRITEFAIL)goto bwrite;
fclose(jfile);
debug("end send");
nsendfail = 0;
return(1);
bwrite:
nsendfail++;
dump.nsendfail++;
fclose(jfile);
addtolog(remote,"^F%c ",remote);
return(0);
sfail:
error("%s: %s",jname,sys_errlist[errno]);
dump.nsendfail++;
return(0);
}
netrcv(){
/* returns -2 in normal fail, -1 in abnormal fail, >= 0 otherwise */
char tmach, fmach;
char mgetc(), cflag, *s;
register int n,i;
char vmajor, vminor, c;
int rcode, dummy;
char buf1[BFS*2];
long timesent,otime,olength,diff,rcvfinish,nt;
double r;
n = nread(hbuf,1,strlen(header));
if(n == BROKENREAD)return(-2);
if(n != strlen(header) || strcmp(header,hbuf) != 0){
error("wrong head %d %s",n,hbuf);
return(-1);
}
n = nread(&length,1,4);
if(n == BROKENREAD)return(-2);
if(n != 4){
error("bad length nread %d",n);
return(-1);
}
length = fixuplong(length);
olength = length;
otime = gettime();
debug("length = %ld\n",length);
i = 0;
code = mgetc();
tmach = mgetc();
if(tmach < 'a' || 'z' < tmach){
error("bad tmach");
return(-1);
}
if(tmach != local)goto forw; /* being forwarded through us */
fmach = mgetc();
vmajor = mgetc();
vminor = mgetc();
i += mgets(status.login);
i += mgets(status.mpasswd);
demask(status.mpasswd);
i += mgets(infile);
i += mgets(outfile);
i += mgets(resp);
i += mgets(status.localname);
i += mgets(ttystr);
if(ttystr[0] == 0)strcpy(ttystr,"/dev/ttyx");
cflag = mgetc();
if(!fmach || !code || !cflag || !vmajor || !vminor){
error("mgetc fails");
return(-1);
}
cflag -= 'a';
vmajor -= 'a';
vminor -= 'a';
if(vmajor != VMAJOR || vminor != VMINOR){
error("versions dont agree (%d,%d) vs. (%d,%d) remote",
VMAJOR,VMINOR,vmajor,vminor);
return(-1);
}
i += mgets(buf);
ltime = 0;
sscanf(buf,"%lo",<ime);
i += mgets(buf1);
status.jobno = atoi(buf1);
i += mgets(buf1); /* time sent */
sscanf(buf1,"%ld",×ent);
i += mgetcmd(cmd);
i += mgetcmd(realcmd);
if(i != 0){error("mgets fails"); return(-1);}
if(realcmd[0] == 0)strcpy(realcmd,cmd);
s = realcmd;
while(*s && *s != ' ')s++;
c = *s;
*s = 0;
if(strcmp(realcmd,"netlpr") == 0)dump.nnetlpr++;
else if(strcmp(realcmd,"netmail") == 0)dump.nnetmail++;
else if(strcmp(realcmd,"mail") == 0)dump.nsmail++;
else if(strcmp(realcmd,"netcp") == 0)dump.nnetcp++;
else if(strcmp(realcmd,"response") == 0)dump.nresp++;
else dump.nnet++;
*s = c;
debug("%c %c %c (%c,%c) %s %s %s %s (%s) %s %c %lo %d %s\n",
code,tmach,fmach,vmajor+'a',vminor+'a',status.login,
infile,outfile,resp,status.localname,
ttystr,cflag+'a',ltime,status.jobno,cmd);
/* any chars left are data */
forw:
sin = 0;
if(length > 0){ /* make a temp input file */
increment(tempfile);
temp = fopen(tempfile,"w");
if(temp == NULL){
error("%s %s",tempfile,sys_errlist[errno]);
return(-1);
}
chmod(tempfile,0600);
if(tmach != local)fprintf(temp,"%c :%c :",code,tmach);
while((n = mread(buf,1,BLOCKSIZE)) > 0)
if(fwrite(buf,1,n,temp) != n){
error("%s %s",tempfile,sys_errlist[errno]);
fclose(temp);
unlink(tempfile);
return(-1);
};
fclose(temp);
if(n == BROKENREAD || length > 0){
unlink(tempfile);
return(-2);
}
sin = 1;
if(tmach != local){
diff = gettime() - otime;
r = olength;
r = r/diff;
addtolog(remote,"^P(to %c, %ldb, %ldsec, %4.1fb/sec)\n",
tmach,olength,diff,r);
dump.npass++;
dump.bytetot += olength;
dump.elaptot += diff;
if(fork() == 0){
sprintf(buf,"-m%c",tmach);
execl(netcmd,"net","-x","-s",tempfile,buf,0);
exit(1);
}
wait(&dummy);
unlink(tempfile);
return(1);
}
}
if(length > 0){error("file too short"); return(-1); }
rcvfinish = gettime();
while((i=fork())== -1)sleep(2);
if(i > 0){wait(&dummy); return(1);} /* normal return */
while((i=fork())== -1)sleep(2);
if(i)exit(0);
/* child process which forks and waits */
mktemp(resfile);
while((i=fork())== -1)sleep(2);
if(i == 0){
/* child */
strcpy(status.loginshell,Bsh);
frommach = fmach;
n = check(status.login,status.mpasswd,(code == 'q'));
if(!n)errormsg(fmach,"Bad remote login/password %s",status.login);
temp = fopen(resfile,"w");
if(temp == NULL)
errormsg(fmach,"creat %s %s",resfile,sys_errlist[errno]);
chmod(resfile,0600);
fclose(temp);
chown(resfile,status.muid,status.mgid);
if(sin)chown(tempfile,status.muid,status.mgid);
setuid(status.muid);
setgid(status.mgid);
if((i=getuid()) != status.muid)error("setuid fails");
debug("uid: %o\n",i);
/* check for allowed root commands, for security reasons */
if(i == 0){
s = cmd;
while(*s && *s != ' ')s++;
c = *s;
*s = 0;
/* these are the only commands root may execute */
if(strcmp(cmd,"cat") != 0
&& strcmp(cmd,writecmd) != 0
&& strcmp(cmd,"/usr/lib/tq") != 0
&& strcmp(cmd,"/usr/lib/rtrrm") != 0
&& strcmp(cmd,"lpr") != 0)
errormsg(fmach,"Not allowed to use that command as root");
*s = c;
}
if(chdir(status.dir) < 0)
errormsg(fmach,"chdir %s %s",status.dir,sys_errlist[errno]);
setenv(status.dir); /* set up v7 environment */
if(sin)mreopen(fmach,tempfile,"r",stdin);
else if(infile[0])mreopen(fmach,infile,"r",stdin);
else mreopen(fmach,"/dev/null","r",stdin);
if(code == 's' && outfile[0]){
if(stat(outfile,&statbuf) < 0
|| getsize(&statbuf) != 0
|| !(statbuf.st_mode&0600))
errormsg(local,"bad result file %s",outfile);
mreopen(fmach,outfile,"w",stdout);
}
else if(outfile[0]){
temp = fopen(outfile,"w");
if(temp == NULL)
errormsg(fmach,"fopen %s %s",outfile,sys_errlist[errno]);
fclose(temp);
mreopen(fmach,outfile,"w",stdout);
}
else mreopen(fmach,resfile,"a",stdout);
debug("exec '%s'\n",cmd);
if(debugflg == 0){
/* cheat */
close(2);
dup(1);
/*
mreopen(fmach,resfile,"a",stderr);
*/
}
for(i=3;i<15;i++)close(i);
do {
mexecl(status.loginshell,"sh","-c",cmd,0);
sleep(2);
} while(errno == ETXTBSY);
exit(1);
}
/* parent */
wait(&rcode);
/*
fclose(stdin);
fclose(stdout);
fclose(stderr);
*/
if(sin)unlink(tempfile);
if(code == 'q' && (resp[0] || !(cflag&F_NONOTIFY))){
/* send response back if a response file
was given or if mail/write is allowed */
/* should give an error message for
non-zero return codes */
if(stat(resfile,&statbuf) < 0){
error("%s %s",resfile,sys_errlist[errno]);
goto next;
}
if(getsize(&statbuf) >= MAXFILE){
errormsg(fmach,"Result file too large - not sent");
goto next;
}
if(getsize(&statbuf) == 0 && resp[0])goto next;
if(resp[0])sprintf(buf1,"-o %s cat",resp);
else sprintf(buf1,"%s %s %s %lo %c %s \"'%s'\" %ld",writecmd,
status.localname,ttystr,ltime,tmach,status.login,
realcmd,timesent);
sprintf(buf,"%s -m%c -z -n -l %s -s %s -c response %s",
netcmd,fmach,status.localname,resfile,buf1);
dummy = system(buf); /* execute command buf */
}
next:
unlink(resfile);
s = ctime(&rcvfinish);
s += 4;
s[strlen(s) -8] = 0;
diff = rcvfinish - otime;
r = olength;
r = r/diff;
dump.bytetot += olength;
dump.elaptot += diff;
addtoname(status.login);
sprintf(buf,"%s rcv %s: %s (%s)",
s,longname(fmach),status.login,status.localname);
addtolog(remote,"%s C: %s\n",buf,realcmd);
addtopublic("%s R: %d C: %s\n",buf,rcode>>8,realcmd);
nt = rcvfinish - timesent - TIMEBASE;
buf[0] = 0;
if(nt > 0L)sprintf(buf," took (%s,%ld)",comptime(nt),nt);
addtolog(remote,"\t\tR: %d%s %ldb %ldsec %4.1fb/sec\n",
rcode>>8,buf,olength,diff,r);
exit(0);
/*UNREACHED*/
}
/* l = login pass=passwd
verify = 1 if password must check */
check(l,pass,verify) /* 1 if OK, 0 if not */
int verify;
char *l, *pass; {
int ver;
char *s, *u, *nullstr = "";
struct passwd *pwd;
ver = (verify == 0); /* ver is true if password verification
was not requested */
if(l[0] == 0)return(ver);
if(!goodacctname(l))return(ver);
pwd = getpwnam(l);
if(pwd == NULL)return(ver);
# ifdef OLDPROT
if(machtype[local-'a'] == M_CC && machtype[frommach-'a'] == M_CC)
s = pass;
else
# endif
if(*pass)s = crypt(pass,pwd->pw_passwd);
else s = nullstr;
status.muid = guid(pwd->pw_uid,pwd->pw_gid);
status.mgid = pwd->pw_gid;
if(isdigit(pwd->pw_gecos[0]))status.jobno = atoi(pwd->pw_gecos);
else status.jobno = 32767;
strcpy(status.dir,pwd->pw_dir);
strcpy(status.loginshell,pwd->pw_shell);
u = status.loginshell;
if(u[0] == 0 /* || strcmp("sh",u+strlen(u)-2) != 0 */) strcpy(u,Bsh);
getpwdf(pwd);
/* ignore network passwd */
if(!spacct(status.login,s,status.localname,status.muid,status.mgid)
&& strcmp(pwd->pw_passwd,s) && verify)
return(0);
return(1);
}
mread(b,i,n)
register int n; {
if(length <= 0)return(0);
if(length < n)n = length;
n = nread(b,i,n);
if(n != BROKENREAD)length -= n;
return(n);
}
char mgetc(){ /* returns 0 if fail */
register char c;
register int n;
char buf[3];
if((n=nread(buf,1,3)) == BROKENREAD)return(0);
if(n != 3){error("bad read %d",n); return(0); }
c = buf[0];
if(buf[1] != ' ' && buf[1] != ':'){error("Bad char %c",buf[1]); return(0); }
length -= 3;
if(length < 0){error("length wrong2 %ld",length); return(0); }
return(c);
}
mgets(s) /* returns 0 if ok, 1 if not */
register char *s; {
register char *q;
register int n;
char c;
q = s;
for(;;) {
if((n=nread(&c,1,1)) == BROKENREAD){
*s = 0;
error("mgets %s",s);
return(1);
}
if(n == 0)break;
if(c == '\\'){
if((n=nread(&c,1,1)) == BROKENREAD){
*s = 0;
error("mgets %s",s);
return(1);
}
if(n == 0)break;
}
if(c == ' ')break;
*s++ = c;
}
*s = 0;
if(nread(&c,1,1) == BROKENREAD){
error("mgets %s",s);
return(1);
}
length -= (s - q + 2);
if(length < 0){error("length wrong1 %ld %s",length,q); return(-1); }
return(0);
}
mgetcmd(s) /* returns 0 if succeed, 1 otherwise */
char *s; {
int i,n;
char c;
i = 0;
for(;;){
if((n=nread(&c,1,1)) == BROKENREAD){
s[i] = 0;
error("mgetcmd %s",s);
return(1);
}
if(n <= 0 || c == '\n')break;
if(c == '\\'){
if(nread(&c,1,1) == BROKENREAD){
s[i] = 0;
error("mgetcmd %s",s);
return(1);
}
length--;
}
s[i++] = c;
length--;
}
s[i] = 0;
length--;
return(0);
}
increment(s)
char *s; {
int i;
char *p;
i = strlen(s) - 1;
while(s[i] == '9')i--;
if(s[i] < '0' || s[i] > '9'){
p = s+i+1;
while(*p)*p++ = '0';
return;
}
(s[i])++;
i++;
while(s[i])s[i++] = '0';
return;
}
pload(currt)
long currt; {
struct tms tbf;
static long out = 0L, ocut = 0L, ost = 0L, ocst = 0L;
long u, s, elapt;
double br,r,ru,rs;
char *str,buf[BUFSIZ];
currt = gettime();
elapt = currt - dump.shorttime;
times(&tbf);
u = tbf.tms_utime-out + tbf.tms_cutime-ocut;
s = tbf.tms_stime-ost + tbf.tms_cstime-ocst;
dump.outime += u;
dump.ostime += s;
r = u + s;
if(elapt > 0)r = (r/elapt)*100.0;
else r = 0.0;
/* adjust to be seconds */
r = r/60.0;
ru = u/60.0;
rs = s/60.0;
str = ctime(&currt);
str[strlen(str) - 5] = 0;
sprintf(buf,"%s (%s):\t%4.1fu\t%4.1fs\t%5.2f\t%s\n",
str,longname(remote),ru,rs,r,comptime(elapt));
addtodump(remote,"%s",buf);
br = dump.bytetot;
if(dump.elaptot > 0)br = br/dump.elaptot;
else br = 0.0;
addtodump(remote, "\tTrans.\t%.6ld bytes\t%4.1f bytes/sec\t%s",
dump.bytetot,br,comptime(dump.elaptot));
addtodump(remote," %s\n",comptime(dump.waittot));
dump.shorttime = currt;
dump.waittot = dump.elaptot = dump.bytetot = 0L;
out = tbf.tms_utime;
ocut = tbf.tms_cutime;
ost = tbf.tms_stime;
ocst = tbf.tms_cstime;
sprintf(buf,"%s %c",NETQSTAT,remote);
system(buf); /* gather stats on netq len. */
}
dumpit(currt)
long currt; {
register int ntot;
long elapt;
double r,ru,rs;
register struct dumpstruc *p = &dump;
register char *tt;
tt = ctime(&currt);
tt[strlen(tt) - 9] = 0;
elapt = currt - dump.longtime;
r = dump.outime + dump.ostime;
if(elapt > 0)r = (r/elapt) * 100.0;
else r = 0.0;
ru = dump.outime/60.0;
rs = dump.ostime/60.0;
r = r/60.0;
dump.longtime = dump.shorttime;
ntot = p->nnetcp + p->nnetmail + p->nsmail + p->nnetlpr
+ p->nresp + p->nnet;
addtodump(remote,"Daily statisics\t(%s):\nSummary:\n",tt);
addtodump(remote,"\t# sent %d\t# pass-thru %d\t# rcv %d:\t# netcp %d\n",
p->nsend,p->npass,ntot,p->nnetcp);
addtodump(remote,"\t# netlpr %d\t# netmail %d\t# sendmail %d\t# resp %d\n",
p->nnetlpr,p->nnetmail,p->nsmail,p->nresp);
addtodump(remote,"Protocol summary:\n");
addtodump(remote,"\t# pk sent %d\t# pk rcv %d\t# b sent %ld\t# b rcv %ld\n",
p->npacksent,p->npackrcv,p->nbytesent, p->nbytercv);
addtodump(remote,
"\t# send fails %d\t# retrans %d\t# abn %d\t\t# cksum errs %d\n",
p->nsendfail,p->nretrans, p->nabnormal,p->ncksum);
addtodump(remote,"Load:\t\t\t\t%4.1fu\t%4.1fs\t%5.2f%%\t%s\n",
ru,rs,r,comptime(elapt));
p->nbytesent = p->nbytercv = p->outime = p->ostime = 0L;
p->nretrans = p->nloop = p->nabnormal = p->ncksum = 0;
p->npacksent = p->npackrcv = p->nnetcp = p->nnetmail = 0;
p->nsmail = p->nnetlpr = p->nnet = p->npass = 0;
p->nsend = p->nsendfail = 0;
}
/* returns 1 if n is ok, 0 if not */
goodacctname(n)
char *n; {
int i;
i = -1;
while(btable[++i].bname)
if(strcmp(btable[i].bname,n) == 0 &&
local == btable[i].bmach)return(0);
return(1);
}
demask(s)
register char *s; {
# ifdef OLDPROT
while(*s){
*s &= 0177; /* strip quote bites */
*s++ ^= 040; /* invert upper-lower */
}
# else
static char buf[20];
strcpy(s,nbsdecrypt(s,THEKEY,buf));
# endif
}
/*VARARGS0*/
mreopen(f,a,b,c){
/* simply handles errors by giving error msg */
if(freopen(a,b,c) == NULL)errormsg(f,"%s: %s",a,sys_errlist[errno]);
}
/*VARARGS0*/
addtopublic(s,a,b,c,d,e,f,g,h,i,j,k,l,m,n)
char *s;
{
static FILE *log = NULL;
if(log == NULL){
if(stat(publogfile,&statbuf) < 0)return;
log = fopen(publogfile,"a");
if(log == NULL)return;
}
fseek(log,0L,2);
fprintf(log,s,a,b,c,d,e,f,g,h,i,j,k,l,m,n);
fflush(log);
}
/*VARARGS0*/
addtodump(mach,str,a,b,c,d,e,f,g,h,i,j,k,l,m,n,o,p,q,r,t,u)
char *str;
{
static FILE *log = NULL;
dumpfile[strlen(dumpfile)-1] = mach;
if(log == NULL){
if(stat(dumpfile,&statbuf) < 0)return;
log = fopen(dumpfile,"a");
if(log == NULL)return;
}
fseek(log,0L,2);
fprintf(log,str,a,b,c,d,e,f,g,h,i,j,k,l,m,n,o,p,q,r,t,u);
fflush(log);
}
/* set up a dummy environment for v7 /bin/sh */
setenv(home)
char *home; {
static char *env[3],benv[2][50];
env[0] = benv[0];
env[1] = benv[1];
strcpy(env[0],"PATH=:/bin:/usr/bin");
sprintf(env[1],"HOME=%s",home);
env[2] = 0;
environ = env;
}
/* errormsg- sends error message to user-
may be on local or remote machine */
/*VARARGS0*/
errormsg(fmach,s,a,b,c,d,e,f,g,h)
char *s;
{
/* can't use -w,-x,-y,-z because must be root for those */
int rcode;
char buf[BFS*2], buf1[BFS*2];
if(fmach < 'a' || 'z' < fmach)fmach = local;
if(ttystr[0] == 0)strcpy(ttystr,"/dev/ttyx");
if(fmach == local && status.login[0])
strcpy(status.localname,status.login);
if(status.localname[0] == 0)strcpy(status.localname,status.login);
if(status.localname[0] == 0 || strcmp(status.localname,"root") == 0)
strcpy(status.localname,"schmidt");
/* will send to localname on fmach machine */
/* in case of error, send to "schmidt" */
/* error messages should never be sent to root */
sprintf(buf,"Error: Cmd: %s Message: ",realcmd);
sprintf(buf1,s,a,b,c,d,e,f,g,h);
strcat(buf,buf1);
strcat(buf,"\n");
addtolog(remote,buf);
if(fmach == local)
sprintf(buf1, "echo \"%s\" | %s %s %s %lo %c %s",
buf,writecmd,status.localname,ttystr,ltime,local,status.login);
else sprintf(buf1,
"echo \"%s\" | %s -m%c -n -c response -l network -p \"\" - %s %s %s %lo %c %s",
buf,netcmd,fmach,writecmd,status.localname,ttystr,ltime,local,status.login);
rcode = system(buf1);
exit(1);
}
handlekill(){ /* SIGTERM signal */
long t;
addtodump(remote,"Netdaemon terminated.\n");
t = gettime();
pload(t);
dumpit(t);
exit(0); /* kill myself */
}
spacct(log,pass,localname,luid,lgid) /* returns 1 if login ok, 0 if not */
char *log,*pass,*localname; {
long lt;
int u,g;
if(strcmp(log,"network") == 0)return(1);
/* experimental */
# ifdef SPACCT
if(strcmp(log,localname) == 0 && luid != 0 && lgid == 0
&& isdigit(pass[0]) && (
strcmp(log,"source") == 0
|| strcmp(log,"daemon") == 0)
){
/* login name is same on both machines, userid is group 0,
non-root, the password is numeric
and the login name is one of a select few */
lt = atol(pass);
u = (lt & 0177777);
g = (lt >> 16);
if((luid == u) && (lgid == g))return(1);
}
# endif
return(0);
}
/* add the user's name to our name list */
/*VARARGS0*/
addtoname(name)
char *name;
{
static FILE *log = NULL;
if(name == 0 ||
name[0] == 0 ||
strcmp(name,"root") == 0 ||
strcmp(name,"network") == 0 ||
strcmp(name,"schmidt") == 0)return;
if(log == NULL){
if(stat(namefile,&statbuf) < 0)return;
log = fopen(namefile,"a");
if(log == NULL)return;
}
fseek(log,0L,2);
fprintf(log,"%s:%s\n",longname(local),name);
fflush(log);
}