diff options
Diffstat (limited to 'acme/bin/source/adict/win.c')
| -rw-r--r-- | acme/bin/source/adict/win.c | 315 |
1 files changed, 315 insertions, 0 deletions
diff --git a/acme/bin/source/adict/win.c b/acme/bin/source/adict/win.c new file mode 100644 index 000000000..e8b2ee257 --- /dev/null +++ b/acme/bin/source/adict/win.c @@ -0,0 +1,315 @@ +#include <u.h> +#include <libc.h> +#include <bio.h> +#include <thread.h> +#include "win.h" + +void* +erealloc(void *p, uint n) +{ + p = realloc(p, n); + if(p == nil) + fprint(2, "realloc failed: %r"); + return p; +} + +void +wnew(Win *w) +{ + char buf[12]; + + w->ctl = open("/mnt/acme/new/ctl", ORDWR); + if(w->ctl<0 || read(w->ctl, buf, 12)!=12) + fprint (2, "can't open window ctl file: %r"); + ctlwrite(w, "noscroll\n"); + w->winid = atoi(buf); + w->event = openfile(w, "event"); + w->addr = -1; /* will be opened when needed */ + w->body = nil; + w->data = -1; +} + +int +openfile(Win *w, char *f) +{ + char buf[64]; + int fd; + + sprint(buf, "/mnt/acme/%d/%s", w->winid, f); + fd = open(buf, ORDWR|OCEXEC); + if(fd < 0) + fprint (2,"can't open window %s file: %r", f); + return fd; +} + +void +openbody(Win *w, int mode) +{ + char buf[64]; + + sprint(buf, "/mnt/acme/%d/body", w->winid); + w->body = Bopen(buf, mode|OCEXEC); + if(w->body == nil) + fprint(2,"can't open window body file: %r"); +} + +void +wwritebody(Win *w, char *s, int n) +{ + if(w->body == nil) + openbody(w, OWRITE); + if(Bwrite(w->body, s, n) != n) + fprint(2,"write error to window: %r"); + Bflush(w->body); +} + +void +wreplace(Win *w, char *addr, char *repl, int nrepl) +{ + if(w->addr < 0) + w->addr = openfile(w, "addr"); + if(w->data < 0) + w->data = openfile(w, "data"); + if(write(w->addr, addr, strlen(addr)) < 0){ + fprint(2, "mail: warning: badd address %s:%r\n", addr); + return; + } + if(write(w->data, repl, nrepl) != nrepl) + fprint(2, "writing data: %r"); +} + +static int +nrunes(char *s, int nb) +{ + int i, n; + Rune r; + + n = 0; + for(i=0; i<nb; n++) + i += chartorune(&r, s+i); + return n; +} + +void +wread(Win *w, uint q0, uint q1, char *data) +{ + int m, n, nr; + char buf[256]; + + if(w->addr < 0) + w->addr = openfile(w, "addr"); + if(w->data < 0) + w->data = openfile(w, "data"); + m = q0; + while(m < q1){ + n = sprint(buf, "#%d", m); + if(write(w->addr, buf, n) != n) + fprint(2,"writing addr: %r"); + n = read(w->data, buf, sizeof buf); + if(n <= 0) + fprint(2,"reading data: %r"); + nr = nrunes(buf, n); + while(m+nr >q1){ + do; while(n>0 && (buf[--n]&0xC0)==0x80); + --nr; + } + if(n == 0) + break; + memmove(data, buf, n); + data += n; + *data = 0; + m += nr; + } +} + +void +wselect(Win *w, char *addr) +{ + if(w->addr < 0) + w->addr = openfile(w, "addr"); + if(write(w->addr, addr, strlen(addr)) < 0) + fprint(2,"writing addr"); + ctlwrite(w, "dot=addr\n"); +} + +void +wtagwrite(Win *w, char *s, int n) +{ + int fd; + + fd = openfile(w, "tag"); + if(write(fd, s, n) != n) + fprint(2,"tag write: %r"); + close(fd); +} + +void +ctlwrite(Win *w, char *s) +{ + int n; + + n = strlen(s); + if(write(w->ctl, s, n) != n) + fprint(2,"write error to ctl file: %r"); +} + +int +wdel(Win *w) +{ + if(write(w->ctl, "del\n", 4) != 4) + return False; + wdormant(w); + close(w->ctl); + w->ctl = -1; + close(w->event); + w->event = -1; + return True; +} + +void +wname(Win *w, char *s) +{ + char buf[128]; + + sprint(buf, "name %s\n", s); + ctlwrite(w, buf); +} + +void +wclean(Win *w) +{ + if(w->body) + Bflush(w->body); + ctlwrite(w, "clean\n"); +} + +void +wdormant(Win *w) +{ + if(w->addr >= 0){ + close(w->addr); + w->addr = -1; + } + if(w->body != nil){ + Bterm(w->body); + w->body = nil; + } + if(w->data >= 0){ + close(w->data); + w->data = -1; + } +} + +int +getec(Win *w) +{ + if(w->nbuf == 0){ + w->nbuf = read(w->event, w->buf, sizeof w->buf); + if(w->nbuf <= 0) + fprint(2,"event read error: %r"); + w->bufp = w->buf; + } + w->nbuf--; + return *w->bufp++; +} + +int +geten(Win *w) +{ + int n, c; + + n = 0; + while('0'<=(c=getec(w)) && c<='9') + n = n*10+(c-'0'); + if(c != ' ') + fprint(2, "event number syntax"); + return n; +} + +int +geter(Win *w, char *buf, int *nb) +{ + Rune r; + int n; + + r = getec(w); + buf[0] = r; + n = 1; + if(r < Runeself) + goto Return; + while(!fullrune(buf, n)) + buf[n++] = getec(w); + chartorune(&r, buf); + Return: + *nb = n; + return r; +} + + +void +wevent(Win *w, Event *e) +{ + int i, nb; + + e->c1 = getec(w); + e->c2 = getec(w); + e->q0 = geten(w); + e->q1 = geten(w); + e->flag = geten(w); + e->nr = geten(w); + if(e->nr > EVENTSIZE) + fprint(2, "wevent: event string too long"); + e->nb = 0; + for(i=0; i<e->nr; i++){ + e->r[i] = geter(w, e->b+e->nb, &nb); + e->nb += nb; + } + e->r[e->nr] = 0; + e->b[e->nb] = 0; + if(getec(w) != '\n') + fprint(2, "wevent: event syntax 2"); +} + +void +wslave(Win *w, Channel *ce) +{ + Event e; + + while(recv(ce, &e) >= 0) + wevent(w, &e); +} + +void +wwriteevent(Win *w, Event *e) +{ + fprint(w->event, "%c%c%d %d\n", e->c1, e->c2, e->q0, e->q1); +} + +int +wreadall(Win *w, char **sp) +{ + char *s; + int m, na, n; + + if(w->body != nil) + Bterm(w->body); + openbody(w, OREAD); + s = nil; + na = 0; + n = 0; + for(;;){ + if(na < n+512){ + na += 1024; + s = erealloc(s, na+1); + } + m = Bread(w->body, s+n, na-n); + if(m <= 0) + break; + n += m; + } + s[n] = 0; + Bterm(w->body); + w->body = nil; + *sp = s; + return n; +} |