ref: 1018d7a7091fd5e0433f501a3474cdc3fec322cc
dir: /appl/cmd/ed.b/
# # Editor # implement Editor; include "sys.m"; sys: Sys; include "draw.m"; include "bufio.m"; bufio: Bufio; Iobuf: import bufio; include "regex.m"; regex: Regex; Re: import regex; include "sh.m"; sh: Sh; Editor: module { init: fn(nil: ref Draw->Context, args: list of string); }; FNSIZE: con 128; # file name LBSIZE: con 4096; # max line size BLKSIZE: con 4096; # block size in temp file NBLK: con 8191; # max size of temp file ESIZE: con 256; # max size of reg exp GBSIZE: con 256; # max size of global command MAXSUB: con 9; # max number of sub reg exp ESCFLG: con 16rFFFF; # escape Rune - user defined code EOF: con -1; BytesPerRune: con 2; RunesPerBlock: con BLKSIZE / BytesPerRune; APPEND_GETTTY, APPEND_GETSUB, APPEND_GETCOPY, APPEND_GETFILE: con iota; Subexp: adt { rsp, rep: int; }; Globp: adt { s: string; isnil: int; }; addr1: int; addr2: int; anymarks: int; col: int; count: int; dol: int; dot: int; fchange: int; file: string; genbuf := array[LBSIZE] of int; given: int; globp: Globp; iblock: int; ichanged: int; io: ref Sys->FD; iobuf: ref Iobuf; lastc: int; line := array [70] of byte; linebp := -1; linebuf := array [LBSIZE] of int; listf: int; listn: int; loc1: int; loc2: int; names := array [26] of int; oblock: int; oflag: int; pattern: Re; peekc: int; pflag: int; rescuing: int; rhsbuf := array [LBSIZE/2] of int; savedfile: string; subnewa: int; subolda: int; subexp: array of Subexp; tfname: string; tline: int; waiting: int; wrapp: int; zero: array of int; drawctxt: ref Draw->Context; Q: con ""; T: con "TMP"; WRERR: con "WRITE ERROR"; bpagesize := 20; hex: con "0123456789abcdef"; linp: int; nlall := 128; tfile: ref Sys->FD; vflag := 1; debug(s: string) { sys->print("%s", s); } init(ctxt: ref Draw->Context, args: list of string) { drawctxt = ctxt; sys = load Sys Sys->PATH; bufio = load Bufio Bufio->PATH; if (bufio == nil) { sys->fprint(sys->fildes(2), "can't load %s\n", Bufio->PATH); return; } regex = load Regex Regex->PATH; if (regex == nil) { sys->fprint(sys->fildes(2), "can't load %s\n", Regex->PATH); return; } # notify(notifyf); if (args != nil) args = tl args; if (args != nil && hd args == "-o") { oflag = 1; vflag = 0; args = tl args; } if (args != nil && hd args == "-") { vflag = 0; args = tl args; } if (oflag) { savedfile = "/fd/1"; globp = ("a", 0); } else if (args != nil) { savedfile = hd args; globp = ("r", 0); } else globp = (nil, 1); zero = array [nlall + 5] of int; tfname = mktemp("/tmp/eXXXXX"); # debug(sys->sprint("tfname %s\n", tfname)); _init(); for(;;){ { commands(); quit(); }exception{ "savej" => ; } } } casee(c: int) { setnoaddr(); if(vflag && fchange) { fchange = 0; error(Q); } filename(c); _init(); addr2 = 0; caseread(); } casep() { newline(); printcom(); } caseq() { setnoaddr(); newline(); quit(); } caseread() { #debug("caseread " + file); if((io=sys->open(file, Sys->OREAD)) == nil) { lastc = '\n'; error(file); } iobuf = bufio->fopen(io, Sys->OREAD); setwide(); squeeze(0); c := 0 != dol; append(APPEND_GETFILE, addr2); exfile(Sys->OREAD); fchange = c; } commands() { a1: int; c, temp: int; lastsep: int; for(;;) { if(pflag) { pflag = 0; addr1 = addr2 = dot; printcom(); } c = '\n'; for(addr1 = -1;;) { lastsep = c; a1 = address(); c = getchr(); if(c != ',' && c != ';') break; if(lastsep == ',') error(Q); if(a1 < 0) { a1 = 1; if(a1 > dol) a1--; } addr1 = a1; if(c == ';') dot = a1; } if(lastsep != '\n' && a1 < 0) a1 = dol; if((addr2=a1) < 0) { given = 0; addr2 = dot; } else given = 1; if(addr1 < 0) addr1 = addr2; #debug(sys->sprint("%d,%d %c\n", addr1, addr2, c)); case c { 'a' => add(0); continue; 'b' => nonzero(); browse(); continue; 'c' => nonzero(); newline(); rdelete(addr1, addr2); append(APPEND_GETTTY, addr1-1); continue; 'd' => nonzero(); newline(); rdelete(addr1, addr2); continue; 'E' => fchange = 0; c = 'e'; casee(c); continue; 'e' => casee(c); continue; 'f' => setnoaddr(); filename(c); putst(savedfile); continue; 'g' => global(1); continue; 'i' => add(-1); continue; 'j' => if(!given) addr2++; newline(); join(); continue; 'k' => nonzero(); c = getchr(); if(c < 'a' || c > 'z') error(Q); newline(); names[c-'a'] = zero[addr2] & ~16r1; anymarks |= 16r1; continue; 'm' => move(0); continue; 'n' => listn++; newline(); printcom(); continue; '\n' => if(a1 < 0) { a1 = dot+1; addr2 = a1; addr1 = a1; } if(lastsep==';') addr1 = a1; printcom(); continue; 'l' => listf++; casep(); continue; 'p' or 'P' => casep(); continue; 'Q' => fchange = 0; caseq(); continue; 'q' => caseq(); continue; 'r' => filename(c); caseread(); continue; 's' => nonzero(); substitute(!globp.isnil); continue; 't' => move(1); continue; 'u' => nonzero(); newline(); if((zero[addr2]&~8r01) != subnewa) error(Q); zero[addr2] = subolda; dot = addr2; continue; 'v' => global(0); continue; 'W' or 'w' => if (c == 'W') wrapp++; setwide(); squeeze(dol>0); temp = getchr(); if(temp != 'q' && temp != 'Q') { peekc = temp; temp = 0; } filename(c); if(!wrapp || ((io = sys->open(file, Sys->OWRITE)) == nil) || ((sys->seek(io, big 0, Sys->SEEKEND)) < big 0)) if((io = sys->create(file, Sys->OWRITE, 8r0666)) == nil) error(file); iobuf = bufio->fopen(io, Sys->OWRITE); wrapp = 0; if(dol > 0) putfile(); exfile(Sys->OWRITE); if(addr1<=1 && addr2==dol) fchange = 0; if(temp == 'Q') fchange = 0; if(temp) quit(); continue; '=' => setwide(); squeeze(0); newline(); count = addr2 - 0; putd(); putchr('\n'); continue; '!' => callunix(); continue; EOF => return; } error(Q); } } printcom() { a1: int; nonzero(); a1 = addr1; do { if(listn) { count = a1-0; putd(); putchr('\t'); } putshst(getline(zero[a1++])); } while(a1 <= addr2); dot = addr2; listf = 0; listn = 0; pflag = 0; } address(): int { sign, a, opcnt, nextopand, b, c: int; nextopand = -1; sign = 1; opcnt = 0; a = dot; do { do { c = getchr(); } while(c == ' ' || c == '\t'); if(c >= '0' && c <= '9') { peekc = c; if(!opcnt) a = 0; a += sign*getnum(); } else case c { '$' or '.' => if (c == '$') a = dol; if(opcnt) error(Q); '\'' => c = getchr(); if(opcnt || c < 'a' || c > 'z') error(Q); a = 0; do { a++; } while(a <= dol && names[c-'a'] != (zero[a] & ~8r01)); '?' or '/' => if (c == '?') sign = -sign; compile(c); b = a; for(;;) { a += sign; if(a <= 0) a = dol; if(a > dol) a = 0; if(match(a)) break; if(a == b) error(Q); } break; * => if(nextopand == opcnt) { a += sign; if(a < 0 || dol < a) continue; # error(Q); } if(c != '+' && c != '-' && c != '^') { peekc = c; if(opcnt == 0) a = -1; return a; } sign = 1; if(c != '+') sign = -sign; nextopand = ++opcnt; continue; } sign = 1; opcnt++; } while(0 <= a && a <= dol); error(Q); return -1; } getnum(): int { r, c: int; r = 0; for(;;) { c = getchr(); if(c < '0' || c > '9') break; r = r*10 + (c-'0'); } peekc = c; return r; } setwide() { if(!given) { addr1 = 0 + (dol>0); addr2 = dol; } } setnoaddr() { if(given) error(Q); } nonzero() { squeeze(1); } squeeze(i: int) { if(addr1 < 0+i || addr2 > dol || addr1 > addr2) error(Q); } newline() { c: int; c = getchr(); if(c == '\n' || c == EOF) return; if(c == 'p' || c == 'l' || c == 'n') { pflag++; if(c == 'l') listf++; else if(c == 'n') listn++; c = getchr(); if(c == '\n') return; } error(Q); } filename(comm: int) { rune: int; c: int; count = 0; c = getchr(); if(c == '\n' || c == EOF) { if(savedfile == nil && comm != 'f') error(Q); file = savedfile; return; } if(c != ' ') error(Q); while((c=getchr()) == ' ') ; if(c == '\n') error(Q); file = nil; do { if(c == ' ' || c == EOF) error(Q); rune = c; file[len file] = c; } while((c=getchr()) != '\n'); if(savedfile == nil || comm == 'e' || comm == 'f') savedfile = file; } exfile(om: int) { if(om == Sys->OWRITE) if(iobuf.flush() < 0) error(Q); iobuf.close(); iobuf = nil; io = nil; if(vflag) { putd(); putchr('\n'); } } error1(s: string) { c: int; wrapp = 0; listf = 0; listn = 0; count = 0; sys->seek(sys->fildes(0), big 0, Sys->SEEKEND); # what does this do? pflag = 0; if(!globp.isnil) lastc = '\n'; globp = (nil, 1); peekc = lastc; if(lastc) for(;;) { c = getchr(); if(c == '\n' || c == EOF) break; } if(io != nil) io = nil; putchr('?'); putst(s); } error(s: string) { error1(s); raise "savej"; } rescue() { rescuing = 1; if(dol > 0) { addr1 = 0+1; addr2 = dol; io = sys->create("ed.hup", Sys->OWRITE, 8r0666); if(io != nil){ iobuf = bufio->fopen(io, Sys->OWRITE); putfile(); } } fchange = 0; quit(); } # void # notifyf(void *a, char *s) # { # if(strcmp(s, "interrupt") == 0){ # if(rescuing || waiting) # noted(NCONT); # putchr(L'\n'); # lastc = '\n'; # error1(Q); # notejmp(a, savej, 0); # } # if(strcmp(s, "hangup") == 0){ # if(rescuing) # noted(NDFLT); # rescue(); # } # fprint(2, "ed: note: %s\n", s); # abort(); # } getchr(): int { s := array [Sys->UTFmax] of byte; i: int; r: int; status: int; if(lastc = peekc) { peekc = 0; #debug(sys->sprint("getchr: peekc %c\n", lastc)); return lastc; } if(!globp.isnil) { if (globp.s != nil) { lastc = globp.s[0]; globp.s = globp.s[1:]; #debug(sys->sprint("getchr: globp %c remaining %d\n", lastc, len globp.s)); return lastc; } globp = (nil, 1); #debug(sys->sprint("getchr: globp end\n")); return EOF; } #debug("globp nil\n"); for(i=0;;) { if(sys->read(sys->fildes(0), s[i:], 1) <= 0) return lastc = EOF; i++; (r, nil, status) = sys->byte2char(s, 0); if (status > 0) break; } lastc = r; return lastc; } gety(): int { c: int; gf: int; p: int; p = 0; gf = !globp.isnil; for(;;) { c = getchr(); if(c == '\n') { linebuf[p] = 0; return 0; } if(c == EOF) { if(gf) peekc = c; return c; } if(c == 0) continue; linebuf[p++] = c; if(p >= len linebuf) error(Q); } return 0; } gettty(): int { rc: int; rc = gety(); if(rc) return rc; if(linebuf[0] == '.' && linebuf[1] == 0) return EOF; return 0; } getfile(): int { c: int; lp: int; lp = 0; do { c = iobuf.getc(); if(c < 0) { if(lp > 0) { putst("'\\n' appended"); c = '\n'; } else return EOF; } if(lp >= len linebuf) { lastc = '\n'; error(Q); } linebuf[lp++] = c; count++; } while(c != '\n'); linebuf[lp - 1] = 0; #debug(sys->sprint("getline read %d\n", lp)); return 0; } putfile() { a1: int; lp: int; c: int; a1 = addr1; do { lp = getline(zero[a1++]); for(;;) { count++; c = linebuf[lp++]; if(c == 0) { if (iobuf.putc('\n') < 0) error(Q); break; } if (iobuf.putc(c) < 0) error(Q); } } while(a1 <= addr2); if(iobuf.flush() < 0) error(Q); } append(f: int, a: int): int { a1, a2, rdot, nline, _tl: int; rv: int; nline = 0; dot = a; for (;;) { case f { APPEND_GETTTY => rv = gettty(); APPEND_GETSUB => rv = getsub(); APPEND_GETCOPY => rv = getcopy(); APPEND_GETFILE => rv = getfile(); } if (rv != 0) break; if(dol >= nlall) { nlall += 512; newzero := array [nlall + 5] of int; if(newzero == nil) { error("MEM?"); rescue(); } newzero[0:] = zero; zero = newzero; } _tl = putline(); nline++; a1 = ++dol; a2 = a1+1; rdot = ++dot; zero[rdot:] = zero[rdot - 1: a1]; zero[rdot] = _tl; } #debug(sys->sprint("end of append - dot %d\n", dot)); return nline; } add(i: int) { if(i && (given || dol > 0)) { addr1--; addr2--; } squeeze(0); newline(); append(APPEND_GETTTY, addr2); } bformat, bnum: int; browse() { forward, n: int; forward = 1; peekc = getchr(); if(peekc != '\n'){ if(peekc == '-' || peekc == '+') { if(peekc == '-') forward = 0; getchr(); } n = getnum(); if(n > 0) bpagesize = n; } newline(); if(pflag) { bformat = listf; bnum = listn; } else { listf = bformat; listn = bnum; } if(forward) { addr1 = addr2; addr2 += bpagesize; if(addr2 > dol) addr2 = dol; } else { addr1 = addr2-bpagesize; if(addr1 <= 0) addr1 = 0+1; } printcom(); } callunix() { buf: string; c: int; if (sh == nil) sh = load Sh Sh->PATH; if (sh == nil) { putst("can't load shell"); return; } setnoaddr(); while((c=getchr()) != EOF && c != '\n') buf[len buf] = c; sh->system(drawctxt, buf); if(vflag) putst("!"); } quit() { if(vflag && fchange && dol!=0) { fchange = 0; error(Q); } sys->remove(tfname); exit; } onquit(nil: int) { quit(); } rdelete(ad1, ad2: int) { a1, a2, a3: int; a1 = ad1; a2 = ad2+1; a3 = dol; dol -= a2 - a1; do { zero[a1++] = zero[a2++]; } while (a2 <= a3); a1 = ad1; if(a1 > dol) a1 = dol; dot = a1; fchange = 1; } gdelete() { a1, a2, a3: int; a3 = dol; for(a1=0; (zero[a1]&8r01)==0; a1++) if(a1>=a3) return; for(a2=a1+1; a2<=a3;) { if(zero[a2] & 8r01) { a2++; dot = a1; } else zero[a1++] = zero[a2++]; } dol = a1-1; if(dot > dol) dot = dol; fchange = 1; } getline(_tl: int): int { lp, bp: int; nl: int; block: array of int; #debug(sys->sprint("getline %d\n", _tl)); lp = 0; (block, bp) = getblock(_tl, Sys->OREAD); nl = len block - bp; _tl &= ~(RunesPerBlock - 1); while(linebuf[lp++] = block[bp++]) { nl--; if(nl == 0) { (block, bp) = getblock(_tl += RunesPerBlock, Sys->OREAD); nl = len block; } } return 0; } putline(): int { lp, bp: int; nl, _tl: int; block: array of int; fchange = 1; lp = 0; _tl = tline; (block, bp) = getblock(_tl, Sys->OWRITE); nl = len block - bp; _tl &= ~(RunesPerBlock-1); # _tl is now at the beginning of the block while(block[bp] = linebuf[lp++]) { if(block[bp++] == '\n') { block[bp-1] = 0; linebp = lp; break; } nl--; if(nl == 0) { _tl += RunesPerBlock; (block, bp) = getblock(_tl, Sys->OWRITE); nl = len block; } } nl = tline; tline += ((lp) + 8r03) & 8r077776; return nl; } tbuf := array [BLKSIZE] of byte; getrune(buf: array of byte): int { return int buf[0] + (int buf[1] << 8); } putrune(buf: array of byte, v: int) { buf[0] = byte (v); buf[1] = byte (v >> 8); } blkio(b: int, buf: array of int, writefunc: int) { sys->seek(tfile, big b * big BLKSIZE, Sys->SEEKSTART); if (writefunc) { # flatten buf into tbuf for (x := 0; x < RunesPerBlock; x++) putrune(tbuf[x * BytesPerRune:], buf[x]); if (sys->write(tfile, tbuf, BLKSIZE) != len tbuf) { error(T); } } else { if (sys->read(tfile, tbuf, len tbuf) != len tbuf) { error(T); } for (x := 0; x < RunesPerBlock; x++) buf[x] = getrune(tbuf[x * BytesPerRune:]); } } ibuff := array [RunesPerBlock] of int; obuff := array [RunesPerBlock] of int; getblock(atl, iof: int): (array of int, int) { bno, off: int; bno = atl / RunesPerBlock; off = (atl * BytesPerRune) & (BLKSIZE-1) & ~8r03; if(bno >= NBLK) { lastc = '\n'; error(T); } off /= BytesPerRune; if(bno == iblock) { ichanged |= iof; #debug(sys->sprint("getblock(%d, %d): returns ibuff offset %d\n", atl, iof, off)); return (ibuff, off); } if(bno == oblock) { #debug(sys->sprint("getblock(%d, %d): returns obuff offset %d\n", atl, iof, off)); return (obuff, off); } if(iof == Sys->OREAD) { if(ichanged) blkio(iblock, ibuff, 1); ichanged = 0; iblock = bno; blkio(bno, ibuff, 0); #debug(sys->sprint("getblock(%d, %d): returns ibuff offset %d\n", atl, iof, off)); return (ibuff, off); } if(oblock >= 0) blkio(oblock, obuff, 1); oblock = bno; #debug(sys->sprint("getblock(%d, %d): returns offset %d\n", atl, iof, off)); return (obuff, off); } _init() { markp: int; tfile = nil; tline = RunesPerBlock; for(markp = 0; markp < len names; markp++) names[markp] = 0; subnewa = 0; anymarks = 0; iblock = -1; oblock = -1; ichanged = 0; if((tfile = sys->create(tfname, Sys->ORDWR, 8r0600)) == nil){ error1(T); exit; } dot = dol = 0; } global(k: int) { globuf: string; c, a1: int; if(!globp.isnil) error(Q); setwide(); squeeze(dol > 0); c = getchr(); if(c == '\n') error(Q); compile(c); globuf = nil; while((c=getchr()) != '\n') { if(c == EOF) error(Q); if(c == '\\') { c = getchr(); if(c != '\n') globuf[len globuf] = '\\'; } globuf[len globuf] = c; } if(globuf == nil) globuf = "p"; globuf[len globuf] = '\n'; for(a1=0; a1<=dol; a1++) { zero[a1] &= ~8r01; if(a1 >= addr1 && a1 <= addr2 && match(a1) == k) zero[a1] |= 8r01; } # # Special case: g/.../d (avoid n^2 algorithm) if(globuf == "d\n") { gdelete(); return; } for(a1=0; a1<=dol; a1++) { if(zero[a1] & 8r01) { zero[a1] &= ~8r01; dot = a1; globp = (globuf, 0); commands(); a1 = 0; } } } join() { gp, lp: int; a1: int; nonzero(); gp = 0; for(a1=addr1; a1<=addr2; a1++) { lp = getline(zero[a1]); while(genbuf[gp] = linebuf[lp++]) if(gp++ >= LBSIZE-2) error(Q); } lp = 0; gp = 0; while(linebuf[lp++] = genbuf[gp++]) ; zero[addr1] = putline(); if(addr1 < addr2) rdelete(addr1+1, addr2); dot = addr1; } substitute(inglob: int) { mp, a1, nl, gsubf, n: int; n = getnum(); # OK even if n==0 gsubf = compsub(); for(a1 = addr1; a1 <= addr2; a1++) { if(match(a1)){ m := n; do { span := loc2-loc1; if(--m <= 0) { dosub(); if(!gsubf) break; if(span == 0) { # null RE match if(zero[loc2] == 0) break; loc2++; } } } while(match(-1)); if(m <= 0) { inglob |= 8r01; subnewa = putline(); zero[a1] &= ~8r01; if(anymarks) { for(mp=0; mp<len names; mp++) if(names[mp] == zero[a1]) names[mp] = subnewa; } subolda = zero[a1]; zero[a1] = subnewa; #debug(sys->sprint("append-getsub linebp = %d\n", linebp)); nl = append(APPEND_GETSUB, a1); addr2 += nl; } } } if(inglob == 0) error(Q); } compsub(): int { seof, c: int; p: int; seof = getchr(); if(seof == '\n' || seof == ' ') error(Q); compile(seof); p = 0; for(;;) { c = getchr(); if(c == '\\') { c = getchr(); rhsbuf[p++] = ESCFLG; if(p >= LBSIZE / 2) error(Q); } else if(c == '\n' && (globp.isnil || globp.s == nil)) { peekc = c; pflag++; break; } else if(c == seof) break; rhsbuf[p++] = c; if(p >= LBSIZE / 2) error(Q); } rhsbuf[p] = 0; peekc = getchr(); if(peekc == 'g') { peekc = 0; newline(); return 1; } newline(); return 0; } getsub(): int { p1, p2: int; p1 = 0; if((p2 = linebp) == -1) return EOF; while(linebuf[p1++] = linebuf[p2++]) ; linebp = -1; return 0; } dosub() { lp, sp, rp: int; c, n: int; # lp = linebuf; # sp = genbuf; # rp = rhsbuf; lp = 0; sp = 0; rp = 0; while(lp < loc1) genbuf[sp++] = linebuf[lp++]; while(c = rhsbuf[rp++]) { if(c == '&'){ sp = place(sp, loc1, loc2); continue; } if(c == ESCFLG && (c = rhsbuf[rp++]) >= '1' && c < MAXSUB+'0') { n = c-'0'; if(n < len subexp && subexp[n].rsp >= 0 && subexp[n].rep >= 0) { sp = place(sp, subexp[n].rsp, subexp[n].rep); continue; } error(Q); } genbuf[sp++] = c; if(sp >= LBSIZE) error(Q); } lp = loc2; loc2 = sp; while(genbuf[sp++] = linebuf[lp++]) if(sp >= LBSIZE) error(Q); linebuf[0:] = genbuf[0: sp]; } place(sp: int, l1: int, l2: int): int { while(l1 < l2) { genbuf[sp++] = linebuf[l1++]; if(sp >= LBSIZE) error(Q); } return sp; } move(cflag: int) { _adt, ad1, ad2: int; nonzero(); if((_adt = address()) < 0) # address() guarantees addr is in range error(Q); newline(); if(cflag) { ad1 = dol; append(APPEND_GETCOPY, ad1++); ad2 = dol; } else { ad2 = addr2; for(ad1 = addr1; ad1 <= ad2;) zero[ad1++] &= ~8r01; ad1 = addr1; } ad2++; if(_adt<ad1) { dot = _adt + (ad2-ad1); if((++_adt)==ad1) return; reverse(_adt, ad1); reverse(ad1, ad2); reverse(_adt, ad2); } else if(_adt >= ad2) { dot = _adt++; reverse(ad1, ad2); reverse(ad2, _adt); reverse(ad1, _adt); } else error(Q); fchange = 1; } reverse(a1, a2: int) { t: int; for(;;) { t = zero[--a2]; if(a2 <= a1) return; zero[a2] = zero[a1]; zero[a1++] = t; } } getcopy(): int { if(addr1 > addr2) return EOF; getline(zero[addr1++]); return 0; } compile(eof: int) { c: int; if((c = getchr()) == '\n') { peekc = c; c = eof; } if(c == eof) { if(pattern == nil) error(Q); return; } pattern = nil; program := ""; do { if(c == '\\') { program[len program] = '\\'; if((c = getchr()) == '\n') { error(Q); return; } } program[len program] = c; } while((c = getchr()) != eof && c != '\n'); if(c == '\n') peekc = c; diag: string; #debug("program " + program + "\n"); (pattern, diag) = regex->compile(program, 1); #if (diag != nil) # debug("diag " + diag + "\n"); if (diag != nil) pattern = nil; } mkstring(a: array of int): string { s: string; for (x := 0; x < len a; x++) { if (a[x] == 0) break; s[x] = a[x]; } return s; } match(addr: int): int { rsp: int; if(pattern == nil) return 0; if(addr >= 0){ if(addr == 0) return 0; rsp = getline(zero[addr]); } else rsp = loc2; s := mkstring(linebuf); subexp = regex->executese(pattern, s, (rsp, len s), rsp == 0, 1); if(subexp != nil) { (loc1, loc2) = subexp[0]; return 1; } loc1 = loc2 = -1; return 0; } putd() { r: int; r = count%10; count /= 10; if(count) putd(); putchr(r + '0'); } putst(s: string) { col = 0; for(x := 0; x < len s; x++) putchr(s[x]); putchr('\n'); } putshst(sp: int) { col = 0; while(linebuf[sp]) { putchr(linebuf[sp++]); } putchr('\n'); } putchr(ac: int) { lp: int; c: int; rune: int; lp = linp; c = ac; if(listf) { if(c == '\n') { if(linp != 0 && line[linp - 1] == byte ' ') { line[lp++] = byte '\\'; line[lp++] = byte 'n'; } } else { if(col > (72-6-2)) { col = 8; line[lp++] = byte '\\'; line[lp++] = byte '\n'; line[lp++] = byte '\t'; } col++; if(c=='\b' || c=='\t' || c=='\\') { line[lp++] = byte '\\'; if(c == '\b') c = 'b'; else if(c == '\t') c = 't'; col++; } else if(c<' ' || c>=8r0177) { line[lp++] = byte '\\'; line[lp++] = byte 'x'; line[lp++] = byte hex[c>>12]; line[lp++] = byte hex[c>>8&16rF]; line[lp++] = byte hex[c>>4&16rF]; c = hex[c&16rF]; col += 5; } } } rune = c; lp += sys->char2byte(rune, line, lp); if(c == '\n' || lp >= len line - 5) { linp = 0; if (oflag) sys->write(sys->fildes(2), line, lp); else sys->write(sys->fildes(1), line, lp); return; } linp = lp; } stringfromint(i: int): string { s: string; s[0] = i; return s; } mktemp(as: string): string { pid: int; s: string; s = nil; pid = sys->pctl(0, nil); for (x := len as - 1; x >= 0; x--) if (as[x] == 'X') { s = stringfromint('0' + pid % 10) + s; pid /= 10; } else s = stringfromint(as[x]) + s; s[len s] = 'a'; for (;;) { (rv, nil) := sys->stat(s); if (rv < 0) break; if (s[len s - 1] == 'z') return "/"; s[len s - 1]++; } return s; }