![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to setup.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Research Unix] / researchv8dc / netfs|
Return to setup.c CVS log | Up to [Research Unix] / researchv8dc / netfs |
1.1 root 1: #include "stdio.h"
2: #include "sys/param.h"
3: #include "sys/stat.h"
4: #include "sys/neta.h"
5: #include "errno.h"
6: #include "sys/ioctl.h"
7: #include "signal.h"
8: #include "setjmp.h"
9:
10: #define RMFSTYP 1 /* file system type for remote file system */
11:
12: struct friend {
13: char *who;
14: char *mount;
15: int dev;
16: int silent;
17: int status;
18: int chan;
19: } friends[NOFILE];
20: int nfriends;
21: #define DEAD 0
22: #define OK 1
23: #define PROBE 2
24: #define KILL 3
25:
26: char *states[] = { "dead", "ok", "probe", "kill", "?"};
27:
28: struct senda x;
29: struct rcva y;
30: extern int errno;
31: extern char *ctime();
32: extern char *malloc();
33: struct stat stb;
34: long looked;
35: jmp_buf jmpbuf;
36:
37: main()
38: { int i;
39: /* any signal but SIGALRM (14) will start it over. SIGALRM is used to
40: * interrupt hung reads. SIGCHLD is ignored too */
41: sigalrm(0);
42: if(setjmp(jmpbuf) == 1)
43: rdfile();
44: else
45: sigcatch();
46: probe();
47: }
48: sigalrm(n)
49: {
50: fprintf(stderr, "sigalrm %d\n", n);
51: fflush(stderr);
52: if(n == SIGALRM || n == 0) /* otherwise might get SIGCHLD in sleep */
53: signal(SIGALRM, sigalrm);
54: signal(SIGCHLD, sigalrm);
55: }
56: sigcatch(n)
57: { int i;
58: for(i = 1; i < NSIG; i++)
59: if(i != SIGALRM && i != SIGCHLD) /* alarm and tdkdial */
60: (void) signal(i, sigcatch);
61: fprintf(stderr, "sigcatch %d\n", n);
62: fflush(stderr);
63: switch(i) {
64: case SIGILL: case SIGBUS: case SIGSEGV:
65: restart();
66: }
67: longjmp(jmpbuf, 1);
68: }
69: restart()
70: {
71: fprintf(stderr, "execing\n");
72: fflush(stderr);
73: execl("/etc/net/setup", "setup", 0);
74: execl("/usr/net/setup", "setup", 0);
75: /* if that doesn't work */
76: fprintf(stderr, "oops, calling main\n");
77: fflush(stderr);
78: main(); /* ho ho */
79: }
80: probe()
81: { int i;
82: static int lastdone;
83: long now;
84: loop:
85: if(lastdone >= nfriends) {
86: lastdone = 0;
87: sleep(30);
88: if(stat("/etc/net/friends", &stb) == 0 && stb.st_mtime > looked)
89: rdfile();
90: if(stat("/usr/net/friends", &stb) == 0 && stb.st_mtime > looked)
91: rdfile();
92: if(time((long *)0) > looked + 1200)
93: rdfile();
94: }
95: i = lastdone++;
96: switch(friends[i].status) {
97: default:
98: break;
99: case PROBE:
100: case OK:
101: friends[i].status++;
102: doprobe(friends + i);
103: if(friends[i].status != OK) {
104: now = time(0);
105: fprintf(stderr, "hmm %s %s %s\n", friends[i].who,
106: states[friends[i].status], ctime(&now));
107: }
108: break;
109: case KILL: /* over the limit */
110: now = time(0);
111: fprintf(stderr, "%s timed out %s 0x%x %s", friends[i].who,
112: states[friends[i].status], friends[i].chan, ctime(&now));
113: errno = 0;
114: gmount(RMFSTYP, friends[i].dev, 1, 0, 0);
115: if(errno == 0 || errno == EINVAL) {
116: friends[i].status = DEAD;
117: fprintf(stderr, "dead now\n");
118: }
119: else
120: perror("xmount");
121: break;
122: }
123: goto loop;
124: }
125: doprobe(x)
126: struct friend *x;
127: { struct stat stb;
128: if(stat(x->mount, &stb) == 0 && stb.st_dev == x->dev)
129: x->status = OK;
130: }
131: startup(p)
132: struct friend *p;
133: { int fd, i;
134: char version;
135: fd = callfs(p->who);
136: if(fd < 0) {
137: fprintf(stderr, "callfs %s failed\n", p->who);
138: return;
139: }
140: (void) fstat(fd, &stb);
141: fprintf(stderr, "starting %s (0x%x)", p->who, stb.st_rdev);
142: gmount(RMFSTYP, p->dev, 1, 0, 0); /* just in case */
143: perror("xunmount");
144: x.trannum = 0;
145: version = x.version = NETVERSION;
146: x.cmd = NSTART;
147: x.uid = p->silent;
148: x.dev = p->dev;
149: alarm(30);
150: x.ta = time(0);
151: if((write(fd, &version, 1) != 1) || write(fd, (char *)&x, sizeof(x))
152: != sizeof(x)) {
153: perror("write in setup");
154: fprintf(stderr, "%s\n", p->who);
155: close(fd);
156: alarm(0);
157: return;
158: }
159: if((i = read(fd, (char *)&y, sizeof(y))) != sizeof(y)) {
160: if(y.trannum == -1)
161: fprintf(stderr, "version mismatch %s\n", p->who);
162: else {
163: fprintf(stderr, "read %d chars for %s\n", i, p->who);
164: perror((char *)&y);
165: }
166: close(fd);
167: return;
168: }
169: alarm(0);
170: if(y.errno != 0) {
171: errno = y.errno;
172: perror("nak in setup");
173: close(fd);
174: return;
175: }
176: if(gmount(RMFSTYP, p->dev, 0, fd, p->mount) != 0) {
177: perror("xmount");
178: fprintf(stderr, "unmounting it\n"); /* garbage collection*/
179: gmount(RMFSTYP, p->dev, 1, 0, 0);
180: perror("xunmount");
181: close(fd);
182: /* and try again later */
183: return;
184: }
185: p->status = OK;
186: fprintf(stderr, "started %s on %s dev %d silent %d chan 0x%x\n", p->who,
187: p->mount, p->dev/256, p->silent, p->chan = stb.st_rdev);
188: close(fd);
189: }
190:
191: #define skip for(; *p == ' ' || *p == '\t'; p++)
192: #define note for(s = p; *p != ' ' && *p != '\t' && *p != '\n'; p++)
193: struct friend *
194: cnvt(s)
195: char *s;
196: { static struct friend x;
197: char *p;
198: s[strlen(s)] = '\n';
199: p = s;
200: skip;
201: if(*p == '\n') {
202: x.who = "#";
203: return(&x);
204: }
205: note;
206: if(*p == '\n')
207: return(0);
208: *p++ = 0;
209: x.who = malloc(strlen(s) + 1);
210: strcpy(x.who, s);
211: s = p;
212: skip;
213: note;
214: if(*p == '\n')
215: return(0);
216: *p++ = 0;
217: x.mount = malloc(strlen(s) + 1);
218: strcpy(x.mount, s);
219: s = p;
220: skip;
221: note;
222: if(*p == '\n')
223: return(0);
224: *p++ = 0;
225: x.dev = 256 * atoi(s);
226: s = p;
227: skip;
228: note;
229: *p++ = 0;
230: x.silent = atoi(s);
231: x.status = DEAD;
232: return(&x);
233: }
234:
235: rdfile()
236: { FILE *fd;
237: int i;
238: char line[128];
239: struct friend *p;
240: alarm(0); /* disable the sleep in probe */
241: fd = fopen("/etc/net/friends", "r");
242: if(fd == NULL) {
243: fd = fopen("/usr/net/friends","r");
244: if(fd == NULL) {
245: perror("friends");
246: exit(1);
247: }
248: }
249: for(;;) {
250: onward:
251: (void) fgets(line, sizeof(line), fd);
252: if(feof(fd))
253: break;
254: p = cnvt(line);
255: if(p == 0) {
256: fprintf(stderr, "weird friends line %s\n", line);
257: continue;
258: }
259: if(p->who[0] == '#')
260: continue;
261: for(i = 0; i < nfriends; i++) {
262: if(strcmp(p->who, friends[i].who))
263: continue;
264: if(friends[i].status != OK) {
265: looked = time(0);
266: fprintf(stderr, "\nrdfile %s (%s) %s",
267: states[friends[i].status],
268: friends[i].who, ctime(&looked));
269: /* off the mother */
270: if(friends[i].status != DEAD) {
271: friends[i].status = KILL;
272: fprintf(stderr, "bye %s\n", friends[i].who);
273: }
274: }
275: if(friends[i].status != DEAD)
276: goto onward;
277: /* one could free the space */
278: fprintf(stderr, "new friend %s\n", p->who);
279: friends[i] = *p;
280: startup(friends + i);
281: goto onward;
282: }
283: for(i = 0; i < nfriends; i++)
284: if(friends[i].status == DEAD) {
285: friends[i] = *p;
286: fprintf(stderr, "new friend %s\n", p->who);
287: startup(friends + i);
288: goto onward;
289: }
290: if(i < nfriends)
291: continue;
292: if(nfriends >= NOFILE) {
293: fprintf(stderr, "friends overflow\n");
294: abort();
295: }
296: fprintf(stderr, "new friend %s\n", p->who);
297: friends[nfriends++] = *p;
298: startup(friends + nfriends - 1);
299: }
300: fclose(fd);
301: looked = time(0);
302: fprintf(stderr, "ok %s", ctime(&looked));
303: }
304:
305: callfs(srvr)
306: char *srvr;
307: {
308: int rem, v;
309: extern int pk_ld, dkp_ld;
310: long x;
311:
312: alarm(30);
313: x = time(0);
314: fprintf(stderr, "%d tdkdial %s %s", getpid(), srvr, ctime(&x));
315: fflush(stderr);
316: rem = _tdkdial(3, 2, srvr);
317: x = time(0);
318: alarm(0);
319: if (rem < 0) {
320: fprintf(stderr, " %d can't rexec err = %d\n", getpid(), errno);
321: fflush(stderr);
322: return(-1);
323: }
324: else
325: fprintf(stderr, "tdkdial ok %s", ctime(&x));
326: /* v = ioctl(rem, FIOPUSHLD, &dkp_ld); /* should be dkproto */
327: v = dkproto(rem, dkp_ld);
328: x = time(0);
329: if (v < 0) {
330: perror("can't start protocol");
331: fprintf(stderr, "\t%s", ctime(&x));
332: close(rem);
333: return(-1);
334: }
335: else
336: fprintf(stderr, "protocol started\n");
337: return(rem);
338: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.