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 452c0935 2005-01-04 devnull #include <9pclient.h>
  6 8ad51794 2004-03-25 devnull #include "term.h"
  7 b4a659b6 2004-04-19 devnull 
  8 8ad51794 2004-03-25 devnull 
  9 8ad51794 2004-03-25 devnull #define	EVENTSIZE	256
 10 8ad51794 2004-03-25 devnull #define	STACK	32768
 11 8ad51794 2004-03-25 devnull 
 12 8ad51794 2004-03-25 devnull typedef struct Event Event;
 13 8ad51794 2004-03-25 devnull typedef struct Q Q;
 14 8ad51794 2004-03-25 devnull 
 15 8ad51794 2004-03-25 devnull struct Event
 16 8ad51794 2004-03-25 devnull {
 17 8ad51794 2004-03-25 devnull 	int	c1;
 18 8ad51794 2004-03-25 devnull 	int	c2;
 19 8ad51794 2004-03-25 devnull 	int	q0;
 20 8ad51794 2004-03-25 devnull 	int	q1;
 21 8ad51794 2004-03-25 devnull 	int	flag;
 22 8ad51794 2004-03-25 devnull 	int	nb;
 23 8ad51794 2004-03-25 devnull 	int	nr;
 24 8ad51794 2004-03-25 devnull 	char	b[EVENTSIZE*UTFmax+1];
 25 8ad51794 2004-03-25 devnull 	Rune	r[EVENTSIZE+1];
 26 8ad51794 2004-03-25 devnull };
 27 8ad51794 2004-03-25 devnull 
 28 8ad51794 2004-03-25 devnull Event blank = {
 29 8ad51794 2004-03-25 devnull 	'M',
 30 8ad51794 2004-03-25 devnull 	'X',
 31 8ad51794 2004-03-25 devnull 	0, 0, 0, 1, 1,
 32 8ad51794 2004-03-25 devnull 	{ ' ', 0 },
 33 cbeb0b26 2006-04-01 devnull 	{ ' ', 0 }
 34 8ad51794 2004-03-25 devnull };
 35 8ad51794 2004-03-25 devnull 
 36 8ad51794 2004-03-25 devnull struct Q
 37 8ad51794 2004-03-25 devnull {
 38 8ad51794 2004-03-25 devnull 	QLock	lk;
 39 8ad51794 2004-03-25 devnull 	int		p;
 40 8ad51794 2004-03-25 devnull 	int		k;
 41 8ad51794 2004-03-25 devnull };
 42 8ad51794 2004-03-25 devnull 
 43 8ad51794 2004-03-25 devnull Q	q;
 44 8ad51794 2004-03-25 devnull 
 45 452c0935 2005-01-04 devnull CFid *eventfd;
 46 452c0935 2005-01-04 devnull CFid *addrfd;
 47 452c0935 2005-01-04 devnull CFid *datafd;
 48 452c0935 2005-01-04 devnull CFid *ctlfd;
 49 cbeb0b26 2006-04-01 devnull /* int bodyfd; */
 50 8ad51794 2004-03-25 devnull 
 51 8ad51794 2004-03-25 devnull char	*typing;
 52 8ad51794 2004-03-25 devnull int	ntypeb;
 53 8ad51794 2004-03-25 devnull int	ntyper;
 54 8ad51794 2004-03-25 devnull int	ntypebreak;
 55 8ad51794 2004-03-25 devnull int	debug;
 56 8ad51794 2004-03-25 devnull int	rcfd;
 57 c8471ac5 2010-10-13 rsc int	cook = 1;
 58 c8471ac5 2010-10-13 rsc int	password;
 59 c8471ac5 2010-10-13 rsc int	israw(int);
 60 8ad51794 2004-03-25 devnull 
 61 8ad51794 2004-03-25 devnull char *name;
 62 8ad51794 2004-03-25 devnull 
 63 8ad51794 2004-03-25 devnull char **prog;
 64 8ad51794 2004-03-25 devnull Channel *cwait;
 65 8ad51794 2004-03-25 devnull int pid = -1;
 66 8ad51794 2004-03-25 devnull 
 67 8ad51794 2004-03-25 devnull int	label(char*, int);
 68 4b970769 2005-03-05 devnull void	error(char*, ...);
 69 8ad51794 2004-03-25 devnull void	stdinproc(void*);
 70 8ad51794 2004-03-25 devnull void	stdoutproc(void*);
 71 452c0935 2005-01-04 devnull void	type(Event*, int, CFid*, CFid*);
 72 452c0935 2005-01-04 devnull void	sende(Event*, int, CFid*, CFid*, CFid*, int);
 73 8ad51794 2004-03-25 devnull char	*onestring(int, char**);
 74 8ad51794 2004-03-25 devnull int	delete(Event*);
 75 8ad51794 2004-03-25 devnull void	deltype(uint, uint);
 76 ef5c6a6e 2010-09-03 rsc void	sendbs(int, int);
 77 8ad51794 2004-03-25 devnull void	runproc(void*);
 78 8ad51794 2004-03-25 devnull 
 79 8ad51794 2004-03-25 devnull int
 80 452c0935 2005-01-04 devnull fsfidprint(CFid *fid, char *fmt, ...)
 81 8ad51794 2004-03-25 devnull {
 82 8ad51794 2004-03-25 devnull 	char buf[256];
 83 8ad51794 2004-03-25 devnull 	va_list arg;
 84 8ad51794 2004-03-25 devnull 	int n;
 85 8ad51794 2004-03-25 devnull 
 86 8ad51794 2004-03-25 devnull 	va_start(arg, fmt);
 87 8ad51794 2004-03-25 devnull 	n = vsnprint(buf, sizeof buf, fmt, arg);
 88 8ad51794 2004-03-25 devnull 	va_end(arg);
 89 8ad51794 2004-03-25 devnull 	return fswrite(fid, buf, n);
 90 8ad51794 2004-03-25 devnull }
 91 8ad51794 2004-03-25 devnull 
 92 8ad51794 2004-03-25 devnull void
 93 8ad51794 2004-03-25 devnull usage(void)
 94 8ad51794 2004-03-25 devnull {
 95 8ad51794 2004-03-25 devnull 	fprint(2, "usage: win cmd args...\n");
 96 8ad51794 2004-03-25 devnull 	threadexitsall("usage");
 97 8ad51794 2004-03-25 devnull }
 98 8ad51794 2004-03-25 devnull 
 99 8ad51794 2004-03-25 devnull void
100 8ad51794 2004-03-25 devnull waitthread(void *v)
101 8ad51794 2004-03-25 devnull {
102 8ad51794 2004-03-25 devnull 	recvp(cwait);
103 8ad51794 2004-03-25 devnull 	threadexitsall(nil);
104 60535a5f 2004-12-26 devnull }
105 60535a5f 2004-12-26 devnull 
106 60535a5f 2004-12-26 devnull void
107 60535a5f 2004-12-26 devnull hangupnote(void *a, char *msg)
108 60535a5f 2004-12-26 devnull {
109 60535a5f 2004-12-26 devnull 	if(strcmp(msg, "hangup") == 0 && pid != 0){
110 60535a5f 2004-12-26 devnull 		postnote(PNGROUP, pid, "hangup");
111 60535a5f 2004-12-26 devnull 		noted(NDFLT);
112 60535a5f 2004-12-26 devnull 	}
113 60535a5f 2004-12-26 devnull 	if(strstr(msg, "child")){
114 6a6c2663 2010-01-05 rsc 		char buf[128];
115 6a6c2663 2010-01-05 rsc 		int n;
116 6a6c2663 2010-01-05 rsc 
117 6a6c2663 2010-01-05 rsc 		n = awaitnohang(buf, sizeof buf-1);
118 6a6c2663 2010-01-05 rsc 		if(n > 0){
119 6a6c2663 2010-01-05 rsc 			buf[n] = 0;
120 6a6c2663 2010-01-05 rsc 			if(atoi(buf) == pid)
121 6a6c2663 2010-01-05 rsc 				threadexitsall(0);
122 6a6c2663 2010-01-05 rsc 		}
123 6a6c2663 2010-01-05 rsc 		noted(NCONT);
124 60535a5f 2004-12-26 devnull 	}
125 60535a5f 2004-12-26 devnull 	noted(NDFLT);
126 8ad51794 2004-03-25 devnull }
127 8ad51794 2004-03-25 devnull 
128 8ad51794 2004-03-25 devnull void
129 8ad51794 2004-03-25 devnull threadmain(int argc, char **argv)
130 8ad51794 2004-03-25 devnull {
131 8ad51794 2004-03-25 devnull 	int fd, id;
132 8ad51794 2004-03-25 devnull 	char buf[256];
133 8ad51794 2004-03-25 devnull 	char buf1[128];
134 452c0935 2005-01-04 devnull 	CFsys *fs;
135 adcb656c 2007-04-17 devnull 	char *dump;
136 adcb656c 2007-04-17 devnull 	
137 adcb656c 2007-04-17 devnull 	dump = onestring(argc, argv);
138 8ad51794 2004-03-25 devnull 
139 8ad51794 2004-03-25 devnull 	ARGBEGIN{
140 8ad51794 2004-03-25 devnull 	case 'd':
141 8ad51794 2004-03-25 devnull 		debug = 1;
142 8ad51794 2004-03-25 devnull 		break;
143 b1455f33 2004-04-30 devnull 	case 'n':
144 b1455f33 2004-04-30 devnull 		name = EARGF(usage());
145 b1455f33 2004-04-30 devnull 		break;
146 8ad51794 2004-03-25 devnull 	default:
147 8ad51794 2004-03-25 devnull 		usage();
148 8ad51794 2004-03-25 devnull 	}ARGEND
149 8ad51794 2004-03-25 devnull 
150 8ad51794 2004-03-25 devnull 	prog = argv;
151 8ad51794 2004-03-25 devnull 
152 b1455f33 2004-04-30 devnull 	if(name == nil){
153 b1455f33 2004-04-30 devnull 		if(argc > 0)
154 b1455f33 2004-04-30 devnull 			name = argv[0];
155 b1455f33 2004-04-30 devnull 		else{
156 b1455f33 2004-04-30 devnull 			name = sysname();
157 b1455f33 2004-04-30 devnull 			if(name == nil)
158 b1455f33 2004-04-30 devnull 				name = "gnot";
159 b1455f33 2004-04-30 devnull 		}
160 b1455f33 2004-04-30 devnull 	}
161 8ad51794 2004-03-25 devnull 
162 65a34c7f 2009-01-06 rsc 	/*
163 65a34c7f 2009-01-06 rsc 	 * notedisable("sys: write on closed pipe");
164 65a34c7f 2009-01-06 rsc 	 * not okay to disable the note, because that
165 65a34c7f 2009-01-06 rsc 	 * gets inherited by the subshell, so that something
166 65a34c7f 2009-01-06 rsc 	 * as simple as "yes | sed 10q" never exits.
167 65a34c7f 2009-01-06 rsc 	 * call notifyoff instead.  (is notedisable ever safe?)
168 65a34c7f 2009-01-06 rsc 	 */
169 65a34c7f 2009-01-06 rsc 	notifyoff("sys: write on closed pipe");
170 65a34c7f 2009-01-06 rsc 
171 60535a5f 2004-12-26 devnull 	noteenable("sys: child");
172 60535a5f 2004-12-26 devnull 	notify(hangupnote);
173 60535a5f 2004-12-26 devnull 
174 be22ae2d 2004-03-26 devnull 	if((fs = nsmount("acme", "")) == 0)
175 8ad51794 2004-03-25 devnull 		sysfatal("nsmount acme: %r");
176 8ad51794 2004-03-25 devnull 	ctlfd = fsopen(fs, "new/ctl", ORDWR|OCEXEC);
177 be22ae2d 2004-03-26 devnull 	if(ctlfd == 0 || fsread(ctlfd, buf, 12) != 12)
178 8ad51794 2004-03-25 devnull 		sysfatal("ctl: %r");
179 8ad51794 2004-03-25 devnull 	id = atoi(buf);
180 2d930d45 2004-04-25 devnull 	snprint(buf, sizeof buf, "%d", id);
181 2d930d45 2004-04-25 devnull 	putenv("winid", buf);
182 8ad51794 2004-03-25 devnull 	sprint(buf, "%d/tag", id);
183 8ad51794 2004-03-25 devnull 	fd = fsopenfd(fs, buf, OWRITE|OCEXEC);
184 ba31ab30 2011-04-27 rsc 	write(fd, " Send", 1+4);
185 8ad51794 2004-03-25 devnull 	close(fd);
186 8ad51794 2004-03-25 devnull 	sprint(buf, "%d/event", id);
187 8ad51794 2004-03-25 devnull 	eventfd = fsopen(fs, buf, ORDWR|OCEXEC);
188 8ad51794 2004-03-25 devnull 	sprint(buf, "%d/addr", id);
189 8ad51794 2004-03-25 devnull 	addrfd = fsopen(fs, buf, ORDWR|OCEXEC);
190 8ad51794 2004-03-25 devnull 	sprint(buf, "%d/data", id);
191 8ad51794 2004-03-25 devnull 	datafd = fsopen(fs, buf, ORDWR|OCEXEC);
192 8ad51794 2004-03-25 devnull 	sprint(buf, "%d/body", id);
193 8ad51794 2004-03-25 devnull /*	bodyfd = fsopenfd(fs, buf, ORDWR|OCEXEC); */
194 8ad51794 2004-03-25 devnull 	if(eventfd==nil || addrfd==nil || datafd==nil)
195 8ad51794 2004-03-25 devnull 		sysfatal("data files: %r");
196 8ad51794 2004-03-25 devnull /*
197 8ad51794 2004-03-25 devnull 	if(eventfd<0 || addrfd<0 || datafd<0 || bodyfd<0)
198 8ad51794 2004-03-25 devnull 		sysfatal("data files: %r");
199 8ad51794 2004-03-25 devnull */
200 8ad51794 2004-03-25 devnull 	fsunmount(fs);
201 8ad51794 2004-03-25 devnull 
202 8ad51794 2004-03-25 devnull 	cwait = threadwaitchan();
203 8ad51794 2004-03-25 devnull 	threadcreate(waitthread, nil, STACK);
204 4dcd9af2 2004-04-15 devnull 	pid = rcstart(argc, argv, &rcfd, nil);
205 8ad51794 2004-03-25 devnull 	if(pid == -1)
206 8ad51794 2004-03-25 devnull 		sysfatal("exec failed");
207 8ad51794 2004-03-25 devnull 
208 8ad51794 2004-03-25 devnull 	getwd(buf1, sizeof buf1);
209 8ad51794 2004-03-25 devnull 	sprint(buf, "name %s/-%s\n0\n", buf1, name);
210 8ad51794 2004-03-25 devnull 	fswrite(ctlfd, buf, strlen(buf));
211 8ad51794 2004-03-25 devnull 	sprint(buf, "dumpdir %s/\n", buf1);
212 8ad51794 2004-03-25 devnull 	fswrite(ctlfd, buf, strlen(buf));
213 adcb656c 2007-04-17 devnull 	sprint(buf, "dump %s\n", dump);
214 8ad51794 2004-03-25 devnull 	fswrite(ctlfd, buf, strlen(buf));
215 e1118cf2 2008-11-13 rsc 	sprint(buf, "scroll");
216 e1118cf2 2008-11-13 rsc 	fswrite(ctlfd, buf, strlen(buf));
217 8ad51794 2004-03-25 devnull 	
218 5e0f7e8a 2004-04-23 devnull 	updatewinsize(25, 80, 0, 0);
219 60535a5f 2004-12-26 devnull 	proccreate(stdoutproc, nil, STACK);
220 8ad51794 2004-03-25 devnull 	stdinproc(nil);
221 8ad51794 2004-03-25 devnull }
222 8ad51794 2004-03-25 devnull 
223 8ad51794 2004-03-25 devnull void
224 4b970769 2005-03-05 devnull error(char *s, ...)
225 8ad51794 2004-03-25 devnull {
226 4b970769 2005-03-05 devnull 	va_list arg;
227 4b970769 2005-03-05 devnull 	
228 4b970769 2005-03-05 devnull 	if(s){
229 4b970769 2005-03-05 devnull 		va_start(arg, s);
230 4b970769 2005-03-05 devnull 		s = vsmprint(s, arg);
231 4b970769 2005-03-05 devnull 		va_end(arg);
232 8ad51794 2004-03-25 devnull 		fprint(2, "win: %s: %r\n", s);
233 0aa79278 2006-03-27 devnull 	}
234 8ad51794 2004-03-25 devnull 	if(pid != -1)
235 8ad51794 2004-03-25 devnull 		postnote(PNGROUP, pid, "hangup");
236 8ad51794 2004-03-25 devnull 	threadexitsall(s);
237 8ad51794 2004-03-25 devnull }
238 8ad51794 2004-03-25 devnull 
239 8ad51794 2004-03-25 devnull char*
240 8ad51794 2004-03-25 devnull onestring(int argc, char **argv)
241 8ad51794 2004-03-25 devnull {
242 8ad51794 2004-03-25 devnull 	char *p;
243 8ad51794 2004-03-25 devnull 	int i, n;
244 8ad51794 2004-03-25 devnull 	static char buf[1024];
245 8ad51794 2004-03-25 devnull 
246 8ad51794 2004-03-25 devnull 	if(argc == 0)
247 8ad51794 2004-03-25 devnull 		return "";
248 8ad51794 2004-03-25 devnull 	p = buf;
249 8ad51794 2004-03-25 devnull 	for(i=0; i<argc; i++){
250 8ad51794 2004-03-25 devnull 		n = strlen(argv[i]);
251 8ad51794 2004-03-25 devnull 		if(p+n+1 >= buf+sizeof buf)
252 8ad51794 2004-03-25 devnull 			break;
253 8ad51794 2004-03-25 devnull 		memmove(p, argv[i], n);
254 8ad51794 2004-03-25 devnull 		p += n;
255 8ad51794 2004-03-25 devnull 		*p++ = ' ';
256 8ad51794 2004-03-25 devnull 	}
257 8ad51794 2004-03-25 devnull 	p[-1] = 0;
258 8ad51794 2004-03-25 devnull 	return buf;
259 8ad51794 2004-03-25 devnull }
260 8ad51794 2004-03-25 devnull 
261 8ad51794 2004-03-25 devnull int
262 452c0935 2005-01-04 devnull getec(CFid *efd)
263 8ad51794 2004-03-25 devnull {
264 8ad51794 2004-03-25 devnull 	static char buf[8192];
265 8ad51794 2004-03-25 devnull 	static char *bufp;
266 8ad51794 2004-03-25 devnull 	static int nbuf;
267 8ad51794 2004-03-25 devnull 
268 8ad51794 2004-03-25 devnull 	if(nbuf == 0){
269 8ad51794 2004-03-25 devnull 		nbuf = fsread(efd, buf, sizeof buf);
270 8ad51794 2004-03-25 devnull 		if(nbuf <= 0)
271 8ad51794 2004-03-25 devnull 			error(nil);
272 8ad51794 2004-03-25 devnull 		bufp = buf;
273 8ad51794 2004-03-25 devnull 	}
274 8ad51794 2004-03-25 devnull 	--nbuf;
275 8ad51794 2004-03-25 devnull 	return *bufp++;
276 8ad51794 2004-03-25 devnull }
277 8ad51794 2004-03-25 devnull 
278 8ad51794 2004-03-25 devnull int
279 452c0935 2005-01-04 devnull geten(CFid *efd)
280 8ad51794 2004-03-25 devnull {
281 8ad51794 2004-03-25 devnull 	int n, c;
282 8ad51794 2004-03-25 devnull 
283 8ad51794 2004-03-25 devnull 	n = 0;
284 8ad51794 2004-03-25 devnull 	while('0'<=(c=getec(efd)) && c<='9')
285 8ad51794 2004-03-25 devnull 		n = n*10+(c-'0');
286 8ad51794 2004-03-25 devnull 	if(c != ' ')
287 8ad51794 2004-03-25 devnull 		error("event number syntax");
288 8ad51794 2004-03-25 devnull 	return n;
289 8ad51794 2004-03-25 devnull }
290 8ad51794 2004-03-25 devnull 
291 8ad51794 2004-03-25 devnull int
292 452c0935 2005-01-04 devnull geter(CFid *efd, char *buf, int *nb)
293 8ad51794 2004-03-25 devnull {
294 8ad51794 2004-03-25 devnull 	Rune r;
295 8ad51794 2004-03-25 devnull 	int n;
296 8ad51794 2004-03-25 devnull 
297 8ad51794 2004-03-25 devnull 	r = getec(efd);
298 8ad51794 2004-03-25 devnull 	buf[0] = r;
299 8ad51794 2004-03-25 devnull 	n = 1;
300 8ad51794 2004-03-25 devnull 	if(r < Runeself)
301 8ad51794 2004-03-25 devnull 		goto Return;
302 8ad51794 2004-03-25 devnull 	while(!fullrune(buf, n))
303 8ad51794 2004-03-25 devnull 		buf[n++] = getec(efd);
304 8ad51794 2004-03-25 devnull 	chartorune(&r, buf);
305 8ad51794 2004-03-25 devnull     Return:
306 8ad51794 2004-03-25 devnull 	*nb = n;
307 8ad51794 2004-03-25 devnull 	return r;
308 8ad51794 2004-03-25 devnull }
309 8ad51794 2004-03-25 devnull 
310 8ad51794 2004-03-25 devnull void
311 452c0935 2005-01-04 devnull gete(CFid *efd, Event *e)
312 8ad51794 2004-03-25 devnull {
313 8ad51794 2004-03-25 devnull 	int i, nb;
314 8ad51794 2004-03-25 devnull 
315 8ad51794 2004-03-25 devnull 	e->c1 = getec(efd);
316 8ad51794 2004-03-25 devnull 	e->c2 = getec(efd);
317 8ad51794 2004-03-25 devnull 	e->q0 = geten(efd);
318 8ad51794 2004-03-25 devnull 	e->q1 = geten(efd);
319 8ad51794 2004-03-25 devnull 	e->flag = geten(efd);
320 8ad51794 2004-03-25 devnull 	e->nr = geten(efd);
321 8ad51794 2004-03-25 devnull 	if(e->nr > EVENTSIZE)
322 8ad51794 2004-03-25 devnull 		error("event string too long");
323 8ad51794 2004-03-25 devnull 	e->nb = 0;
324 8ad51794 2004-03-25 devnull 	for(i=0; i<e->nr; i++){
325 8ad51794 2004-03-25 devnull 		e->r[i] = geter(efd, e->b+e->nb, &nb);
326 8ad51794 2004-03-25 devnull 		e->nb += nb;
327 8ad51794 2004-03-25 devnull 	}
328 8ad51794 2004-03-25 devnull 	e->r[e->nr] = 0;
329 8ad51794 2004-03-25 devnull 	e->b[e->nb] = 0;
330 8ad51794 2004-03-25 devnull 	if(getec(efd) != '\n')
331 8ad51794 2004-03-25 devnull 		error("event syntax 2");
332 8ad51794 2004-03-25 devnull }
333 8ad51794 2004-03-25 devnull 
334 8ad51794 2004-03-25 devnull int
335 8ad51794 2004-03-25 devnull nrunes(char *s, int nb)
336 8ad51794 2004-03-25 devnull {
337 8ad51794 2004-03-25 devnull 	int i, n;
338 8ad51794 2004-03-25 devnull 	Rune r;
339 8ad51794 2004-03-25 devnull 
340 8ad51794 2004-03-25 devnull 	n = 0;
341 8ad51794 2004-03-25 devnull 	for(i=0; i<nb; n++)
342 8ad51794 2004-03-25 devnull 		i += chartorune(&r, s+i);
343 8ad51794 2004-03-25 devnull 	return n;
344 8ad51794 2004-03-25 devnull }
345 8ad51794 2004-03-25 devnull 
346 8ad51794 2004-03-25 devnull void
347 8ad51794 2004-03-25 devnull stdinproc(void *v)
348 8ad51794 2004-03-25 devnull {
349 452c0935 2005-01-04 devnull 	CFid *cfd = ctlfd;
350 452c0935 2005-01-04 devnull 	CFid *efd = eventfd;
351 452c0935 2005-01-04 devnull 	CFid *dfd = datafd;
352 452c0935 2005-01-04 devnull 	CFid *afd = addrfd;
353 8ad51794 2004-03-25 devnull 	int fd0 = rcfd;
354 8ad51794 2004-03-25 devnull 	Event e, e2, e3, e4;
355 ef5c6a6e 2010-09-03 rsc 	int n;
356 8ad51794 2004-03-25 devnull 
357 8ad51794 2004-03-25 devnull 	USED(v);
358 8ad51794 2004-03-25 devnull 
359 8ad51794 2004-03-25 devnull 	for(;;){
360 8ad51794 2004-03-25 devnull 		if(debug)
361 8ad51794 2004-03-25 devnull 			fprint(2, "typing[%d,%d)\n", q.p, q.p+ntyper);
362 8ad51794 2004-03-25 devnull 		gete(efd, &e);
363 8ad51794 2004-03-25 devnull 		if(debug)
364 8ad51794 2004-03-25 devnull 			fprint(2, "msg %c%c q[%d,%d)... ", e.c1, e.c2, e.q0, e.q1);
365 8ad51794 2004-03-25 devnull 		qlock(&q.lk);
366 8ad51794 2004-03-25 devnull 		switch(e.c1){
367 8ad51794 2004-03-25 devnull 		default:
368 8ad51794 2004-03-25 devnull 		Unknown:
369 8ad51794 2004-03-25 devnull 			print("unknown message %c%c\n", e.c1, e.c2);
370 8ad51794 2004-03-25 devnull 			break;
371 8ad51794 2004-03-25 devnull 
372 6a6c2663 2010-01-05 rsc 		case 'E':	/* write to body or tag; can't affect us */
373 6a6c2663 2010-01-05 rsc 			switch(e.c2){
374 6a6c2663 2010-01-05 rsc 			case 'I':
375 6a6c2663 2010-01-05 rsc 			case 'D':		/* body */
376 6a6c2663 2010-01-05 rsc 				if(debug)
377 6a6c2663 2010-01-05 rsc 					fprint(2, "shift typing %d... ", e.q1-e.q0);
378 6a6c2663 2010-01-05 rsc 				q.p += e.q1-e.q0;
379 6a6c2663 2010-01-05 rsc 				break;
380 6a6c2663 2010-01-05 rsc 			
381 6a6c2663 2010-01-05 rsc 			case 'i':
382 6a6c2663 2010-01-05 rsc 			case 'd':		/* tag */
383 6a6c2663 2010-01-05 rsc 				break;
384 6a6c2663 2010-01-05 rsc 			
385 6a6c2663 2010-01-05 rsc 			default:
386 6a6c2663 2010-01-05 rsc 				goto Unknown;
387 6a6c2663 2010-01-05 rsc 			}
388 8ad51794 2004-03-25 devnull 			break;
389 8ad51794 2004-03-25 devnull 
390 8ad51794 2004-03-25 devnull 		case 'F':	/* generated by our actions; ignore */
391 8ad51794 2004-03-25 devnull 			break;
392 8ad51794 2004-03-25 devnull 
393 8ad51794 2004-03-25 devnull 		case 'K':
394 8ad51794 2004-03-25 devnull 		case 'M':
395 8ad51794 2004-03-25 devnull 			switch(e.c2){
396 8ad51794 2004-03-25 devnull 			case 'I':
397 d66973d2 2008-11-13 rsc 				if(e.nr == 1 && e.r[0] == 0x7F) {
398 95cb0f63 2008-11-14 rsc 					char buf[1];
399 d66973d2 2008-11-13 rsc 					fsprint(addrfd, "#%ud,#%ud", e.q0, e.q1);
400 d66973d2 2008-11-13 rsc 					fswrite(datafd, "", 0);
401 95cb0f63 2008-11-14 rsc 					buf[0] = 0x7F;
402 95cb0f63 2008-11-14 rsc 					write(fd0, buf, 1);
403 d66973d2 2008-11-13 rsc 					break;
404 d66973d2 2008-11-13 rsc 				}
405 8ad51794 2004-03-25 devnull 				if(e.q0 < q.p){
406 8ad51794 2004-03-25 devnull 					if(debug)
407 8ad51794 2004-03-25 devnull 						fprint(2, "shift typing %d... ", e.q1-e.q0);
408 8ad51794 2004-03-25 devnull 					q.p += e.q1-e.q0;
409 8ad51794 2004-03-25 devnull 				}
410 8ad51794 2004-03-25 devnull 				else if(e.q0 <= q.p+ntyper){
411 8ad51794 2004-03-25 devnull 					if(debug)
412 8ad51794 2004-03-25 devnull 						fprint(2, "type... ");
413 8ad51794 2004-03-25 devnull 					type(&e, fd0, afd, dfd);
414 8ad51794 2004-03-25 devnull 				}
415 8ad51794 2004-03-25 devnull 				break;
416 8ad51794 2004-03-25 devnull 
417 8ad51794 2004-03-25 devnull 			case 'D':
418 ef5c6a6e 2010-09-03 rsc 				n = delete(&e);
419 ef5c6a6e 2010-09-03 rsc 				q.p -= n;
420 c8471ac5 2010-10-13 rsc 				if(israw(fd0) && e.q1 >= q.p+n)
421 ef5c6a6e 2010-09-03 rsc 					sendbs(fd0, n);
422 8ad51794 2004-03-25 devnull 				break;
423 8ad51794 2004-03-25 devnull 
424 8ad51794 2004-03-25 devnull 			case 'x':
425 8ad51794 2004-03-25 devnull 			case 'X':
426 8ad51794 2004-03-25 devnull 				if(e.flag & 2)
427 8ad51794 2004-03-25 devnull 					gete(efd, &e2);
428 8ad51794 2004-03-25 devnull 				if(e.flag & 8){
429 8ad51794 2004-03-25 devnull 					gete(efd, &e3);
430 8ad51794 2004-03-25 devnull 					gete(efd, &e4);
431 8ad51794 2004-03-25 devnull 				}
432 8ad51794 2004-03-25 devnull 				if(e.flag&1 || (e.c2=='x' && e.nr==0 && e2.nr==0)){
433 8ad51794 2004-03-25 devnull 					/* send it straight back */
434 8ad51794 2004-03-25 devnull 					fsfidprint(efd, "%c%c%d %d\n", e.c1, e.c2, e.q0, e.q1);
435 8ad51794 2004-03-25 devnull 					break;
436 8ad51794 2004-03-25 devnull 				}
437 8ad51794 2004-03-25 devnull 				if(e.q0==e.q1 && (e.flag&2)){
438 8ad51794 2004-03-25 devnull 					e2.flag = e.flag;
439 8ad51794 2004-03-25 devnull 					e = e2;
440 e1118cf2 2008-11-13 rsc 				}
441 e1118cf2 2008-11-13 rsc 				char buf[100];
442 e1118cf2 2008-11-13 rsc 				snprint(buf, sizeof buf, "%.*S", e.nr, e.r);
443 875351f4 2010-09-10 rsc 				if(cistrcmp(buf, "cook") == 0) {
444 875351f4 2010-09-10 rsc 					cook = 1;
445 875351f4 2010-09-10 rsc 					break;
446 875351f4 2010-09-10 rsc 				}
447 875351f4 2010-09-10 rsc 				if(cistrcmp(buf, "nocook") == 0) {
448 875351f4 2010-09-10 rsc 					cook = 0;
449 875351f4 2010-09-10 rsc 					break;
450 875351f4 2010-09-10 rsc 				}
451 8ad51794 2004-03-25 devnull 				if(e.flag & 8){
452 8ad51794 2004-03-25 devnull 					if(e.q1 != e.q0){
453 8ad51794 2004-03-25 devnull 						sende(&e, fd0, cfd, afd, dfd, 0);
454 8ad51794 2004-03-25 devnull 						sende(&blank, fd0, cfd, afd, dfd, 0);
455 8ad51794 2004-03-25 devnull 					}
456 8ad51794 2004-03-25 devnull 					sende(&e3, fd0, cfd, afd, dfd, 1);
457 8ad51794 2004-03-25 devnull 				}else	 if(e.q1 != e.q0)
458 8ad51794 2004-03-25 devnull 					sende(&e, fd0, cfd, afd, dfd, 1);
459 8ad51794 2004-03-25 devnull 				break;
460 8ad51794 2004-03-25 devnull 
461 8ad51794 2004-03-25 devnull 			case 'l':
462 8ad51794 2004-03-25 devnull 			case 'L':
463 8ad51794 2004-03-25 devnull 				/* just send it back */
464 8ad51794 2004-03-25 devnull 				if(e.flag & 2)
465 8ad51794 2004-03-25 devnull 					gete(efd, &e2);
466 8ad51794 2004-03-25 devnull 				fsfidprint(efd, "%c%c%d %d\n", e.c1, e.c2, e.q0, e.q1);
467 8ad51794 2004-03-25 devnull 				break;
468 8ad51794 2004-03-25 devnull 
469 8ad51794 2004-03-25 devnull 			case 'd':
470 8ad51794 2004-03-25 devnull 			case 'i':
471 8ad51794 2004-03-25 devnull 				break;
472 8ad51794 2004-03-25 devnull 
473 8ad51794 2004-03-25 devnull 			default:
474 8ad51794 2004-03-25 devnull 				goto Unknown;
475 8ad51794 2004-03-25 devnull 			}
476 8ad51794 2004-03-25 devnull 		}
477 8ad51794 2004-03-25 devnull 		qunlock(&q.lk);
478 8ad51794 2004-03-25 devnull 	}
479 8ad51794 2004-03-25 devnull }
480 8ad51794 2004-03-25 devnull 
481 8ad51794 2004-03-25 devnull void
482 8ad51794 2004-03-25 devnull stdoutproc(void *v)
483 8ad51794 2004-03-25 devnull {
484 8ad51794 2004-03-25 devnull 	int fd1 = rcfd;
485 452c0935 2005-01-04 devnull 	CFid *afd = addrfd;
486 452c0935 2005-01-04 devnull 	CFid *dfd = datafd;
487 8ad51794 2004-03-25 devnull 	int n, m, w, npart;
488 8ad51794 2004-03-25 devnull 	char *buf, *s, *t;
489 8ad51794 2004-03-25 devnull 	Rune r;
490 8ad51794 2004-03-25 devnull 	char x[16], hold[UTFmax];
491 8ad51794 2004-03-25 devnull 
492 8ad51794 2004-03-25 devnull 	USED(v);
493 8ad51794 2004-03-25 devnull 	buf = malloc(8192+UTFmax+1);
494 8ad51794 2004-03-25 devnull 	npart = 0;
495 8ad51794 2004-03-25 devnull 	for(;;){
496 8ad51794 2004-03-25 devnull 		/* Let typing have a go -- maybe there's a rubout waiting. */
497 8ad51794 2004-03-25 devnull 		yield();
498 60535a5f 2004-12-26 devnull 		n = read(fd1, buf+npart, 8192);
499 f8104b3d 2005-01-05 devnull 		if(n <= 0)
500 8ad51794 2004-03-25 devnull 			error(nil);
501 ef5c6a6e 2010-09-03 rsc 		
502 ef5c6a6e 2010-09-03 rsc 		n = echocancel(buf+npart, n);
503 ef5c6a6e 2010-09-03 rsc 		if(n == 0)
504 ef5c6a6e 2010-09-03 rsc 			continue;
505 ef5c6a6e 2010-09-03 rsc 		
506 ef5c6a6e 2010-09-03 rsc 		n = dropcrnl(buf+npart, n);
507 ef5c6a6e 2010-09-03 rsc 		if(n == 0)
508 ef5c6a6e 2010-09-03 rsc 			continue;
509 8ad51794 2004-03-25 devnull 
510 8ad51794 2004-03-25 devnull 		/* squash NULs */
511 8ad51794 2004-03-25 devnull 		s = memchr(buf+npart, 0, n);
512 8ad51794 2004-03-25 devnull 		if(s){
513 8ad51794 2004-03-25 devnull 			for(t=s; s<buf+npart+n; s++)
514 8ad51794 2004-03-25 devnull 				if(*t = *s)	/* assign = */
515 8ad51794 2004-03-25 devnull 					t++;
516 8ad51794 2004-03-25 devnull 			n = t-(buf+npart);
517 8ad51794 2004-03-25 devnull 		}
518 8ad51794 2004-03-25 devnull 
519 8ad51794 2004-03-25 devnull 		n += npart;
520 8ad51794 2004-03-25 devnull 
521 8ad51794 2004-03-25 devnull 		/* hold on to final partial rune */
522 8ad51794 2004-03-25 devnull 		npart = 0;
523 8ad51794 2004-03-25 devnull 		while(n>0 && (buf[n-1]&0xC0)){
524 8ad51794 2004-03-25 devnull 			--n;
525 8ad51794 2004-03-25 devnull 			npart++;
526 8ad51794 2004-03-25 devnull 			if((buf[n]&0xC0)!=0x80){
527 8ad51794 2004-03-25 devnull 				if(fullrune(buf+n, npart)){
528 8ad51794 2004-03-25 devnull 					w = chartorune(&r, buf+n);
529 8ad51794 2004-03-25 devnull 					n += w;
530 8ad51794 2004-03-25 devnull 					npart -= w;
531 8ad51794 2004-03-25 devnull 				}
532 8ad51794 2004-03-25 devnull 				break;
533 8ad51794 2004-03-25 devnull 			}
534 8ad51794 2004-03-25 devnull 		}
535 8ad51794 2004-03-25 devnull 		if(n > 0){
536 8ad51794 2004-03-25 devnull 			memmove(hold, buf+n, npart);
537 8ad51794 2004-03-25 devnull 			buf[n] = 0;
538 8ad51794 2004-03-25 devnull 			n = label(buf, n);
539 8ad51794 2004-03-25 devnull 			buf[n] = 0;
540 c8471ac5 2010-10-13 rsc 			
541 c8471ac5 2010-10-13 rsc 			// clumsy but effective: notice password
542 c8471ac5 2010-10-13 rsc 			// prompts so we can disable echo.
543 c8471ac5 2010-10-13 rsc 			password = 0;
544 13666ca7 2011-08-26 rsc 			if(cistrstr(buf, "password") || cistrstr(buf, "passphrase")) {
545 c8471ac5 2010-10-13 rsc 				int i;
546 c8471ac5 2010-10-13 rsc 				
547 c8471ac5 2010-10-13 rsc 				i = n;
548 c8471ac5 2010-10-13 rsc 				while(i > 0 && buf[i-1] == ' ')
549 c8471ac5 2010-10-13 rsc 					i--;
550 c8471ac5 2010-10-13 rsc 				password = i > 0 && buf[i-1] == ':';
551 c8471ac5 2010-10-13 rsc 			}
552 c8471ac5 2010-10-13 rsc 
553 8ad51794 2004-03-25 devnull 			qlock(&q.lk);
554 8ad51794 2004-03-25 devnull 			m = sprint(x, "#%d", q.p);
555 4b970769 2005-03-05 devnull 			if(fswrite(afd, x, m) != m){
556 ef5c6a6e 2010-09-03 rsc 				fprint(2, "stdout writing address %s: %r; resetting\n", x);
557 ef5c6a6e 2010-09-03 rsc 				if(fswrite(afd, "$", 1) < 0)
558 ef5c6a6e 2010-09-03 rsc 					fprint(2, "reset: %r\n");
559 ef5c6a6e 2010-09-03 rsc 				fsseek(afd, 0, 0);
560 4b970769 2005-03-05 devnull 				m = fsread(afd, x, sizeof x-1);
561 4b970769 2005-03-05 devnull 				if(m >= 0){
562 4b970769 2005-03-05 devnull 					x[m] = 0;
563 4b970769 2005-03-05 devnull 					q.p = atoi(x);
564 4b970769 2005-03-05 devnull 				}
565 4b970769 2005-03-05 devnull 			}
566 8ad51794 2004-03-25 devnull 			if(fswrite(dfd, buf, n) != n)
567 8ad51794 2004-03-25 devnull 				error("stdout writing body");
568 bea7c49a 2010-03-19 rsc 			/* Make sure acme scrolls to the end of the above write. */
569 bea7c49a 2010-03-19 rsc 			if(fswrite(dfd, nil, 0) != 0)
570 bea7c49a 2010-03-19 rsc 				error("stdout flushing body");
571 8ad51794 2004-03-25 devnull 			q.p += nrunes(buf, n);
572 8ad51794 2004-03-25 devnull 			qunlock(&q.lk);
573 8ad51794 2004-03-25 devnull 			memmove(buf, hold, npart);
574 8ad51794 2004-03-25 devnull 		}
575 8ad51794 2004-03-25 devnull 	}
576 8ad51794 2004-03-25 devnull }
577 8ad51794 2004-03-25 devnull 
578 efe12411 2005-01-30 devnull char wdir[512];
579 8ad51794 2004-03-25 devnull int
580 8ad51794 2004-03-25 devnull label(char *sr, int n)
581 8ad51794 2004-03-25 devnull {
582 efe12411 2005-01-30 devnull 	char *sl, *el, *er, *r, *p;
583 8ad51794 2004-03-25 devnull 
584 8ad51794 2004-03-25 devnull 	er = sr+n;
585 8ad51794 2004-03-25 devnull 	for(r=er-1; r>=sr; r--)
586 8ad51794 2004-03-25 devnull 		if(*r == '\007')
587 8ad51794 2004-03-25 devnull 			break;
588 8ad51794 2004-03-25 devnull 	if(r < sr)
589 8ad51794 2004-03-25 devnull 		return n;
590 8ad51794 2004-03-25 devnull 
591 8ad51794 2004-03-25 devnull 	el = r+1;
592 efe12411 2005-01-30 devnull 	if(el-sr > sizeof wdir - strlen(name) - 20)
593 efe12411 2005-01-30 devnull 		sr = el - sizeof wdir - strlen(name) - 20;
594 8ad51794 2004-03-25 devnull 	for(sl=el-3; sl>=sr; sl--)
595 8ad51794 2004-03-25 devnull 		if(sl[0]=='\033' && sl[1]==']' && sl[2]==';')
596 8ad51794 2004-03-25 devnull 			break;
597 8ad51794 2004-03-25 devnull 	if(sl < sr)
598 8ad51794 2004-03-25 devnull 		return n;
599 8ad51794 2004-03-25 devnull 
600 8ad51794 2004-03-25 devnull 	*r = 0;
601 0e881c05 2011-10-11 rsc 	if(strcmp(sl+3, "*9term-hold+") != 0) {
602 0e881c05 2011-10-11 rsc 		/*
603 0e881c05 2011-10-11 rsc 		 * add /-sysname if not present
604 0e881c05 2011-10-11 rsc 		 */
605 0e881c05 2011-10-11 rsc 		snprint(wdir, sizeof wdir, "name %s", sl+3);
606 0e881c05 2011-10-11 rsc 		p = strrchr(wdir, '/');
607 0e881c05 2011-10-11 rsc 		if(p==nil || *(p+1) != '-'){
608 0e881c05 2011-10-11 rsc 			p = wdir+strlen(wdir);
609 0e881c05 2011-10-11 rsc 			if(*(p-1) != '/')
610 0e881c05 2011-10-11 rsc 				*p++ = '/';
611 0e881c05 2011-10-11 rsc 			*p++ = '-';
612 0e881c05 2011-10-11 rsc 			strcpy(p, name);
613 0e881c05 2011-10-11 rsc 		}
614 0e881c05 2011-10-11 rsc 		strcat(wdir, "\n0\n");
615 0e881c05 2011-10-11 rsc 		fswrite(ctlfd, wdir, strlen(wdir));
616 efe12411 2005-01-30 devnull 	}
617 8ad51794 2004-03-25 devnull 
618 8ad51794 2004-03-25 devnull 	memmove(sl, el, er-el);
619 8ad51794 2004-03-25 devnull 	n -= (el-sl);
620 8ad51794 2004-03-25 devnull 	return n;
621 8ad51794 2004-03-25 devnull }
622 8ad51794 2004-03-25 devnull 
623 8ad51794 2004-03-25 devnull int
624 8ad51794 2004-03-25 devnull delete(Event *e)
625 8ad51794 2004-03-25 devnull {
626 8ad51794 2004-03-25 devnull 	uint q0, q1;
627 8ad51794 2004-03-25 devnull 	int deltap;
628 8ad51794 2004-03-25 devnull 
629 8ad51794 2004-03-25 devnull 	q0 = e->q0;
630 8ad51794 2004-03-25 devnull 	q1 = e->q1;
631 8ad51794 2004-03-25 devnull 	if(q1 <= q.p)
632 8ad51794 2004-03-25 devnull 		return e->q1-e->q0;
633 8ad51794 2004-03-25 devnull 	if(q0 >= q.p+ntyper)
634 8ad51794 2004-03-25 devnull 		return 0;
635 8ad51794 2004-03-25 devnull 	deltap = 0;
636 8ad51794 2004-03-25 devnull 	if(q0 < q.p){
637 8ad51794 2004-03-25 devnull 		deltap = q.p-q0;
638 8ad51794 2004-03-25 devnull 		q0 = 0;
639 8ad51794 2004-03-25 devnull 	}else
640 8ad51794 2004-03-25 devnull 		q0 -= q.p;
641 8ad51794 2004-03-25 devnull 	if(q1 > q.p+ntyper)
642 8ad51794 2004-03-25 devnull 		q1 = ntyper;
643 8ad51794 2004-03-25 devnull 	else
644 8ad51794 2004-03-25 devnull 		q1 -= q.p;
645 8ad51794 2004-03-25 devnull 	deltype(q0, q1);
646 8ad51794 2004-03-25 devnull 	return deltap;
647 8ad51794 2004-03-25 devnull }
648 8ad51794 2004-03-25 devnull 
649 8ad51794 2004-03-25 devnull void
650 8ad51794 2004-03-25 devnull addtype(int c, uint p0, char *b, int nb, int nr)
651 8ad51794 2004-03-25 devnull {
652 8ad51794 2004-03-25 devnull 	int i, w;
653 8ad51794 2004-03-25 devnull 	Rune r;
654 8ad51794 2004-03-25 devnull 	uint p;
655 8ad51794 2004-03-25 devnull 	char *b0;
656 8ad51794 2004-03-25 devnull 
657 8ad51794 2004-03-25 devnull 	for(i=0; i<nb; i+=w){
658 8ad51794 2004-03-25 devnull 		w = chartorune(&r, b+i);
659 8ad51794 2004-03-25 devnull 		if((r==0x7F||r==3) && c=='K'){
660 8ad51794 2004-03-25 devnull 			write(rcfd, "\x7F", 1);
661 8ad51794 2004-03-25 devnull 			/* toss all typing */
662 8ad51794 2004-03-25 devnull 			q.p += ntyper+nr;
663 8ad51794 2004-03-25 devnull 			ntypebreak = 0;
664 8ad51794 2004-03-25 devnull 			ntypeb = 0;
665 8ad51794 2004-03-25 devnull 			ntyper = 0;
666 8ad51794 2004-03-25 devnull 			/* buglet:  more than one delete ignored */
667 8ad51794 2004-03-25 devnull 			return;
668 8ad51794 2004-03-25 devnull 		}
669 8ad51794 2004-03-25 devnull 		if(r=='\n' || r==0x04)
670 8ad51794 2004-03-25 devnull 			ntypebreak++;
671 8ad51794 2004-03-25 devnull 	}
672 8ad51794 2004-03-25 devnull 	typing = realloc(typing, ntypeb+nb);
673 8ad51794 2004-03-25 devnull 	if(typing == nil)
674 8ad51794 2004-03-25 devnull 		error("realloc");
675 8ad51794 2004-03-25 devnull 	if(p0 == ntyper)
676 8ad51794 2004-03-25 devnull 		memmove(typing+ntypeb, b, nb);
677 8ad51794 2004-03-25 devnull 	else{
678 8ad51794 2004-03-25 devnull 		b0 = typing;
679 8ad51794 2004-03-25 devnull 		for(p=0; p<p0 && b0<typing+ntypeb; p++){
680 8ad51794 2004-03-25 devnull 			w = chartorune(&r, b0+i);
681 8ad51794 2004-03-25 devnull 			b0 += w;
682 8ad51794 2004-03-25 devnull 		}
683 8ad51794 2004-03-25 devnull 		if(p != p0)
684 8ad51794 2004-03-25 devnull 			error("typing: findrune");
685 8ad51794 2004-03-25 devnull 		memmove(b0+nb, b0, (typing+ntypeb)-b0);
686 8ad51794 2004-03-25 devnull 		memmove(b0, b, nb);
687 8ad51794 2004-03-25 devnull 	}
688 8ad51794 2004-03-25 devnull 	ntypeb += nb;
689 8ad51794 2004-03-25 devnull 	ntyper += nr;
690 c8471ac5 2010-10-13 rsc }
691 c8471ac5 2010-10-13 rsc 
692 c8471ac5 2010-10-13 rsc int
693 c8471ac5 2010-10-13 rsc israw(int fd0)
694 c8471ac5 2010-10-13 rsc {
695 c8471ac5 2010-10-13 rsc 	return (!cook || password) && !isecho(fd0);
696 8ad51794 2004-03-25 devnull }
697 8ad51794 2004-03-25 devnull 
698 8ad51794 2004-03-25 devnull void
699 8ad51794 2004-03-25 devnull sendtype(int fd0)
700 8ad51794 2004-03-25 devnull {
701 ef5c6a6e 2010-09-03 rsc 	int i, n, nr, raw;
702 ef5c6a6e 2010-09-03 rsc 	
703 c8471ac5 2010-10-13 rsc 	raw = israw(fd0);
704 ef5c6a6e 2010-09-03 rsc 	while(ntypebreak || (raw && ntypeb > 0)){
705 8ad51794 2004-03-25 devnull 		for(i=0; i<ntypeb; i++)
706 ef5c6a6e 2010-09-03 rsc 			if(typing[i]=='\n' || typing[i]==0x04 || (i==ntypeb-1 && raw)){
707 ef5c6a6e 2010-09-03 rsc 				if((typing[i] == '\n' || typing[i] == 0x04) && ntypebreak > 0)
708 ef5c6a6e 2010-09-03 rsc 					ntypebreak--;
709 4f30f3b4 2004-03-30 devnull 				n = i+1;
710 8ad51794 2004-03-25 devnull 				i++;
711 875351f4 2010-09-10 rsc 				if(!raw)
712 ef5c6a6e 2010-09-03 rsc 					echoed(typing, n);
713 8ad51794 2004-03-25 devnull 				if(write(fd0, typing, n) != n)
714 8ad51794 2004-03-25 devnull 					error("sending to program");
715 8ad51794 2004-03-25 devnull 				nr = nrunes(typing, i);
716 8ad51794 2004-03-25 devnull 				q.p += nr;
717 8ad51794 2004-03-25 devnull 				ntyper -= nr;
718 8ad51794 2004-03-25 devnull 				ntypeb -= i;
719 8ad51794 2004-03-25 devnull 				memmove(typing, typing+i, ntypeb);
720 8ad51794 2004-03-25 devnull 				goto cont2;
721 8ad51794 2004-03-25 devnull 			}
722 8ad51794 2004-03-25 devnull 		print("no breakchar\n");
723 8ad51794 2004-03-25 devnull 		ntypebreak = 0;
724 8ad51794 2004-03-25 devnull cont2:;
725 8ad51794 2004-03-25 devnull 	}
726 8ad51794 2004-03-25 devnull }
727 8ad51794 2004-03-25 devnull 
728 8ad51794 2004-03-25 devnull void
729 ef5c6a6e 2010-09-03 rsc sendbs(int fd0, int n)
730 ef5c6a6e 2010-09-03 rsc {
731 ef5c6a6e 2010-09-03 rsc 	char buf[128];
732 ef5c6a6e 2010-09-03 rsc 	int m;
733 ef5c6a6e 2010-09-03 rsc 
734 ef5c6a6e 2010-09-03 rsc 	memset(buf, 0x08, sizeof buf);
735 ef5c6a6e 2010-09-03 rsc 	while(n > 0) {
736 ef5c6a6e 2010-09-03 rsc 		m = sizeof buf;
737 ef5c6a6e 2010-09-03 rsc 		if(m > n)
738 ef5c6a6e 2010-09-03 rsc 			m = n;
739 ef5c6a6e 2010-09-03 rsc 		n -= m;
740 ef5c6a6e 2010-09-03 rsc 		write(fd0, buf, m);
741 ef5c6a6e 2010-09-03 rsc 	}
742 ef5c6a6e 2010-09-03 rsc }
743 ef5c6a6e 2010-09-03 rsc 
744 ef5c6a6e 2010-09-03 rsc void
745 8ad51794 2004-03-25 devnull deltype(uint p0, uint p1)
746 8ad51794 2004-03-25 devnull {
747 8ad51794 2004-03-25 devnull 	int w;
748 8ad51794 2004-03-25 devnull 	uint p, b0, b1;
749 8ad51794 2004-03-25 devnull 	Rune r;
750 8ad51794 2004-03-25 devnull 
751 8ad51794 2004-03-25 devnull 	/* advance to p0 */
752 8ad51794 2004-03-25 devnull 	b0 = 0;
753 8ad51794 2004-03-25 devnull 	for(p=0; p<p0 && b0<ntypeb; p++){
754 8ad51794 2004-03-25 devnull 		w = chartorune(&r, typing+b0);
755 8ad51794 2004-03-25 devnull 		b0 += w;
756 8ad51794 2004-03-25 devnull 	}
757 8ad51794 2004-03-25 devnull 	if(p != p0)
758 8ad51794 2004-03-25 devnull 		error("deltype 1");
759 8ad51794 2004-03-25 devnull 	/* advance to p1 */
760 8ad51794 2004-03-25 devnull 	b1 = b0;
761 8ad51794 2004-03-25 devnull 	for(; p<p1 && b1<ntypeb; p++){
762 8ad51794 2004-03-25 devnull 		w = chartorune(&r, typing+b1);
763 8ad51794 2004-03-25 devnull 		b1 += w;
764 8ad51794 2004-03-25 devnull 		if(r=='\n' || r==0x04)
765 8ad51794 2004-03-25 devnull 			ntypebreak--;
766 8ad51794 2004-03-25 devnull 	}
767 8ad51794 2004-03-25 devnull 	if(p != p1)
768 8ad51794 2004-03-25 devnull 		error("deltype 2");
769 8ad51794 2004-03-25 devnull 	memmove(typing+b0, typing+b1, ntypeb-b1);
770 8ad51794 2004-03-25 devnull 	ntypeb -= b1-b0;
771 8ad51794 2004-03-25 devnull 	ntyper -= p1-p0;
772 8ad51794 2004-03-25 devnull }
773 8ad51794 2004-03-25 devnull 
774 8ad51794 2004-03-25 devnull void
775 452c0935 2005-01-04 devnull type(Event *e, int fd0, CFid *afd, CFid *dfd)
776 8ad51794 2004-03-25 devnull {
777 8ad51794 2004-03-25 devnull 	int m, n, nr;
778 8ad51794 2004-03-25 devnull 	char buf[128];
779 8ad51794 2004-03-25 devnull 
780 8ad51794 2004-03-25 devnull 	if(e->nr > 0)
781 8ad51794 2004-03-25 devnull 		addtype(e->c1, e->q0-q.p, e->b, e->nb, e->nr);
782 8ad51794 2004-03-25 devnull 	else{
783 8ad51794 2004-03-25 devnull 		m = e->q0;
784 8ad51794 2004-03-25 devnull 		while(m < e->q1){
785 8ad51794 2004-03-25 devnull 			n = sprint(buf, "#%d", m);
786 8ad51794 2004-03-25 devnull 			fswrite(afd, buf, n);
787 8ad51794 2004-03-25 devnull 			n = fsread(dfd, buf, sizeof buf);
788 8ad51794 2004-03-25 devnull 			nr = nrunes(buf, n);
789 8ad51794 2004-03-25 devnull 			while(m+nr > e->q1){
790 8ad51794 2004-03-25 devnull 				do; while(n>0 && (buf[--n]&0xC0)==0x80);
791 8ad51794 2004-03-25 devnull 				--nr;
792 8ad51794 2004-03-25 devnull 			}
793 8ad51794 2004-03-25 devnull 			if(n == 0)
794 8ad51794 2004-03-25 devnull 				break;
795 8ad51794 2004-03-25 devnull 			addtype(e->c1, m-q.p, buf, n, nr);
796 8ad51794 2004-03-25 devnull 			m += nr;
797 8ad51794 2004-03-25 devnull 		}
798 8ad51794 2004-03-25 devnull 	}
799 c8471ac5 2010-10-13 rsc 	if(israw(fd0)) {
800 ef5c6a6e 2010-09-03 rsc 		n = sprint(buf, "#%d,#%d", e->q0, e->q1);
801 ef5c6a6e 2010-09-03 rsc 		fswrite(afd, buf, n);
802 ef5c6a6e 2010-09-03 rsc 		fswrite(dfd, "", 0);
803 ef5c6a6e 2010-09-03 rsc 		q.p -= e->q1 - e->q0;
804 ef5c6a6e 2010-09-03 rsc 	}
805 8ad51794 2004-03-25 devnull 	sendtype(fd0);
806 c8471ac5 2010-10-13 rsc 	if(e->nb > 0 && e->b[e->nb-1] == '\n')
807 c8471ac5 2010-10-13 rsc 		cook = 1;
808 8ad51794 2004-03-25 devnull }
809 8ad51794 2004-03-25 devnull 
810 8ad51794 2004-03-25 devnull void
811 452c0935 2005-01-04 devnull sende(Event *e, int fd0, CFid *cfd, CFid *afd, CFid *dfd, int donl)
812 8ad51794 2004-03-25 devnull {
813 8ad51794 2004-03-25 devnull 	int l, m, n, nr, lastc, end;
814 8ad51794 2004-03-25 devnull 	char abuf[16], buf[128];
815 8ad51794 2004-03-25 devnull 
816 8ad51794 2004-03-25 devnull 	end = q.p+ntyper;
817 8ad51794 2004-03-25 devnull 	l = sprint(abuf, "#%d", end);
818 8ad51794 2004-03-25 devnull 	fswrite(afd, abuf, l);
819 8ad51794 2004-03-25 devnull 	if(e->nr > 0){
820 8ad51794 2004-03-25 devnull 		fswrite(dfd, e->b, e->nb);
821 8ad51794 2004-03-25 devnull 		addtype(e->c1, ntyper, e->b, e->nb, e->nr);
822 8ad51794 2004-03-25 devnull 		lastc = e->r[e->nr-1];
823 8ad51794 2004-03-25 devnull 	}else{
824 8ad51794 2004-03-25 devnull 		m = e->q0;
825 8ad51794 2004-03-25 devnull 		lastc = 0;
826 8ad51794 2004-03-25 devnull 		while(m < e->q1){
827 8ad51794 2004-03-25 devnull 			n = sprint(buf, "#%d", m);
828 8ad51794 2004-03-25 devnull 			fswrite(afd, buf, n);
829 8ad51794 2004-03-25 devnull 			n = fsread(dfd, buf, sizeof buf);
830 8ad51794 2004-03-25 devnull 			nr = nrunes(buf, n);
831 8ad51794 2004-03-25 devnull 			while(m+nr > e->q1){
832 8ad51794 2004-03-25 devnull 				do; while(n>0 && (buf[--n]&0xC0)==0x80);
833 8ad51794 2004-03-25 devnull 				--nr;
834 8ad51794 2004-03-25 devnull 			}
835 8ad51794 2004-03-25 devnull 			if(n == 0)
836 8ad51794 2004-03-25 devnull 				break;
837 8ad51794 2004-03-25 devnull 			l = sprint(abuf, "#%d", end);
838 8ad51794 2004-03-25 devnull 			fswrite(afd, abuf, l);
839 8ad51794 2004-03-25 devnull 			fswrite(dfd, buf, n);
840 8ad51794 2004-03-25 devnull 			addtype(e->c1, ntyper, buf, n, nr);
841 8ad51794 2004-03-25 devnull 			lastc = buf[n-1];
842 8ad51794 2004-03-25 devnull 			m += nr;
843 8ad51794 2004-03-25 devnull 			end += nr;
844 8ad51794 2004-03-25 devnull 		}
845 8ad51794 2004-03-25 devnull 	}
846 8ad51794 2004-03-25 devnull 	if(donl && lastc!='\n'){
847 8ad51794 2004-03-25 devnull 		fswrite(dfd, "\n", 1);
848 8ad51794 2004-03-25 devnull 		addtype(e->c1, ntyper, "\n", 1, 1);
849 8ad51794 2004-03-25 devnull 	}
850 8ad51794 2004-03-25 devnull 	fswrite(cfd, "dot=addr", 8);
851 8ad51794 2004-03-25 devnull 	sendtype(fd0);
852 8ad51794 2004-03-25 devnull }