#include #include #include #include #include #include #include #include #include "libframe/frame.h" #include #include #include #include <9pclient.h> #include "dat.h" #include "fns.h" Buffer snarfbuf; /* * These functions get called as: * * fn(et, t, argt, flag1, flag1, flag2, s, n); * * Where the arguments are: * * et: the Text* in which the executing event (click) occurred * t: the Text* containing the current selection (Edit, Cut, Snarf, Paste) * argt: the Text* containing the argument for a 2-1 click. * e->flag1: from Exectab entry * e->flag2: from Exectab entry * s: the command line remainder (e.g., "x" if executing "Dump x") * n: length of s (s is *not* NUL-terminated) */ void doabort(Text*, Text*, Text*, int, int, Rune*, int); void del(Text*, Text*, Text*, int, int, Rune*, int); void delcol(Text*, Text*, Text*, int, int, Rune*, int); void dotfiles(Text*, Text*, Text*, int, int, Rune*, int); void dump(Text*, Text*, Text*, int, int, Rune*, int); void edit(Text*, Text*, Text*, int, int, Rune*, int); void xexit(Text*, Text*, Text*, int, int, Rune*, int); void fontx(Text*, Text*, Text*, int, int, Rune*, int); void get(Text*, Text*, Text*, int, int, Rune*, int); void id(Text*, Text*, Text*, int, int, Rune*, int); void incl(Text*, Text*, Text*, int, int, Rune*, int); void indent(Text*, Text*, Text*, int, int, Rune*, int); void xkill(Text*, Text*, Text*, int, int, Rune*, int); void local(Text*, Text*, Text*, int, int, Rune*, int); void look(Text*, Text*, Text*, int, int, Rune*, int); void newcol(Text*, Text*, Text*, int, int, Rune*, int); void paste(Text*, Text*, Text*, int, int, Rune*, int); void put(Text*, Text*, Text*, int, int, Rune*, int); void putall(Text*, Text*, Text*, int, int, Rune*, int); void sendx(Text*, Text*, Text*, int, int, Rune*, int); void sort(Text*, Text*, Text*, int, int, Rune*, int); void tab(Text*, Text*, Text*, int, int, Rune*, int); void zeroxx(Text*, Text*, Text*, int, int, Rune*, int); typedef struct Exectab Exectab; struct Exectab { Rune* name; void (*fn)(Text*, Text*, Text*, int, int, Rune*, int); int mark; int flag1; int flag2; }; static Rune LAbort[] = {'A', 'b', 'o', 'r', 't', 0}; static Rune LCut[] = {'C', 'u', 't', 0}; static Rune LDel[] = {'D', 'e', 'l', 0}; static Rune LDelcol[] = {'D', 'e', 'l', 'c', 'o', 'l', 0}; static Rune LDelete[] = {'D', 'e', 'l', 'e', 't', 'e', 0}; static Rune LDump[] = {'D', 'u', 'm', 'p', 0}; static Rune LEdit[] = {'E', 'd', 'i', 't', 0}; static Rune LExit[] = {'E', 'x', 'i', 't', 0}; static Rune LFont[] = {'F', 'o', 'n', 't', 0}; static Rune LGet[] = {'G', 'e', 't', 0}; static Rune LID[] = {'I', 'D', 0}; static Rune LIncl[] = {'I', 'n', 'c', 'l', 0}; static Rune LIndent[] = {'I', 'n', 'd', 'e', 'n', 't', 0}; static Rune LKill[] = {'K', 'i', 'l', 'l', 0}; static Rune LLoad[] = {'L', 'o', 'a', 'd', 0}; static Rune LLocal[] = {'L', 'o', 'c', 'a', 'l', 0}; static Rune LLook[] = {'L', 'o', 'o', 'k', 0}; static Rune LNew[] = {'N', 'e', 'w', 0}; static Rune LNewcol[] = {'N', 'e', 'w', 'c', 'o', 'l', 0}; static Rune LPaste[] = {'P', 'a', 's', 't', 'e', 0}; static Rune LPut[] = {'P', 'u', 't', 0}; static Rune LPutall[] = {'P', 'u', 't', 'a', 'l', 'l', 0}; static Rune LRedo[] = {'R', 'e', 'd', 'o', 0}; static Rune LSend[] = {'S', 'e', 'n', 'd', 0}; static Rune LSnarf[] = {'S', 'n', 'a', 'r', 'f', 0}; static Rune LSort[] = {'S', 'o', 'r', 't', 0}; static Rune LSpaces[] = {'S', 'p', 'a', 'c', 'e', 's', 0}; static Rune LTab[] = {'T', 'a', 'b', 0}; static Rune LUndo[] = {'U', 'n', 'd', 'o', 0}; static Rune LZerox[] = {'Z', 'e', 'r', 'o', 'x', 0}; Exectab exectab[] = { { LAbort, doabort, FALSE, XXX, XXX, }, {LCut, cut, TRUE, TRUE, TRUE}, {LDel, del, FALSE, FALSE, XXX}, {LDelcol, delcol, FALSE, XXX, XXX}, {LDelete, del, FALSE, TRUE, XXX}, {LDump, dump, FALSE, TRUE, XXX}, {LEdit, edit, FALSE, XXX, XXX}, {LExit, xexit, FALSE, XXX, XXX}, {LFont, fontx, FALSE, XXX, XXX}, {LGet, get, FALSE, TRUE, XXX}, {LID, id, FALSE, XXX, XXX}, {LIncl, incl, FALSE, XXX, XXX}, {LIndent, indent, FALSE, AUTOINDENT, XXX}, {LKill, xkill, FALSE, XXX, XXX}, {LLoad, dump, FALSE, FALSE, XXX}, {LLocal, local, FALSE, XXX, XXX}, {LLook, look, FALSE, XXX, XXX}, {LNew, new, FALSE, XXX, XXX}, {LNewcol, newcol, FALSE, XXX, XXX}, {LPaste, paste, TRUE, TRUE, XXX}, {LPut, put, FALSE, XXX, XXX}, {LPutall, putall, FALSE, XXX, XXX}, {LRedo, undo, FALSE, FALSE, XXX}, {LSend, sendx, TRUE, XXX, XXX}, {LSnarf, cut, FALSE, TRUE, FALSE}, {LSort, sort, FALSE, XXX, XXX}, {LSpaces, indent, FALSE, SPACESINDENT, XXX}, {LTab, tab, FALSE, XXX, XXX}, {LUndo, undo, FALSE, TRUE, XXX}, {LZerox, zeroxx, FALSE, XXX, XXX}, {nil, 0, 0, 0, 0}}; Exectab* lookup(Rune* r, int n) { Exectab* e; int nr; r = skipbl(r, n, &n); if (n == 0) return nil; findbl(r, n, &nr); nr = n - nr; for (e = exectab; e->name; e++) if (runeeq(r, nr, e->name, runestrlen(e->name)) == TRUE) return e; return nil; } int isexecc(int c) { if (isfilec(c)) return 1; return c == '<' || c == '|' || c == '>'; } void execute(Text* t, uint aq0, uint aq1, int external, Text* argt) { uint q0, q1; Rune *r, *s; char *b, *a, *aa; Exectab* e; int c, n, f; Runestr dir; q0 = aq0; q1 = aq1; if (q1 == q0) { /* expand to find word (actually file name) */ /* if in selection, choose selection */ if (t->q1 > t->q0 && t->q0 <= q0 && q0 <= t->q1) { q0 = t->q0; q1 = t->q1; } else { while (q1 < t->file->b.nc && isexecc(c = textreadc(t, q1)) && c != ':') q1++; while (q0 > 0 && isexecc(c = textreadc(t, q0 - 1)) && c != ':') q0--; if (q1 == q0) return; } } r = runemalloc(q1 - q0); bufread(&t->file->b, q0, r, q1 - q0); e = lookup(r, q1 - q0); if (!external && t->w != nil && t->w->nopen[QWevent] > 0) { f = 0; if (e) f |= 1; if (q0 != aq0 || q1 != aq1) { bufread(&t->file->b, aq0, r, aq1 - aq0); f |= 2; } aa = getbytearg(argt, TRUE, TRUE, &a); if (a) { if (strlen(a) > EVENTSIZE) { /* too big; too bad */ free(r); free(aa); free(a); warning(nil, "argument string too long\n"); return; } f |= 8; } c = 'x'; if (t->what == Body) c = 'X'; n = aq1 - aq0; if (n <= EVENTSIZE) winevent(t->w, "%c%d %d %d %d %.*S\n", c, aq0, aq1, f, n, n, r); else winevent(t->w, "%c%d %d %d 0 \n", c, aq0, aq1, f, n); if (q0 != aq0 || q1 != aq1) { n = q1 - q0; bufread(&t->file->b, q0, r, n); if (n <= EVENTSIZE) winevent(t->w, "%c%d %d 0 %d %.*S\n", c, q0, q1, n, n, r); else winevent(t->w, "%c%d %d 0 0 \n", c, q0, q1, n); } if (a) { winevent(t->w, "%c0 0 0 %d %s\n", c, utflen(a), a); if (aa) winevent(t->w, "%c0 0 0 %d %s\n", c, utflen(aa), aa); else winevent(t->w, "%c0 0 0 0 \n", c); } free(r); free(aa); free(a); return; } if (e) { if (e->mark && seltext != nil) if (seltext->what == Body) { seq++; filemark(seltext->w->body.file); } s = skipbl(r, q1 - q0, &n); s = findbl(s, n, &n); s = skipbl(s, n, &n); (*e->fn)(t, seltext, argt, e->flag1, e->flag2, s, n); free(r); return; } b = runetobyte(r, q1 - q0); free(r); dir = dirname(t, nil, 0); if (dir.nr == 1 && dir.r[0] == '.') { /* sigh */ free(dir.r); dir.r = nil; dir.nr = 0; } aa = getbytearg(argt, TRUE, TRUE, &a); if (t->w) incref(&t->w->ref); run(t->w, b, dir.r, dir.nr, TRUE, aa, a, FALSE); } char* printarg(Text* argt, uint q0, uint q1) { char* buf; if (argt->what != Body || argt->file->name == nil) return nil; buf = emalloc(argt->file->nname + 32); if (q0 == q1) sprint(buf, "%.*S:#%d", argt->file->nname, argt->file->name, q0); else sprint(buf, "%.*S:#%d,#%d", argt->file->nname, argt->file->name, q0, q1); return buf; } char* getarg(Text* argt, int doaddr, int dofile, Rune** rp, int* nrp) { int n; Expand e; char* a; *rp = nil; *nrp = 0; if (argt == nil) return nil; a = nil; textcommit(argt, TRUE); if (expand(argt, argt->q0, argt->q1, &e)) { free(e.bname); if (e.nname && dofile) { e.name = runerealloc(e.name, e.nname + 1); if (doaddr) a = printarg(argt, e.q0, e.q1); *rp = e.name; *nrp = e.nname; return a; } free(e.name); } else { e.q0 = argt->q0; e.q1 = argt->q1; } n = e.q1 - e.q0; *rp = runemalloc(n + 1); bufread(&argt->file->b, e.q0, *rp, n); if (doaddr) a = printarg(argt, e.q0, e.q1); *nrp = n; return a; } char* getbytearg(Text* argt, int doaddr, int dofile, char** bp) { Rune* r; int n; char* aa; *bp = nil; aa = getarg(argt, doaddr, dofile, &r, &n); if (r == nil) return nil; *bp = runetobyte(r, n); free(r); return aa; } void doabort(Text* __0, Text* _0, Text* _1, int _2, int _3, Rune* _4, int _5) { static int n; USED(__0); USED(_0); USED(_1); USED(_2); USED(_3); USED(_4); USED(_5); if (n++ == 0) warning(nil, "executing Abort again will call abort()\n"); else abort(); } void newcol(Text* et, Text* _0, Text* _1, int _2, int _3, Rune* _4, int _5) { Column* c; Window* w; USED(_0); USED(_1); USED(_2); USED(_3); USED(_4); USED(_5); c = rowadd(et->row, nil, -1); if (c) { w = coladd(c, nil, nil, -1); winsettag(w); xfidlog(w, "new"); } } void delcol(Text* et, Text* _0, Text* _1, int _2, int _3, Rune* _4, int _5) { int i; Column* c; Window* w; USED(_0); USED(_1); USED(_2); USED(_3); USED(_4); USED(_5); c = et->col; if (c == nil || colclean(c) == 0) return; for (i = 0; i < c->nw; i++) { w = c->w[i]; if ( w->nopen[QWevent] + w->nopen[QWaddr] + w->nopen[QWdata] + w->nopen[QWxdata] > 0) { warning( nil, "can't delete column; %.*S is running an external command\n", w->body.file->nname, w->body.file->name); return; } } rowclose(et->col->row, et->col, TRUE); } void del(Text* et, Text* _0, Text* _1, int flag1, int _2, Rune* _3, int _4) { USED(_0); USED(_1); USED(_2); USED(_3); USED(_4); if (et->col == nil || et->w == nil) return; if (flag1 || et->w->body.file->ntext > 1 || winclean(et->w, FALSE)) colclose(et->col, et->w, TRUE); } void sort(Text* et, Text* _0, Text* _1, int _2, int _3, Rune* _4, int _5) { USED(_0); USED(_1); USED(_2); USED(_3); USED(_4); USED(_5); if (et->col) colsort(et->col); } uint seqof(Window* w, int isundo) { /* if it's undo, see who changed with us */ if (isundo) return w->body.file->seq; /* if it's redo, see who we'll be sync'ed up with */ return fileredoseq(w->body.file); } void undo(Text* et, Text* _0, Text* _1, int flag1, int _2, Rune* _3, int _4) { int i, j; Column* c; Window* w; uint seq; USED(_0); USED(_1); USED(_2); USED(_3); USED(_4); if (et == nil || et->w == nil) return; seq = seqof(et->w, flag1); if (seq == 0) { /* nothing to undo */ return; } /* * Undo the executing window first. Its display will update. other windows * in the same file will not call show() and jump to a different location in * the file. Simultaneous changes to other files will be chaotic, however. */ winundo(et->w, flag1); for (i = 0; i < row.ncol; i++) { c = row.col[i]; for (j = 0; j < c->nw; j++) { w = c->w[j]; if (w == et->w) continue; if (seqof(w, flag1) == seq) winundo(w, flag1); } } } char* getname(Text* t, Text* argt, Rune* arg, int narg, int isput) { char* s; Rune* r; int i, n, promote; Runestr dir; getarg(argt, FALSE, TRUE, &r, &n); promote = FALSE; if (r == nil) promote = TRUE; else if (isput) { /* if are doing a Put, want to synthesize name even for non-existent file */ /* best guess is that file name doesn't contain a slash */ promote = TRUE; for (i = 0; i < n; i++) if (r[i] == '/') { promote = FALSE; break; } if (promote) { t = argt; arg = r; narg = n; } } if (promote) { n = narg; if (n <= 0) { s = runetobyte(t->file->name, t->file->nname); return s; } /* prefix with directory name if necessary */ dir.r = nil; dir.nr = 0; if (n > 0 && arg[0] != '/') { dir = dirname(t, nil, 0); if (dir.nr == 1 && dir.r[0] == '.') { /* sigh */ free(dir.r); dir.r = nil; dir.nr = 0; } } if (dir.r) { r = runemalloc(dir.nr + n + 1); runemove(r, dir.r, dir.nr); free(dir.r); if (dir.nr > 0 && r[dir.nr] != '/' && n > 0 && arg[0] != '/') r[dir.nr++] = '/'; runemove(r + dir.nr, arg, n); n += dir.nr; } else { r = runemalloc(n + 1); runemove(r, arg, n); } } s = runetobyte(r, n); free(r); if (strlen(s) == 0) { free(s); s = nil; } return s; } void zeroxx(Text* et, Text* t, Text* _1, int _2, int _3, Rune* _4, int _5) { Window* nw; int c, locked; USED(_1); USED(_2); USED(_3); USED(_4); USED(_5); locked = FALSE; if (t != nil && t->w != nil && t->w != et->w) { locked = TRUE; c = 'M'; if (et->w) c = et->w->owner; winlock(t->w, c); } if (t == nil) t = et; if (t == nil || t->w == nil) return; t = &t->w->body; if (t->w->isdir) warning( nil, "%.*S is a directory; Zerox illegal\n", t->file->nname, t->file->name); else { nw = coladd(t->w->col, nil, t->w, -1); /* ugly: fix locks so w->unlock works */ winlock1(nw, t->w->owner); xfidlog(nw, "zerox"); } if (locked) winunlock(t->w); } typedef struct TextAddr TextAddr; struct TextAddr { long lorigin; // line+rune for origin long rorigin; long lq0; // line+rune for q0 long rq0; long lq1; // line+rune for q1 long rq1; }; void get( Text* et, Text* t, Text* argt, int flag1, int _0, Rune* arg, int narg) { char* name; Rune* r; int i, n, dirty, samename, isdir; TextAddr *addr, *a; Window* w; Text* u; Dir* d; long q0, q1; USED(_0); if (flag1) if (et == nil || et->w == nil) return; if (!et->w->isdir && (et->w->body.file->b.nc > 0 && !winclean(et->w, TRUE))) return; w = et->w; t = &w->body; name = getname(t, argt, arg, narg, FALSE); if (name == nil) { warning(nil, "no file name\n"); return; } if (t->file->ntext > 1) { d = dirstat(name); isdir = (d != nil && (d->qid.type & QTDIR)); free(d); if (isdir) { warning( nil, "%s is a directory; can't read with multiple windows on it\n", name); return; } } addr = emalloc((t->file->ntext) * sizeof(TextAddr)); for (i = 0; i < t->file->ntext; i++) { a = &addr[i]; u = t->file->text[i]; a->lorigin = nlcount(u, 0, u->org, &a->rorigin); a->lq0 = nlcount(u, 0, u->q0, &a->rq0); a->lq1 = nlcount(u, u->q0, u->q1, &a->rq1); } r = bytetorune(name, &n); for (i = 0; i < t->file->ntext; i++) { u = t->file->text[i]; /* second and subsequent calls with zero an already empty buffer, but OK */ textreset(u); windirfree(u->w); } samename = runeeq(r, n, t->file->name, t->file->nname); textload(t, 0, name, samename); if (samename) { t->file->mod = FALSE; dirty = FALSE; } else { t->file->mod = TRUE; dirty = TRUE; } for (i = 0; i < t->file->ntext; i++) t->file->text[i]->w->dirty = dirty; free(name); free(r); winsettag(w); t->file->unread = FALSE; for (i = 0; i < t->file->ntext; i++) { u = t->file->text[i]; textsetselect(&u->w->tag, u->w->tag.file->b.nc, u->w->tag.file->b.nc); if (samename) { a = &addr[i]; // warning(nil, "%d %d %d %d %d %d\n", a->lorigin, a->rorigin, a->lq0, // a->rq0, a->lq1, a->rq1); q0 = nlcounttopos(u, 0, a->lq0, a->rq0); q1 = nlcounttopos(u, q0, a->lq1, a->rq1); textsetselect(u, q0, q1); q0 = nlcounttopos(u, 0, a->lorigin, a->rorigin); textsetorigin(u, q0, FALSE); } textscrdraw(u); } free(addr); xfidlog(w, "get"); } static void checksha1(char* name, File* f, Dir* d) { int fd, n; DigestState* h; uchar out[20]; uchar* buf; fd = open(name, OREAD); if (fd < 0) return; h = sha1(nil, 0, nil, nil); buf = emalloc(8192); while ((n = read(fd, buf, 8192)) > 0) sha1(buf, n, nil, h); free(buf); close(fd); sha1(nil, 0, out, h); if (memcmp(out, f->sha1, sizeof out) == 0) { f->dev = d->dev; f->qidpath = d->qid.path; f->mtime = d->mtime; } } void putfile(File* f, int q0, int q1, Rune* namer, int nname) { uint n, m; Rune* r; Biobuf* b; char *s, *name; int i, fd, q; Dir *d, *d1; Window* w; int isapp; DigestState* h; w = f->curtext->w; name = runetobyte(namer, nname); d = dirstat(name); if (d != nil && runeeq(namer, nname, f->name, f->nname)) { if (f->dev != d->dev || f->qidpath != d->qid.path || f->mtime != d->mtime) checksha1(name, f, d); if (f->dev != d->dev || f->qidpath != d->qid.path || f->mtime != d->mtime) { if (f->unread) warning(nil, "%s not written; file already exists\n", name); else warning( nil, "%s modified%s%s since last read\n\twas %t; now %t\n", name, d->muid[0] ? " by " : "", d->muid, f->mtime, d->mtime); f->dev = d->dev; f->qidpath = d->qid.path; f->mtime = d->mtime; goto Rescue1; } } fd = create(name, OWRITE, 0666); if (fd < 0) { warning(nil, "can't create file %s: %r\n", name); goto Rescue1; } // Use bio in order to force the writes to be large and // block-aligned (bio's default is 8K). This is not strictly // necessary; it works around some buggy underlying // file systems that mishandle unaligned writes. // https://codereview.appspot.com/89550043/ b = emalloc(sizeof *b); Binit(b, fd, OWRITE); r = fbufalloc(); s = fbufalloc(); free(d); d = dirfstat(fd); h = sha1(nil, 0, nil, nil); isapp = (d != nil && d->length > 0 && (d->qid.type & QTAPPEND)); if (isapp) { warning(nil, "%s not written; file is append only\n", name); goto Rescue2; } for (q = q0; q < q1; q += n) { n = q1 - q; if (n > BUFSIZE / UTFmax) n = BUFSIZE / UTFmax; bufread(&f->b, q, r, n); m = snprint(s, BUFSIZE + 1, "%.*S", n, r); sha1((uchar*)s, m, nil, h); if (Bwrite(b, s, m) != m) { warning(nil, "can't write file %s: %r\n", name); goto Rescue2; } } if (Bflush(b) < 0) { warning(nil, "can't write file %s: %r\n", name); goto Rescue2; } Bterm(b); free(b); b = nil; if (runeeq(namer, nname, f->name, f->nname)) { if (q0 != 0 || q1 != f->b.nc) { f->mod = TRUE; w->dirty = TRUE; f->unread = TRUE; } else { // In case the file is on NFS, reopen the fd // before dirfstat to cause the attribute cache // to be updated (otherwise the mtime in the // dirfstat below will be stale and not match // what NFS sees). The file is already written, // so this should be a no-op when not on NFS. // Opening for OWRITE (but no truncation) // in case we don't have read permission. // (The create above worked, so we probably // still have write permission.) close(fd); fd = open(name, OWRITE); d1 = dirfstat(fd); if (d1 != nil) { free(d); d = d1; } f->qidpath = d->qid.path; f->dev = d->dev; f->mtime = d->mtime; sha1(nil, 0, f->sha1, h); h = nil; f->mod = FALSE; w->dirty = FALSE; f->unread = FALSE; } for (i = 0; i < f->ntext; i++) { f->text[i]->w->putseq = f->seq; f->text[i]->w->dirty = w->dirty; } } fbuffree(s); fbuffree(r); free(h); free(d); free(namer); free(name); close(fd); winsettag(w); return; Rescue2: if (b != nil) { Bterm(b); free(b); } free(h); fbuffree(s); fbuffree(r); close(fd); /* fall through */ Rescue1: free(d); free(namer); free(name); } static void trimspaces(Text* et) { File* f; Rune* r; Text* t; uint q0, n, delstart; int c, i, marked; t = &et->w->body; f = t->file; marked = 0; if (t->w != nil && et->w != t->w) { /* can this happen when t == &et->w->body? */ c = 'M'; if (et->w) c = et->w->owner; winlock(t->w, c); } r = fbufalloc(); q0 = f->b.nc; delstart = q0; /* end of current space run, or 0 if no active run; = q0 to delete spaces before EOF */ while (q0 > 0) { n = RBUFSIZE; if (n > q0) n = q0; q0 -= n; bufread(&f->b, q0, r, n); for (i = n;; i--) { if (i == 0 || (r[i - 1] != ' ' && r[i - 1] != '\t')) { // Found non-space or start of buffer. Delete active space run. if (q0 + i < delstart) { if (!marked) { marked = 1; seq++; filemark(f); } textdelete(t, q0 + i, delstart, TRUE); } if (i == 0) { /* keep run active into tail of next buffer */ if (delstart > 0) delstart = q0; break; } delstart = 0; if (r[i - 1] == '\n') delstart = q0 + i - 1; /* delete spaces before this newline */ } } } fbuffree(r); if (t->w != nil && et->w != t->w) winunlock(t->w); } void put(Text* et, Text* _0, Text* argt, int _1, int _2, Rune* arg, int narg) { int nname; Rune* namer; Window* w; File* f; char* name; USED(_0); USED(_1); USED(_2); if (et == nil || et->w == nil || et->w->isdir) return; w = et->w; f = w->body.file; name = getname(&w->body, argt, arg, narg, TRUE); if (name == nil) { warning(nil, "no file name\n"); return; } if (w->indent[NINDENT]) trimspaces(et); namer = bytetorune(name, &nname); putfile(f, 0, f->b.nc, namer, nname); xfidlog(w, "put"); free(name); } void dump( Text* _0, Text* _1, Text* argt, int isdump, int _2, Rune* arg, int narg) { char* name; USED(_0); USED(_1); USED(_2); if (narg) name = runetobyte(arg, narg); else getbytearg(argt, FALSE, TRUE, &name); if (isdump) rowdump(&row, name); else rowload(&row, name, FALSE); free(name); } void cut( Text* et, Text* t, Text* _0, int dosnarf, int docut, Rune* _2, int _3) { uint q0, q1, n, locked, c; Rune* r; USED(_0); USED(_2); USED(_3); /* * if not executing a mouse chord (et != t) and snarfing (dosnarf) * and executed Cut or Snarf in window tag (et->w != nil), * then use the window body selection or the tag selection * or do nothing at all. */ if (et != t && dosnarf && et->w != nil) { if (et->w->body.q1 > et->w->body.q0) { t = &et->w->body; if (docut) filemark(t->file); /* seq has been incremented by execute */ } else if (et->w->tag.q1 > et->w->tag.q0) t = &et->w->tag; else t = nil; } if (t == nil) /* no selection */ return; locked = FALSE; if (t->w != nil && et->w != t->w) { locked = TRUE; c = 'M'; if (et->w) c = et->w->owner; winlock(t->w, c); } if (t->q0 == t->q1) { if (locked) winunlock(t->w); return; } if (dosnarf) { q0 = t->q0; q1 = t->q1; bufdelete(&snarfbuf, 0, snarfbuf.nc); r = fbufalloc(); while (q0 < q1) { n = q1 - q0; if (n > RBUFSIZE) n = RBUFSIZE; bufread(&t->file->b, q0, r, n); bufinsert(&snarfbuf, snarfbuf.nc, r, n); q0 += n; } fbuffree(r); acmeputsnarf(); } if (docut) { textdelete(t, t->q0, t->q1, TRUE); textsetselect(t, t->q0, t->q0); if (t->w) { textscrdraw(t); winsettag(t->w); } } else if (dosnarf) /* Snarf command */ argtext = t; if (locked) winunlock(t->w); } void paste( Text* et, Text* t, Text* _0, int selectall, int tobody, Rune* _1, int _2) { int c; uint q, q0, q1, n; Rune* r; USED(_0); USED(_1); USED(_2); /* if(tobody), use body of executing window (Paste or Send command) */ if (tobody && et != nil && et->w != nil) { t = &et->w->body; filemark(t->file); /* seq has been incremented by execute */ } if (t == nil) return; acmegetsnarf(); if (t == nil || snarfbuf.nc == 0) return; if (t->w != nil && et->w != t->w) { c = 'M'; if (et->w) c = et->w->owner; winlock(t->w, c); } cut(t, t, nil, FALSE, TRUE, nil, 0); q = 0; q0 = t->q0; q1 = t->q0 + snarfbuf.nc; r = fbufalloc(); while (q0 < q1) { n = q1 - q0; if (n > RBUFSIZE) n = RBUFSIZE; if (r == nil) r = runemalloc(n); bufread(&snarfbuf, q, r, n); textinsert(t, q0, r, n, TRUE); q += n; q0 += n; } fbuffree(r); if (selectall) textsetselect(t, t->q0, q1); else textsetselect(t, q1, q1); if (t->w) { textscrdraw(t); winsettag(t->w); } if (t->w != nil && et->w != t->w) winunlock(t->w); } void look(Text* et, Text* t, Text* argt, int _0, int _1, Rune* arg, int narg) { Rune* r; int n; USED(_0); USED(_1); if (et && et->w) { t = &et->w->body; if (narg > 0) { search(t, arg, narg); return; } getarg(argt, FALSE, FALSE, &r, &n); if (r == nil) { n = t->q1 - t->q0; r = runemalloc(n); bufread(&t->file->b, t->q0, r, n); } search(t, r, n); free(r); } } static Rune Lnl[] = {'\n', 0}; void sendx(Text* et, Text* t, Text* _0, int _1, int _2, Rune* _3, int _4) { USED(_0); USED(_1); USED(_2); USED(_3); USED(_4); if (et->w == nil) return; t = &et->w->body; if (t->q0 != t->q1) cut(t, t, nil, TRUE, FALSE, nil, 0); textsetselect(t, t->file->b.nc, t->file->b.nc); paste(t, t, nil, TRUE, TRUE, nil, 0); if (textreadc(t, t->file->b.nc - 1) != '\n') { textinsert(t, t->file->b.nc, Lnl, 1, TRUE); textsetselect(t, t->file->b.nc, t->file->b.nc); } t->iq1 = t->q1; textshow(t, t->q1, t->q1, 1); } void edit(Text* et, Text* _0, Text* argt, int _1, int _2, Rune* arg, int narg) { Rune* r; int len; USED(_0); USED(_1); USED(_2); if (et == nil) return; getarg(argt, FALSE, TRUE, &r, &len); seq++; if (r != nil) { editcmd(et, r, len); free(r); } else editcmd(et, arg, narg); } void xexit(Text* et, Text* _0, Text* _1, int _2, int _3, Rune* _4, int _5) { USED(et); USED(_0); USED(_1); USED(_2); USED(_3); USED(_4); USED(_5); if (rowclean(&row)) { sendul(cexit, 0); threadexits(nil); } } void putall(Text* et, Text* _0, Text* _1, int _2, int _3, Rune* _4, int _5) { int i, j, e; Window* w; Column* c; char* a; USED(et); USED(_0); USED(_1); USED(_2); USED(_3); USED(_4); USED(_5); for (i = 0; i < row.ncol; i++) { c = row.col[i]; for (j = 0; j < c->nw; j++) { w = c->w[j]; if (w->isscratch || w->isdir || w->body.file->nname == 0) continue; if (w->nopen[QWevent] > 0) continue; a = runetobyte(w->body.file->name, w->body.file->nname); e = access(a, 0); if (w->body.file->mod || w->body.ncache) if (e < 0) warning(nil, "no auto-Put of %s: %r\n", a); else { wincommit(w, &w->body); put(&w->body, nil, nil, XXX, XXX, nil, 0); } free(a); } } } void id(Text* et, Text* _0, Text* _1, int _2, int _3, Rune* _4, int _5) { USED(_0); USED(_1); USED(_2); USED(_3); USED(_4); USED(_5); if (et && et->w) warning(nil, "/mnt/acme/%d/\n", et->w->id); } void local( Text* et, Text* _0, Text* argt, int _1, int _2, Rune* arg, int narg) { char *a, *aa; Runestr dir; USED(_0); USED(_1); USED(_2); aa = getbytearg(argt, TRUE, TRUE, &a); dir = dirname(et, nil, 0); if (dir.nr == 1 && dir.r[0] == '.') { /* sigh */ free(dir.r); dir.r = nil; dir.nr = 0; } run(nil, runetobyte(arg, narg), dir.r, dir.nr, FALSE, aa, a, FALSE); } void xkill( Text* _0, Text* _1, Text* argt, int _2, int _3, Rune* arg, int narg) { Rune *a, *cmd, *r; int na; USED(_0); USED(_1); USED(_2); USED(_3); getarg(argt, FALSE, FALSE, &r, &na); if (r) xkill(nil, nil, nil, 0, 0, r, na); /* loop condition: *arg is not a blank */ for (;;) { a = findbl(arg, narg, &na); if (a == arg) break; cmd = runemalloc(narg - na + 1); runemove(cmd, arg, narg - na); sendp(ckill, cmd); arg = skipbl(a, na, &narg); } } static Rune Lfix[] = {'f', 'i', 'x', 0}; static Rune Lvar[] = {'v', 'a', 'r', 0}; void fontx(Text* et, Text* t, Text* argt, int _0, int _1, Rune* arg, int narg) { Rune *a, *r, *flag, *file; int na, nf; char* aa; Reffont* newfont; Dirlist* dp; int i, fix; USED(_0); USED(_1); if (et == nil || et->w == nil) return; t = &et->w->body; flag = nil; file = nil; /* loop condition: *arg is not a blank */ nf = 0; for (;;) { a = findbl(arg, narg, &na); if (a == arg) break; r = runemalloc(narg - na + 1); runemove(r, arg, narg - na); if (runeeq(r, narg - na, Lfix, 3) || runeeq(r, narg - na, Lvar, 3)) { free(flag); flag = r; } else { free(file); file = r; nf = narg - na; } arg = skipbl(a, na, &narg); } getarg(argt, FALSE, TRUE, &r, &na); if (r) if (runeeq(r, na, Lfix, 3) || runeeq(r, na, Lvar, 3)) { free(flag); flag = r; } else { free(file); file = r; nf = na; } fix = 1; if (flag) fix = runeeq(flag, runestrlen(flag), Lfix, 3); else if (file == nil) { newfont = rfget(FALSE, FALSE, FALSE, nil); if (newfont) fix = strcmp(newfont->f->name, t->fr.font->name) == 0; } if (file) { aa = runetobyte(file, nf); newfont = rfget(fix, flag != nil, FALSE, aa); free(aa); } else newfont = rfget(fix, FALSE, FALSE, nil); if (newfont) { draw(screen, t->w->r, textcols[BACK], nil, ZP); rfclose(t->reffont); t->reffont = newfont; t->fr.font = newfont->f; frinittick(&t->fr); if (t->w->isdir) { t->all.min.x++; /* force recolumnation; disgusting! */ for (i = 0; i < t->w->ndl; i++) { dp = t->w->dlp[i]; aa = runetobyte(dp->r, dp->nr); dp->wid = stringwidth(newfont->f, aa); free(aa); } } /* avoid shrinking of window due to quantization */ colgrow(t->w->col, t->w, -1); } free(file); free(flag); } void incl(Text* et, Text* _0, Text* argt, int _1, int _2, Rune* arg, int narg) { Rune *a, *r; Window* w; int na, n, len; USED(_0); USED(_1); USED(_2); if (et == nil || et->w == nil) return; w = et->w; n = 0; getarg(argt, FALSE, TRUE, &r, &len); if (r) { n++; winaddincl(w, r, len); } /* loop condition: *arg is not a blank */ for (;;) { a = findbl(arg, narg, &na); if (a == arg) break; r = runemalloc(narg - na + 1); runemove(r, arg, narg - na); n++; winaddincl(w, r, narg - na); arg = skipbl(a, na, &narg); } if (n == 0 && w->nincl) { for (n = w->nincl; --n >= 0;) warning(nil, "%S ", w->incl[n]); warning(nil, "\n"); } } static Rune LON[] = {'O', 'N', 0}; static Rune LOFF[] = {'O', 'F', 'F', 0}; static Rune Lon[] = {'o', 'n', 0}; static Rune Loff[] = {'o', 'f', 'f', 0}; enum { IGlobal = -2, IError = -1, }; static int indentval(Rune* s, int n, int type) { static char* strs[] = { [SPACESINDENT] = "Spaces", [AUTOINDENT] = "Indent", }; if (n < 2) return IError; if (runestrncmp(s, LON, n) == 0) { globalindent[type] = TRUE; warning(nil, "%s ON\n", strs[type]); return IGlobal; } if (runestrncmp(s, LOFF, n) == 0) { globalindent[type] = FALSE; warning(nil, "%s OFF\n", strs[type]); return IGlobal; } if (runestrncmp(s, Lon, n) == 0) return TRUE; if (runestrncmp(s, Loff, n) == 0) return FALSE; return IError; } static void fixindent(Window* w, void* arg) { int t; t = (int)arg; w->indent[t] = globalindent[t]; } void indent( Text* et, Text* _0, Text* argt, int type, int _1, Rune* arg, int narg) { Rune *a, *r; Window* w; int na, len, ival; USED(_0); USED(_1); w = nil; if (et != nil && et->w != nil) w = et->w; ival = IError; getarg(argt, FALSE, TRUE, &r, &len); if (r != nil && len > 0) ival = indentval(r, len, type); else { a = findbl(arg, narg, &na); if (a != arg) ival = indentval(arg, narg - na, type); } if (ival == IGlobal) allwindows(fixindent, (void*)type); else if (w != nil && ival >= 0) w->indent[type] = ival; } void tab(Text* et, Text* _0, Text* argt, int _1, int _2, Rune* arg, int narg) { Rune *a, *r; Window* w; int na, len, tab; char* p; USED(_0); USED(_1); USED(_2); if (et == nil || et->w == nil) return; w = et->w; getarg(argt, FALSE, TRUE, &r, &len); tab = 0; if (r != nil && len > 0) { p = runetobyte(r, len); if ('0' <= p[0] && p[0] <= '9') tab = atoi(p); free(p); } else { a = findbl(arg, narg, &na); if (a != arg) { p = runetobyte(arg, narg - na); if ('0' <= p[0] && p[0] <= '9') tab = atoi(p); free(p); } } if (tab > 0) { if (w->body.tabstop != tab) { w->body.tabstop = tab; winresize(w, w->r, FALSE, TRUE); } } else warning( nil, "%.*S: Tab %d\n", w->body.file->nname, w->body.file->name, w->body.tabstop); } void runproc(void* argvp) { /* args: */ Window* win; char* s; Rune* rdir; int ndir; int newns; char* argaddr; char* arg; Command* c; Channel* cpid; int iseditcmd; /* end of args */ char *e, *t, *name, *filename, *dir, **av, *news; Rune r, **incl; int ac, w, inarg, i, n, fd, nincl, winid; int sfd[3]; int pipechar; char buf[512]; int ret; /*static void *parg[2]; */ char* rcarg[4]; void** argv; CFsys* fs; char* shell; threadsetname("runproc"); argv = argvp; win = argv[0]; s = argv[1]; rdir = argv[2]; ndir = (uintptr)argv[3]; newns = (uintptr)argv[4]; argaddr = argv[5]; arg = argv[6]; c = argv[7]; cpid = argv[8]; iseditcmd = (uintptr)argv[9]; free(argv); t = s; while (*t == ' ' || *t == '\n' || *t == '\t') t++; for (e = t; *e; e++) if (*e == ' ' || *e == '\n' || *e == '\t') break; name = emalloc((e - t) + 2); memmove(name, t, e - t); name[e - t] = 0; e = utfrrune(name, '/'); if (e) memmove(name, e + 1, strlen(e + 1) + 1); /* strcpy but overlaps */ strcat(name, " "); /* add blank here for ease in waittask */ c->name = bytetorune(name, &c->nname); free(name); pipechar = 0; if (*t == '<' || *t == '|' || *t == '>') pipechar = *t++; c->iseditcmd = iseditcmd; c->text = s; if (newns) { nincl = 0; incl = nil; if (win) { filename = smprint("%.*S", win->body.file->nname, win->body.file->name); nincl = win->nincl; if (nincl > 0) { incl = emalloc(nincl * sizeof(Rune*)); for (i = 0; i < nincl; i++) { n = runestrlen(win->incl[i]); incl[i] = runemalloc(n + 1); runemove(incl[i], win->incl[i], n); } } winid = win->id; } else { filename = nil; winid = 0; if (activewin) winid = activewin->id; } rfork(RFNAMEG | RFENVG | RFFDG | RFNOTEG); sprint(buf, "%d", winid); putenv("winid", buf); if (filename) { putenv("%", filename); putenv("samfile", filename); free(filename); } c->md = fsysmount(rdir, ndir, incl, nincl); if (c->md == nil) { fprint(2, "child: can't allocate mntdir: %r\n"); threadexits("fsysmount"); } sprint(buf, "%d", c->md->id); if ((fs = nsmount("acme", buf)) == nil) { fprint(2, "child: can't mount acme: %r\n"); fsysdelid(c->md); c->md = nil; threadexits("nsmount"); } if (winid > 0 && (pipechar == '|' || pipechar == '>')) { sprint(buf, "%d/rdsel", winid); sfd[0] = fsopenfd(fs, buf, OREAD); } else sfd[0] = open("/dev/null", OREAD); if ((winid > 0 || iseditcmd) && (pipechar == '|' || pipechar == '<')) { if (iseditcmd) { if (winid > 0) sprint(buf, "%d/editout", winid); else sprint(buf, "editout"); } else sprint(buf, "%d/wrsel", winid); sfd[1] = fsopenfd(fs, buf, OWRITE); sfd[2] = fsopenfd(fs, "cons", OWRITE); } else { sfd[1] = fsopenfd(fs, "cons", OWRITE); sfd[2] = sfd[1]; } fsunmount(fs); } else { rfork(RFFDG | RFNOTEG); fsysclose(); sfd[0] = open("/dev/null", OREAD); sfd[1] = open("/dev/null", OWRITE); sfd[2] = dup(erroutfd, -1); } if (win) winclose(win); if (argaddr) putenv("acmeaddr", argaddr); if (acmeshell != nil) goto Hard; if (strlen(t) > sizeof buf - 10) /* may need to print into stack */ goto Hard; inarg = FALSE; for (e = t; *e; e += w) { w = chartorune(&r, e); if (r == ' ' || r == '\t') continue; if (r < ' ') goto Hard; if (utfrune("#;&|^$=`'{}()<>[]*?^~`/", r)) goto Hard; inarg = TRUE; } if (!inarg) goto Fail; ac = 0; av = nil; inarg = FALSE; for (e = t; *e; e += w) { w = chartorune(&r, e); if (r == ' ' || r == '\t') { inarg = FALSE; *e = 0; continue; } if (!inarg) { inarg = TRUE; av = realloc(av, (ac + 1) * sizeof(char**)); av[ac++] = e; } } av = realloc(av, (ac + 2) * sizeof(char**)); av[ac++] = arg; av[ac] = nil; c->av = av; dir = nil; if (rdir != nil) dir = runetobyte(rdir, ndir); ret = threadspawnd(sfd, av[0], av, dir); free(dir); if (ret >= 0) { if (cpid) sendul(cpid, ret); threadexits(""); } /* libthread uses execvp so no need to do this */ #if 0 e = av[0]; if(e[0]=='/' || (e[0]=='.' && e[1]=='/')) goto Fail; if(cputype){ sprint(buf, "%s/%s", cputype, av[0]); procexec(cpid, sfd, buf, av); } sprint(buf, "/bin/%s", av[0]); procexec(cpid, sfd, buf, av); #endif goto Fail; Hard: /* * ugly: set path = (. $cputype /bin) * should honor $path if unusual. */ if (cputype) { n = 0; memmove(buf + n, ".", 2); n += 2; i = strlen(cputype) + 1; memmove(buf + n, cputype, i); n += i; memmove(buf + n, "/bin", 5); n += 5; fd = create("/env/path", OWRITE, 0666); write(fd, buf, n); close(fd); } if (arg) { news = emalloc(strlen(t) + 1 + 1 + strlen(arg) + 1 + 1); if (news) { sprint(news, "%s '%s'", t, arg); /* BUG: what if quote in arg? */ free(s); t = news; c->text = news; } } dir = nil; if (rdir != nil) dir = runetobyte(rdir, ndir); shell = acmeshell; if (shell == nil) shell = "rc"; rcarg[0] = shell; rcarg[1] = "-c"; rcarg[2] = t; rcarg[3] = nil; ret = threadspawnd(sfd, rcarg[0], rcarg, dir); free(dir); if (ret >= 0) { if (cpid) sendul(cpid, ret); threadexits(nil); } warning(nil, "exec %s: %r\n", shell); Fail: /* threadexec hasn't happened, so send a zero */ close(sfd[0]); close(sfd[1]); if (sfd[2] != sfd[1]) close(sfd[2]); sendul(cpid, 0); threadexits(nil); } void runwaittask(void* v) { Command* c; Channel* cpid; void** a; threadsetname("runwaittask"); a = v; c = a[0]; cpid = a[1]; free(a); do c->pid = recvul(cpid); while (c->pid == ~0); free(c->av); if (c->pid != 0) /* successful exec */ sendp(ccommand, c); else { if (c->iseditcmd) sendul(cedit, 0); free(c->name); free(c->text); free(c); } chanfree(cpid); } void run( Window* win, char* s, Rune* rdir, int ndir, int newns, char* argaddr, char* xarg, int iseditcmd) { void** arg; Command* c; Channel* cpid; if (s == nil) return; arg = emalloc(10 * sizeof(void*)); c = emalloc(sizeof *c); cpid = chancreate(sizeof(ulong), 0); chansetname(cpid, "cpid %s", s); arg[0] = win; arg[1] = s; arg[2] = rdir; arg[3] = (void*)(uintptr)ndir; arg[4] = (void*)(uintptr)newns; arg[5] = argaddr; arg[6] = xarg; arg[7] = c; arg[8] = cpid; arg[9] = (void*)(uintptr)iseditcmd; threadcreate(runproc, arg, STACK); /* mustn't block here because must be ready to answer mount() call in run() */ arg = emalloc(2 * sizeof(void*)); arg[0] = c; arg[1] = cpid; threadcreate(runwaittask, arg, STACK); }