![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to dsa.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / quipu|
Return to dsa.c CVS log | Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / quipu |
1.1 root 1: /* dsa.c - Main routine for QUIPU DSA process */
2:
3: #ifndef lint
4: static char *rcsid = "$Header: /f/osi/quipu/RCS/dsa.c,v 7.5 90/07/09 14:45:56 mrose Exp $";
5: #endif
6:
7: /*
8: * $Header: /f/osi/quipu/RCS/dsa.c,v 7.5 90/07/09 14:45:56 mrose Exp $
9: *
10: *
11: * $Log: dsa.c,v $
12: * Revision 7.5 90/07/09 14:45:56 mrose
13: * sync
14: *
15: * Revision 7.4 90/03/15 11:18:57 mrose
16: * quipu-sync
17: *
18: * Revision 7.3 90/01/11 23:55:57 mrose
19: * lint
20: *
21: * Revision 7.2 90/01/11 18:37:21 mrose
22: * real-sync
23: *
24: * Revision 7.1 89/12/19 16:53:08 mrose
25: * dgram
26: *
27: * Revision 7.0 89/11/23 22:17:19 mrose
28: * Release 6.0
29: *
30: */
31:
32: /*
33: * NOTICE
34: *
35: * Acquisition, use, and distribution of this module and related
36: * materials are subject to the restrictions of a license agreement.
37: * Consult the Preface in the User's Manual for the full terms of
38: * this agreement.
39: *
40: */
41:
42:
43: #include <signal.h>
44: #include <stdio.h>
45: #include <varargs.h>
46: #include "rosap.h"
47: #include "tsap.h"
48: #include "logger.h"
49: #include "tailor.h"
50: #include "quipu/util.h"
51: #include "quipu/connection.h"
52: #include <sys/ioctl.h>
53: #include <sys/stat.h>
54: #ifdef BSD42
55: #include <sys/file.h>
56: #endif
57: #ifdef SYS5
58: #include <fcntl.h>
59: #endif
60:
61: #include "dgram.h"
62: #ifdef TCP
63: #include "internet.h"
64: #endif
65:
66: PS opt;
67: static int debug = 1;
68: static int nbits = FD_SETSIZE;
69:
70: extern LLog * log_dsap;
71:
72: static char *myname;
73:
74: void adios (), advise ();
75: static envinit (), setdsauid();
76: SFD attempt_restart();
77: extern int print_parse_errors;
78: extern int parse_line;
79: struct task_act * task_select();
80:
81: extern SFP abort_vector;
82:
83: #ifndef NO_STATS
84: extern LLog *log_stat;
85: #endif
86:
87: /*
88: * Basic data structure of the DSA server.
89: */
90: char * mydsaname = "undefined";
91: struct PSAPaddr * mydsaaddr = NULLPA;
92: struct connection * connlist;
93: int conns_used;
94: struct connection * connwaitlist;
95: struct di_block * deferred_dis = NULL_DI_BLOCK;
96: struct oper_act * get_edb_ops;
97: OID acse_pci;
98: OID x500_da_ac;
99: OID x500_da_as;
100: OID x500_ds_ac;
101: OID x500_ds_as;
102: OID quipu_ds_ac;
103: OID quipu_ds_as;
104: struct PSAPctxlist x500_da_pcdl_s;
105: struct PSAPctxlist * x500_da_pcdl = &x500_da_pcdl_s;
106: struct PSAPctxlist x500_ds_pcdl_s;
107: struct PSAPctxlist * x500_ds_pcdl = &x500_ds_pcdl_s;
108: struct PSAPctxlist quipu_ds_pcdl_s;
109: struct PSAPctxlist * quipu_ds_pcdl = &quipu_ds_pcdl_s;
110:
111:
112: char ** sargv;
113:
114: main(argc, argv)
115: int argc;
116: char **argv;
117: {
118: #ifdef DEBUG
119: unsigned proc_size = 0;
120: unsigned new_size;
121: extern caddr_t sbrk();
122: #endif
123: extern char * mydsaname;
124: extern char startup_update;
125: extern struct PSAPaddr * mydsaaddr;
126: struct task_act * task;
127: int secs;
128: char start_buf [LINESIZE];
129: /*
130: * Function to stop DSA server.
131: */
132: SFD stop_dsa();
133:
134: sargv = argv;
135:
136: if (myname = rindex (argv[0], '/'))
137: myname++;
138: if (myname == NULL || *myname == NULL)
139: myname = argv[0];
140:
141: isodetailor (myname,0);
142:
143: envinit(); /* detach */
144:
145: quipu_syntaxes ();
146: dsa_sys_init(&argc, &argv);
147: setdsauid();
148:
149: print_parse_errors = FALSE;
150:
151: #ifndef NO_STATS
152: ll_hdinit (log_stat,myname);
153: #endif
154:
155: if ((opt = ps_alloc (std_open)) == NULLPS)
156: fatal (-12,"ps_alloc failed");
157: if (std_setup (opt,stdout) == NOTOK)
158: fatal (-13,"std_setup failed");
159:
160: DLOG (log_dsap,LLOG_DEBUG,( "About to dsa_init()"));
161:
162: if(dsa_init() == NOTOK)
163: {
164: fatal(-14,"Couldn't initialise the DSA!!");
165: }
166:
167:
168: if(net_init() == NOTOK)
169: {
170: fatal(-15,"Couldn't start the DSA!!");
171: }
172:
173:
174: if (startup_update)
175: {
176: /* Will generate a list of EDB operations! */
177: slave_update();
178: }
179:
180: {
181: extern char *treedir;
182: char filebuf[BUFSIZ];
183: FILE *fp;
184:
185: (void) sprintf (filebuf, "%s/PID", treedir);
186: if (fp = fopen (filebuf, "w")) {
187: (void) fprintf (fp, "%d\n", getpid ());
188: (void) fclose (fp);
189: }
190: else
191: LLOG (log_dsap,LLOG_EXCEPTIONS,("Can't open PID file %s",filebuf));
192: }
193:
194: /*
195: * Do stop_dsa() on receiving a Ctrl-C
196: */
197:
198: (void) signal (SIGINT, stop_dsa);
199: (void) signal (SIGTERM,stop_dsa);
200: (void) signal (SIGHUP, stop_dsa);
201:
202: /* now started don't stop on core dumps !!! */
203: (void) signal (SIGQUIT, attempt_restart);
204: (void) signal (SIGILL, attempt_restart);
205: (void) signal (SIGBUS, attempt_restart);
206: (void) signal (SIGSEGV, attempt_restart);
207: (void) signal (SIGSYS, attempt_restart);
208:
209: abort_vector = attempt_restart;
210: parse_line = 0;
211:
212: (void) sprintf (start_buf,"DSA %s has started on %s",mydsaname,paddr2str(mydsaaddr,NULLNA));
213: LLOG (log_dsap,LLOG_NOTICE,(start_buf));
214: #ifndef NO_STATS
215: LLOG (log_stat,LLOG_NOTICE,(start_buf));
216: #endif
217:
218: if (debug)
219: (void) fprintf (stderr,"%s\n",start_buf);
220:
221: start_malloc_trace (NULLCP);
222:
223: #ifdef DEBUG
224: proc_size = (unsigned) sbrk(0);
225: #endif
226:
227: for(;;)
228: {
229: if((task = task_select(&secs)) == NULLTASK)
230: {
231: #ifdef DEBUG
232: if (secs > 0) {
233: /* Only if we are idle ! */
234: new_size = (unsigned) sbrk(0);
235: if ( new_size > proc_size) {
236: LLOG (log_dsap, LLOG_NOTICE, ("Process grown by %d bytes", new_size - proc_size));
237: proc_size = new_size;
238: }
239: }
240: #endif
241: dsa_wait(secs); /* Check network with timeout of secs */
242: }
243: else
244: {
245: dsa_work(task); /* Process the DSA task selected */
246: dsa_wait(0);
247: }
248: } /* forever */
249: } /* main */
250:
251: dsa_abort(isfatal)
252: int isfatal;
253: {
254: struct connection * cn;
255: struct DSAPindication di_s;
256: struct DSAPindication * di = &di_s;
257:
258: for(cn=connlist; cn!=NULLCONN; cn=cn->cn_next)
259: if (cn -> cn_ad != NOTOK) {
260: if (isfatal || (! cn -> cn_initiator))
261: (void) close (cn -> cn_ad);
262: else {
263: watch_dog ("DUAbortRequest quit");
264: (void) DUAbortRequest(cn->cn_ad, di);
265: watch_dog_reset ();
266: }
267: }
268:
269: watch_dog ("stop_listeners");
270: stop_listeners();
271: watch_dog_reset();
272: }
273:
274: SFD stop_dsa (sig)
275: int sig;
276: {
277: (void) signal (sig, SIG_DFL); /* to stop recursion */
278: LLOG (log_dsap,LLOG_FATAL,("*** Stopping on signal %d ***",sig));
279: if (debug)
280: (void) fprintf (stderr,"DSA %s has Stopped\n",mydsaname);
281: dsa_abort(0);
282: exit (0);
283: }
284:
285: static envinit () {
286: int i,
287: sd;
288:
289: nbits = getdtablesize ();
290:
291: if (!(debug = isatty (2))) {
292: for (i = 0; i < 5; i++) {
293: switch (fork ()) {
294: case NOTOK:
295: sleep (5);
296: continue;
297:
298: case OK:
299: goto fork_ok;
300:
301: default:
302: _exit (0);
303: }
304: break;
305: }
306:
307: fork_ok:;
308: (void) chdir ("/");
309:
310: if ((sd = open ("/dev/null", O_RDWR)) == NOTOK)
311: adios ("/dev/null", "unable to read");
312: if (sd != 0)
313: (void) dup2 (sd, 0), (void) close (sd);
314: (void) dup2 (0, 1);
315: (void) dup2 (0, 2);
316:
317: #ifdef SETSID
318: if (setsid () == NOTOK)
319: advise (LLOG_EXCEPTIONS, "failed", "setsid");
320: #endif
321: #ifdef TIOCNOTTY
322: if ((sd = open ("/dev/tty", O_RDWR)) != NOTOK) {
323: (void) ioctl (sd, TIOCNOTTY, NULLCP);
324: (void) close (sd);
325: }
326: #else
327: #ifdef SYS5
328: (void) setpgrp ();
329: (void) signal (SIGINT, SIG_IGN);
330: (void) signal (SIGQUIT, SIG_IGN);
331: #endif
332: #endif
333: }
334: #ifndef DEBUG
335: /* "Normal" ISODE behavior of full logging only without DEBUG */
336: else
337: ll_dbinit (log_dsap, myname);
338: #endif
339:
340: #ifndef sun /* damn YP... */
341: for (sd = 3; sd < nbits; sd++) {
342: if (log_dsap -> ll_fd == sd)
343: continue;
344: #ifdef NO_STATS
345: if (log_stats -> ll_fd == sd)
346: continue;
347: #endif
348: (void) close (sd);
349: }
350: #endif
351:
352: (void) signal (SIGPIPE, SIG_IGN);
353:
354: ll_hdinit (log_dsap, myname);
355: #ifdef DEBUG
356: advise (LLOG_TRACE, NULLCP, "starting");
357: #endif
358: }
359:
360:
361: /* ERRORS */
362:
363: #ifndef lint
364: void adios (va_alist)
365: va_dcl
366: {
367: va_list ap;
368:
369: va_start (ap);
370:
371: _ll_log (log_dsap, LLOG_FATAL, ap);
372:
373: va_end (ap);
374:
375: if (debug)
376: (void) fprintf (stderr,"adios exit - see dsap.log\n");
377: dsa_abort(1);
378: _exit (-18);
379: }
380: #else
381: /* VARARGS */
382:
383: void adios (what, fmt)
384: char *what,
385: *fmt;
386: {
387: adios (what, fmt);
388: }
389: #endif
390:
391: #ifndef lint
392: void advise (va_alist)
393: va_dcl
394: {
395: int code;
396: va_list ap;
397:
398: va_start (ap);
399:
400: code = va_arg (ap, int);
401:
402: (void) _ll_log (log_dsap, code, ap);
403:
404: va_end (ap);
405: }
406: #else
407: /* VARARGS */
408:
409: void advise (code, what, fmt)
410: char *what,
411: *fmt;
412: int code;
413: {
414: advise (code, what, fmt);
415: }
416: #endif
417:
418:
419:
420: static setdsauid ()
421: {
422: struct stat buf;
423: extern char * treedir;
424:
425: (void) stat (treedir,&buf);
426:
427: if (setgid (buf.st_gid) == -1)
428: LLOG (log_dsap,LLOG_EXCEPTIONS,("Can't set gid %d (database directory \"%s\")",buf.st_uid,treedir));
429:
430: if (setuid (buf.st_uid) == -1)
431: LLOG (log_dsap,LLOG_EXCEPTIONS,("Can't set uid %d (database directory \"%s\")",buf.st_uid,treedir));
432: }
433:
434: #define RESTART_TIME 30 /* for connections to clear... */
435: #define CLEAR_TIME 300 /* .. */
436:
437: SFD attempt_restart (sig)
438: int sig;
439: {
440: int fpid, sd;
441: unsigned int secs;
442: extern char * mydsaname;
443:
444: if (sig > 0)
445: (void) signal (sig, SIG_DFL); /* to stop recursion */
446:
447: if (sig >= 0 && debug)
448: (void) fprintf (stderr,"DSA %s has a problem\n",mydsaname);
449:
450: dsa_abort(sig != NOTOK);
451: secs = sig != NOTOK ? CLEAR_TIME : RESTART_TIME;
452:
453: for (sd = 3; sd < nbits; sd++) {
454: if (log_dsap -> ll_fd == sd)
455: continue;
456: #ifdef NO_STATS
457: if (log_stats -> ll_fd == sd)
458: continue;
459: #endif
460: (void) close (sd);
461: }
462:
463: if ( sig == -2 || (fpid = fork()) == 0) {
464: if (sig == -2) { /* restart due to congestion... */
465: LLOG (log_dsap,LLOG_FATAL, ("*** in-situ restart attempted ***"));
466: #ifndef NO_STATS
467: LLOG (log_stat,LLOG_NOTICE,("RESTARTING (%s)",mydsaname));
468: #endif
469: }
470:
471: sleep (secs); /* give connections time to clear */
472: execv (isodefile(sargv[0], 1),sargv);
473: exit (-19);
474: }
475:
476: if (sig >= 0)
477: LLOG (log_dsap,LLOG_FATAL,("*** Process dying on signal %d ***",sig));
478:
479: if (fpid != -1) {
480: LLOG (log_dsap,LLOG_FATAL,("*** restart attempted in %d seconds ***", secs));
481: #ifndef NO_STATS
482: LLOG (log_stat,LLOG_NOTICE,("RESTARTING with pid %d (%s)",fpid,mydsaname));
483: } else {
484: LLOG (log_stat,LLOG_NOTICE,("PANIC (%s)",mydsaname));
485: #endif
486: }
487:
488: (void) signal (SIGIOT, SIG_DFL);
489: abort ();
490: exit (-20); /* abort should not return */
491: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.