![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to mgrproc.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Research Unix] / researchv10no / dk / cmd|
Return to mgrproc.c CVS log | Up to [Research Unix] / researchv10no / dk / cmd |
1.1 root 1: /*
2: * processor manager for UNIX systems
3: */
4:
5: #include <dk.h>
6: #include <dkmgr.h>
7: #include <pwd.h>
8: #include <stdio.h>
9: #include <signal.h>
10: #include <sys/ioctl.h>
11: #include <utmp.h>
12: #include <errno.h>
13: #include <sys/types.h>
14: #include <sys/stat.h>
15: #include <sys/param.h>
16: #include <wait.h>
17: #include <string.h>
18: #include <dkwindow.h>
19:
20: #define CTLFILE "/etc/procctl"
21: #define CTL2FILE "/etc/procctl.local"
22: #define UIDFILE "/etc/procuid"
23: #define UID2FILE "/etc/procuid.local"
24: #define LOGLVL 1
25:
26: #define SYSERR 010 /* system error, "something is wrong" */
27: #define BUSY 011 /* destination busy */
28: #define NOCMC 012 /* remote node not answering */
29: #define NODEST 013 /* destination not answering */
30: #define INTERT 014 /* unassigned number */
31: #define REORT 015 /* system overload */
32: #define PERMISSION 017 /* permission denied */
33:
34: /*
35: * format of procctl file entry --
36: *
37: * field 1 - source name, or * for any, of requester for this entry
38: * field 2 - service type requested, character string
39: * field 3 - converted service name for local use in this program
40: * field 4 - parameters, use depends on service type
41: *
42: */
43: struct sprocctl {
44: char * p_sname ; /* source name */
45: char * p_code ; /* service type */
46: char * p_ncode ; /* case stmt type */
47: char * p_param ; /* params for sub-case */
48: } procctl[64] ;
49:
50: /*
51: * format of procuid file entry ---
52: *
53: * field 1 - source name, or * for any, or requester for this entry
54: * field 2 - converted service name requested
55: * field 3 - uid as passed from source nachine, of * for any
56: * field 4 - uid to use locally, or * for same as source
57: */
58: struct sprocuid {
59: char * u_sname ; /* source name */
60: char * u_code ; /* service type */
61: char * u_uid ; /* source provided uid */
62: char * u_nuid ; /* local uid */
63: } procuid[256] ;
64:
65: FILE *fprocctl, *f2procctl, *fprocuid, *f2procuid ; /* file descriptor for control file */
66: long tprocctl, t2procctl, tprocuid, t2procuid ; /* last ctime of file */
67: int nprocctl, nprocuid ; /* number of entries read from file */
68: int zprocctl, zprocuid ; /* size of file at last look */
69: char *bprocctl, *bprocuid ; /* where in memory the file lives */
70:
71: /*
72: * defines for a character string "switch" statement
73: * SSWITCH(string) {
74: * SCASE("value")
75: * statements ;
76: * SCASE("value")
77: * statements ;
78: * }
79: */
80: #define SSWITCH(c) SSTR=c;if(0)
81: #define SCASE(c) }else if (strcmp(SSTR,c)==0){
82: char * SSTR ;
83:
84: char *ncode ; /* converted service code */
85: char uid[16] ; /* uid if special */
86: char dkname[32] ; /* system name from /etc/whoami */
87:
88: char *params ; /* parameters for sub-case handling */
89: char parmbuf[512] ; /* for additional parameters */
90: short parmlen ; /* length of additional stuff */
91: char env1[64];
92: extern char **environ ;
93: static char *envinit[] = {
94: env1,
95: 0
96: } ;
97:
98: char *oursrv ; /* pointer to our server name */
99: struct mgrmsg *imsg ; /* pointer to request message from remote */
100: struct passwd *pwent, *pwsearch(); /* password entry */
101: struct passwd *getnam();
102: int rootable ; /* should we allow root here? */
103: char pwline[256]; /* line from password file */
104: int proctab[512];
105: void chdies(), rmut() ;
106:
107: char *logfile = "/usr/dk/LOGPROC" ;
108: char logbuf[BUFSIZ];
109: int loglvl = LOGLVL ;
110: FILE *logf ;
111: struct sgttyb term ;
112: char FROGS[] = "\n&;^|<>(){}"; /* disallowed argument characters */
113:
114: extern int getopt(), optind;
115: extern char *optarg;
116: extern char *dkfilename();
117:
118: main(argc, argv)
119: char **argv ;
120: {
121: register short i ;
122: register short fi ;
123: short f2 ;
124: FILE * fip ;
125: extern int dkmgropen ;
126: struct mgrmsg *dkmgr() ;
127: extern int errno, dkp_ld, tty_ld, cdkp_ld, rmesg_ld ;
128: register char *cp, *filename;
129: int msg, tty, wargs;
130: int traffic = 2;
131:
132: fi = open("/etc/whoami", 0) ;
133: if (fi < 0) {
134: perror("mgrproc: open /etc/whoami: ") ;
135: exit(1) ;
136: }
137: i = read(fi, dkname, sizeof(dkname)) ;
138: if (i <= 0) {
139: printf("bad read of /etc/whoami\n") ;
140: exit(1) ;
141: }
142: dkname[i] = '\0' ;
143: if ((cp = strchr(dkname, '\n')))
144: *cp = '\0';
145: close(fi) ;
146: oursrv = dkname;
147: while ((i = getopt(argc, argv, "s:t:v:l:")) != EOF) {
148: switch(i) {
149: case 's': /* server */
150: oursrv = optarg;
151: continue;
152:
153: case 't': /* traffic class */
154: traffic = atoi(optarg);
155: continue;
156:
157: case 'v': /* verbosity of logfile comments */
158: loglvl = atoi(optarg);
159: continue;
160:
161: case 'l': /* name of logfile */
162: logfile = optarg;
163: continue;
164:
165: default:
166: exit(1);
167:
168: }
169: }
170: if (i = fork()) {
171: printf("mgrproc: starting server %s on system %s, pid %d\n",
172: oursrv, dkname, i) ;
173: exit(0) ; /* parent exits, child continues */
174: }
175: logf = fopen(logfile, "a") ;
176: if (logf == NULL)
177: printf("cannot open/create log file\n") ;
178: else
179: setbuf(logf, logbuf);
180:
181:
182: signal(SIGINT, SIG_IGN) ;
183: signal(SIGQUIT, SIG_IGN) ;
184: signal(SIGHUP, SIG_IGN) ;
185: signal(SIGTERM, SIG_IGN) ;
186: signal(SIGPIPE, SIG_IGN) ;
187: signal(SIGALRM, SIG_IGN) ;
188: signal(SIGCHLD, chdies) ;
189: pwsearch("root", -1, pwline); /* prime passwd file lookup */
190: loadfiles() ;
191: for (;;) {
192: imsg = dkmgr(oursrv, traffic) ;
193: if (imsg == NULL) {
194: if (errno == EINTR) {
195: # define INULL (int *)NULL
196: while ((i = wait3(INULL, WNOHANG, INULL)) > 0) {
197: register j;
198: for (j=0; j<512; j++)
199: if (proctab[j]==i) {
200: rmut(j);
201: proctab[j] = 0;
202: break;
203: }
204: dolog(3, "CHILD DIES c=%d\n", j) ;
205: }
206: continue ;
207: }
208: perror("mgrproc error in dkmgr: ") ;
209: exit(1) ;
210: }
211: if (imsg->m_service == NULL)
212: imsg->m_service = "(NULL)" ; /* default service */
213: if (imsg->m_uid == NULL || imsg->m_uid[0] == 0)
214: imsg->m_uid = imsg->m_origin ;
215: if (imsg->m_source == NULL)
216: imsg->m_source = "(NULL)" ;
217: dolog(1, "REQUEST c=%d, t=%s, UID=%s, from %s traf %x\n",
218: imsg->m_chan, imsg->m_service, imsg->m_uid, imsg->m_source,
219: imsg->m_traffic&0xFFFF) ;
220: for (cp=imsg->m_service; *cp; cp++)
221: if (*cp == '.')
222: *cp = '\0' ;
223: loadfiles() ;
224: for (i=0; i<nprocctl; i++) {
225: if (strcmp(procctl[i].p_code, imsg->m_service) == 0 &&
226: cksource(procctl[i].p_sname, imsg->m_source)) {
227: ncode = procctl[i].p_ncode ;
228: params = procctl[i].p_param ;
229: goto gotit ;
230: }
231: }
232: dolog(0, "ILLEGAL REQUEST chan %d\n", imsg->m_chan) ;
233: dkmgrnak(imsg->m_chan, INTERT) ;
234: continue ;
235:
236: gotit:
237: pwent = NULL;
238: rootable = 0 ;
239: if (strcmp(imsg->m_uid, "(NULL)")) {
240: for (i=0; i<nprocuid; i++) {
241: if (cksource(procuid[i].u_sname, imsg->m_source) &&
242: cksource(procuid[i].u_code, imsg->m_service) &&
243: cksource(procuid[i].u_uid, imsg->m_uid)) {
244: if (procuid[i].u_nuid[0] != '*') {
245: dolog(1, "UID %s.%s -> %s\n", imsg->m_source, imsg->m_uid, procuid[i].u_nuid) ;
246: imsg->m_uid = procuid[i].u_nuid ;
247: rootable = 1 ;
248: }
249: goto gotuid ;
250: }
251: }
252: imsg->m_uid = "**BAD**" ;
253: gotuid:
254: pwent = pwsearch(imsg->m_uid, -1, pwline);
255: }
256: if ((i = fork()) > 0) {
257: proctab[imsg->m_chan] = i;
258: continue ;
259: } else if (i < 0) {
260: dolog(0, "ERROR can't fork");
261: dkmgrnak(imsg->m_chan, NODEST);
262: continue;
263: }
264: filename = dkfilename(imsg->m_chan);
265: if (filename == NULL) {
266: dolog(0, "Can't find file for chan %d\n", imsg->m_chan);
267: dkmgrnak(imsg->m_chan, NODEST);
268: exit(1);
269: }
270: f2 = open(filename, 2) ;
271: if (f2 < 0) {
272: dolog(0, "ERROR cannot open %s\n", filename);
273: dkmgrnak(imsg->m_chan, NODEST) ; /* error */
274: exit(1) ;
275: }
276: ioctl(f2, DIOCNXCL, 0);
277: dolog(7, "DEBUG ncode %s\n", ncode) ;
278: environ = envinit ;
279: sprintf(environ[0], "DKSOURCE=%s.%s", imsg->m_source,
280: imsg->m_uid);
281:
282: SSWITCH(ncode) {
283:
284: SCASE("login")
285: if (dkproto(f2, cdkp_ld) < 0 ||
286: ioctl(f2, FIOPUSHLD, &tty_ld) < 0) {
287: dolog(0, "FAILED PUSHLD %s\n", ncode) ;
288: dkmgrnak(imsg->m_chan, REORT) ;
289: exit(1) ;
290: }
291: dkmgrack(imsg->m_chan) ;
292: setfd(f2) ;
293: execl("/etc/login", "login", 0) ;
294: execl("/bin/login", "login", 0) ;
295: dolog(0, "FAILED EXEC login\n") ;
296: exit(1) ;
297:
298: SCASE("dcon")
299: msg = 0;
300: goto dc;
301:
302: SCASE("mesgdcon")
303: msg = 1;
304:
305: dc:
306: if (dkproto(f2, dkp_ld) < 0) {
307: dolog(0, "FAILED PUSHLD %s\n", ncode) ;
308: dkmgrnak(imsg->m_chan, REORT) ;
309: exit(1) ;
310: }
311: dkmgrack(imsg->m_chan) ;
312: setwins(f2, imsg->m_traffic);
313: pwent = getnam(imsg->m_uid, f2, pwent, 0) ;
314: if (pwent == NULL) {
315: dolog(0,"FAILED passwd %s\n",imsg->m_uid);
316: exit(1) ;
317: }
318: setfd(f2) ;
319: if (msg)
320: ioctl(0, FIOPUSHLD, &rmesg_ld);
321: else
322: ioctl(0, FIOPUSHLD, &tty_ld);
323: execl("/etc/login", "login", "-p", pwline, 0) ;
324: execl("/bin/login", "login", "-p", pwline, 0) ;
325: dolog(0, "FAILED EXEC login\n") ;
326: exit(1);
327:
328: SCASE("mesgexec")
329: msg = 1;
330: tty = 0;
331: goto ex;
332:
333: SCASE("exec")
334: msg = 0;
335: tty = 0;
336: goto ex;
337:
338: SCASE("ttyexec")
339: msg = 0;
340: tty = 1;
341: ex:
342: if (dkproto(f2, dkp_ld)<0) {
343: dolog(0, "FAILED PUSHLD %s\n", ncode) ;
344: dkmgrnak(imsg->m_chan, REORT) ;
345: exit(1) ;
346: }
347: dkmgrack(imsg->m_chan) ;
348: setwins(f2, imsg->m_traffic);
349: pwent = getnam(imsg->m_uid, f2, pwent, 0) ;
350: if (pwent == NULL)
351: exit(0) ;
352: setfd(f2) ;
353: if (rparm(0, "") < 0)
354: exit(0) ;
355: if (msg) {
356: if (ioctl(0, FIOPUSHLD, &rmesg_ld) < 0) {
357: dolog(0, "FAILED PUSHLD(rmesg)\n");
358: exit(1) ;
359: }
360: }
361: if (tty) {
362: if (ioctl(0, FIOPUSHLD, &tty_ld)<0) {
363: dolog(0, "FAILED PUSHLD(tty)\n");
364: exit(1) ;
365: }
366: }
367: execl("/etc/login", "login", "-p", pwline, parmbuf, 0);
368: execl("/bin/login", "login", "-p", pwline, parmbuf, 0);
369: dolog(0, "FAILED EXEC login\n");
370: exit(1) ;
371:
372: SCASE("cmda") /* fixed cmd, user args */
373: wargs = 1;
374: goto cm;
375:
376: SCASE("cmd") /* fixed cmd, fixed args */
377: wargs = 0;
378: goto cm;
379: cm:
380: /* first param is uid, rest go to sh */
381: dolog(7, "DEBUG cmd %s\n", params) ;
382: if (dkproto(f2, dkp_ld)<0) {
383: dolog(0, "FAILED PUSHLD %s\n", ncode) ;
384: dkmgrnak(imsg->m_chan, REORT) ;
385: exit(1) ;
386: }
387: cp = params ;
388: while (*cp != ' ' && *cp != '\t' && *cp != '\0')
389: cp++ ;
390: *cp++ = '\0' ;
391: while (*cp == ' ' || *cp == '\t')
392: cp++ ;
393: if (params[0] == '*') {
394: params = imsg->m_uid ;
395: if (pwent == NULL || (pwent->pw_uid==0 && rootable==0)) {
396: dkmgrnak(imsg->m_chan, PERMISSION) ;
397: dolog(1, "FAILED procuid %s.%s\n", imsg->m_source, imsg->m_uid) ;
398: exit(1) ;
399: }
400: } else {
401: pwent = pwsearch(params, -1, pwline);
402: rootable = 1 ;
403: }
404: dkmgrack(imsg->m_chan) ;
405: setwins(f2, imsg->m_traffic);
406: setfd(f2) ;
407: dolog(7, "DEBUG cmd uid %s cmd %s\n", params, cp) ;
408: if (wargs) {
409: register char *cp1;
410: char tparmbuf[786];
411:
412: pwent = getnam(params, 0, pwent, rootable);
413: if (rparm(0, FROGS) < 0) {
414: dolog(0, "bad args, cmda\n");
415: exit(0);
416: }
417: /* copy cmd name from procctl, args from parmbuf */
418: cp1 = tparmbuf;
419: while (*cp != ' ' && *cp != '\t' && *cp != '\0')
420: *cp1++ = *cp++ ;
421: *cp1++ = ' ';
422: cp = parmbuf;
423: while ((*cp1++ = *cp++) != '\0')
424: ;
425: strcpy(parmbuf, tparmbuf);
426: cp = parmbuf;
427: dolog(7, "cmda <%s>\n", cp);
428: }
429: execl("/etc/login", "login", "-p", pwline, cp, 0) ;
430: execl("/bin/login", "login", "-p", pwline, cp, 0) ;
431: dolog(0, "FAILED EXEC login %s\n", cp) ;
432: exit(1) ;
433:
434: }
435: dolog(0, "ILLEGAL CODE %s\n", ncode) ;
436: dkmgrnak(imsg->m_chan, INTERT) ;
437: exit(1) ;
438: }
439: }
440:
441: /* VARARGS2 */
442: dolog(level, fmt, a1, a2, a3, a4, a5)
443: char *fmt;
444: {
445: long clock ;
446: long time() ;
447: char *ctime() ;
448:
449: if (loglvl<level || logf==NULL)
450: return;
451: clock = time(0) ;
452: fseek(logf, 0L, 2);
453: fprintf(logf, "%.15s-%d(%d) ", ctime(&clock)+4, getpid(), loglvl) ;
454: fprintf(logf, fmt, a1, a2, a3, a4, a5);
455: fflush(logf);
456: }
457:
458:
459: /*
460: * Interrupt routine for child death
461: */
462: void
463: chdies()
464: {
465: signal(SIGCHLD, chdies);
466: }
467:
468: /*
469: * delete entry from utmp file
470: */
471: void
472: rmut(i)
473: {
474: register f;
475: register char *line;
476: struct utmp wtmp;
477:
478: line = dkfilename(i);
479: if (line==0)
480: return;
481: line += sizeof("/dev/") - 1;
482: f = open("/etc/utmp", 2);
483: if(f >= 0) {
484: while(read(f, (char *)&wtmp, sizeof(wtmp)) == sizeof(wtmp)) {
485: if (strncmp(wtmp.ut_line, line, sizeof(wtmp.ut_line)))
486: continue;
487: lseek(f, -(long)sizeof(wtmp), 1);
488: strncpy(wtmp.ut_name, "", sizeof(wtmp.ut_name));
489: time(&wtmp.ut_time);
490: write(f, (char *)&wtmp, sizeof(wtmp));
491: }
492: close(f);
493: }
494: f = open("/usr/adm/wtmp", 1);
495: if (f >= 0) {
496: strncpy(wtmp.ut_line, line, sizeof(wtmp.ut_line));
497: strncpy(wtmp.ut_name, "", sizeof(wtmp.ut_name));
498: time(&wtmp.ut_time);
499: lseek(f, (long)0, 2);
500: write(f, (char *)&wtmp, sizeof(wtmp));
501: close(f);
502: }
503: }
504:
505: /*
506: * check a source name against a prototype name
507: * in the control file
508: * return 0 if no match
509: * return 1 if ok match
510: */
511: cksource(ck, src)
512: register char *ck, *src ;
513: {
514:
515: while (*ck == *src) {
516: if (*ck == 0)
517: break ;
518: ck++ ; src++ ;
519: }
520: if (*ck == *src)
521: return 1 ;
522: if (*ck == '*')
523: return 1 ;
524: return 0 ;
525: }
526:
527: struct passwd *
528: getnam(try1, f2, pw, root)
529: char * try1;
530: register struct passwd *pw ;
531: int root ;
532: {
533: register char * cp ;
534:
535: if (pw && (pw->pw_uid!=0 || root!=0)) {
536: write(f2, "OK", 2) ;
537: return pw ;
538: }
539: write(f2, "NO", 2);
540: while (1) {
541: if (rparm(f2, "") < 0) {
542: dolog(2, "HANGUP c=%d receiving uid\n", imsg->m_chan) ;
543: exit(1) ;
544: }
545: for (cp = parmbuf; *cp; cp++) {
546: if (*cp == ' ' || *cp == '.' || *cp == ',') {
547: *cp++ = '\0';
548: break ;
549: }
550: }
551: pw = pwsearch(parmbuf, -1, pwline) ;
552: if (pw && pw->pw_uid != 0 && (pw->pw_passwd==NULL
553: || strcmp(crypt(cp, pw->pw_passwd), pw->pw_passwd)==0))
554: break;
555: write(f2, "NO", 2) ;
556: }
557: dolog(4, "TRACE UID %s\n", parmbuf) ;
558: write(f2, "OK", 2) ;
559: return pw ;
560: }
561:
562: /* read command parameters, delete funny ones */
563: rparm(f, frogs)
564: register char *frogs;
565: {
566: register len ;
567: register rlen ;
568: register char *cp ;
569:
570:
571: rlen = sizeof(parmbuf) ;
572: parmlen = 0 ;
573: cp = parmbuf ;
574: while (1) {
575: len = read(f, cp, rlen) ;
576: if (len <= 0)
577: return -1 ;
578: parmlen += len ;
579: rlen -= len ;
580: cp += len - 1 ;
581: if (*cp == '\n' || *cp == '\r') {
582: *cp = '\0' ;
583: cp = parmbuf;
584: while (*cp) {
585: *cp &= 0177;
586: if (strchr(frogs, *cp))
587: *cp = 'X';
588: cp++;
589: }
590: dolog(7, "DEBUG rparam %s\n", parmbuf) ;
591: return 0 ;
592: }
593: cp++ ;
594: }
595: }
596:
597: setfd(f)
598: {
599: int i ;
600:
601: signal(SIGTERM, SIG_DFL) ;
602: signal(SIGPIPE, SIG_DFL) ;
603: signal(SIGQUIT, SIG_DFL) ;
604: signal(SIGINT, SIG_DFL) ;
605: signal(SIGALRM, SIG_DFL) ;
606: signal(SIGHUP, SIG_DFL) ;
607: signal(SIGCHLD, SIG_DFL) ;
608: ioctl(f, TIOCSPGRP, 0) ;
609: close(0) ;
610: close(1) ;
611: close(2) ;
612: close(3) ;
613: dup(f) ;
614: dup(f) ;
615: dup(f) ;
616: dup(f) ;
617: for (i=NSYSFILE; i<9; i++)
618: if (i != fileno(logf))
619: close(i) ;
620: }
621:
622: /* use large transmit window? */
623: setwins(f, traffic)
624: {
625: char ws[5];
626: long wins;
627: if (W_VALID(traffic) && W_TRAF(traffic)) {
628: wins = W_VALUE(W_ORIG(traffic));
629: /* try 3 X 1/4 */
630: wins >>= 2;
631: ws[0] = wins;
632: ws[1] = wins>>8;
633: ws[2] = 0;
634: ws[3] = 0;
635: ws[4] = 3;
636: ioctl(f, DIOCXWIN, ws);
637: }
638: }
639:
640: char * adv(cp)
641: register char *cp ;
642: {
643: while (*cp != '\0' && *cp != '\n' && *cp != ' ' && *cp != '\t') cp++ ;
644: if (*cp == ' ' || *cp == '\t') *cp++ = '\0' ;
645: while (*cp == ' ' || *cp == '\t') cp++ ;
646: return (cp) ;
647: }
648:
649: char * advn(cp)
650: register char *cp ;
651: {
652: while (*cp != '\0' && *cp != '\n') cp++ ;
653: if (*cp == '\n') *cp++ = '\0' ;
654: while (*cp == ' ' || *cp == '\t' || *cp == '\n') cp++ ;
655: return (cp) ;
656: }
657:
658:
659: loadfiles()
660: {
661: struct stat statb ;
662: struct stat statb2 ;
663: register char *cp ;
664: register struct sprocctl *ctlptr ;
665: register struct sprocuid *uidptr ;
666: register i ;
667:
668: f0:
669: if (fprocctl == NULL || f2procctl == NULL) {
670: if (fprocctl == NULL)
671: fprocctl = fopen(CTLFILE, "r") ;
672: if (f2procctl == NULL)
673: f2procctl = fopen(CTL2FILE, "r") ;
674: if (fprocctl == NULL) {
675: fprintf(stderr, "mgrproc, can't open %s\n", CTLFILE) ;
676: nprocctl = 0 ;
677: goto f2 ;
678: }
679: if (f2procctl == NULL) {
680: fprintf(stderr, "mgrproc, can't open %s\n", CTL2FILE) ;
681: nprocctl = 0 ;
682: goto f2 ;
683: }
684: fstat(fileno(fprocctl), &statb) ;
685: fstat(fileno(f2procctl), &statb2) ;
686: } else {
687: fstat(fileno(fprocctl), &statb) ;
688: fstat(fileno(f2procctl), &statb2) ;
689: if (statb.st_ctime == tprocctl && statb2.st_ctime == t2procctl)
690: goto f2 ;
691: fclose(fprocctl) ;
692: fclose(f2procctl) ;
693: fprocctl = f2procctl = NULL ;
694: goto f0 ;
695: }
696: tprocctl = statb.st_ctime ;
697: t2procctl = statb2.st_ctime ;
698: i = statb.st_size + statb2.st_size ;
699: if (i > zprocctl) {
700: if (zprocctl > 0)
701: free(bprocctl) ;
702: bprocctl = (char *)malloc(i+4) ;
703: zprocctl = i ;
704: }
705: rewind(fprocctl) ;
706: rewind(f2procctl) ;
707: fread(bprocctl, statb2.st_size, 1, f2procctl) ;
708: if (statb2.st_size)
709: fread(&bprocctl[statb2.st_size], statb.st_size, 1, fprocctl) ;
710: bprocctl[i] = '\0' ;
711: cp = bprocctl ;
712: ctlptr = procctl ;
713: while (*cp) {
714: while (*cp == '#')
715: cp = advn(cp) ;
716: if (*cp == 0)
717: break ;
718: ctlptr->p_sname = cp ;
719: cp = adv(cp) ;
720: ctlptr->p_code = cp ;
721: cp = adv(cp) ;
722: ctlptr->p_ncode = cp ;
723: if (*cp == '*')
724: ctlptr->p_ncode = ctlptr->p_code ;
725: cp = adv(cp) ;
726: ctlptr->p_param = cp ;
727: cp = advn(cp) ;
728: ctlptr++ ;
729: }
730: nprocctl = ctlptr - procctl ;
731: dolog(7, "Reloaded %s; %d entries\n", CTLFILE, nprocctl) ;
732: f2:
733: if (fprocuid == NULL || f2procuid == NULL) {
734: if (fprocuid == NULL)
735: fprocuid = fopen(UIDFILE, "r") ;
736: if (f2procuid == NULL)
737: f2procuid = fopen(UID2FILE, "r") ;
738: if (fprocuid == NULL) {
739: fprintf(stderr, "mgrproc: can't open %s\n", UIDFILE) ;
740: nprocuid = 0 ;
741: return ;
742: }
743: if (f2procuid == NULL) {
744: fprintf(stderr, "mgrproc: can't open %s\n", UID2FILE) ;
745: nprocuid = 0 ;
746: return ;
747: }
748: fstat(fileno(fprocuid), &statb) ;
749: fstat(fileno(f2procuid), &statb2) ;
750: } else {
751: fstat(fileno(fprocuid), &statb) ;
752: fstat(fileno(f2procuid), &statb2) ;
753: if (statb.st_ctime == tprocuid && statb2.st_ctime == t2procuid)
754: return ;
755: fclose(fprocuid) ;
756: fclose(f2procuid) ;
757: fprocuid = f2procuid = NULL ;
758: goto f2 ;
759: }
760: tprocuid = statb.st_ctime ;
761: t2procuid = statb2.st_ctime ;
762: i = statb.st_size + statb2.st_size ;
763: if (i > zprocuid) {
764: if (zprocuid)
765: free(bprocuid) ;
766: bprocuid = (char *)malloc(i+4) ;
767: zprocuid = i ;
768: }
769: rewind(fprocuid) ;
770: rewind(f2procuid) ;
771: fread(bprocuid, statb2.st_size, 1, f2procuid) ;
772: fread(&bprocuid[statb2.st_size], statb.st_size, 1, fprocuid) ;
773: bprocuid[i] = '\0' ;
774: cp = bprocuid ;
775: uidptr = procuid ;
776: while (*cp) {
777: while (*cp == '#')
778: cp = advn(cp) ;
779: if (*cp == '\0')
780: break ;
781: uidptr->u_sname = cp ;
782: cp = adv(cp) ;
783: uidptr->u_code = cp ;
784: cp = adv(cp) ;
785: uidptr->u_uid = cp ;
786: cp = adv(cp) ;
787: uidptr->u_nuid = cp ;
788: cp = adv(cp) ;
789: cp = advn(cp) ;
790: uidptr++ ;
791: }
792: nprocuid = uidptr - procuid ;
793: dolog(7, "Reloaded %s; %d entries\n", UIDFILE, nprocuid) ;
794: }
795:
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.