321 lines
5 KiB
C
321 lines
5 KiB
C
|
#include "acd.h"
|
||
|
|
||
|
Window*
|
||
|
newwindow(void)
|
||
|
{
|
||
|
char buf[12];
|
||
|
Window *w;
|
||
|
|
||
|
w = emalloc(sizeof(Window));
|
||
|
w->ctl = open("/mnt/wsys/new/ctl", ORDWR|OCEXEC);
|
||
|
if(w->ctl<0 || read(w->ctl, buf, 12)!=12)
|
||
|
error("can't open window ctl file: %r");
|
||
|
ctlprint(w->ctl, "noscroll\n");
|
||
|
w->id = atoi(buf);
|
||
|
w->event = winopenfile(w, "event");
|
||
|
w->addr = -1; /* will be opened when needed */
|
||
|
w->body = nil;
|
||
|
w->data = -1;
|
||
|
w->cevent = chancreate(sizeof(Event*), 0);
|
||
|
if(w->cevent == nil)
|
||
|
error("cevent is nil: %r");
|
||
|
return w;
|
||
|
}
|
||
|
|
||
|
void
|
||
|
winsetdump(Window *w, char *dir, char *cmd)
|
||
|
{
|
||
|
if(dir != nil)
|
||
|
ctlprint(w->ctl, "dumpdir %s\n", dir);
|
||
|
if(cmd != nil)
|
||
|
ctlprint(w->ctl, "dump %s\n", cmd);
|
||
|
}
|
||
|
|
||
|
void
|
||
|
wineventproc(void *v)
|
||
|
{
|
||
|
Window *w;
|
||
|
int i;
|
||
|
|
||
|
threadsetname("wineventproc");
|
||
|
w = v;
|
||
|
for(i=0; ; i++){
|
||
|
if(i >= NEVENT)
|
||
|
i = 0;
|
||
|
wingetevent(w, &w->e[i]);
|
||
|
sendp(w->cevent, &w->e[i]);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
int
|
||
|
winopenfile(Window *w, char *f)
|
||
|
{
|
||
|
char buf[64];
|
||
|
int fd;
|
||
|
|
||
|
sprint(buf, "/mnt/wsys/%d/%s", w->id, f);
|
||
|
fd = open(buf, ORDWR|OCEXEC);
|
||
|
if(fd < 0)
|
||
|
error("can't open window file %s: %r", f);
|
||
|
return fd;
|
||
|
}
|
||
|
|
||
|
void
|
||
|
wintagwrite(Window *w, char *s, int n)
|
||
|
{
|
||
|
int fd;
|
||
|
|
||
|
fd = winopenfile(w, "tag");
|
||
|
if(write(fd, s, n) != n)
|
||
|
error("tag write: %r");
|
||
|
close(fd);
|
||
|
}
|
||
|
|
||
|
void
|
||
|
winname(Window *w, char *s)
|
||
|
{
|
||
|
ctlprint(w->ctl, "name %s\n", s);
|
||
|
}
|
||
|
|
||
|
void
|
||
|
winopenbody(Window *w, int mode)
|
||
|
{
|
||
|
char buf[256];
|
||
|
|
||
|
sprint(buf, "/mnt/wsys/%d/body", w->id);
|
||
|
w->body = Bopen(buf, mode|OCEXEC);
|
||
|
if(w->body == nil)
|
||
|
error("can't open window body file: %r");
|
||
|
}
|
||
|
|
||
|
void
|
||
|
winclosebody(Window *w)
|
||
|
{
|
||
|
if(w->body != nil){
|
||
|
Bterm(w->body);
|
||
|
w->body = nil;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
void
|
||
|
winwritebody(Window *w, char *s, int n)
|
||
|
{
|
||
|
if(w->body == nil)
|
||
|
winopenbody(w, OWRITE);
|
||
|
if(Bwrite(w->body, s, n) != n)
|
||
|
error("write error to window: %r");
|
||
|
}
|
||
|
|
||
|
int
|
||
|
wingetec(Window *w)
|
||
|
{
|
||
|
if(w->nbuf == 0){
|
||
|
w->nbuf = read(w->event, w->buf, sizeof w->buf);
|
||
|
if(w->nbuf <= 0){
|
||
|
/* probably because window has exited, and only called by wineventproc, so just shut down */
|
||
|
threadexits(nil);
|
||
|
}
|
||
|
w->bufp = w->buf;
|
||
|
}
|
||
|
w->nbuf--;
|
||
|
return *w->bufp++;
|
||
|
}
|
||
|
|
||
|
int
|
||
|
wingeten(Window *w)
|
||
|
{
|
||
|
int n, c;
|
||
|
|
||
|
n = 0;
|
||
|
while('0'<=(c=wingetec(w)) && c<='9')
|
||
|
n = n*10+(c-'0');
|
||
|
if(c != ' ')
|
||
|
error("event number syntax");
|
||
|
return n;
|
||
|
}
|
||
|
|
||
|
int
|
||
|
wingeter(Window *w, char *buf, int *nb)
|
||
|
{
|
||
|
Rune r;
|
||
|
int n;
|
||
|
|
||
|
r = wingetec(w);
|
||
|
buf[0] = r;
|
||
|
n = 1;
|
||
|
if(r >= Runeself) {
|
||
|
while(!fullrune(buf, n))
|
||
|
buf[n++] = wingetec(w);
|
||
|
chartorune(&r, buf);
|
||
|
}
|
||
|
*nb = n;
|
||
|
return r;
|
||
|
}
|
||
|
|
||
|
void
|
||
|
wingetevent(Window *w, Event *e)
|
||
|
{
|
||
|
int i, nb;
|
||
|
|
||
|
e->c1 = wingetec(w);
|
||
|
e->c2 = wingetec(w);
|
||
|
e->q0 = wingeten(w);
|
||
|
e->q1 = wingeten(w);
|
||
|
e->flag = wingeten(w);
|
||
|
e->nr = wingeten(w);
|
||
|
if(e->nr > EVENTSIZE)
|
||
|
error("event string too long");
|
||
|
e->nb = 0;
|
||
|
for(i=0; i<e->nr; i++){
|
||
|
e->r[i] = wingeter(w, e->b+e->nb, &nb);
|
||
|
e->nb += nb;
|
||
|
}
|
||
|
e->r[e->nr] = 0;
|
||
|
e->b[e->nb] = 0;
|
||
|
if(wingetec(w) != '\n')
|
||
|
error("event syntax error");
|
||
|
}
|
||
|
|
||
|
void
|
||
|
winwriteevent(Window *w, Event *e)
|
||
|
{
|
||
|
fprint(w->event, "%c%c%d %d\n", e->c1, e->c2, e->q0, e->q1);
|
||
|
}
|
||
|
|
||
|
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
|
||
|
winread(Window *w, uint q0, uint q1, char *data)
|
||
|
{
|
||
|
int m, n, nr;
|
||
|
char buf[256];
|
||
|
|
||
|
if(w->addr < 0)
|
||
|
w->addr = winopenfile(w, "addr");
|
||
|
if(w->data < 0)
|
||
|
w->data = winopenfile(w, "data");
|
||
|
m = q0;
|
||
|
while(m < q1){
|
||
|
n = sprint(buf, "#%d", m);
|
||
|
if(write(w->addr, buf, n) != n)
|
||
|
error("error writing addr: %r");
|
||
|
n = read(w->data, buf, sizeof buf);
|
||
|
if(n <= 0)
|
||
|
error("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
|
||
|
windormant(Window *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
|
||
|
windel(Window *w, int sure)
|
||
|
{
|
||
|
if(sure)
|
||
|
write(w->ctl, "delete\n", 7);
|
||
|
else if(write(w->ctl, "del\n", 4) != 4)
|
||
|
return 0;
|
||
|
/* event proc will die due to read error from event file */
|
||
|
windormant(w);
|
||
|
close(w->ctl);
|
||
|
w->ctl = -1;
|
||
|
close(w->event);
|
||
|
w->event = -1;
|
||
|
return 1;
|
||
|
}
|
||
|
|
||
|
void
|
||
|
winclean(Window *w)
|
||
|
{
|
||
|
if(w->body)
|
||
|
Bflush(w->body);
|
||
|
ctlprint(w->ctl, "clean\n");
|
||
|
}
|
||
|
|
||
|
int
|
||
|
winsetaddr(Window *w, char *addr, int errok)
|
||
|
{
|
||
|
if(w->addr < 0)
|
||
|
w->addr = winopenfile(w, "addr");
|
||
|
if(write(w->addr, addr, strlen(addr)) < 0){
|
||
|
if(!errok)
|
||
|
error("error writing addr(%s): %r", addr);
|
||
|
return 0;
|
||
|
}
|
||
|
return 1;
|
||
|
}
|
||
|
|
||
|
int
|
||
|
winselect(Window *w, char *addr, int errok)
|
||
|
{
|
||
|
if(winsetaddr(w, addr, errok)){
|
||
|
ctlprint(w->ctl, "dot=addr\n");
|
||
|
return 1;
|
||
|
}
|
||
|
return 0;
|
||
|
}
|
||
|
|
||
|
char*
|
||
|
winreadbody(Window *w, int *np) /* can't use readfile because acme doesn't report the length */
|
||
|
{
|
||
|
char *s;
|
||
|
int m, na, n;
|
||
|
|
||
|
if(w->body != nil)
|
||
|
winclosebody(w);
|
||
|
winopenbody(w, OREAD);
|
||
|
s = nil;
|
||
|
na = 0;
|
||
|
n = 0;
|
||
|
for(;;){
|
||
|
if(na < n+512){
|
||
|
na += 1024;
|
||
|
s = realloc(s, na+1);
|
||
|
}
|
||
|
m = Bread(w->body, s+n, na-n);
|
||
|
if(m <= 0)
|
||
|
break;
|
||
|
n += m;
|
||
|
}
|
||
|
s[n] = 0;
|
||
|
winclosebody(w);
|
||
|
*np = n;
|
||
|
return s;
|
||
|
}
|