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