1 #include <u.h>
2 #include <libc.h>
3 #include <bio.h>
4 #include <thread.h>
5 #include "win.h"
6
7 void*
erealloc(void * p,uint n)8 erealloc(void *p, uint n)
9 {
10 p = realloc(p, n);
11 if(p == nil)
12 fprint(2, "realloc failed: %r");
13 return p;
14 }
15
16 void
wnew(Win * w)17 wnew(Win *w)
18 {
19 char buf[12];
20
21 w->ctl = open("/mnt/acme/new/ctl", ORDWR);
22 if(w->ctl<0 || read(w->ctl, buf, 12)!=12)
23 fprint (2, "can't open window ctl file: %r");
24 ctlwrite(w, "noscroll\n");
25 w->winid = atoi(buf);
26 w->event = openfile(w, "event");
27 w->addr = -1; /* will be opened when needed */
28 w->body = nil;
29 w->data = -1;
30 }
31
32 int
openfile(Win * w,char * f)33 openfile(Win *w, char *f)
34 {
35 char buf[64];
36 int fd;
37
38 sprint(buf, "/mnt/acme/%d/%s", w->winid, f);
39 fd = open(buf, ORDWR|OCEXEC);
40 if(fd < 0)
41 fprint (2,"can't open window %s file: %r", f);
42 return fd;
43 }
44
45 void
openbody(Win * w,int mode)46 openbody(Win *w, int mode)
47 {
48 char buf[64];
49
50 sprint(buf, "/mnt/acme/%d/body", w->winid);
51 w->body = Bopen(buf, mode|OCEXEC);
52 if(w->body == nil)
53 fprint(2,"can't open window body file: %r");
54 }
55
56 void
wwritebody(Win * w,char * s,int n)57 wwritebody(Win *w, char *s, int n)
58 {
59 if(w->body == nil)
60 openbody(w, OWRITE);
61 if(Bwrite(w->body, s, n) != n)
62 fprint(2,"write error to window: %r");
63 Bflush(w->body);
64 }
65
66 void
wreplace(Win * w,char * addr,char * repl,int nrepl)67 wreplace(Win *w, char *addr, char *repl, int nrepl)
68 {
69 if(w->addr < 0)
70 w->addr = openfile(w, "addr");
71 if(w->data < 0)
72 w->data = openfile(w, "data");
73 if(write(w->addr, addr, strlen(addr)) < 0){
74 fprint(2, "mail: warning: badd address %s:%r\n", addr);
75 return;
76 }
77 if(write(w->data, repl, nrepl) != nrepl)
78 fprint(2, "writing data: %r");
79 }
80
81 static int
nrunes(char * s,int nb)82 nrunes(char *s, int nb)
83 {
84 int i, n;
85 Rune r;
86
87 n = 0;
88 for(i=0; i<nb; n++)
89 i += chartorune(&r, s+i);
90 return n;
91 }
92
93 void
wread(Win * w,uint q0,uint q1,char * data)94 wread(Win *w, uint q0, uint q1, char *data)
95 {
96 int m, n, nr;
97 char buf[256];
98
99 if(w->addr < 0)
100 w->addr = openfile(w, "addr");
101 if(w->data < 0)
102 w->data = openfile(w, "data");
103 m = q0;
104 while(m < q1){
105 n = sprint(buf, "#%d", m);
106 if(write(w->addr, buf, n) != n)
107 fprint(2,"writing addr: %r");
108 n = read(w->data, buf, sizeof buf);
109 if(n <= 0)
110 fprint(2,"reading data: %r");
111 nr = nrunes(buf, n);
112 while(m+nr >q1){
113 do; while(n>0 && (buf[--n]&0xC0)==0x80);
114 --nr;
115 }
116 if(n == 0)
117 break;
118 memmove(data, buf, n);
119 data += n;
120 *data = 0;
121 m += nr;
122 }
123 }
124
125 void
wselect(Win * w,char * addr)126 wselect(Win *w, char *addr)
127 {
128 if(w->addr < 0)
129 w->addr = openfile(w, "addr");
130 if(write(w->addr, addr, strlen(addr)) < 0)
131 fprint(2,"writing addr");
132 ctlwrite(w, "dot=addr\n");
133 }
134
135 void
wtagwrite(Win * w,char * s,int n)136 wtagwrite(Win *w, char *s, int n)
137 {
138 int fd;
139
140 fd = openfile(w, "tag");
141 if(write(fd, s, n) != n)
142 fprint(2,"tag write: %r");
143 close(fd);
144 }
145
146 void
ctlwrite(Win * w,char * s)147 ctlwrite(Win *w, char *s)
148 {
149 int n;
150
151 n = strlen(s);
152 if(write(w->ctl, s, n) != n)
153 fprint(2,"write error to ctl file: %r");
154 }
155
156 int
wdel(Win * w)157 wdel(Win *w)
158 {
159 if(write(w->ctl, "del\n", 4) != 4)
160 return False;
161 wdormant(w);
162 close(w->ctl);
163 w->ctl = -1;
164 close(w->event);
165 w->event = -1;
166 return True;
167 }
168
169 void
wname(Win * w,char * s)170 wname(Win *w, char *s)
171 {
172 char buf[128];
173
174 sprint(buf, "name %s\n", s);
175 ctlwrite(w, buf);
176 }
177
178 void
wclean(Win * w)179 wclean(Win *w)
180 {
181 if(w->body)
182 Bflush(w->body);
183 ctlwrite(w, "clean\n");
184 }
185
186 void
wdormant(Win * w)187 wdormant(Win *w)
188 {
189 if(w->addr >= 0){
190 close(w->addr);
191 w->addr = -1;
192 }
193 if(w->body != nil){
194 Bterm(w->body);
195 w->body = nil;
196 }
197 if(w->data >= 0){
198 close(w->data);
199 w->data = -1;
200 }
201 }
202
203 int
getec(Win * w)204 getec(Win *w)
205 {
206 if(w->nbuf == 0){
207 w->nbuf = read(w->event, w->buf, sizeof w->buf);
208 if(w->nbuf <= 0)
209 fprint(2,"event read error: %r");
210 w->bufp = w->buf;
211 }
212 w->nbuf--;
213 return *w->bufp++;
214 }
215
216 int
geten(Win * w)217 geten(Win *w)
218 {
219 int n, c;
220
221 n = 0;
222 while('0'<=(c=getec(w)) && c<='9')
223 n = n*10+(c-'0');
224 if(c != ' ')
225 fprint(2, "event number syntax");
226 return n;
227 }
228
229 int
geter(Win * w,char * buf,int * nb)230 geter(Win *w, char *buf, int *nb)
231 {
232 Rune r;
233 int n;
234
235 r = getec(w);
236 buf[0] = r;
237 n = 1;
238 if(r < Runeself)
239 goto Return;
240 while(!fullrune(buf, n))
241 buf[n++] = getec(w);
242 chartorune(&r, buf);
243 Return:
244 *nb = n;
245 return r;
246 }
247
248
249 void
wevent(Win * w,Event * e)250 wevent(Win *w, Event *e)
251 {
252 int i, nb;
253
254 e->c1 = getec(w);
255 e->c2 = getec(w);
256 e->q0 = geten(w);
257 e->q1 = geten(w);
258 e->flag = geten(w);
259 e->nr = geten(w);
260 if(e->nr > EVENTSIZE)
261 fprint(2, "wevent: event string too long");
262 e->nb = 0;
263 for(i=0; i<e->nr; i++){
264 e->r[i] = geter(w, e->b+e->nb, &nb);
265 e->nb += nb;
266 }
267 e->r[e->nr] = 0;
268 e->b[e->nb] = 0;
269 if(getec(w) != '\n')
270 fprint(2, "wevent: event syntax 2");
271 }
272
273 void
wslave(Win * w,Channel * ce)274 wslave(Win *w, Channel *ce)
275 {
276 Event e;
277
278 while(recv(ce, &e) >= 0)
279 wevent(w, &e);
280 }
281
282 void
wwriteevent(Win * w,Event * e)283 wwriteevent(Win *w, Event *e)
284 {
285 fprint(w->event, "%c%c%d %d\n", e->c1, e->c2, e->q0, e->q1);
286 }
287
288 int
wreadall(Win * w,char ** sp)289 wreadall(Win *w, char **sp)
290 {
291 char *s;
292 int m, na, n;
293
294 if(w->body != nil)
295 Bterm(w->body);
296 openbody(w, OREAD);
297 s = nil;
298 na = 0;
299 n = 0;
300 for(;;){
301 if(na < n+512){
302 na += 1024;
303 s = erealloc(s, na+1);
304 }
305 m = Bread(w->body, s+n, na-n);
306 if(m <= 0)
307 break;
308 n += m;
309 }
310 s[n] = 0;
311 Bterm(w->body);
312 w->body = nil;
313 *sp = s;
314 return n;
315 }
316