1 8ad51794 2004-03-25 devnull #include <u.h>
  2 8ad51794 2004-03-25 devnull #include <libc.h>
  3 8ad51794 2004-03-25 devnull #include <thread.h>
  4 8ad51794 2004-03-25 devnull #include <fcall.h>
  5 8ad51794 2004-03-25 devnull #include <fs.h>
  6 8ad51794 2004-03-25 devnull #include "term.h"
  7 b4a659b6 2004-04-19 devnull 
  8 b4a659b6 2004-04-19 devnull int noecho = 1;
  9 8ad51794 2004-03-25 devnull 
 10 8ad51794 2004-03-25 devnull #define	EVENTSIZE	256
 11 8ad51794 2004-03-25 devnull #define	STACK	32768
 12 8ad51794 2004-03-25 devnull 
 13 8ad51794 2004-03-25 devnull typedef struct Event Event;
 14 8ad51794 2004-03-25 devnull typedef struct Q Q;
 15 8ad51794 2004-03-25 devnull 
 16 8ad51794 2004-03-25 devnull struct Event
 17 8ad51794 2004-03-25 devnull {
 18 8ad51794 2004-03-25 devnull 	int	c1;
 19 8ad51794 2004-03-25 devnull 	int	c2;
 20 8ad51794 2004-03-25 devnull 	int	q0;
 21 8ad51794 2004-03-25 devnull 	int	q1;
 22 8ad51794 2004-03-25 devnull 	int	flag;
 23 8ad51794 2004-03-25 devnull 	int	nb;
 24 8ad51794 2004-03-25 devnull 	int	nr;
 25 8ad51794 2004-03-25 devnull 	char	b[EVENTSIZE*UTFmax+1];
 26 8ad51794 2004-03-25 devnull 	Rune	r[EVENTSIZE+1];
 27 8ad51794 2004-03-25 devnull };
 28 8ad51794 2004-03-25 devnull 
 29 8ad51794 2004-03-25 devnull Event blank = {
 30 8ad51794 2004-03-25 devnull 	'M',
 31 8ad51794 2004-03-25 devnull 	'X',
 32 8ad51794 2004-03-25 devnull 	0, 0, 0, 1, 1,
 33 8ad51794 2004-03-25 devnull 	{ ' ', 0 },
 34 8ad51794 2004-03-25 devnull 	{ ' ', 0 },
 35 8ad51794 2004-03-25 devnull };
 36 8ad51794 2004-03-25 devnull 
 37 8ad51794 2004-03-25 devnull struct Q
 38 8ad51794 2004-03-25 devnull {
 39 8ad51794 2004-03-25 devnull 	QLock	lk;
 40 8ad51794 2004-03-25 devnull 	int		p;
 41 8ad51794 2004-03-25 devnull 	int		k;
 42 8ad51794 2004-03-25 devnull };
 43 8ad51794 2004-03-25 devnull 
 44 8ad51794 2004-03-25 devnull Q	q;
 45 8ad51794 2004-03-25 devnull 
 46 8ad51794 2004-03-25 devnull Fid *eventfd;
 47 8ad51794 2004-03-25 devnull Fid *addrfd;
 48 8ad51794 2004-03-25 devnull Fid *datafd;
 49 8ad51794 2004-03-25 devnull Fid *ctlfd;
 50 8ad51794 2004-03-25 devnull // int bodyfd;
 51 8ad51794 2004-03-25 devnull 
 52 8ad51794 2004-03-25 devnull char	*typing;
 53 8ad51794 2004-03-25 devnull int	ntypeb;
 54 8ad51794 2004-03-25 devnull int	ntyper;
 55 8ad51794 2004-03-25 devnull int	ntypebreak;
 56 8ad51794 2004-03-25 devnull int	debug;
 57 8ad51794 2004-03-25 devnull int	rcfd;
 58 8ad51794 2004-03-25 devnull 
 59 8ad51794 2004-03-25 devnull char *name;
 60 8ad51794 2004-03-25 devnull 
 61 8ad51794 2004-03-25 devnull char **prog;
 62 8ad51794 2004-03-25 devnull Channel *cwait;
 63 8ad51794 2004-03-25 devnull int pid = -1;
 64 8ad51794 2004-03-25 devnull 
 65 8ad51794 2004-03-25 devnull int	label(char*, int);
 66 8ad51794 2004-03-25 devnull void	error(char*);
 67 8ad51794 2004-03-25 devnull void	stdinproc(void*);
 68 8ad51794 2004-03-25 devnull void	stdoutproc(void*);
 69 8ad51794 2004-03-25 devnull void	type(Event*, int, Fid*, Fid*);
 70 8ad51794 2004-03-25 devnull void	sende(Event*, int, Fid*, Fid*, Fid*, int);
 71 8ad51794 2004-03-25 devnull char	*onestring(int, char**);
 72 8ad51794 2004-03-25 devnull int	delete(Event*);
 73 8ad51794 2004-03-25 devnull void	deltype(uint, uint);
 74 8ad51794 2004-03-25 devnull void	runproc(void*);
 75 8ad51794 2004-03-25 devnull 
 76 8ad51794 2004-03-25 devnull int
 77 8ad51794 2004-03-25 devnull fsfidprint(Fid *fid, char *fmt, ...)
 78 8ad51794 2004-03-25 devnull {
 79 8ad51794 2004-03-25 devnull 	char buf[256];
 80 8ad51794 2004-03-25 devnull 	va_list arg;
 81 8ad51794 2004-03-25 devnull 	int n;
 82 8ad51794 2004-03-25 devnull 
 83 8ad51794 2004-03-25 devnull 	va_start(arg, fmt);
 84 8ad51794 2004-03-25 devnull 	n = vsnprint(buf, sizeof buf, fmt, arg);
 85 8ad51794 2004-03-25 devnull 	va_end(arg);
 86 8ad51794 2004-03-25 devnull 	return fswrite(fid, buf, n);
 87 8ad51794 2004-03-25 devnull }
 88 8ad51794 2004-03-25 devnull 
 89 8ad51794 2004-03-25 devnull void
 90 8ad51794 2004-03-25 devnull usage(void)
 91 8ad51794 2004-03-25 devnull {
 92 8ad51794 2004-03-25 devnull 	fprint(2, "usage: win cmd args...\n");
 93 8ad51794 2004-03-25 devnull 	threadexitsall("usage");
 94 8ad51794 2004-03-25 devnull }
 95 8ad51794 2004-03-25 devnull 
 96 8ad51794 2004-03-25 devnull int
 97 8ad51794 2004-03-25 devnull nopipes(void *v, char *msg)
 98 8ad51794 2004-03-25 devnull {
 99 8ad51794 2004-03-25 devnull 	USED(v);
100 8ad51794 2004-03-25 devnull 	if(strcmp(msg, "sys: write on closed pipe") == 0)
101 8ad51794 2004-03-25 devnull 		return 1;
102 8ad51794 2004-03-25 devnull 	return 0;
103 8ad51794 2004-03-25 devnull }
104 8ad51794 2004-03-25 devnull 
105 8ad51794 2004-03-25 devnull void
106 8ad51794 2004-03-25 devnull waitthread(void *v)
107 8ad51794 2004-03-25 devnull {
108 8ad51794 2004-03-25 devnull 	recvp(cwait);
109 8ad51794 2004-03-25 devnull 	threadexitsall(nil);
110 8ad51794 2004-03-25 devnull }
111 8ad51794 2004-03-25 devnull 
112 8ad51794 2004-03-25 devnull void
113 8ad51794 2004-03-25 devnull threadmain(int argc, char **argv)
114 8ad51794 2004-03-25 devnull {
115 8ad51794 2004-03-25 devnull 	int fd, id;
116 8ad51794 2004-03-25 devnull 	char buf[256];
117 8ad51794 2004-03-25 devnull 	char buf1[128];
118 8ad51794 2004-03-25 devnull 	Fsys *fs;
119 8ad51794 2004-03-25 devnull 
120 8ad51794 2004-03-25 devnull 	ARGBEGIN{
121 8ad51794 2004-03-25 devnull 	case 'd':
122 8ad51794 2004-03-25 devnull 		debug = 1;
123 8ad51794 2004-03-25 devnull 		break;
124 8ad51794 2004-03-25 devnull 	default:
125 8ad51794 2004-03-25 devnull 		usage();
126 8ad51794 2004-03-25 devnull 	}ARGEND
127 8ad51794 2004-03-25 devnull 
128 8ad51794 2004-03-25 devnull 	prog = argv;
129 8ad51794 2004-03-25 devnull 
130 8ad51794 2004-03-25 devnull 	if(argc > 0){
131 8ad51794 2004-03-25 devnull 		name = argv[0];
132 8ad51794 2004-03-25 devnull 		argc--;
133 8ad51794 2004-03-25 devnull 		argv++;
134 8ad51794 2004-03-25 devnull 	}else
135 8ad51794 2004-03-25 devnull 		name = "gnot";
136 8ad51794 2004-03-25 devnull 
137 8ad51794 2004-03-25 devnull 	threadnotify(nopipes, 1);
138 be22ae2d 2004-03-26 devnull 	if((fs = nsmount("acme", "")) == 0)
139 8ad51794 2004-03-25 devnull 		sysfatal("nsmount acme: %r");
140 8ad51794 2004-03-25 devnull 	ctlfd = fsopen(fs, "new/ctl", ORDWR|OCEXEC);
141 be22ae2d 2004-03-26 devnull 	if(ctlfd == 0 || fsread(ctlfd, buf, 12) != 12)
142 8ad51794 2004-03-25 devnull 		sysfatal("ctl: %r");
143 8ad51794 2004-03-25 devnull 	id = atoi(buf);
144 8ad51794 2004-03-25 devnull 	sprint(buf, "%d/tag", id);
145 8ad51794 2004-03-25 devnull 	fd = fsopenfd(fs, buf, OWRITE|OCEXEC);
146 8ad51794 2004-03-25 devnull 	write(fd, " Send Delete", 12);
147 8ad51794 2004-03-25 devnull 	close(fd);
148 8ad51794 2004-03-25 devnull 	sprint(buf, "%d/event", id);
149 8ad51794 2004-03-25 devnull 	eventfd = fsopen(fs, buf, ORDWR|OCEXEC);
150 8ad51794 2004-03-25 devnull 	sprint(buf, "%d/addr", id);
151 8ad51794 2004-03-25 devnull 	addrfd = fsopen(fs, buf, ORDWR|OCEXEC);
152 8ad51794 2004-03-25 devnull 	sprint(buf, "%d/data", id);
153 8ad51794 2004-03-25 devnull 	datafd = fsopen(fs, buf, ORDWR|OCEXEC);
154 8ad51794 2004-03-25 devnull 	sprint(buf, "%d/body", id);
155 8ad51794 2004-03-25 devnull /*	bodyfd = fsopenfd(fs, buf, ORDWR|OCEXEC); */
156 8ad51794 2004-03-25 devnull 	if(eventfd==nil || addrfd==nil || datafd==nil)
157 8ad51794 2004-03-25 devnull 		sysfatal("data files: %r");
158 8ad51794 2004-03-25 devnull /*
159 8ad51794 2004-03-25 devnull 	if(eventfd<0 || addrfd<0 || datafd<0 || bodyfd<0)
160 8ad51794 2004-03-25 devnull 		sysfatal("data files: %r");
161 8ad51794 2004-03-25 devnull */
162 8ad51794 2004-03-25 devnull 	fsunmount(fs);
163 8ad51794 2004-03-25 devnull 
164 8ad51794 2004-03-25 devnull 	cwait = threadwaitchan();
165 8ad51794 2004-03-25 devnull 	threadcreate(waitthread, nil, STACK);
166 4dcd9af2 2004-04-15 devnull 	pid = rcstart(argc, argv, &rcfd, nil);
167 8ad51794 2004-03-25 devnull 	if(pid == -1)
168 8ad51794 2004-03-25 devnull 		sysfatal("exec failed");
169 8ad51794 2004-03-25 devnull 
170 8ad51794 2004-03-25 devnull 	getwd(buf1, sizeof buf1);
171 8ad51794 2004-03-25 devnull 	sprint(buf, "name %s/-%s\n0\n", buf1, name);
172 8ad51794 2004-03-25 devnull 	fswrite(ctlfd, buf, strlen(buf));
173 8ad51794 2004-03-25 devnull 	sprint(buf, "dumpdir %s/\n", buf1);
174 8ad51794 2004-03-25 devnull 	fswrite(ctlfd, buf, strlen(buf));
175 8ad51794 2004-03-25 devnull 	sprint(buf, "dump %s\n", onestring(argc, argv));
176 8ad51794 2004-03-25 devnull 	fswrite(ctlfd, buf, strlen(buf));
177 8ad51794 2004-03-25 devnull 	
178 8ad51794 2004-03-25 devnull 	threadcreate(stdoutproc, nil, STACK);
179 8ad51794 2004-03-25 devnull 	stdinproc(nil);
180 8ad51794 2004-03-25 devnull }
181 8ad51794 2004-03-25 devnull 
182 8ad51794 2004-03-25 devnull void
183 8ad51794 2004-03-25 devnull error(char *s)
184 8ad51794 2004-03-25 devnull {
185 8ad51794 2004-03-25 devnull 	if(s)
186 8ad51794 2004-03-25 devnull 		fprint(2, "win: %s: %r\n", s);
187 8ad51794 2004-03-25 devnull 	else
188 8ad51794 2004-03-25 devnull 		s = "kill";
189 8ad51794 2004-03-25 devnull 	if(pid != -1)
190 8ad51794 2004-03-25 devnull 		postnote(PNGROUP, pid, "hangup");
191 8ad51794 2004-03-25 devnull 	threadexitsall(s);
192 8ad51794 2004-03-25 devnull }
193 8ad51794 2004-03-25 devnull 
194 8ad51794 2004-03-25 devnull char*
195 8ad51794 2004-03-25 devnull onestring(int argc, char **argv)
196 8ad51794 2004-03-25 devnull {
197 8ad51794 2004-03-25 devnull 	char *p;
198 8ad51794 2004-03-25 devnull 	int i, n;
199 8ad51794 2004-03-25 devnull 	static char buf[1024];
200 8ad51794 2004-03-25 devnull 
201 8ad51794 2004-03-25 devnull 	if(argc == 0)
202 8ad51794 2004-03-25 devnull 		return "";
203 8ad51794 2004-03-25 devnull 	p = buf;
204 8ad51794 2004-03-25 devnull 	for(i=0; i<argc; i++){
205 8ad51794 2004-03-25 devnull 		n = strlen(argv[i]);
206 8ad51794 2004-03-25 devnull 		if(p+n+1 >= buf+sizeof buf)
207 8ad51794 2004-03-25 devnull 			break;
208 8ad51794 2004-03-25 devnull 		memmove(p, argv[i], n);
209 8ad51794 2004-03-25 devnull 		p += n;
210 8ad51794 2004-03-25 devnull 		*p++ = ' ';
211 8ad51794 2004-03-25 devnull 	}
212 8ad51794 2004-03-25 devnull 	p[-1] = 0;
213 8ad51794 2004-03-25 devnull 	return buf;
214 8ad51794 2004-03-25 devnull }
215 8ad51794 2004-03-25 devnull 
216 8ad51794 2004-03-25 devnull int
217 8ad51794 2004-03-25 devnull getec(Fid *efd)
218 8ad51794 2004-03-25 devnull {
219 8ad51794 2004-03-25 devnull 	static char buf[8192];
220 8ad51794 2004-03-25 devnull 	static char *bufp;
221 8ad51794 2004-03-25 devnull 	static int nbuf;
222 8ad51794 2004-03-25 devnull 
223 8ad51794 2004-03-25 devnull 	if(nbuf == 0){
224 8ad51794 2004-03-25 devnull 		nbuf = fsread(efd, buf, sizeof buf);
225 8ad51794 2004-03-25 devnull 		if(nbuf <= 0)
226 8ad51794 2004-03-25 devnull 			error(nil);
227 8ad51794 2004-03-25 devnull 		bufp = buf;
228 8ad51794 2004-03-25 devnull 	}
229 8ad51794 2004-03-25 devnull 	--nbuf;
230 8ad51794 2004-03-25 devnull 	return *bufp++;
231 8ad51794 2004-03-25 devnull }
232 8ad51794 2004-03-25 devnull 
233 8ad51794 2004-03-25 devnull int
234 8ad51794 2004-03-25 devnull geten(Fid *efd)
235 8ad51794 2004-03-25 devnull {
236 8ad51794 2004-03-25 devnull 	int n, c;
237 8ad51794 2004-03-25 devnull 
238 8ad51794 2004-03-25 devnull 	n = 0;
239 8ad51794 2004-03-25 devnull 	while('0'<=(c=getec(efd)) && c<='9')
240 8ad51794 2004-03-25 devnull 		n = n*10+(c-'0');
241 8ad51794 2004-03-25 devnull 	if(c != ' ')
242 8ad51794 2004-03-25 devnull 		error("event number syntax");
243 8ad51794 2004-03-25 devnull 	return n;
244 8ad51794 2004-03-25 devnull }
245 8ad51794 2004-03-25 devnull 
246 8ad51794 2004-03-25 devnull int
247 8ad51794 2004-03-25 devnull geter(Fid *efd, char *buf, int *nb)
248 8ad51794 2004-03-25 devnull {
249 8ad51794 2004-03-25 devnull 	Rune r;
250 8ad51794 2004-03-25 devnull 	int n;
251 8ad51794 2004-03-25 devnull 
252 8ad51794 2004-03-25 devnull 	r = getec(efd);
253 8ad51794 2004-03-25 devnull 	buf[0] = r;
254 8ad51794 2004-03-25 devnull 	n = 1;
255 8ad51794 2004-03-25 devnull 	if(r < Runeself)
256 8ad51794 2004-03-25 devnull 		goto Return;
257 8ad51794 2004-03-25 devnull 	while(!fullrune(buf, n))
258 8ad51794 2004-03-25 devnull 		buf[n++] = getec(efd);
259 8ad51794 2004-03-25 devnull 	chartorune(&r, buf);
260 8ad51794 2004-03-25 devnull     Return:
261 8ad51794 2004-03-25 devnull 	*nb = n;
262 8ad51794 2004-03-25 devnull 	return r;
263 8ad51794 2004-03-25 devnull }
264 8ad51794 2004-03-25 devnull 
265 8ad51794 2004-03-25 devnull void
266 8ad51794 2004-03-25 devnull gete(Fid *efd, Event *e)
267 8ad51794 2004-03-25 devnull {
268 8ad51794 2004-03-25 devnull 	int i, nb;
269 8ad51794 2004-03-25 devnull 
270 8ad51794 2004-03-25 devnull 	e->c1 = getec(efd);
271 8ad51794 2004-03-25 devnull 	e->c2 = getec(efd);
272 8ad51794 2004-03-25 devnull 	e->q0 = geten(efd);
273 8ad51794 2004-03-25 devnull 	e->q1 = geten(efd);
274 8ad51794 2004-03-25 devnull 	e->flag = geten(efd);
275 8ad51794 2004-03-25 devnull 	e->nr = geten(efd);
276 8ad51794 2004-03-25 devnull 	if(e->nr > EVENTSIZE)
277 8ad51794 2004-03-25 devnull 		error("event string too long");
278 8ad51794 2004-03-25 devnull 	e->nb = 0;
279 8ad51794 2004-03-25 devnull 	for(i=0; i<e->nr; i++){
280 8ad51794 2004-03-25 devnull 		e->r[i] = geter(efd, e->b+e->nb, &nb);
281 8ad51794 2004-03-25 devnull 		e->nb += nb;
282 8ad51794 2004-03-25 devnull 	}
283 8ad51794 2004-03-25 devnull 	e->r[e->nr] = 0;
284 8ad51794 2004-03-25 devnull 	e->b[e->nb] = 0;
285 8ad51794 2004-03-25 devnull 	if(getec(efd) != '\n')
286 8ad51794 2004-03-25 devnull 		error("event syntax 2");
287 8ad51794 2004-03-25 devnull }
288 8ad51794 2004-03-25 devnull 
289 8ad51794 2004-03-25 devnull int
290 8ad51794 2004-03-25 devnull nrunes(char *s, int nb)
291 8ad51794 2004-03-25 devnull {
292 8ad51794 2004-03-25 devnull 	int i, n;
293 8ad51794 2004-03-25 devnull 	Rune r;
294 8ad51794 2004-03-25 devnull 
295 8ad51794 2004-03-25 devnull 	n = 0;
296 8ad51794 2004-03-25 devnull 	for(i=0; i<nb; n++)
297 8ad51794 2004-03-25 devnull 		i += chartorune(&r, s+i);
298 8ad51794 2004-03-25 devnull 	return n;
299 8ad51794 2004-03-25 devnull }
300 8ad51794 2004-03-25 devnull 
301 8ad51794 2004-03-25 devnull void
302 8ad51794 2004-03-25 devnull stdinproc(void *v)
303 8ad51794 2004-03-25 devnull {
304 8ad51794 2004-03-25 devnull 	Fid *cfd = ctlfd;
305 8ad51794 2004-03-25 devnull 	Fid *efd = eventfd;
306 8ad51794 2004-03-25 devnull 	Fid *dfd = datafd;
307 8ad51794 2004-03-25 devnull 	Fid *afd = addrfd;
308 8ad51794 2004-03-25 devnull 	int fd0 = rcfd;
309 8ad51794 2004-03-25 devnull 	Event e, e2, e3, e4;
310 8ad51794 2004-03-25 devnull 
311 8ad51794 2004-03-25 devnull 	USED(v);
312 8ad51794 2004-03-25 devnull 
313 8ad51794 2004-03-25 devnull 	for(;;){
314 8ad51794 2004-03-25 devnull 		if(debug)
315 8ad51794 2004-03-25 devnull 			fprint(2, "typing[%d,%d)\n", q.p, q.p+ntyper);
316 8ad51794 2004-03-25 devnull 		gete(efd, &e);
317 8ad51794 2004-03-25 devnull 		if(debug)
318 8ad51794 2004-03-25 devnull 			fprint(2, "msg %c%c q[%d,%d)... ", e.c1, e.c2, e.q0, e.q1);
319 8ad51794 2004-03-25 devnull 		qlock(&q.lk);
320 8ad51794 2004-03-25 devnull 		switch(e.c1){
321 8ad51794 2004-03-25 devnull 		default:
322 8ad51794 2004-03-25 devnull 		Unknown:
323 8ad51794 2004-03-25 devnull 			print("unknown message %c%c\n", e.c1, e.c2);
324 8ad51794 2004-03-25 devnull 			break;
325 8ad51794 2004-03-25 devnull 
326 8ad51794 2004-03-25 devnull 		case 'E':	/* write to body; can't affect us */
327 8ad51794 2004-03-25 devnull 			if(debug)
328 8ad51794 2004-03-25 devnull 				fprint(2, "shift typing %d... ", e.q1-e.q0);
329 8ad51794 2004-03-25 devnull 			q.p += e.q1-e.q0;
330 8ad51794 2004-03-25 devnull 			break;
331 8ad51794 2004-03-25 devnull 
332 8ad51794 2004-03-25 devnull 		case 'F':	/* generated by our actions; ignore */
333 8ad51794 2004-03-25 devnull 			break;
334 8ad51794 2004-03-25 devnull 
335 8ad51794 2004-03-25 devnull 		case 'K':
336 8ad51794 2004-03-25 devnull 		case 'M':
337 8ad51794 2004-03-25 devnull 			switch(e.c2){
338 8ad51794 2004-03-25 devnull 			case 'I':
339 8ad51794 2004-03-25 devnull 				if(e.q0 < q.p){
340 8ad51794 2004-03-25 devnull 					if(debug)
341 8ad51794 2004-03-25 devnull 						fprint(2, "shift typing %d... ", e.q1-e.q0);
342 8ad51794 2004-03-25 devnull 					q.p += e.q1-e.q0;
343 8ad51794 2004-03-25 devnull 				}
344 8ad51794 2004-03-25 devnull 				else if(e.q0 <= q.p+ntyper){
345 8ad51794 2004-03-25 devnull 					if(debug)
346 8ad51794 2004-03-25 devnull 						fprint(2, "type... ");
347 8ad51794 2004-03-25 devnull 					type(&e, fd0, afd, dfd);
348 8ad51794 2004-03-25 devnull 				}
349 8ad51794 2004-03-25 devnull 				break;
350 8ad51794 2004-03-25 devnull 
351 8ad51794 2004-03-25 devnull 			case 'D':
352 8ad51794 2004-03-25 devnull 				q.p -= delete(&e);
353 8ad51794 2004-03-25 devnull 				break;
354 8ad51794 2004-03-25 devnull 
355 8ad51794 2004-03-25 devnull 			case 'x':
356 8ad51794 2004-03-25 devnull 			case 'X':
357 8ad51794 2004-03-25 devnull 				if(e.flag & 2)
358 8ad51794 2004-03-25 devnull 					gete(efd, &e2);
359 8ad51794 2004-03-25 devnull 				if(e.flag & 8){
360 8ad51794 2004-03-25 devnull 					gete(efd, &e3);
361 8ad51794 2004-03-25 devnull 					gete(efd, &e4);
362 8ad51794 2004-03-25 devnull 				}
363 8ad51794 2004-03-25 devnull 				if(e.flag&1 || (e.c2=='x' && e.nr==0 && e2.nr==0)){
364 8ad51794 2004-03-25 devnull 					/* send it straight back */
365 8ad51794 2004-03-25 devnull 					fsfidprint(efd, "%c%c%d %d\n", e.c1, e.c2, e.q0, e.q1);
366 8ad51794 2004-03-25 devnull 					break;
367 8ad51794 2004-03-25 devnull 				}
368 8ad51794 2004-03-25 devnull 				if(e.q0==e.q1 && (e.flag&2)){
369 8ad51794 2004-03-25 devnull 					e2.flag = e.flag;
370 8ad51794 2004-03-25 devnull 					e = e2;
371 8ad51794 2004-03-25 devnull 				}
372 8ad51794 2004-03-25 devnull 				if(e.flag & 8){
373 8ad51794 2004-03-25 devnull 					if(e.q1 != e.q0){
374 8ad51794 2004-03-25 devnull 						sende(&e, fd0, cfd, afd, dfd, 0);
375 8ad51794 2004-03-25 devnull 						sende(&blank, fd0, cfd, afd, dfd, 0);
376 8ad51794 2004-03-25 devnull 					}
377 8ad51794 2004-03-25 devnull 					sende(&e3, fd0, cfd, afd, dfd, 1);
378 8ad51794 2004-03-25 devnull 				}else	 if(e.q1 != e.q0)
379 8ad51794 2004-03-25 devnull 					sende(&e, fd0, cfd, afd, dfd, 1);
380 8ad51794 2004-03-25 devnull 				break;
381 8ad51794 2004-03-25 devnull 
382 8ad51794 2004-03-25 devnull 			case 'l':
383 8ad51794 2004-03-25 devnull 			case 'L':
384 8ad51794 2004-03-25 devnull 				/* just send it back */
385 8ad51794 2004-03-25 devnull 				if(e.flag & 2)
386 8ad51794 2004-03-25 devnull 					gete(efd, &e2);
387 8ad51794 2004-03-25 devnull 				fsfidprint(efd, "%c%c%d %d\n", e.c1, e.c2, e.q0, e.q1);
388 8ad51794 2004-03-25 devnull 				break;
389 8ad51794 2004-03-25 devnull 
390 8ad51794 2004-03-25 devnull 			case 'd':
391 8ad51794 2004-03-25 devnull 			case 'i':
392 8ad51794 2004-03-25 devnull 				break;
393 8ad51794 2004-03-25 devnull 
394 8ad51794 2004-03-25 devnull 			default:
395 8ad51794 2004-03-25 devnull 				goto Unknown;
396 8ad51794 2004-03-25 devnull 			}
397 8ad51794 2004-03-25 devnull 		}
398 8ad51794 2004-03-25 devnull 		qunlock(&q.lk);
399 8ad51794 2004-03-25 devnull 	}
400 8ad51794 2004-03-25 devnull }
401 8ad51794 2004-03-25 devnull 
402 8ad51794 2004-03-25 devnull void
403 8ad51794 2004-03-25 devnull stdoutproc(void *v)
404 8ad51794 2004-03-25 devnull {
405 8ad51794 2004-03-25 devnull 	int fd1 = rcfd;
406 8ad51794 2004-03-25 devnull 	Fid *afd = addrfd;
407 8ad51794 2004-03-25 devnull 	Fid *dfd = datafd;
408 8ad51794 2004-03-25 devnull 	int n, m, w, npart;
409 8ad51794 2004-03-25 devnull 	char *buf, *s, *t;
410 8ad51794 2004-03-25 devnull 	Rune r;
411 8ad51794 2004-03-25 devnull 	char x[16], hold[UTFmax];
412 8ad51794 2004-03-25 devnull 
413 8ad51794 2004-03-25 devnull 	USED(v);
414 8ad51794 2004-03-25 devnull 	threadnotify(nopipes, 1);
415 8ad51794 2004-03-25 devnull 	buf = malloc(8192+UTFmax+1);
416 8ad51794 2004-03-25 devnull 	npart = 0;
417 8ad51794 2004-03-25 devnull 	for(;;){
418 8ad51794 2004-03-25 devnull 		/* Let typing have a go -- maybe there's a rubout waiting. */
419 8ad51794 2004-03-25 devnull 		yield();
420 8ad51794 2004-03-25 devnull 		n = threadread(fd1, buf+npart, 8192);
421 8ad51794 2004-03-25 devnull 		if(n < 0)
422 8ad51794 2004-03-25 devnull 			error(nil);
423 8ad51794 2004-03-25 devnull 		if(n == 0)
424 8ad51794 2004-03-25 devnull 			continue;
425 8ad51794 2004-03-25 devnull 
426 8ad51794 2004-03-25 devnull 		/* squash NULs */
427 8ad51794 2004-03-25 devnull 		s = memchr(buf+npart, 0, n);
428 8ad51794 2004-03-25 devnull 		if(s){
429 8ad51794 2004-03-25 devnull 			for(t=s; s<buf+npart+n; s++)
430 8ad51794 2004-03-25 devnull 				if(*t = *s)	/* assign = */
431 8ad51794 2004-03-25 devnull 					t++;
432 8ad51794 2004-03-25 devnull 			n = t-(buf+npart);
433 8ad51794 2004-03-25 devnull 		}
434 8ad51794 2004-03-25 devnull 
435 8ad51794 2004-03-25 devnull 		n += npart;
436 8ad51794 2004-03-25 devnull 
437 8ad51794 2004-03-25 devnull 		/* hold on to final partial rune */
438 8ad51794 2004-03-25 devnull 		npart = 0;
439 8ad51794 2004-03-25 devnull 		while(n>0 && (buf[n-1]&0xC0)){
440 8ad51794 2004-03-25 devnull 			--n;
441 8ad51794 2004-03-25 devnull 			npart++;
442 8ad51794 2004-03-25 devnull 			if((buf[n]&0xC0)!=0x80){
443 8ad51794 2004-03-25 devnull 				if(fullrune(buf+n, npart)){
444 8ad51794 2004-03-25 devnull 					w = chartorune(&r, buf+n);
445 8ad51794 2004-03-25 devnull 					n += w;
446 8ad51794 2004-03-25 devnull 					npart -= w;
447 8ad51794 2004-03-25 devnull 				}
448 8ad51794 2004-03-25 devnull 				break;
449 8ad51794 2004-03-25 devnull 			}
450 8ad51794 2004-03-25 devnull 		}
451 8ad51794 2004-03-25 devnull 		if(n > 0){
452 8ad51794 2004-03-25 devnull 			memmove(hold, buf+n, npart);
453 8ad51794 2004-03-25 devnull 			buf[n] = 0;
454 8ad51794 2004-03-25 devnull 			n = label(buf, n);
455 8ad51794 2004-03-25 devnull 			buf[n] = 0;
456 8ad51794 2004-03-25 devnull 			qlock(&q.lk);
457 8ad51794 2004-03-25 devnull 			m = sprint(x, "#%d", q.p);
458 8ad51794 2004-03-25 devnull 			if(fswrite(afd, x, m) != m)
459 8ad51794 2004-03-25 devnull 				error("stdout writing address");
460 8ad51794 2004-03-25 devnull 			if(fswrite(dfd, buf, n) != n)
461 8ad51794 2004-03-25 devnull 				error("stdout writing body");
462 8ad51794 2004-03-25 devnull 			q.p += nrunes(buf, n);
463 8ad51794 2004-03-25 devnull 			qunlock(&q.lk);
464 8ad51794 2004-03-25 devnull 			memmove(buf, hold, npart);
465 8ad51794 2004-03-25 devnull 		}
466 8ad51794 2004-03-25 devnull 	}
467 8ad51794 2004-03-25 devnull }
468 8ad51794 2004-03-25 devnull 
469 8ad51794 2004-03-25 devnull char wdir[256];
470 8ad51794 2004-03-25 devnull int
471 8ad51794 2004-03-25 devnull label(char *sr, int n)
472 8ad51794 2004-03-25 devnull {
473 8ad51794 2004-03-25 devnull 	char *sl, *el, *er, *r;
474 8ad51794 2004-03-25 devnull 
475 8ad51794 2004-03-25 devnull 	er = sr+n;
476 8ad51794 2004-03-25 devnull 	for(r=er-1; r>=sr; r--)
477 8ad51794 2004-03-25 devnull 		if(*r == '\007')
478 8ad51794 2004-03-25 devnull 			break;
479 8ad51794 2004-03-25 devnull 	if(r < sr)
480 8ad51794 2004-03-25 devnull 		return n;
481 8ad51794 2004-03-25 devnull 
482 8ad51794 2004-03-25 devnull 	el = r+1;
483 8ad51794 2004-03-25 devnull 	if(el-sr > sizeof wdir)
484 8ad51794 2004-03-25 devnull 		sr = el - sizeof wdir;
485 8ad51794 2004-03-25 devnull 	for(sl=el-3; sl>=sr; sl--)
486 8ad51794 2004-03-25 devnull 		if(sl[0]=='\033' && sl[1]==']' && sl[2]==';')
487 8ad51794 2004-03-25 devnull 			break;
488 8ad51794 2004-03-25 devnull 	if(sl < sr)
489 8ad51794 2004-03-25 devnull 		return n;
490 8ad51794 2004-03-25 devnull 
491 8ad51794 2004-03-25 devnull 	*r = 0;
492 8ad51794 2004-03-25 devnull 	snprint(wdir, sizeof wdir, "name %s/-%s\n0\n", sl+3, name);
493 8ad51794 2004-03-25 devnull 	fswrite(ctlfd, wdir, strlen(wdir));
494 8ad51794 2004-03-25 devnull 
495 8ad51794 2004-03-25 devnull 	memmove(sl, el, er-el);
496 8ad51794 2004-03-25 devnull 	n -= (el-sl);
497 8ad51794 2004-03-25 devnull 	return n;
498 8ad51794 2004-03-25 devnull }
499 8ad51794 2004-03-25 devnull 
500 8ad51794 2004-03-25 devnull int
501 8ad51794 2004-03-25 devnull delete(Event *e)
502 8ad51794 2004-03-25 devnull {
503 8ad51794 2004-03-25 devnull 	uint q0, q1;
504 8ad51794 2004-03-25 devnull 	int deltap;
505 8ad51794 2004-03-25 devnull 
506 8ad51794 2004-03-25 devnull 	q0 = e->q0;
507 8ad51794 2004-03-25 devnull 	q1 = e->q1;
508 8ad51794 2004-03-25 devnull 	if(q1 <= q.p)
509 8ad51794 2004-03-25 devnull 		return e->q1-e->q0;
510 8ad51794 2004-03-25 devnull 	if(q0 >= q.p+ntyper)
511 8ad51794 2004-03-25 devnull 		return 0;
512 8ad51794 2004-03-25 devnull 	deltap = 0;
513 8ad51794 2004-03-25 devnull 	if(q0 < q.p){
514 8ad51794 2004-03-25 devnull 		deltap = q.p-q0;
515 8ad51794 2004-03-25 devnull 		q0 = 0;
516 8ad51794 2004-03-25 devnull 	}else
517 8ad51794 2004-03-25 devnull 		q0 -= q.p;
518 8ad51794 2004-03-25 devnull 	if(q1 > q.p+ntyper)
519 8ad51794 2004-03-25 devnull 		q1 = ntyper;
520 8ad51794 2004-03-25 devnull 	else
521 8ad51794 2004-03-25 devnull 		q1 -= q.p;
522 8ad51794 2004-03-25 devnull 	deltype(q0, q1);
523 8ad51794 2004-03-25 devnull 	return deltap;
524 8ad51794 2004-03-25 devnull }
525 8ad51794 2004-03-25 devnull 
526 8ad51794 2004-03-25 devnull void
527 8ad51794 2004-03-25 devnull addtype(int c, uint p0, char *b, int nb, int nr)
528 8ad51794 2004-03-25 devnull {
529 8ad51794 2004-03-25 devnull 	int i, w;
530 8ad51794 2004-03-25 devnull 	Rune r;
531 8ad51794 2004-03-25 devnull 	uint p;
532 8ad51794 2004-03-25 devnull 	char *b0;
533 8ad51794 2004-03-25 devnull 
534 8ad51794 2004-03-25 devnull 	for(i=0; i<nb; i+=w){
535 8ad51794 2004-03-25 devnull 		w = chartorune(&r, b+i);
536 8ad51794 2004-03-25 devnull 		if((r==0x7F||r==3) && c=='K'){
537 8ad51794 2004-03-25 devnull 			write(rcfd, "\x7F", 1);
538 8ad51794 2004-03-25 devnull 			/* toss all typing */
539 8ad51794 2004-03-25 devnull 			q.p += ntyper+nr;
540 8ad51794 2004-03-25 devnull 			ntypebreak = 0;
541 8ad51794 2004-03-25 devnull 			ntypeb = 0;
542 8ad51794 2004-03-25 devnull 			ntyper = 0;
543 8ad51794 2004-03-25 devnull 			/* buglet:  more than one delete ignored */
544 8ad51794 2004-03-25 devnull 			return;
545 8ad51794 2004-03-25 devnull 		}
546 8ad51794 2004-03-25 devnull 		if(r=='\n' || r==0x04)
547 8ad51794 2004-03-25 devnull 			ntypebreak++;
548 8ad51794 2004-03-25 devnull 	}
549 8ad51794 2004-03-25 devnull 	typing = realloc(typing, ntypeb+nb);
550 8ad51794 2004-03-25 devnull 	if(typing == nil)
551 8ad51794 2004-03-25 devnull 		error("realloc");
552 8ad51794 2004-03-25 devnull 	if(p0 == ntyper)
553 8ad51794 2004-03-25 devnull 		memmove(typing+ntypeb, b, nb);
554 8ad51794 2004-03-25 devnull 	else{
555 8ad51794 2004-03-25 devnull 		b0 = typing;
556 8ad51794 2004-03-25 devnull 		for(p=0; p<p0 && b0<typing+ntypeb; p++){
557 8ad51794 2004-03-25 devnull 			w = chartorune(&r, b0+i);
558 8ad51794 2004-03-25 devnull 			b0 += w;
559 8ad51794 2004-03-25 devnull 		}
560 8ad51794 2004-03-25 devnull 		if(p != p0)
561 8ad51794 2004-03-25 devnull 			error("typing: findrune");
562 8ad51794 2004-03-25 devnull 		memmove(b0+nb, b0, (typing+ntypeb)-b0);
563 8ad51794 2004-03-25 devnull 		memmove(b0, b, nb);
564 8ad51794 2004-03-25 devnull 	}
565 8ad51794 2004-03-25 devnull 	ntypeb += nb;
566 8ad51794 2004-03-25 devnull 	ntyper += nr;
567 8ad51794 2004-03-25 devnull }
568 8ad51794 2004-03-25 devnull 
569 8ad51794 2004-03-25 devnull void
570 8ad51794 2004-03-25 devnull sendtype(int fd0)
571 8ad51794 2004-03-25 devnull {
572 8ad51794 2004-03-25 devnull 	int i, n, nr;
573 8ad51794 2004-03-25 devnull 
574 8ad51794 2004-03-25 devnull 	while(ntypebreak){
575 8ad51794 2004-03-25 devnull 		for(i=0; i<ntypeb; i++)
576 8ad51794 2004-03-25 devnull 			if(typing[i]=='\n' || typing[i]==0x04){
577 4f30f3b4 2004-03-30 devnull 				n = i+1;
578 8ad51794 2004-03-25 devnull 				i++;
579 8ad51794 2004-03-25 devnull 				if(write(fd0, typing, n) != n)
580 8ad51794 2004-03-25 devnull 					error("sending to program");
581 8ad51794 2004-03-25 devnull 				nr = nrunes(typing, i);
582 8ad51794 2004-03-25 devnull 				q.p += nr;
583 8ad51794 2004-03-25 devnull 				ntyper -= nr;
584 8ad51794 2004-03-25 devnull 				ntypeb -= i;
585 8ad51794 2004-03-25 devnull 				memmove(typing, typing+i, ntypeb);
586 8ad51794 2004-03-25 devnull 				ntypebreak--;
587 8ad51794 2004-03-25 devnull 				goto cont2;
588 8ad51794 2004-03-25 devnull 			}
589 8ad51794 2004-03-25 devnull 		print("no breakchar\n");
590 8ad51794 2004-03-25 devnull 		ntypebreak = 0;
591 8ad51794 2004-03-25 devnull cont2:;
592 8ad51794 2004-03-25 devnull 	}
593 8ad51794 2004-03-25 devnull }
594 8ad51794 2004-03-25 devnull 
595 8ad51794 2004-03-25 devnull void
596 8ad51794 2004-03-25 devnull deltype(uint p0, uint p1)
597 8ad51794 2004-03-25 devnull {
598 8ad51794 2004-03-25 devnull 	int w;
599 8ad51794 2004-03-25 devnull 	uint p, b0, b1;
600 8ad51794 2004-03-25 devnull 	Rune r;
601 8ad51794 2004-03-25 devnull 
602 8ad51794 2004-03-25 devnull 	/* advance to p0 */
603 8ad51794 2004-03-25 devnull 	b0 = 0;
604 8ad51794 2004-03-25 devnull 	for(p=0; p<p0 && b0<ntypeb; p++){
605 8ad51794 2004-03-25 devnull 		w = chartorune(&r, typing+b0);
606 8ad51794 2004-03-25 devnull 		b0 += w;
607 8ad51794 2004-03-25 devnull 	}
608 8ad51794 2004-03-25 devnull 	if(p != p0)
609 8ad51794 2004-03-25 devnull 		error("deltype 1");
610 8ad51794 2004-03-25 devnull 	/* advance to p1 */
611 8ad51794 2004-03-25 devnull 	b1 = b0;
612 8ad51794 2004-03-25 devnull 	for(; p<p1 && b1<ntypeb; p++){
613 8ad51794 2004-03-25 devnull 		w = chartorune(&r, typing+b1);
614 8ad51794 2004-03-25 devnull 		b1 += w;
615 8ad51794 2004-03-25 devnull 		if(r=='\n' || r==0x04)
616 8ad51794 2004-03-25 devnull 			ntypebreak--;
617 8ad51794 2004-03-25 devnull 	}
618 8ad51794 2004-03-25 devnull 	if(p != p1)
619 8ad51794 2004-03-25 devnull 		error("deltype 2");
620 8ad51794 2004-03-25 devnull 	memmove(typing+b0, typing+b1, ntypeb-b1);
621 8ad51794 2004-03-25 devnull 	ntypeb -= b1-b0;
622 8ad51794 2004-03-25 devnull 	ntyper -= p1-p0;
623 8ad51794 2004-03-25 devnull }
624 8ad51794 2004-03-25 devnull 
625 8ad51794 2004-03-25 devnull void
626 8ad51794 2004-03-25 devnull type(Event *e, int fd0, Fid *afd, Fid *dfd)
627 8ad51794 2004-03-25 devnull {
628 8ad51794 2004-03-25 devnull 	int m, n, nr;
629 8ad51794 2004-03-25 devnull 	char buf[128];
630 8ad51794 2004-03-25 devnull 
631 8ad51794 2004-03-25 devnull 	if(e->nr > 0)
632 8ad51794 2004-03-25 devnull 		addtype(e->c1, e->q0-q.p, e->b, e->nb, e->nr);
633 8ad51794 2004-03-25 devnull 	else{
634 8ad51794 2004-03-25 devnull 		m = e->q0;
635 8ad51794 2004-03-25 devnull 		while(m < e->q1){
636 8ad51794 2004-03-25 devnull 			n = sprint(buf, "#%d", m);
637 8ad51794 2004-03-25 devnull 			fswrite(afd, buf, n);
638 8ad51794 2004-03-25 devnull 			n = fsread(dfd, buf, sizeof buf);
639 8ad51794 2004-03-25 devnull 			nr = nrunes(buf, n);
640 8ad51794 2004-03-25 devnull 			while(m+nr > e->q1){
641 8ad51794 2004-03-25 devnull 				do; while(n>0 && (buf[--n]&0xC0)==0x80);
642 8ad51794 2004-03-25 devnull 				--nr;
643 8ad51794 2004-03-25 devnull 			}
644 8ad51794 2004-03-25 devnull 			if(n == 0)
645 8ad51794 2004-03-25 devnull 				break;
646 8ad51794 2004-03-25 devnull 			addtype(e->c1, m-q.p, buf, n, nr);
647 8ad51794 2004-03-25 devnull 			m += nr;
648 8ad51794 2004-03-25 devnull 		}
649 8ad51794 2004-03-25 devnull 	}
650 8ad51794 2004-03-25 devnull 	sendtype(fd0);
651 8ad51794 2004-03-25 devnull }
652 8ad51794 2004-03-25 devnull 
653 8ad51794 2004-03-25 devnull void
654 8ad51794 2004-03-25 devnull sende(Event *e, int fd0, Fid *cfd, Fid *afd, Fid *dfd, int donl)
655 8ad51794 2004-03-25 devnull {
656 8ad51794 2004-03-25 devnull 	int l, m, n, nr, lastc, end;
657 8ad51794 2004-03-25 devnull 	char abuf[16], buf[128];
658 8ad51794 2004-03-25 devnull 
659 8ad51794 2004-03-25 devnull 	end = q.p+ntyper;
660 8ad51794 2004-03-25 devnull 	l = sprint(abuf, "#%d", end);
661 8ad51794 2004-03-25 devnull 	fswrite(afd, abuf, l);
662 8ad51794 2004-03-25 devnull 	if(e->nr > 0){
663 8ad51794 2004-03-25 devnull 		fswrite(dfd, e->b, e->nb);
664 8ad51794 2004-03-25 devnull 		addtype(e->c1, ntyper, e->b, e->nb, e->nr);
665 8ad51794 2004-03-25 devnull 		lastc = e->r[e->nr-1];
666 8ad51794 2004-03-25 devnull 	}else{
667 8ad51794 2004-03-25 devnull 		m = e->q0;
668 8ad51794 2004-03-25 devnull 		lastc = 0;
669 8ad51794 2004-03-25 devnull 		while(m < e->q1){
670 8ad51794 2004-03-25 devnull 			n = sprint(buf, "#%d", m);
671 8ad51794 2004-03-25 devnull 			fswrite(afd, buf, n);
672 8ad51794 2004-03-25 devnull 			n = fsread(dfd, buf, sizeof buf);
673 8ad51794 2004-03-25 devnull 			nr = nrunes(buf, n);
674 8ad51794 2004-03-25 devnull 			while(m+nr > e->q1){
675 8ad51794 2004-03-25 devnull 				do; while(n>0 && (buf[--n]&0xC0)==0x80);
676 8ad51794 2004-03-25 devnull 				--nr;
677 8ad51794 2004-03-25 devnull 			}
678 8ad51794 2004-03-25 devnull 			if(n == 0)
679 8ad51794 2004-03-25 devnull 				break;
680 8ad51794 2004-03-25 devnull 			l = sprint(abuf, "#%d", end);
681 8ad51794 2004-03-25 devnull 			fswrite(afd, abuf, l);
682 8ad51794 2004-03-25 devnull 			fswrite(dfd, buf, n);
683 8ad51794 2004-03-25 devnull 			addtype(e->c1, ntyper, buf, n, nr);
684 8ad51794 2004-03-25 devnull 			lastc = buf[n-1];
685 8ad51794 2004-03-25 devnull 			m += nr;
686 8ad51794 2004-03-25 devnull 			end += nr;
687 8ad51794 2004-03-25 devnull 		}
688 8ad51794 2004-03-25 devnull 	}
689 8ad51794 2004-03-25 devnull 	if(donl && lastc!='\n'){
690 8ad51794 2004-03-25 devnull 		fswrite(dfd, "\n", 1);
691 8ad51794 2004-03-25 devnull 		addtype(e->c1, ntyper, "\n", 1, 1);
692 8ad51794 2004-03-25 devnull 	}
693 8ad51794 2004-03-25 devnull 	fswrite(cfd, "dot=addr", 8);
694 8ad51794 2004-03-25 devnull 	sendtype(fd0);
695 8ad51794 2004-03-25 devnull }