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
9Window*
10newwindow(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
30void
31winincref(Window *w)
32{
33 qlock(&w->lk);
34 ++w->ref;
35 qunlock(&w->lk);
36}
37
38void
39windecref(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
51void
52winsetdump(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
60void
61wineventproc(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
75static CFid*
76winopenfile1(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
88CFid*
89winopenfile(Window *w, char *f)
90{
91 return winopenfile1(w, f, ORDWR);
92}
93
94void
95wintagwrite(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
105void
106winname(Window *w, char *s)
107{
108 int len;
109 char *ns, *sp;
110 Rune r = L'␣'; /* visible space */
111
112 len = 0;
113 ns = emalloc(strlen(s)*runelen(r) + 1);
114 for(sp = s; *sp != '\0'; sp++, len++){
115 if(isspace(*sp)){
116 len += runetochar(ns+len, &r)-1;
117 continue;
118 }
119 *(ns+len) = *sp;
120 }
121 ctlprint(w->ctl, "name %s\n", ns);
122 free(ns);
123 return;
124}
125
126void
127winopenbody(Window *w, int mode)
128{
129 char buf[256];
130 CFid* fid;
131
132 sprint(buf, "%d/body", w->id);
133 fid = fsopen(acmefs, buf, mode|OCEXEC);
134 w->body = fid;
135 if(w->body == nil)
136 error("can't open window body file: %r");
137}
138
139void
140winclosebody(Window *w)
141{
142 if(w->body != nil){
143 fsclose(w->body);
144 w->body = nil;
145 }
146}
147
148void
149winwritebody(Window *w, char *s, int n)
150{
151 if(w->body == nil)
152 winopenbody(w, OWRITE);
153 if(fswrite(w->body, s, n) != n)
154 error("write error to window: %r");
155}
156
157int
158wingetec(Window *w)
159{
160 if(w->nbuf == 0){
161 w->nbuf = fsread(w->event, w->buf, sizeof w->buf);
162 if(w->nbuf <= 0){
163 /* probably because window has exited, and only called by wineventproc, so just shut down */
164 windecref(w);
165 threadexits(nil);
166 }
167 w->bufp = w->buf;
168 }
169 w->nbuf--;
170 return *w->bufp++;
171}
172
173int
174wingeten(Window *w)
175{
176 int n, c;
177
178 n = 0;
179 while('0'<=(c=wingetec(w)) && c<='9')
180 n = n*10+(c-'0');
181 if(c != ' ')
182 error("event number syntax");
183 return n;
184}
185
186int
187wingeter(Window *w, char *buf, int *nb)
188{
189 Rune r;
190 int n;
191
192 r = wingetec(w);
193 buf[0] = r;
194 n = 1;
195 if(r >= Runeself) {
196 while(!fullrune(buf, n))
197 buf[n++] = wingetec(w);
198 chartorune(&r, buf);
199 }
200 *nb = n;
201 return r;
202}
203
204void
205wingetevent(Window *w, Event *e)
206{
207 int i, nb;
208
209 e->c1 = wingetec(w);
210 e->c2 = wingetec(w);
211 e->q0 = wingeten(w);
212 e->q1 = wingeten(w);
213 e->flag = wingeten(w);
214 e->nr = wingeten(w);
215 if(e->nr > EVENTSIZE)
216 error("event string too long");
217 e->nb = 0;
218 for(i=0; i<e->nr; i++){
219 e->r[i] = wingeter(w, e->b+e->nb, &nb);
220 e->nb += nb;
221 }
222 e->r[e->nr] = 0;
223 e->b[e->nb] = 0;
224 if(wingetec(w) != '\n')
225 error("event syntax error");
226}
227
228void
229winwriteevent(Window *w, Event *e)
230{
231 fsprint(w->event, "%c%c%d %d\n", e->c1, e->c2, e->q0, e->q1);
232}
233
234void
235winread(Window *w, uint q0, uint q1, char *data)
236{
237 int m, n, nr;
238 char buf[256];
239
240 if(w->addr == nil)
241 w->addr = winopenfile(w, "addr");
242 if(w->data == nil)
243 w->data = winopenfile(w, "data");
244 m = q0;
245 while(m < q1){
246 n = sprint(buf, "#%d", m);
247 if(fswrite(w->addr, buf, n) != n)
248 error("error writing addr: %r");
249 n = fsread(w->data, buf, sizeof buf);
250 if(n <= 0)
251 error("reading data: %r");
252 nr = utfnlen(buf, n);
253 while(m+nr >q1){
254 do; while(n>0 && (buf[--n]&0xC0)==0x80);
255 --nr;
256 }
257 if(n == 0)
258 break;
259 memmove(data, buf, n);
260 data += n;
261 *data = 0;
262 m += nr;
263 }
264}
265
266void
267windormant(Window *w)
268{
269 if(w->addr != nil){
270 fsclose(w->addr);
271 w->addr = nil;
272 }
273 if(w->body != nil){
274 fsclose(w->body);
275 w->body = nil;
276 }
277 if(w->data != nil){
278 fsclose(w->data);
279 w->data = nil;
280 }
281}
282
283
284int
285windel(Window *w, int sure)
286{
287 if(sure)
288 fswrite(w->ctl, "delete\n", 7);
289 else if(fswrite(w->ctl, "del\n", 4) != 4)
290 return 0;
291 /* event proc will die due to read error from event file */
292 windormant(w);
293 fsclose(w->ctl);
294 w->ctl = nil;
295 return 1;
296}
297
298void
299winclean(Window *w)
300{
301 ctlprint(w->ctl, "clean\n");
302}
303
304int
305winsetaddr(Window *w, char *addr, int errok)
306{
307 if(w->addr == nil)
308 w->addr = winopenfile(w, "addr");
309 if(fswrite(w->addr, addr, strlen(addr)) < 0){
310 if(!errok)
311 error("error writing addr(%s): %r", addr);
312 return 0;
313 }
314 return 1;
315}
316
317int
318winselect(Window *w, char *addr, int errok)
319{
320 if(winsetaddr(w, addr, errok)){
321 ctlprint(w->ctl, "dot=addr\n");
322 return 1;
323 }
324 return 0;
325}
326
327char*
328winreadbody(Window *w, int *np) /* can't use readfile because acme doesn't report the length */
329{
330 char *s;
331 int m, na, n;
332
333 if(w->body != nil)
334 winclosebody(w);
335 winopenbody(w, OREAD);
336 s = nil;
337 na = 0;
338 n = 0;
339 for(;;){
340 if(na < n+512){
341 na += 1024;
342 s = realloc(s, na+1);
343 }
344 m = fsread(w->body, s+n, na-n);
345 if(m <= 0)
346 break;
347 n += m;
348 }
349 s[n] = 0;
350 winclosebody(w);
351 *np = n;
352 return s;
353}
354
355char*
356winselection(Window *w)
357{
358 int m, n;
359 char *buf;
360 char tmp[256];
361 CFid* fid;
362
363 fid = winopenfile1(w, "rdsel", OREAD);
364 if(fid == nil)
365 error("can't open rdsel: %r");
366 n = 0;
367 buf = nil;
368 for(;;){
369 m = fsread(fid, tmp, sizeof tmp);
370 if(m <= 0)
371 break;
372 buf = erealloc(buf, n+m+1);
373 memmove(buf+n, tmp, m);
374 n += m;
375 buf[n] = '\0';
376 }
377 fsclose(fid);
378 return buf;
379}