1 #include <u.h>
2 #include <libc.h>
3 #include <bio.h>
4 #include <thread.h>
5 #include <plumb.h>
6 #include <9pclient.h>
7 #include "dat.h"
8 
9 Window*
10 newwindow(void)
11 {
12 	char buf[12];
13 	Window *w;
14 
15 	w = emalloc(sizeof(Window));
16 	w->ctl = fsopen(acmefs, "new/ctl", ORDWR|OCEXEC);
17 	if(w->ctl == nil || fsread(w->ctl, buf, 12)!=12)
18 		error("can't open window ctl file: %r");
19 
20 	w->id = atoi(buf);
21 	w->event = winopenfile(w, "event");
22 	w->addr = nil;	/* will be opened when needed */
23 	w->body = nil;
24 	w->data = nil;
25 	w->cevent = chancreate(sizeof(Event*), 0);
26 	w->ref = 1;
27 	return w;
28 }
29 
30 void
31 winincref(Window *w)
32 {
33 	qlock(&w->lk);
34 	++w->ref;
35 	qunlock(&w->lk);
36 }
37 
38 void
39 windecref(Window *w)
40 {
41 	qlock(&w->lk);
42 	if(--w->ref > 0){
43 		qunlock(&w->lk);
44 		return;
45 	}
46 	fsclose(w->event);
47 	chanfree(w->cevent);
48 	free(w);
49 }
50 
51 void
52 winsetdump(Window *w, char *dir, char *cmd)
53 {
54 	if(dir != nil)
55 		ctlprint(w->ctl, "dumpdir %s\n", dir);
56 	if(cmd != nil)
57 		ctlprint(w->ctl, "dump %s\n", cmd);
58 }
59 
60 void
61 wineventproc(void *v)
62 {
63 	Window *w;
64 	int i;
65 
66 	w = v;
67 	for(i=0; ; i++){
68 		if(i >= NEVENT)
69 			i = 0;
70 		wingetevent(w, &w->e[i]);
71 		sendp(w->cevent, &w->e[i]);
72 	}
73 }
74 
75 static CFid*
76 winopenfile1(Window *w, char *f, int m)
77 {
78 	char buf[64];
79 	CFid* fd;
80 
81 	sprint(buf, "%d/%s", w->id, f);
82 	fd = fsopen(acmefs, buf, m|OCEXEC);
83 	if(fd == nil)
84 		error("can't open window file %s: %r", f);
85 	return fd;
86 }
87 
88 CFid*
89 winopenfile(Window *w, char *f)
90 {
91 	return winopenfile1(w, f, ORDWR);
92 }
93 
94 void
95 wintagwrite(Window *w, char *s, int n)
96 {
97 	CFid* fid;
98 
99 	fid = winopenfile(w, "tag");
100 	if(fswrite(fid, s, n) != n)
101 		error("tag write: %r");
102 	fsclose(fid);
103 }
104 
105 void
106 winname(Window *w, char *s)
107 {
108 	ctlprint(w->ctl, "name %s\n", s);
109 }
110 
111 void
112 winopenbody(Window *w, int mode)
113 {
114 	char buf[256];
115 	CFid* fid;
116 
117 	sprint(buf, "%d/body", w->id);
118 	fid = fsopen(acmefs, buf, mode|OCEXEC);
119 	w->body = fid;
120 	if(w->body == nil)
121 		error("can't open window body file: %r");
122 }
123 
124 void
125 winclosebody(Window *w)
126 {
127 	if(w->body != nil){
128 		fsclose(w->body);
129 		w->body = nil;
130 	}
131 }
132 
133 void
134 winwritebody(Window *w, char *s, int n)
135 {
136 	if(w->body == nil)
137 		winopenbody(w, OWRITE);
138 	if(fswrite(w->body, s, n) != n)
139 		error("write error to window: %r");
140 }
141 
142 int
143 wingetec(Window *w)
144 {
145 	if(w->nbuf == 0){
146 		w->nbuf = fsread(w->event, w->buf, sizeof w->buf);
147 		if(w->nbuf <= 0){
148 			/* probably because window has exited, and only called by wineventproc, so just shut down */
149 			windecref(w);
150 			threadexits(nil);
151 		}
152 		w->bufp = w->buf;
153 	}
154 	w->nbuf--;
155 	return *w->bufp++;
156 }
157 
158 int
159 wingeten(Window *w)
160 {
161 	int n, c;
162 
163 	n = 0;
164 	while('0'<=(c=wingetec(w)) && c<='9')
165 		n = n*10+(c-'0');
166 	if(c != ' ')
167 		error("event number syntax");
168 	return n;
169 }
170 
171 int
172 wingeter(Window *w, char *buf, int *nb)
173 {
174 	Rune r;
175 	int n;
176 
177 	r = wingetec(w);
178 	buf[0] = r;
179 	n = 1;
180 	if(r >= Runeself) {
181 		while(!fullrune(buf, n))
182 			buf[n++] = wingetec(w);
183 		chartorune(&r, buf);
184 	} 
185 	*nb = n;
186 	return r;
187 }
188 
189 void
190 wingetevent(Window *w, Event *e)
191 {
192 	int i, nb;
193 
194 	e->c1 = wingetec(w);
195 	e->c2 = wingetec(w);
196 	e->q0 = wingeten(w);
197 	e->q1 = wingeten(w);
198 	e->flag = wingeten(w);
199 	e->nr = wingeten(w);
200 	if(e->nr > EVENTSIZE)
201 		error("event string too long");
202 	e->nb = 0;
203 	for(i=0; i<e->nr; i++){
204 		e->r[i] = wingeter(w, e->b+e->nb, &nb);
205 		e->nb += nb;
206 	}
207 	e->r[e->nr] = 0;
208 	e->b[e->nb] = 0;
209 	if(wingetec(w) != '\n')
210 		error("event syntax error");
211 }
212 
213 void
214 winwriteevent(Window *w, Event *e)
215 {
216 	fsprint(w->event, "%c%c%d %d\n", e->c1, e->c2, e->q0, e->q1);
217 }
218 
219 void
220 winread(Window *w, uint q0, uint q1, char *data)
221 {
222 	int m, n, nr;
223 	char buf[256];
224 
225 	if(w->addr == nil)
226 		w->addr = winopenfile(w, "addr");
227 	if(w->data == nil)
228 		w->data = winopenfile(w, "data");
229 	m = q0;
230 	while(m < q1){
231 		n = sprint(buf, "#%d", m);
232 		if(fswrite(w->addr, buf, n) != n)
233 			error("error writing addr: %r");
234 		n = fsread(w->data, buf, sizeof buf);
235 		if(n <= 0)
236 			error("reading data: %r");
237 		nr = utfnlen(buf, n);
238 		while(m+nr >q1){
239 			do; while(n>0 && (buf[--n]&0xC0)==0x80);
240 			--nr;
241 		}
242 		if(n == 0)
243 			break;
244 		memmove(data, buf, n);
245 		data += n;
246 		*data = 0;
247 		m += nr;
248 	}
249 }
250 
251 void
252 windormant(Window *w)
253 {
254 	if(w->addr != nil){
255 		fsclose(w->addr);
256 		w->addr = nil;
257 	}
258 	if(w->body != nil){
259 		fsclose(w->body);
260 		w->body = nil;
261 	}
262 	if(w->data != nil){
263 		fsclose(w->data);
264 		w->data = nil;
265 	}
266 }
267 
268 
269 int
270 windel(Window *w, int sure)
271 {
272 	if(sure)
273 		fswrite(w->ctl, "delete\n", 7);
274 	else if(fswrite(w->ctl, "del\n", 4) != 4)
275 		return 0;
276 	/* event proc will die due to read error from event file */
277 	windormant(w);
278 	fsclose(w->ctl);
279 	w->ctl = nil;
280 	return 1;
281 }
282 
283 void
284 winclean(Window *w)
285 {
286 	ctlprint(w->ctl, "clean\n");
287 }
288 
289 int
290 winsetaddr(Window *w, char *addr, int errok)
291 {
292 	if(w->addr == nil)
293 		w->addr = winopenfile(w, "addr");
294 	if(fswrite(w->addr, addr, strlen(addr)) < 0){
295 		if(!errok)
296 			error("error writing addr(%s): %r", addr);
297 		return 0;
298 	}
299 	return 1;
300 }
301 
302 int
303 winselect(Window *w, char *addr, int errok)
304 {
305 	if(winsetaddr(w, addr, errok)){
306 		ctlprint(w->ctl, "dot=addr\n");
307 		return 1;
308 	}
309 	return 0;
310 }
311 
312 char*
313 winreadbody(Window *w, int *np)	/* can't use readfile because acme doesn't report the length */
314 {
315 	char *s;
316 	int m, na, n;
317 
318 	if(w->body != nil)
319 		winclosebody(w);
320 	winopenbody(w, OREAD);
321 	s = nil;
322 	na = 0;
323 	n = 0;
324 	for(;;){
325 		if(na < n+512){
326 			na += 1024;
327 			s = realloc(s, na+1);
328 		}
329 		m = fsread(w->body, s+n, na-n);
330 		if(m <= 0)
331 			break;
332 		n += m;
333 	}
334 	s[n] = 0;
335 	winclosebody(w);
336 	*np = n;
337 	return s;
338 }
339 
340 char*
341 winselection(Window *w)
342 {
343 	int m, n;
344 	char *buf;
345 	char tmp[256];
346 	CFid* fid;
347 
348 	fid = winopenfile1(w, "rdsel", OREAD);
349 	if(fid == nil)
350 		error("can't open rdsel: %r");
351 	n = 0;
352 	buf = nil;
353 	for(;;){
354 		m = fsread(fid, tmp, sizeof tmp);
355 		if(m <= 0)
356 			break;
357 		buf = erealloc(buf, n+m+1);
358 		memmove(buf+n, tmp, m);
359 		n += m;
360 		buf[n] = '\0';
361 	}
362 	fsclose(fid);
363 	return buf;
364 }