![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to pupucommon.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Research Unix] / researchv10dc / ipc / bin / pupu|
Return to pupucommon.c CVS log | Up to [Research Unix] / researchv10dc / ipc / bin / pupu |
1.1 root 1:
2: static char SCCSID[] = "@(#)pupucommon.c 2.1 DKHOST 85/01/15";
3:
4: #include <sys/types.h>
5: #include "sysexits.h"
6: #include <signal.h>
7: #include "tdefs.h"
8: #include "udefs.h"
9: #include <varargs.h>
10: #include <errno.h>
11: #include <string.h>
12: #include <stdio.h>
13: #include "pupu.h"
14: extern int errno ;
15:
16: Xint cfd;
17:
18: Xchar mhead[H_DATA] = "\206\006";
19: Xchar buf[BLOCKSIZE];
20: XcharP mnext;
21: Xchar sseq, rseq;
22:
23: Xjmp giveup;
24: XfnP alarmwas;
25:
26: Xchar wdir[NAMELEN];
27: Xchar basedir[NAMELEN];
28: Xchar wholename[NAMELEN];
29:
30: Xlink linkhead;
31:
32: XfnP errorfunction;
33: Xint lasterror;
34: XcharP remoteorlocal;
35: XcharP currentfile, timeoutmsg;
36:
37: Xchar openfiles[TOPFD+4];
38:
39: Efn gotinit, gotinitreply;
40:
41: Xexp inittable[] = {
42: 'I', gotinit,
43: 'i', gotinitreply,
44: 0, 0
45: };
46:
47: Efn remotedone, remoteerror, alldone;
48:
49: Xexp justquit[] = {
50: 'x', remotedone,
51: 'e', remoteerror,
52: 'X', alldone,
53: 0, 0
54: };
55:
56: SexpP toexpect;
57:
58: Xchar myversion[6] = "1";
59: Xchar theirversion[6];
60:
61: Xchar options[32];
62:
63: Efn timeout;
64:
65: begin(fd, errfcn, rol, initwdir)
66: PfnP errfcn;
67: PcharP rol, initwdir;
68: {
69: cfd = fd;
70: errorfunction = errfcn;
71: remoteorlocal = rol;
72: currentfile = NIL;
73: lasterror = 0;
74:
75: strcpy(wdir, initwdir);
76:
77: signal(SIGALRM, timeout);
78: }
79:
80: sendinit(opt)
81: PcharP opt;
82: {
83: msginit('I');
84: msgfmt("%s", myversion);
85: msgfmt("%s", opt);
86:
87: msgconf(inittable);
88: }
89:
90: gotinit()
91: {
92: msgtake("%s", theirversion);
93: msgtake("%s", options);
94:
95: msginit('i');
96: msgfmt("%s", myversion);
97: msgsend();
98:
99: return(1);
100: }
101:
102: gotinitreply()
103: {
104: msgtake("%s", theirversion);
105:
106: return(1);
107: }
108:
109: err(msg, parm, en)
110: PcharP msg, parm;
111: {
112: warn(msg, parm, en);
113:
114: if(*remoteorlocal == 'r')
115: reply('X');
116:
117: stopnow(en);
118: }
119:
120: warn(msg, parm, en)
121: PcharP msg, parm;
122: {
123: RcharP ep;
124: Achar ebuf[BUFSIZ];
125:
126: ep = ebuf;
127:
128: ep += sprintf(ep, "(%s): %s", remoteorlocal, msg);
129:
130: if(parm)
131: ep += sprintf(ep, " [%s]", parm);
132:
133: if(en > 0 && errno >= 0 && errno <= sys_nerr)
134: sprintf(ep, " -- %s", sys_errlist[errno]);
135:
136: db(stderr, "warn * %s\n", ebuf);
137: if(*remoteorlocal == 'l')
138: (*errorfunction)(ebuf);
139: else{
140: msginit('e');
141: msgfmt("%s", ebuf);
142: msgsend();
143: }
144:
145: lasterror = en < 0 ? -en : en;
146: }
147:
148: creatn(name, mode)
149: PcharP name;
150: {
151: Rint fd;
152:
153: fd = creat(name, mode);
154:
155: if(fd >= 0)
156: openfiles[fd] = 1;
157:
158: return(fd);
159: }
160:
161: openn(name, flags)
162: PcharP name;
163: {
164: Rint fd;
165:
166: fd = open(name, flags);
167:
168: if(fd >= 0)
169: openfiles[fd] = 1;
170:
171: return(fd);
172: }
173:
174: closen(fd)
175: {
176: close(fd);
177:
178: openfiles[fd] = 0;
179: }
180:
181: remotedone()
182: {
183: Aint en;
184:
185: msgtake("%d", &en);
186:
187: if(en)
188: lasterror = en;
189:
190: return(1);
191: }
192:
193: alldone()
194: {
195: stopnow(0);
196: }
197:
198: stopnow(en)
199: {
200: Rint i;
201: RlinkP lp, nlp;
202:
203: alarm(0);
204: signal(SIGALRM, alarmwas);
205:
206: for(i = 0; i < sizeof(openfiles)/sizeof(openfiles[0]); i++)
207: if(openfiles[i])
208: closen(i);
209:
210: for(lp = linkhead.next; lp; lp = nlp){
211: nlp = lp->next;
212: free(lp);
213: }
214: linkhead.next = 0;
215:
216: if(en > 0)
217: lasterror = en;
218: else if(en < 0)
219: lasterror = -en;
220:
221: longjmp(giveup, 1);
222: }
223:
224: msgtake(fmt, ptr)
225: PcharP fmt, ptr;
226: {
227: if(strcmp(fmt, "%s") == 0)
228: strcpy(ptr, mnext); /* Foo! sscanf stops at white space */
229: else
230: sscanf(mnext, fmt, ptr);
231:
232: mnext += strlen(mnext)+1;
233: }
234:
235: reply(type)
236: Pchar type;
237: {
238: if(++sseq > SEQMAX)
239: sseq = SEQMIN;
240: mhead[H_SEQN] = sseq;
241:
242: mhead[H_TYPE] = type;
243:
244: timeoutmsg = "Protocol exchange timed out";
245:
246: alarm(WTIMEOUT);
247:
248: msgwrite(cfd, mhead, sizeof(mhead));
249:
250: alarm(0);
251: }
252:
253: confirmed()
254: {
255: return(1);
256: }
257:
258: remoteerror()
259: {
260: Achar ebuf[BUFSIZ];
261:
262: msgtake("%s", ebuf);
263:
264: (*errorfunction)(ebuf);
265:
266: return(0);
267: }
268:
269: msginit(type)
270: Pchar type;
271: {
272: if(toexpect){
273: msgwait(toexpect);
274: toexpect = 0;
275: }
276:
277: if(++sseq > SEQMAX)
278: sseq = SEQMIN;
279: mhead[H_SEQN] = sseq;
280:
281: mhead[H_TYPE] = type;
282:
283: strcpy(buf, mhead);
284:
285: mnext = &buf[H_DATA];
286: }
287:
288: /* VARARGS0 */
289: msgfmt(va_alist)
290: va_dcl
291: {
292: RcharP fmt;
293: va_list args;
294:
295: va_start(args);
296:
297: fmt = va_arg(args, TcharP);
298:
299: mnext += vsprintf(mnext, fmt, args) + 1;
300: }
301:
302: msgconf(expect)
303: PexpP expect;
304: {
305: msgsend();
306:
307: toexpect = expect;
308: }
309:
310: msgsend()
311: {
312: Rint len;
313: db(stderr, "msgsend %c\n", buf[H_TYPE]);
314:
315: len = mnext - buf;
316:
317: timeoutmsg = "Protocol exchange timed out";
318:
319: alarm(WTIMEOUT);
320:
321: if(msgwrite(cfd, buf, len) != len)
322: if(*remoteorlocal == 'r')
323: stopnow(EX_IOERR);
324: else
325: err("Message write failed", NIL, EX_IOERR);
326:
327: alarm(0);
328: }
329:
330: msgwait(expect)
331: PexpP expect;
332: {
333: Rint len;
334: RexpP ep;
335:
336: db(stderr, "msgwait %X\n", expect);
337: timeoutmsg = "Protocol exchange timed out";
338:
339: for(;;){
340: alarm(RTIMEOUT);
341:
342: len = msgread(cfd, buf, sizeof(buf));
343:
344: alarm(0);
345: db(stderr, "read len %d type %c\n", len, buf[H_TYPE]);
346:
347: if(len <= 0)
348: err("Message read error", NIL, EX_IOERR);
349:
350: if(++rseq > SEQMAX)
351: rseq = SEQMIN;
352: if(buf[H_MAG1] != mhead[H_MAG1] || buf[H_MAG2] != mhead[H_MAG2])
353: err("Bad magic number on message", NIL, -EX_PROTOCOL);
354: if(buf[H_SEQN] != rseq)
355: err("Bad sequence number on message", NIL, -EX_PROTOCOL);
356:
357: mnext = &buf[H_DATA];
358:
359: for(ep = expect; ep->type; ep++)
360: if(ep->type == buf[H_TYPE])
361: if((*ep->fn)())
362: return;
363: else
364: break;
365:
366: if(!ep->type)
367: err("Unexpected message type", &buf[H_TYPE], -EX_PROTOCOL);
368: }
369: }
370:
371:
372: sendfile(name)
373: RcharP name;
374: {
375: AcharP d;
376:
377: db(stderr, "sendfile %s\n", name);
378: if(d = strrchr(name, '/')){
379: if(!wdir[0])
380: curdir(wdir);
381:
382: if(d == name)
383: name = "/";
384: else
385: *d = '\0';
386:
387: if(chdir(name) < 0){
388: warn("Can't change directory to", name, EX_NOINPUT);
389: return;
390: }
391:
392: name = d+1;
393: }
394:
395: putfile(name, name);
396:
397: if(d)
398: chdir(wdir);
399: }
400:
401: timeout()
402: {
403: err(timeoutmsg, currentfile, -EX_IOERR);
404: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.