![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to io.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Research Unix] / researchv9 / jtools / src / sam|
Return to io.c CVS log | Up to [Research Unix] / researchv9 / jtools / src / sam |
1.1 ! root 1: #include "sam.h" ! 2: #include <sys/ioctl.h> ! 3: #ifdef SUN ! 4: /* a hack to get around redef of ushort in sys/types.h . ! 5: this depends on non-use of ushort in this file */ ! 6: #define ushort USHORT ! 7: #endif ! 8: #include <sys/types.h> ! 9: #include <sys/stat.h> ! 10: #ifndef SUN ! 11: #include "/usr/jerq/include/jioctl.h" ! 12: #endif ! 13: ! 14: writef(f) ! 15: register File *f; ! 16: { ! 17: uchar c; ! 18: Posn n; ! 19: struct stat statb; ! 20: int newfile=0; ! 21: if(stat((char *)genstr.s, &statb)==-1) ! 22: newfile++; ! 23: else if(strcmp(genstr.s, f->name.s)==0 && ! 24: (f->inumber!=statb.st_ino || f->date<statb.st_mtime)){ ! 25: f->inumber=statb.st_ino; ! 26: f->date=statb.st_mtime; ! 27: warn_s(Wdate, (char *)genstr.s); ! 28: return; ! 29: } ! 30: if((io=creat((char *)genstr.s, 0666))<0) ! 31: error_s(Ecreate, (char *)genstr.s); ! 32: dprint("%s: ", (char *)genstr.s); ! 33: n=writeio(f); ! 34: if(f->name.s[0]==0 || strcmp(genstr.s, f->name.s)==0) ! 35: state(f, addr.r.p1==0 && addr.r.p2==f->nbytes? Clean : Dirty); ! 36: if(newfile) ! 37: dprint("(new file) "); ! 38: if(addr.r.p2>0 && Fchars(f, &c, addr.r.p2-1, addr.r.p2) && c!='\n') ! 39: warn(Wnotnewline); ! 40: if(f->name.s[0]==0 || strcmp(genstr.s, f->name.s)==0){ ! 41: fstat(io, &statb); ! 42: f->inumber=statb.st_ino; ! 43: f->date=statb.st_mtime; ! 44: } ! 45: closeio(n); ! 46: } ! 47: Posn ! 48: readio(f, nonascii, setdate) ! 49: register File *f; ! 50: int *nonascii; ! 51: { ! 52: register n; ! 53: register Posn nt; ! 54: register Posn p=addr.r.p2; ! 55: struct stat statb; ! 56: if(nonascii) ! 57: *nonascii=FALSE; ! 58: for(nt=0; (n=read(io, (char *)genbuf, BLOCKSIZE))>0; nt+=n){ ! 59: n=clean(genbuf, n, nonascii); ! 60: Finsert(f, tempstr(genbuf, n), p); ! 61: } ! 62: if(nonascii && *nonascii) ! 63: warn(Wnonascii); ! 64: if(setdate){ ! 65: fstat(io, &statb); ! 66: f->inumber=statb.st_ino; ! 67: f->date=statb.st_mtime; ! 68: } ! 69: return nt; ! 70: } ! 71: Posn ! 72: writeio(f) ! 73: register File *f; ! 74: { ! 75: register n; ! 76: register Posn p=addr.r.p1; ! 77: while(p<addr.r.p2){ ! 78: if(addr.r.p2-p>BLOCKSIZE) ! 79: n=BLOCKSIZE; ! 80: else ! 81: n=addr.r.p2-p; ! 82: if(Fchars(f, genbuf, p, p+n)!=n) ! 83: panic("writef read"); ! 84: (void)Write(io, genbuf, n); ! 85: p+=n; ! 86: } ! 87: return addr.r.p2-addr.r.p1; ! 88: } ! 89: closeio(p) ! 90: Posn p; ! 91: { ! 92: (void)close(io); ! 93: io=0; ! 94: if(p>=0) ! 95: dprint("#%lud\n", p); ! 96: } ! 97: clean(s, n, nonascii) ! 98: register uchar *s; ! 99: register n; ! 100: int *nonascii; ! 101: { ! 102: register uchar *p, *q; ! 103: register i; ! 104: /* for speed, just look first */ ! 105: p=s; ! 106: if(i=n) ! 107: do ! 108: if(*p==0 || (*p++&HIGHBIT)) ! 109: goto Cleanup; ! 110: while(--i); ! 111: return n; /* usual case */ ! 112: Cleanup: ! 113: for(q=p=s, i=0; i<n; i++, p++) ! 114: if(*p!=0 && (*p&HIGHBIT)==0) ! 115: *q++= *p; ! 116: if(nonascii) ! 117: *nonascii=TRUE; ! 118: return q-s; ! 119: } ! 120: #ifndef SUN ! 121: bootterm(zflag) ! 122: { ! 123: if(system("/usr/jerq/bin/32ld", "32ld", ! 124: #ifdef DIST ! 125: zflag? "-z" : "-", "/usr/jerq/mbin/sam.m")){ ! 126: #else ! 127: zflag? "-z" : "-", "/n/ikeya/usr/rob/sam/term/a.out")){ ! 128: #endif ! 129: dprint("sam: can't boot terminal program\n"); ! 130: return 0; ! 131: } ! 132: return 1; ! 133: } ! 134: #endif !SUN ! 135: rawmode(raw) ! 136: { ! 137: struct sgttyb buf; ! 138: ioctl(0, TIOCGETP, &buf); ! 139: if(raw){ ! 140: ioctl(0, TIOCEXCL, (struct sgttyb *)0); ! 141: buf.sg_flags|=RAW|ANYP; ! 142: }else{ ! 143: ioctl(0, TIOCNXCL, (struct sgttyb *)0); ! 144: #ifndef SUN ! 145: ioctl(0, JTERM, (struct sgttyb *)0); ! 146: #endif ! 147: buf.sg_flags&=~(RAW|ANYP); ! 148: } ! 149: ioctl(0, TIOCSETP, &buf); ! 150: } ! 151: system(s, t, u, v) ! 152: char *s, *t, *u, *v; ! 153: { ! 154: int status, pid, l; ! 155: if((pid=fork()) == 0) { ! 156: execl(s, t, u, v, 0); ! 157: _exit(127); ! 158: } ! 159: do; while((l=wait(&status))!=pid && l!=-1); ! 160: if(l==-1) ! 161: status= -1; ! 162: return(status); ! 163: } ! 164: closeonexec(fd){ ! 165: ioctl(fd, FIOCLEX, (struct sgttyb *)0); ! 166: } ! 167: #ifndef SUN ! 168: static int remotefd; ! 169: connectto(machine) ! 170: char *machine; ! 171: { ! 172: if(strncmp((uchar *)machine, (uchar *)"inet/", 5)==0) ! 173: remotefd=tcpexec(machine+5, "exec /usr/jerq/bin/sam -R"); ! 174: else ! 175: remotefd=tdkexec(machine, "exec /usr/jerq/bin/sam -R"); ! 176: if(remotefd<0){ ! 177: dprint("sam: can't call %s\n", machine); ! 178: exit(1); ! 179: } ! 180: } ! 181: join(){ ! 182: switch(fork()){ ! 183: case 0: ! 184: close(0); ! 185: dup(remotefd); ! 186: execl("/bin/cat", 0); ! 187: default: ! 188: close(1); ! 189: dup(remotefd); ! 190: execl("/bin/cat", 0); ! 191: case -1: ! 192: dprint("sam: can't fork\n"); ! 193: } ! 194: exit(1); ! 195: } ! 196: ! 197: int ! 198: tcpexec(host, cmd) ! 199: char *host; ! 200: char *cmd; ! 201: { ! 202: int pfd[2]; ! 203: ! 204: if (pipe(pfd)<0) ! 205: return -1; ! 206: switch(fork()) { ! 207: case -1: ! 208: return -1; ! 209: case 0: ! 210: break; ! 211: default: ! 212: close(pfd[0]); ! 213: return(pfd[1]); ! 214: } ! 215: close(pfd[1]); ! 216: if (dup2(pfd[0], 0)<0 || dup2(pfd[0], 1)<0 || dup2(pfd[0], 2)<0) { ! 217: dprint("sam: can't redirect\n"); ! 218: exit(1); ! 219: } ! 220: close(pfd[0]); ! 221: execl("/usr/inet/bin/rsh", host, cmd, 0); ! 222: dprint("sam: can't exec rsh\n"); ! 223: exit(1); ! 224: return -1; /* for cyntax */ ! 225: } ! 226: #endif !SUN
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.